U lu f† ã@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}|jD]´\}}t|tjƒr<| | tj¡¡qnNt|tƒrL|}n>t|dƒr~zt|  ¡ƒ}WqŠt dƒ‚YqŠXn t d|ƒ‚|tj @rž| |¡|tj @r²| |¡|tj@r| |¡q|||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ÚappendÚ getsockoptZFDÚintÚhasattrrÚ ValueErrorÚ TypeErrorÚPOLLINÚPOLLOUTÚPOLLERR)ÚselfÚrlistÚwlistÚxlistÚsocketÚflagsÚfd©rú2/tmp/pip-unpacked-wheel-h6ekxre8/zmq/green/poll.pyÚ_get_descriptorss4   ÿÿ      z_Poller._get_descriptorséÿÿÿÿc s4|dkr d}|dkrd}d}d}d}|dkr>tj |d¡}nd}zØz–| ¡\}}}tƒ d¡}|sl|dkrv|WW¢¨Stj |j¡}zFzt |||¡Wn.tjk rÆ}z||k r¶‚W5d}~XYnXW5| ¡XqTWn<tjk r}z||k rú‚gWY¢W¢Sd}~XYnXW5|dkr.| ¡XdS)zOverridden method to ensure that the green version of Poller is used. Behaves the same as :meth:`zmq.core.Poller.poll` Nrrg@@) ÚgeventÚTimeoutÚ start_newÚcancelrÚsuperÚpollÚ_gevent_bug_timeoutr) rÚtimeoutrrrZtoutÚeventsZ _bug_timeoutÚt©Ú __class__rrr!3s8   " z _Poller.poll)r)Ú__name__Ú __module__Ú __qualname__Ú__doc__r"rr!Ú __classcell__rrr&rrs"r)rrrrZ_original_PollerrrrrrÚs