B H/\'@svdZddlmZmZmZddlZddlmZddlm Z ddlm Z ddl mZddl mZdd lmZdd lmZdd lmZdd lmZejd rddZneZy,ddlmZddlmZmZmZddgZWne k rdZdgZYnXdgeZ!ddlZ"e"j#Z#ee"e$e!ddZ%dZ&dZ'ddZ(Gddde)Z*d!ddZedk rpGddde)Z+Gd dde)Z[dS)"z Waiting for I/O completion. )absolute_importdivisionprint_functionN)Event)_get_hub_noargs)sleep) integer_types) iteritems) copy_globals)_NONE)EINTR)selectZwin32cCs|s|s|sdSt||||S)N)rr)_real_original_select)rwxtrr,lib/python3.7/site-packages/gevent/select.py_original_selects r)poll)POLLINPOLLOUTPOLLNVALr rerrorr)Znames_to_ignoreZdunder_names_to_keepcCsBy |j}Wn,tk r6t|ts2td|f|SX|SdS)Nz6argument must be an int, or have a fileno() method: %r)filenoAttributeError isinstancer TypeError)objZfileno_frrr get_fileno3s  r"c@sTeZdZdZddZddZee_ddZe e_dd Z d d Z d d Z ddZ dS) SelectResult)readwriteeventcCsg|_g|_t|_dS)N)r$r%rr&)selfrrr__init__AszSelectResult.__init__cCs|j||jdS)N)r$appendr&set)r'socketrrradd_readFs zSelectResult.add_readcCs|j||jdS)N)r%r)r&r*)r'r+rrr add_writeLs zSelectResult.add_writecCs>x8|D]0}|t||j}||_|||||qWdS)N)r"r&priorityr)start)r'watchersZfdlistcallbackioZprifdwatcherrrrZ__add_watchersRs   zSelectResult.__add_watchersc Csrtj}|j}|j}y,||||j||||||j||Wn,tk rl}zt|j Wdd}~XYnXdS)N) get_hubloopr2MAXPRI_SelectResult__add_watchersr,r-IOErrorrargs)r'r0rlistwlistr6r2r7exrrr_make_watchersYszSelectResult._make_watcherscCs,x|D]}||qW|dd=dS)N)stopclose)r'r0r4rrr _closeallds  zSelectResult._closeallc Cs@g}z*|||||jj|d|j|jgfS||XdS)N)timeout)r>r&waitr$r%rA)r'r;r<rBr0rrrr js zSelectResult.selectN)__name__ __module__ __qualname__ __slots__r(r,_EV_READr&r- _EV_WRITEr8r>rAr rrrrr#>s r#c Cs|dk r|dkrtdd}yt|||d}WnBtk rp}z$t|ddpT|jd}|tkr`Wdd}~XYnX|ds|ds|ds|dk r|dkrt|St}||||S)aAn implementation of :meth:`select.select` that blocks only the current greenlet. .. caution:: *xlist* is ignored. .. versionchanged:: 1.2a1 Raise a :exc:`ValueError` if timeout is negative. This matches Python 3's behaviour (Python 2 would raise a ``select.error``). Previously gevent had undefined behaviour. .. versionchanged:: 1.2a1 Raise an exception if any of the file descriptors are invalid. Nrztimeout must be non-negative)rrrerrnorr) ValueErrorrrgetattrr:r _g_sleepr#r )r;r<ZxlistrBZ sel_resultseZenumberresultrrrr ts ( c@s eZdZdZddZddZdS) PollResult)eventsr&cCst|_t|_dS)N)r*rQrr&)r'rrrr(szPollResult.__init__cCsL|dkrt}n d}|t@rt}|t@r.|tO}|j||f|jdS)Nr) rrHrrIrrQaddr&r*)r'rQr3Z result_flagsrrr add_eventszPollResult.add_eventN)rDrErFrGr(rSrrrrrPsrPc@s>eZdZdZddZefddZddZd d d Zd d Z dS)rz An implementation of :class:`select.poll` that blocks only the current greenlet. .. caution:: ``POLLPRI`` data is not supported. .. versionadded:: 1.1b1 cCsi|_tj|_dS)N)fdsr5r6)r'rrrr(sz poll.__init__cCsH|tkrttB}n d}|t@r"t}|t@r2|tO}t|}||j|<dS)Nr)r rHrIrrr"rT)r'r3 eventmaskflagsrrrrregisters z poll.registercCs|||dS)N)rW)r'r3rUrrrmodifysz poll.modifyNc Cst}g}|jj}|jj}z~xBt|jD]4\}}|||}||||_|j|j |ddq(W|dk r|dkrvd}n |r|d}|j j |dt |j Sx|D]} | | qWXdS)ad poll the registered fds. .. versionchanged:: 1.2a1 File descriptors that are closed are reported with POLLNVAL. .. versionchanged:: 1.3a2 Under libuv, interpret *timeout* values less than 0 the same as *None*, i.e., block. This was always the case with libev. T)Z pass_eventsNrg@@)rB)rPr6r2r7r rTr)r.r/rSr&rClistrQr?r@) r'rBrOr0r2r7r3rVr4Zawatcherrrrrs(      z poll.pollcCst|}|j|=dS)z Unregister the *fd*. .. versionchanged:: 1.2a1 Raise a `KeyError` if *fd* was not registered, like the standard library. Previously gevent did nothing. N)r"rT)r'r3rrrr unregisterszpoll.unregister)N) rDrErF__doc__r(r rWrXrrZrrrrrs   0)N),r[Z __future__rrrsysZ gevent.eventrZ gevent.hubrr5rrMZgevent._compatrr Z gevent._utilr r rJr r rplatform startswithrrZ original_pollrrrZ__implements__ ImportError__all__Z __select__rglobalsZ __imports__rHrIr"objectr#rPrrrrsH                6 8 ]