File: //lib64/python3.6/site-packages/zmq/backend/cffi/__pycache__/_poll.cpython-36.opt-1.pyc
3
VS�_ � @ s� d Z yddlmZ W n ek
r4 ddlmZ Y nX ddlZddlmZmZ ddl m
Z
m Z dd � Z d
d � Z
d d
� Zd
gZdS )zzmq poll function� )� monotonic)�clockN� )�C�ffi)�InterruptedSystemCall� _check_rcc C s0 | j }tjd�}||_d|_||_d|_|d S )Nzzmq_pollitem_t*r )� _zmq_socketr �new�socket�fd�events�revents)r �flagsZ
zmq_socket� zmq_pollitem� r � /usr/lib64/python3.6/_poll.py�_make_zmq_pollitem s
r c C s, t jd�}t j|_| |_||_d|_|d S )Nzzmq_pollitem_t*r )r r
�NULLr r r
r )Z socket_fdr r r r r �_make_zmq_pollitem_fromfd s
r c C s� g }i }ddl m} x�| D ]�}t|d |�rT|||d j< |jt|d |d �� qt|d t�sv|d j� |d f}|||d < |jt|d |d �� qW t j
d|�}t j dt |��}x�t j d|�}t
� } tj|||�}
y t|
� W n` tk
�rH |dk�rBtdt
� | �} | dk �r4tjd| t� d} td|| �}w�Y q�X P q�W g } xvtt |��D ]f}
||
jdk�rb||
jt jk�s�| j|||
j d ||
jf� n| j||
j||
jf� �qbW | S ) Nr )�Socketr zzmq_pollitem_t[]�intZlongi� zFNegative elapsed time for interrupted poll: %s. Did the clock change?)Zzmqr �
isinstancer �appendr r �filenor r r
�cast�lenr r �zmq_pollr r �warnings�warn�RuntimeWarning�max�ranger r r r )ZsocketsZtimeoutZcffi_pollitem_listZlow_level_to_socket_objr �item�itemsZ list_lengthZ c_timeout�startZrcZ ms_passed�result�indexr r r r ! sN
r )�__doc__Ztimer � ImportErrorr r Z_cffir r Z zmq.errorr r r r r �__all__r r r r �<module> s /