3

VS�_v�@s<dd
lZdd
l
Z
ddl
mZ
ddlmZ
Gdd�de�Zd
S)�N)
�select)
�Pollercs.eZ
dZd
ZdZdd�Zd	�f
dd�	Z�ZS)
�_Pollerz�Replacement for :class:`zmq.Poller`

    Ensures that the greened Poller below is used in calls to
    :meth:`zmq.Poller.poll`.
    gH�z�G�?c

Cs�g}
g}g}x�|jD]�\}}t
|tj�r>|
j|jtj�
�

qnNt
|t�rN|}n>t|d
�r�yt|j	��
}Wq�


t
d�
�
Yq�Xntd|�
�
|tj@r�|
j|�

|tj
@r�|j|�

|tj@r|j|�

qW|
||fS)zdReturns three elements tuple with socket descriptors ready
        for gevent.select.select
        �filenoz(fileno() must return an valid integer fdzHSocket must be a 0MQ socket, an integer fd or have a fileno() method: %r)Zsockets�
isinstance�zmqZSocket�appendZ
getsockoptZFD�int�hasattrr�
ValueError�	TypeErrorZPOLLINZPOLLOUTZPOLLERR)�self�rlist�wlist�xlistZsocket�flags�fd�r�/usr/lib64/python3.6/poll.py�_get_descriptorss.
























z_Poller._get_descriptors�
c	"s*
|
d
krd}
|
dkrd}
d
}d
}d
}|
dkr>tj
j|
d�
}nd
}z�y�|j�\}}}x�tt|�jd�
}|sr|
dkrv|Stj
j|j�
}zFytj|||�
Wn.tj
k
r�
}
z||k	r��WYd
d
}~XnXWd
|j	�
XqVWWn0tj
k
�
r
}
z||k	�r��gSd
}~XnXWd
|
dk�
r$|j	�
Xd
S)z�Overridden method to ensure that the green version of
        Poller is used.

        Behaves the same as :meth:`zmq.core.Poller.poll`
        Nrr
g@�@���r)
�geventZTimeout�	start_newr�superr�poll�_gevent_bug_timeoutrZcancel)	r
ZtimeoutrrrZtoutZeventsZ_bug_timeout�
t)
�	__class__rrr0s:



















z_Poller.pollr)
r)�__name__�
__module__�__qualname__�__doc__rrr�
__classcell__rr)
rrrs
 r)rrrrZ_original_Pollerrrrrr�<module>
s