o Zh @sHddlmZddlZddlmZddlZddlmZGdddeZdS)) annotationsN)select)Pollercs.eZdZdZdZddZdfdd ZZS) _PollerzReplacement for :class:`zmq.Poller` Ensures that the greened Poller below is used in calls to :meth:`zmq.Poller.poll`. gHzG?c Csg}g}g}|jD]Z\}}t|tjr||tjq t|tr%|}n t|dr>zt| }Wnt y=t dwt d||tj @rO|||tj@rY|||tj@rc||q |||fS)zdReturns three elements tuple with socket descriptors ready for gevent.select.select filenoz(fileno() must return an valid integer fdzFSocket must be a 0MQ socket, an integer fd or have a fileno() method: )Zsockets isinstancezmqZSocketappend getsockoptZFDinthasattrr Exception ValueError TypeErrorPOLLINPOLLOUTPOLLERR)selfrlistwlistxlistsocketflagsfdrE/var/www/html/lang_env/lib/python3.10/site-packages/zmq/green/poll.py_get_descriptorss8           z_Poller._get_descriptorsc sP|durd}|dkr d}d}d}d}|dkrtj|d}nd}z|zW|\}}} td}|s7|dkrD|WW|dkrC|SStj|j}z(z t|||Wntjym}z ||urcWYd}~nd}~wwW|n|wq+tjy}z||urgWYd}~W|dkr|SSd}~ww|dkr|ww)zOverridden method to ensure that the green version of Poller is used. Behaves the same as :meth:`zmq.core.Poller.poll` Nrrg@@) geventTimeout start_newrsuperpollcancel_gevent_bug_timeoutr) rtimeoutrrrZtouteventsZ _bug_timeoutt __class__rrr"5sV      z _Poller.poll)r)__name__ __module__ __qualname____doc__r$rr" __classcell__rrr(rr s "r) __future__rrrrrZ_original_Pollerrrrrrs