o 0׾g3@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)rwxtrrW/var/www/html/backend_erp/backend_erp_env/lib/python3.10/site-packages/gevent/select.py_original_selects r @selectpollerrorr)names_to_ignoredunder_names_to_keepcCs>z|j}W|Styt|tstd|f|YSw)Nz6argument must be an int, or have a fileno() method: %r)filenoAttributeError isinstancer TypeError)objfileno_frrr get_filenoBs r+c@s<eZdZdZeddZeddZeddZdd Z d S) SelectResultrcsfdd}||_|S)Ncs||dSN)appendcloseset)fdwatchereventready_collectionrrcbQs  z'SelectResult._make_callback..cb)mask)r5r4r7r6rr3r_make_callbackOszSelectResult._make_callbackc Gstj}|j}|j}|D]3\}}z|D]}|t||j} || _|| | ||| qWq t y?} zt | j d} ~ wwdSr-) get_hubloopioMAXPRIr+r7priorityr.startIOErrorr"args) clswatchersfd_cbr:r;r<fdlistcallbackr1r2exrrr_make_watchersXs    zSelectResult._make_watcherscCs(|D] }||q|dd=dSr-)stopr/)rBr2rrr _closeallhs zSelectResult._closeallc Cstg}g}g}t}|||t}|||t} z||||f|| f|j|d||gfW||S||w)Ntimeout)rr8_EV_READ _EV_WRITErGwaitrI) selfrlistwlistrKrBreadwriter4add_read add_writerrrr os   zSelectResult.selectN) __name__ __module__ __qualname__ __slots__ staticmethodr8 classmethodrGrIr 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 )rPrQxlistrK sel_resultseenumberresultrrrr s&   ( c@s eZdZdZddZddZdS) PollResult)eventsr4cCst|_t|_dSr-)r0rhrr4rOrrr__init__s zPollResult.__init__cCsL|dkrt}nd}|t@rt}|t@r|tO}|j||f|jdS)Nr) POLLNVALrLPOLLINrMPOLLOUTrhaddr4r0)rOrhr1 result_flagsrrr add_eventszPollResult.add_eventN)rVrWrXrYrjrprrrrrgs rgc@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-)fdsr9r:rirrrrjsz 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 rLrMrlrmr+rq)rOr1 eventmaskflagsr%rrrregisters z poll.registercCs|||dS)zA Change the set of events being watched on *fd*. N)rt)rOr1rrrrrmodifysz poll.modifyc Cs|g}|jj}|jj}z"t|jD]\}}|||}||||_|j||ddqW|S|D] }|| q2)NT) pass_events) r:r;r<r rqr.r=r>rHr/) rO watcher_cbrBr;r<r1rsr2awatcherrrr_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@@rJ) rgryrpr4rNr^rhrHr/)rOrKrfrBrxrrrr!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+rq)rOr1r%rrr unregisterZs zpoll.unregisterr-) rVrWrX__doc__rjr rtruryr!rzrrrrr!s   )cCs.|jd}||r|dddddSdS)N aggressiveepollkqueuekeventdevpoll) patch_kwargsdefault_patch_items remove_item) patch_requestr|rrr_gevent_do_monkey_patchfs rr-)5r{ __future__rrrsysr __select__ gevent.eventr gevent.hubrr9rragevent._compatrr gevent._utilr r r\r rplatform startswithrrlPOLLPRIrmPOLLERRPOLLHUPrk POLLRDNORM POLLRDBAND POLLWRNORM POLLWRBAND__implements__hasattrr. __extra____all__r"globals __imports__rLrMr+objectr,rgr!rrrrrs^              AD