File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/sugar/__pycache__/poll.cpython-310.pyc
Back
o ;jx � @ sd d Z ddlmZ ddlmZ ddlmZ ddlmZm Z m Z G dd� d�Z dddd�Z ddgZ dS )z*0MQ polling related functions and classes.� )� annotations)�Any)�zmq_poll)�POLLERR�POLLIN�POLLOUTc @ sn e Zd ZU dZded< ded< d dd �Zd d d�ZeeB fd dd�Z eeB fdd�Z d dd�Z d d!dd�Z dS )"�Pollerz>A stateful poll interface that mirrors Python's built-in poll.�list[tuple[Any, int]]�sockets�dict�_map�return�Nonec C s g | _ i | _d S �N)r r )�self� r �B/opt/saltstack/salt/lib/python3.10/site-packages/zmq/sugar/poll.py�__init__ s zPoller.__init__�socketr �boolc C s || j v S r )r )r r r r r � __contains__ s zPoller.__contains__�flags�intc C sp |r)|| j v r| j | }||f| j|< dS t| j�}| j�||f� || j |< dS || j v r5| �|� dS dS )a p.register(socket, flags=POLLIN|POLLOUT) Register a 0MQ socket or native fd for I/O monitoring. register(s,0) is equivalent to unregister(s). Parameters ---------- socket : zmq.Socket or native socket A zmq.Socket or any Python object having a ``fileno()`` method that returns a valid file descriptor. flags : int The events to watch for. Can be POLLIN, POLLOUT or POLLIN|POLLOUT. If `flags=0`, socket will be unregistered. N)r r �len�append� unregister)r r r �idxr r r �register s zPoller.registerc C s | � ||� dS )zCModify the flags for an already registered 0MQ socket or native fd.N)r )r r r r r r �modify> s z Poller.modifyc C sF | j �|�}| j�|� | j|d� D ] \}}| j | d8 < qdS )z�Remove a 0MQ socket or native fd for I/O monitoring. Parameters ---------- socket : Socket The socket instance to stop polling. N� )r �popr )r r r r r r r r B s �zPoller.unregisterN�timeout� int | Nonec C s6 |du s|dk r d}n t |t�rt|�}t| j|d�S )a� Poll the registered 0MQ or native fds for I/O. If there are currently events ready to be processed, this function will return immediately. Otherwise, this function will return as soon the first event is available or after timeout milliseconds have elapsed. Parameters ---------- timeout : int The timeout in milliseconds. If None, no `timeout` (infinite). This is in milliseconds to be compatible with ``select.poll()``. Returns ------- events : list The list of events that are ready to be processed. This is a list of tuples of the form ``(socket, event_mask)``, where the 0MQ Socket or integer fd is the first element, and the poll event mask (POLLIN, POLLOUT) is the second. It is common to call ``events = dict(poller.poll())``, which turns the list of tuples into a mapping of ``socket : event_mask``. Nr ���)r! )� isinstance�floatr r r )r r! r r r �pollP s z Poller.poll)r r )r r r r )r r r r )r r r )r! r" r r ) �__name__� __module__� __qualname__�__doc__�__annotations__r r r r r r r r& r r r r r s r N�rlist�list�wlist�xlistr! � float | Noner �tuple[list, list, list]c C s� |du rd}t |d �}|dk rd}g }t| | | �D ]#}d}|| v r(|tO }||v r0|tO }||v r8|tO }|�||f� q t||�}g g g } }}|D ] \}}|t@ r\| �|� |t@ re|�|� |t@ rn|�|� qO| ||fS )a[ select(rlist, wlist, xlist, timeout=None) -> (rlist, wlist, xlist) Return the result of poll as a lists of sockets ready for r/w/exception. This has the same interface as Python's built-in ``select.select()`` function. Parameters ---------- timeout : float, optional The timeout in seconds. If None, no timeout (infinite). This is in seconds to be compatible with ``select.select()``. rlist : list sockets/FDs to be polled for read events wlist : list sockets/FDs to be polled for write events xlist : list sockets/FDs to be polled for error events Returns ------- rlist: list list of sockets or FDs that are readable wlist: list list of sockets or FDs that are writable xlist: list list of sockets or FDs that had error events (rare) Nr# g @�@r )r �setr r r r r )r, r. r/ r! r �sr Zreturn_socketsr r r �selectm s4 � r4 r ) r, r- r. r- r/ r- r! r0 r r1 )r* � __future__r �typingr Z zmq.backendr Z zmq.constantsr r r r r4 �__all__r r r r �<module> s \ � ?
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings