L]c@sRddlZddlZddlmZddlmZdefdYZdS(iN(tselect(tPollert_PollercBs)eZdZdZdZddZRS(sReplacement for :class:`zmq.Poller` Ensures that the greened Poller below is used in calls to :meth:`zmq.Poller.poll`. gHzG?cCs'g}g}g}x|jD]\}}t|tjrY|j|jtjqnft|trq|}nNt|dryt|j }Wqt dqXnt d||tj @r|j|n|tj @r|j|n|tj@r|j|qqW|||fS(sdReturns three elements tuple with socket descriptors ready for gevent.select.select tfilenos(fileno() must return an valid integer fdsHSocket must be a 0MQ socket, an integer fd or have a fileno() method: %r(tsocketst isinstancetzmqtSockettappendt getsockopttFDtintthasattrRt ValueErrort TypeErrortPOLLINtPOLLOUTtPOLLERR(tselftrlisttwlisttxlisttsockettflagstfd((s-lib/python2.7/site-packages/zmq/green/poll.pyt_get_descriptorss.     ic Csu|dkrd}n|dkr*d}nd}d}d}|dkratjj|d}nd}zy|j\}}}xtr%tt|jd}|s|dkr|Stjj|j }zFyt j |||Wn(tjk r}||k rqnXWd|j XqWWn)tjk rR}||k rNngSXWd|dkrp|j nXdS(sOverridden method to ensure that the green version of Poller is used. Behaves the same as :meth:`zmq.core.Poller.poll` iig@@N( tNonetgeventtTimeoutt start_newRtTruetsuperRtpollt_gevent_bug_timeoutRtcancel( RttimeoutRRRttoutteventst _bug_timeouttt((s-lib/python2.7/site-packages/zmq/green/poll.pyR 0s>          (t__name__t __module__t__doc__R!RR (((s-lib/python2.7/site-packages/zmq/green/poll.pyRs (RRRRt_original_PollerR(((s-lib/python2.7/site-packages/zmq/green/poll.pyts