o e3@sjdZddlmZmZmZddlZddlZddlm Z ddl m Z ddl m ZddlmZddlmZdd lmZdd lmZdd lmZejZejd rRd dZneZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dgZ%e&edrve%'dndgZ(dge%Z)ej*Z*eee+e)ddZ,dZ-dZ.ddZ/Gdd d e0Z1d'd!dZGd"d#d#e0Z2Gd$dde0Z3d%d&Z4dS)(z Waiting for I/O completion. )absolute_importdivisionprint_functionN)Event)_get_hub_noargs)sleep) integer_types) iteritems) copy_globals)_NONE)EINTRwin32cCs|s|s|sdSt||||S)Nrr)_real_original_select)rwxtrr=D:\Projects\ConvertPro\env\Lib\site-packages\gevent/select.py_original_selects r @selectpollerrorr)Znames_to_ignoreZdunder_names_to_keepcCs>z|j}W|Styt|tstd|f|YSw)Nz6argument must be an int, or have a fileno() method: %r)filenoAttributeError isinstancer TypeError)objZfileno_frrr get_filenoBs r(c@s<eZdZdZeddZeddZeddZdd Z d S) SelectResultrcsfdd}||_|S)Ncs||dSN)appendcloseset)fdwatchereventready_collectionrrcbQs  z'SelectResult._make_callback..cb)mask)r2r1r4r3rr0r_make_callbackOszSelectResult._make_callbackc Gstj}|j}|j}|D]3\}}z|D]}|t||j} || _|| | ||| qWq t y?} zt | j d} ~ wwdSr*) get_hubloopioMAXPRIr(r4priorityr+startIOErrorr"args) clswatchersZfd_cbr7r8r9Zfdlistcallbackr.r/exrrr_make_watchersXs    zSelectResult._make_watcherscCs(|D] }||q|dd=dSr*)stopr,)r?r/rrr _closeallhs zSelectResult._closeallc Cstg}g}g}t}|||t}|||t} z||||f|| f|j|d||gfW||S||w)Ntimeout)rr5_EV_READ _EV_WRITErBwaitrD) selfrlistwlistrFr?readwriter1Zadd_readZ add_writerrrr os   zSelectResult.selectN) __name__ __module__ __qualname__ __slots__ staticmethodr5 classmethodrBrDr rrrrr)Ls    r)c Cs|dur |dkr tdt|ttfr|nt|}t|ttfr"|nt|}d}z t|||d}Wn"tyS}zt|ddpC|jd}|tkrIWYd}~nd}~ww|dsh|dsh|dsh|durm|dkrmt |St }| |||S)aAn implementation of :obj:`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-negativererrnorr) ValueErrorr%listtuplerr"getattrr=r _g_sleepr)r )rKrLZxlistrFZ sel_resultseZenumberresultrrrr s&   ( c@s eZdZdZddZddZdS) PollResult)eventsr1cCst|_t|_dSr*)r-r^rr1rJrrr__init__s zPollResult.__init__cCsL|dkrt}nd}|t@rt}|t@r|tO}|j||f|jdS)Nr) POLLNVALrGPOLLINrHPOLLOUTr^addr1r-)rJr^r.Z result_flagsrrr add_eventszPollResult.add_eventN)rOrPrQrRr`rerrrrr]s r]c@sFeZdZdZddZefddZddZdd Zdd d Z d dZ d S)r!a An implementation of :obj:`select.poll` that blocks only the current greenlet. With only one exception, the interface is the same as the standard library interface. .. caution:: ``POLLPRI`` data is not supported. .. versionadded:: 1.1b1 .. versionchanged:: 1.5 This is now always defined, regardless of whether the standard library defines :func:`select.poll` or not. Note that it may have different performance characteristics. cCsi|_tj|_dSr*)fdsr6r7r_rrrr`sz poll.__init__cCsH|tur ttB}nd}|t@rt}|t@r|tO}t|}||j|<dS)a Register a file descriptor *fd* with the polling object. Future calls to the :meth:`poll`` method will then check whether the file descriptor has any pending I/O events. *fd* can be either an integer, or an object with a ``fileno()`` method that returns an integer. File objects implement ``fileno()``, so they can also be used as the argument (but remember that regular files are usually always ready). *eventmask* is an optional bitmask describing the type of events you want to check for, and can be a combination of the constants ``POLLIN``, and ``POLLOUT`` (``POLLPRI`` is not supported). rN)r rGrHrbrcr(rf)rJr. eventmaskflagsr#rrrregisters z poll.registercCs|||dS)zA Change the set of events being watched on *fd*. N)ri)rJr.rgrrrmodifysz poll.modifyc Cs|g}|jj}|jj}z"t|jD]\}}|||}||||_|j||ddqW|S|D] }|| q2)NT)Z pass_events) r7r8r9r rfr+r:r;rCr,) rJZ watcher_cbr?r8r9r.rhr/awatcherrrr_get_started_watcherss     zpoll._get_started_watchersNc Cst}||j}z+|dur|dkrd}n|r|d}|jj|dt|jW|D] }||q)S|D] }||q7w)aH 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. Nrg@@rE) r]rlrer1rIrWr^rCr,)rJrFr\r?rkrrrr!1s"      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(rf)rJr.r#rrr unregisterZs zpoll.unregisterr*) rOrPrQ__doc__r`r rirjrlr!rmrrrrr!s   )cCs.|jd}||r|dddddSdS)N aggressiveZepollZkqueueZkeventZdevpoll)Z patch_kwargsZdefault_patch_itemsZ remove_item)Z patch_requestrorrr_gevent_do_monkey_patchfs rpr*)5rn __future__rrrsysr Z __select__Z gevent.eventrZ gevent.hubrr6rrZZgevent._compatrr Z gevent._utilr r rUr rplatform startswithrrbZPOLLPRIrcZPOLLERRZPOLLHUPraZ POLLRDNORMZ POLLRDBANDZ POLLWRNORMZ POLLWRBANDZ__implements__hasattrr+Z __extra____all__r"globalsZ __imports__rGrHr(objectr)r]r!rprrrrs^              AD