B b ,c† ã@s<ddlZddlmZddlZddlmZGdd„deƒZdS)éN)Úselect)ÚPollercs.eZdZdZdZdd„Zd‡fdd„ 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õ?cCsÖg}g}g}x¾|jD]´\}}t|tjƒr>| | tj¡¡qnNt|tƒrN|}n>t|dƒr€yt|  ¡ƒ}WqŒt dƒ‚YqŒXn t d|ƒ‚|tj @r | |¡|tj @r´| |¡|tj@r| |¡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ú-lib/python3.7/site-packages/zmq/green/poll.pyÚ_get_descriptorss0        z_Poller._get_descriptorséÿÿÿÿc s&|dkr d}|dkrd}d}d}d}|dkr>tj |d¡}nd}zÊy”| ¡\}}}x€tƒ d¡}|sn|dkrr|Stj |j¡}zFyt |||¡Wn.tjk rÂ}z||k r²‚Wdd}~XYnXWd| ¡XqVWWn0tjk r}z||k rø‚gSd}~XYnXWd|dkr | ¡XdS)zOverridden method to ensure that the green version of Poller is used. Behaves the same as :meth:`zmq.core.Poller.poll` Nrrg@@) ÚgeventZTimeoutÚ start_newrÚsuperÚpollÚ_gevent_bug_timeoutrZcancel) r ZtimeoutrrrZtoutZeventsZ _bug_timeoutÚt)Ú __class__rrr3s:   z _Poller.poll)r)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrÚ __classcell__rr)rrrs"r)rrrrZ_original_PollerrrrrrÚs