Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/__pycache__/_future.cpython-39.pyc
Ðазад
a a�hcH � @ sn d Z ddlmZmZ ddlmZ ddlmZmZm Z ddlZ edd�Z G dd � d e j �Z G d d � d e j�ZdS ) z%Future-returning APIs for coroutines.� )� namedtuple�deque)�chain)�EVENTS�POLLOUT�POLLINN� _FutureEvent)�future�kind�kwargs�msgc s" e Zd ZdZd� fdd� Z� ZS )� _AsyncPollerz:Poller that returns a Future on poll, instead of blocking.���c s� �� � � |dkrbztt���d�}W n. tyR } z� �|� W Y d}~nd}~0 0 � �|� � S ��� ��� � �g ��fdd�}�����fdd�� �j D ]�\}}t |t j �r�t |�j �sʈj �|�}|t j@ r�|jd�d� |t j@ r�|jd�d� q���|� d}|t j@ �r |�jO }|t j@ �r6|�jO }���|||� q��� ��fd d �}��|� |du�r�|dk�r��fd d �} ��d | | ����fdd�} � �| � �fdd�} � �| � � S )z Return a Future for a poll eventr Nc s � � � s� �d � d S �N��done� set_result)�args��watcher� �{/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/_future.py�wake_raw- s z#_AsyncPoller.poll.<locals>.wake_rawc s �j � g��R � S r )Z_unwatch_raw_sockets��f)�loop� raw_sockets�selfr r �<lambda>1 � z#_AsyncPoller.poll.<locals>.<lambda>�poll�r c s� �� � r d S ��� r8z ��� W n ty2 Y n0 d S ��� rP����� � nNztt���d�}W n. t y� } z��|� W Y d }~nd }~0 0 �� |� d S �Nr ) r � cancelled�cancel� RuntimeError� exception� set_exception�superr r � Exceptionr )r �result�e)� __class__r r r r r � on_poll_readyE s z(_AsyncPoller.poll.<locals>.on_poll_readyc s � � � s� �d � d S r r r r r r �trigger_timeout\ s z*_AsyncPoller.poll.<locals>.trigger_timeout���MbP?c s" t �d�r��� n � ��� d S )Nr$ )�hasattrr$ Zremove_timeoutr )r �timeout_handler r �cancel_timeoutd s z)_AsyncPoller.poll.<locals>.cancel_timeoutc s � � � s� �� d S r )r r$ r r r r �cancel_watcherk s z)_AsyncPoller.poll.<locals>.cancel_watcher)�_Futurer( r r r) r' r � _default_loop�add_done_callbackZsockets� isinstance�_zmq�SocketZ _socket_class� from_socketr �_add_recv_eventr �_add_send_event�append�_READZ_WRITEZ_watch_raw_socket� call_later) r �timeoutr* r+ r �socket�maskZevtr- r. r2 r3 �r, )r r r r r1 r r r sR � z_AsyncPoller.poll)r )�__name__� __module__� __qualname__�__doc__r � __classcell__r r rC r r s r c s6 e Zd ZdZdZdZdZeZdZ dZ d6� fdd� Z e d7dd��Z d8� fdd � Zejjje_� fd d �Zejjje_d9dd�Zd:dd�Zd;dd�Zd<dd�Zdd� Zdejfdd�Zdd� Zd d � Ze d d � �Z d=d d!�Z d>d"d#�Z d$d%� Z d&d'� Z!d?d(d)�Z"d@d*d+�Z#d,d-� Z$d.d/� Z%d0d1� Z&d2d3� Z'd4d5� Z(� Z)S )A� _AsyncSocketNr r c s� t |tj�rd | }}n |�dd �}|d urHtt| �j|jd� || _n*tt| �j||fi |�� tj� | j�| _|p|| � � | _ t � | _ t � | _d| _| jj| _| �� d S )N� _from_socket)�shadowr )r7 r8 r9 �popr( rI �__init__Z underlying� _shadow_sockrK r5 �io_loopr � _recv_futures� _send_futures�_stateZFD�_fd�_init_io_state)r �context� socket_typerO r r: rC r r rM � s z_AsyncSocket.__init__c C s | ||d�S )z.Create an async socket from an existing Socket)rJ rO r )�clsrA rO r r r r: � s z_AsyncSocket.from_socketc sh | j sRtt| j| j��D ]0}|j�� sz|j�� W q tyF Y q0 q| � � t t | �j |d� d S )N)�linger) �closed�listr rP rQ r r r$ r% �_clear_io_stater( rI �close)r rX �eventrC r r r\ � s z_AsyncSocket.closec s& t t| ��|�}|tkr"| �|� |S r )r( rI �getr �_schedule_remaining_events)r �keyr* rC r r r^ � s z_AsyncSocket.getTFc C s | � dt|||d��S )z~Receive a complete multipart zmq message. Returns a Future whose result will be a multipart message. �recv_multipart��flags�copy�track�r; �dict�r rc rd re r r r ra � s �z_AsyncSocket.recv_multipartc C s | � dt|||d��S )z�Receive a single zmq frame. Returns a Future, whose result will be the received frame. Recommend using recv_multipart instead. �recvrb rf rh r r r ri � s �z_AsyncSocket.recvc K s( ||d< ||d< ||d< | j d||d�S )zqSend a complete multipart zmq message. Returns a Future that resolves when sending is complete. rc rd re �send_multipart�r r )r< �r r rc rd re r r r r rj � s z_AsyncSocket.send_multipartc K s< ||d< ||d< ||d< |� t|||d�� | jd||d�S )z�Send a single zmq frame. Returns a Future that resolves when sending is complete. Recommend using send_multipart instead. rc rd re rb �sendrk )�updaterg r< rl r r r rm � s z_AsyncSocket.sendc s> | � � � � ��fdd�}��|� � �fdd�}� �|� � S )zDeserialize with Futuresc sv � � � r dS ��� r$� ���� � nN��� }z �|�}W n. tyf } z� �|� W Y d}~nd}~0 0 � �|� dS )z+Chain result through serialization to recvdN)r r& r' r* r) r )�_�bufZloadedr+ �r �load�recvdr r �_chain� s z)_AsyncSocket._deserialize.<locals>._chainc s �� � r dS � �� r ��� dS )z"Chain cancellation from f to recvdN)r r# r$ )ro )r rs r r � _chain_cancel� s z0_AsyncSocket._deserialize.<locals>._chain_cancel)r4 r6 )r rs rr rt ru r rq r � _deserialize� s z_AsyncSocket._deserializec sf �j rt�tj����� }|��|� |�|�}��� � � �fdd�}|�� rX||� n |� |� � S )zSpoll the socket for events returns a Future for the poll results. c sr � � � r d S | �� r8z � �� W n ty2 Y n0 d S | �� rP� �| �� � n t| �� �}� �|� �d�� d S r" ) r r# r$ r% r& r' rg r* r r^ )r Zevts�r r r r � unwrap_result s z(_AsyncSocket.poll.<locals>.unwrap_result) rY r8 ZZMQError�ENOTSUP� _poller_class�registerr r4 r r6 )r r@ rc �pr rx r rw r r � s z_AsyncSocket.pollc s � fdd�}| � ||� dS )z'Add a timeout for a send or recv Futurec s � � � r d S � �t�� � d S r )r r' r8 �Againr r! r r �future_timeout s z1_AsyncSocket._add_timeout.<locals>.future_timeoutN)� _call_later)r r r@ r~ r r! r � _add_timeout s z_AsyncSocket._add_timeoutc C s | j �||� dS )z�Schedule a function to be called later Override for different IOLoop implementations Tornado and asyncio happen to both have ioloop.call_later with the same signature. N)rO r? )r �delay�callbackr r r r # s z_AsyncSocket._call_laterc C s< t |�D ] \}\}}}}|| u r q*qdS |�|| � dS )z�Make sure that futures are removed from the event list when they resolve Avoids delaying cleanup until the next send/recv event, which may never come. N)� enumerate�remove)r Z event_listZf_idxr r r ro r r r �_remove_finished_future- s z$_AsyncSocket._remove_finished_futurec s |p � � � }|�d�r�|�dd�tj@ r�t� j|�}z|f i |��}W n. tyt } z|�|� W Y d}~nd}~0 0 |� |� |S � j � t |||dd�� |� � fdd�� ttd�r؈ jj}|dkr؈ �||d � � j�t�t@ r� �� � j �r� �t� |S ) z4Add a recv event, returning the corresponding Futureri rc r N)r c s � � | � j�S r )r� rP r �r r r r R r z._AsyncSocket._add_recv_event.<locals>.<lambda>ZRCVTIMEOr/ )r4 � startswithr^ r8 �DONTWAIT�getattrrN r) r' r rP r= r r6 r0 Zrcvtimeor� r r � _handle_recv� _add_io_state) r r r r r ri �rr+ � timeout_msr r� r r; = s, � z _AsyncSocket._add_recv_eventc sZ |p � � � }|dv r� js�|�dd�}|�� }|tjB |d< t� j|�}d} z||fi |��} W nl tjy� } z&|tj@ r�|� | � nd} W Y d} ~ n@d} ~ 0 t y� } z|� | � W Y d} ~ nd} ~ 0 0 |� | � | r� j r� � � |S � j�t||||d�� |�� fdd �� ttd ��rL� j�tj�} | dk�rL� �|| d � � �t� |S ) z4Add a send event, returning the corresponding Future)rm rj rc r TFN)r r c s � � | � j�S r )r� rQ r r� r r r � r z._AsyncSocket._add_send_event.<locals>.<lambda>�SNDTIMEOr/ )r4 rQ r^ rd r8 r� r� rN r} r' r) r rP r_ r= r r6 r0 r� r� r� r ) r r r r r r rc Z nowait_kwargsrm Z finish_earlyr� r+ r� r r� r r< ` sB �� � z _AsyncSocket._add_send_eventc C s | j �t�t@ sdS d}| jrB| j�� \}}}}|�� rBd}qqBq| jsR| �t� |du r^dS |dkrt|�d� dS |dkr�| j j }n |dkr�| j j }n t d| ��|d t j O < z|f i |��}W n. ty� } z|�|� W Y d}~nd}~0 0 |�|� dS )zHandle recv eventsNr ra ri z Unhandled recv event type: %rrc )rN r^ r r rP �popleftr �_drop_io_stater ra ri � ValueErrorr8 r� r) r' )r r r r ro ri r* r+ r r r r� � s4 z_AsyncSocket._handle_recvc C s | j �t�t@ sd S d }| jrB| j�� \}}}}|�� rBd }qqBq| jsR| �t� |d u r^d S |dkrt|�d � d S |dkr�| j j }n |dkr�| j j }n t d| ��|d t j O < z||fi |��}W n. ty� } z|�|� W Y d }~nd }~0 0 |�|� d S )Nr rj rm z Unhandled send event type: %rrc )rN r^ r r rQ r� r r� r rj rm r� r8 r� r) r' )r r r r r rm r* r+ r r r � _handle_send� s4 z_AsyncSocket._handle_sendc C s< | j �t�}|tj@ r | �� |tj@ r0| �� | �� dS )z(Dispatch IO events to _handle_recv, etc.N) rN r^ r r8 r r� r r� r_ )r �fd�eventsZ zmq_eventsr r r �_handle_events� s z_AsyncSocket._handle_eventsc C s> | j dkrdS |du r"| j�t�}|| j @ r:| �d| j� dS )zkSchedule a call to handle_events next loop iteration If there are still events to handle. r N)rR rN r^ r r r� )r r� r r r r_ � s z'_AsyncSocket._schedule_remaining_eventsc C s* | j |kr| j |B }| _ | �| j � dS )zAdd io_state to poller.N�rR �_update_handler�r �stater r r r� � s z_AsyncSocket._add_io_statec C s( | j |@ r| j | @ | _ | �| j � dS )z&Stop poller from watching an io_state.Nr� r� r r r r� s z_AsyncSocket._drop_io_statec C s | � � dS )zOUpdate IOLoop handler with state. zmq FD is always read-only. N)r_ r� r r r r� s z _AsyncSocket._update_handlerc C s( | j �| j| j| j� | �d| j� dS )z#initialize the ioloop event handlerr N)rO � add_handlerrN r� r> r r� r r r rT s z_AsyncSocket._init_io_statec C s$ | j }| j jr| j}| j�|� dS )zNunregister the ioloop event handler called once during close N)rN rY rS rO Zremove_handler)r r� r r r r[ s z _AsyncSocket._clear_io_state)Nr N)N)N)r TF)r TF)r TF)r TF)NN)NNN)r r )N)*rD rE rF rP rQ rR rN r rz rO rS rM � classmethodr: r\ r8 r9 rG r^ ra ri rj rm rv r r r� r � staticmethodr� r; r< r� r� r� r_ r� r� r� rT r[ rH r r rC r rI s sF % # 8'' rI )rG � collectionsr r � itertoolsr Zzmqr r r r8 r ZPollerr r9 rI r r r r �<module> s \
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка