File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/devices/__pycache__/monitoredqueue.cpython-310.pyc
Back
o ;j � @ s^ U d Z ddlmZ ddlZddlmZ dd� Z d d d �Zee d < edur(eZneZd gZ dS ) ztpure Python monitored_queue function For use when Cython extension is unavailable (PyPy). Authors ------- * MinRK � )�CallableN)�monitored_queuec C sH | � � }|r|d d� d d d� |d d�< |�|� |�|g| � d S )N� ���)Zrecv_multipartZsend_multipart)ZinsZoutsZsides�prefix�swap_ids�msg� r �N/opt/saltstack/salt/lib/python3.10/site-packages/zmq/devices/monitoredqueue.py�_relay s r � in� outc C s| | j tjko |j tjk}t�� }|�| tj� |�|tj� t|�� �}| |v r1t| ||||� ||v r=t|| |||� q )N) �type�zmqZROUTERZPoller�register�POLLIN�dict�pollr )Z in_socketZ out_socketZ mon_socketZ in_prefixZ out_prefixr Zpoller�eventsr r r �_monitored_queue s �r r )r r ) �__doc__�typingr r Z zmq.backendr Z _backend_mqr r �__annotations__�__all__r r r r �<module> s �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings