File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/green/__pycache__/core.cpython-310.pyc
Back
o ;j�, � @ s� U d Z ddlmZ ddlZddlZddlZddlZddlmZ ddl m Z ddl Z ddl m Z ddl mZ dd lmZ ee d �rKe je jfZd ed < nd Zdd� ZG dd� de�ZG dd� de e �ZdS )ziThis module wraps the :class:`Socket` and :class:`Context` found in :mod:`pyzmq <zmq>` to be non blocking� )� annotationsN)� AsyncResult)�get_hub)�Context)�Socket� )�_Poller�RCVTIMEO�tuple�TIMEOS� c C s, z| � � W dS ty | �� Y dS w )zNsimple wrapper for stopping an Event, allowing for method rename in gevent 1.0N)�stop�AttributeError�cancel)Zevtr r �B/opt/saltstack/salt/lib/python3.10/site-packages/zmq/green/core.py�_stop# s �r c s� e Zd ZdZdZdZdZdZdZdZ dZ e Z dZ � fdd�Zdd � Zd'� fd d � Zd d � Zdd� Zd(� fdd� Zdd� Zdd� Zd)� fdd� Zd)� fdd� Zddd �� fd d � Z� fd d �Z� fd!d"�Z� fd#d$�Z� fd%d&�Z � Z S )*�_SocketaK Green version of :class:`zmq.Socket` The following methods are overridden: * send * recv To ensure that the ``zmq.NOBLOCK`` flag is set and that sending or receiving is deferred to the hub if a ``zmq.EAGAIN`` (retry) error is raised. The `__state_changed` method is triggered when the zmq.FD for the socket is marked as readable and triggers the necessary read and write events (which are waited for in the recv and send methods). Some double underscore prefixes are used to minimize pollution of :class:`zmq.Socket`'s namespace. FNg333333'@zzmq.green.Socketc s* t � j|i |�� d| _d| _| �� d S )NF)�super�__init__�_Socket__in_send_multipart�_Socket__in_recv_multipart�_Socket__setup_events)�self�a�kw�� __class__r r r I s z_Socket.__init__c C s | � � d S �N)�close�r r r r �__del__O s z_Socket.__del__c s t � �|� | �� d S r )r r �_Socket__cleanup_events)r Zlingerr r r r R s z _Socket.closec C s4 t | dd �rt| j� d | _| j�� | j�� d S )N� _state_event)�getattrr r" �_Socket__writable�set�_Socket__readabler r r r Z__cleanup_eventsV s z_Socket.__cleanup_eventsc C s� t � | _t � | _| j�� | j�� zt� j�| �tj �d�| _ | j � | j � W d S t yF ddlm} || �tj �| j dd�| _ Y d S w )Nr r )� read_eventT)Zpersist)r r& r$ r% r Zloop�io� getsockopt�zmq�FDr" �start�_Socket__state_changedr Z gevent.corer' )r r' r r r Z__setup_events_ s � ��z_Socket.__setup_eventsc s� | j r | �� d S z t� �tj�}W n tjy2 } z| j�|� | j �|� W Y d }~d S d }~ww |tj @ r=| j� � |tj @ rI| j � � d S d S r ) �closedr! r r) r* �EVENTS�ZMQErrorr$ Z set_exceptionr& �POLLOUTr% �POLLIN)r �eventZ_evtype�events�excr r r Z__state_changedr s �� �z_Socket.__state_changedc C � | j �� s J d��t� | _ t�� }| j}|r tj|d�}nd }zZz|r'|�� | j jdd� W n< tjyk } z/||ur=� t�� }| j ra|ra|| |kra| � t j �t j @ ratd| j� d�tjd� W Y d }~nd }~ww W |rs|�� | j �� d S |r�|�� | j �� w )N�.Only one greenlet can be waiting on this event��secondsT��blockz3BUG: gevent may have missed a libzmq send event on �!��file)r$ �readyr �time�_gevent_bug_timeout�gevent�Timeoutr, �get� _debug_geventr) r* r/ r1 �printr+ �sys�stderrr r% �r Ztic�dt�timeout�tZtocr r r � _wait_write� sF �� � ����� z_Socket._wait_writec C r6 )Nr7 r8 Tr: z3BUG: gevent may have missed a libzmq recv event on r< r= )r& r? r r@ rA rB rC r, rD rE r) r* r/ r2 rF r+ rG rH r r% rI r r r � _wait_read� sF �� � ����� z_Socket._wait_readr Tc s� |t j@ r&zt� j||||fi |��}W | js| �� |S | js%| �� w w |t jO } z t� �||||�}W n! t jyX } z|jt jkrN| jsM| �� � W Y d}~nd}~ww | js`| �� |S | � � q,)z�send, which will only block current greenlet state_changed always fires exactly once (success or fail) at the end of this method. TN) r* �NOBLOCKr �sendr r- r0 �errno�EAGAINrM )r �data�flags�copy�track�kwargs�msg�er r r rP � s4 � � ����z _Socket.sendc s� |t j@ r!zt� �|||�}W | js| �� |S | js | �� w w |t jO } z t� �|||�}W n! t jyR } z|jt jkrH| jsG| �� � W Y d}~nd}~ww | jsZ| �� |S | � � q')z�recv, which will only block current greenlet state_changed always fires exactly once (success or fail) at the end of this method. TN) r* rO r �recvr r- r0 rQ rR rN )r rT rU rV rX rY r r r rZ � s4 � � ����z _Socket.recv��nbytesrT c s� |t j@ rt� j|||d�S |t jO } z t� j|||d�}W n t jy= } z|jt jkr3| �� � W Y d}~n d}~ww | �� |S | �� q)z1recv_into, which will only block current greenletr[ TN) r* ZDONTWAITr � recv_intor0 rQ rR r- rN )r �bufferr\ rT ZrecvdrY r r r r] s" ����z_Socket.recv_intoc �> d| _ zt� j|i |��}W d| _ | �� |S d| _ | �� w )zAwrap send_multipart to prevent state_changed on each partial sendTF)r r �send_multipartr- �r �argsrW rX r r r r` � � z_Socket.send_multipartc r_ )zAwrap recv_multipart to prevent state_changed on each partial recvTF)r r �recv_multipartr- ra r r r rd & rc z_Socket.recv_multipartc s6 |t v r t�dt� t� �|�}|tjkr| �� |S )z+trigger state_changed on getsockopt(EVENTS)�0TIMEO socket options have no effect in zmq.green) r �warnings�warn� UserWarningr rD r* r/ r- )r �optZoptvalr r r rD 0 s � z _Socket.getc s" |t v r t�dt� t� �||�S )zset socket optionre )r rf rg rh r r% )r ri �valr r r r% ; s �z _Socket.setr )NN)r TF) �__name__� __module__� __qualname__�__doc__r r r$ r& r" rA rE r Z _poller_class� _repr_clsr r r r! r r- rM rN rP rZ r] r` rd rD r% � __classcell__r r r r r , s4 $&" r c @ s e Zd ZdZeZdZdZdS )�_ContextzrReplacement for :class:`zmq.Context` Ensures that the greened Socket above is used in calls to `socket`. zzmq.green.ContextN)rk rl rm rn r Z _socket_classro Z _instancer r r r rq D s rq )rn � __future__r rG r@ rf rB Z gevent.eventr Z gevent.hubr r* r Z_original_Contextr Z_original_Socket�pollr �hasattrr ZSNDTIMEOr �__annotations__r r rq r r r r �<module> s(
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings