o U˟i5@sRdZddlmZmZmZddlZddlZddlm Z ddl m Z ddl m ZddlmZddlmZdd lmZejZejd rFd d ZneZd ZdZdZdZdZdZdZdZdZ dZ!dgZ"e#edrje"$dndgZ%dge"Z&ej'Z'eee(e&ddZ)d Z*dZ+ddZ,Gddde-Z.d%ddZGd d!d!e-Z/Gd"dde-Z0d#d$Z1dS)&z Waiting for I/O completion. )absolute_importdivisionprint_functionN)Event)_get_hub_noargs)sleep) copy_globals)_NONE)EBADFwin32cCs|s|s|sdSt||||S)N)r r )_real_original_select)rwxtr r U/var/www/apps/myagent/mysuperagent/venv/lib/python3.10/site-packages/gevent/select.py_original_selects r @selectpollerrorr )names_to_ignoredunder_names_to_keepc Cs`t|tr|}nzt|}Wntttfy"td|dw|dkr.td||S)NzInvalid file object: {!r}rzInvalid file descriptor: {}) isinstanceintfilenoAttributeError TypeError ValueErrorformat)fileobjfdr r r get_filenoEs r+c@s<eZdZdZeddZeddZeddZdd Z d S) SelectResultr csfdd}||_|S)Ncs||dSN)appendcloseset)r*watchereventready_collectionr rcbXs  z'SelectResult._make_callback..cb)mask)r4r3r6r5r r2r_make_callbackVszSelectResult._make_callbackc Gs^tj}|j}|j}|D] \}}|D]}|t||j} || _|| | ||| qq dSr-) get_hubloopioMAXPRIr+r6priorityr.start) clswatchersfd_cbr9r:r;fdlistcallbackr*r1r r r_make_watchers_s  zSelectResult._make_watcherscCs(|D] }||q|dd=dSr-)stopr/)r?r1r r r _closeallls zSelectResult._closeallc Cstg}g}g}t}|||t}|||t} z||||f|| f|j|d||gfW||S||w)Ntimeout)rr7_EV_READ _EV_WRITErCwaitrE) selfrlistwlistrGr?readwriter3add_read add_writer r rrss   zSelectResult.selectN) __name__ __module__ __qualname__ __slots__ staticmethodr7 classmethodrCrErr r r rr,Ss    r,cCs|dur |dkr tdt|ttfr|nt|}t|ttfr"|nt|}t|||d}|dsA|dsA|dsA|durF|dkrFt|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-negativerr)r'r"listtupler_g_sleepr,r)rLrMxlistrG sel_resultsresultr r rrs  ( c@s(eZdZdZddZddZddZdS) PollResult)eventsr3cCst|_t|_dSr-)r0r_rr3rKr r r__init__s zPollResult.__init__cCsL|dkrt}nd}|t@rt}|t@r|tO}|j||f|jdS)Nr) POLLNVALrHPOLLINrIPOLLOUTr_addr3r0)rKr_r* result_flagsr r r add_eventszPollResult.add_eventcCs|j|tfdSr-)r_rerb)rKr*r r radd_error_before_ioszPollResult.add_error_before_ioN)rRrSrTrUrargrhr r r rr^s  r^c@sFeZdZdZddZefddZddZdd Zdd d Z d dZ d S)ra 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-)fdsr8r9r`r r rrasz 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 rHrIrcrdr+ri)rKr* eventmaskflagsr$r r rregisters z poll.registercCs|||dS)zA Change the set of events being watched on *fd*. N)rl)rKr*rjr r rmodifysz poll.modifyc Csg}|jj}|jj}|j}zB|jD]9\}}z|||}Wnty;} z| jtkr,| |WYd} ~ qd} ~ ww| |||_ |j ||ddqW|S|D] } | | qU)NT) pass_events)r9r:r;rgriitemsOSErrorerrnor rhr.r<r=rDr/) rK poll_resultr?r:r; watcher_cbr*rkr1exawatcherr r r_get_started_watchers s2     zpoll._get_started_watchersNc Cst}||}z+|dur|dkrd}n|r|d}|jj|dt|jW|D] }||q(S|D] }||q6w)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@@rF)r^rvr3rJrXr_rDr/)rKrGr]r?rur r rr:s"      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+ri)rKr*r$r r r unregistercs zpoll.unregisterr-) rRrSrT__doc__rar rlrmrvrrwr r r rrs   )cCs.|jd}||r|dddddSdS)N aggressiveepollkqueuekeventdevpoll) patch_kwargsdefault_patch_items remove_item) patch_requestryr r r_gevent_do_monkey_patchos rr-)2rx __future__rrrsysr __select__ gevent.eventr gevent.hubrr8rrZ gevent._utilrr rqr r platform startswithrrcPOLLPRIrdPOLLERRPOLLHUPrb POLLRDNORM POLLRDBAND POLLWRNORM POLLWRBAND__implements__hasattrr. __extra____all__rglobals __imports__rHrIr+objectr,r^rrr r r rsZ            >>