i5dZddlmZmZmZddlZddlZddlm Z ddl m Z ddl m ZddlmZddlmZdd lmZejZejd rd ZneZd Zd ZdZdZdZdZdZdZdZ dZ!dgZ"e#edre"$dndgZ%dge"zZ&ej'Z'eee(e&dZ)d Z*d Z+dZ,Gdde-Z.d"dZGdde-Z/Gd de-Z0d!Z1dS)#z Waiting for I/O completion. )absolute_importdivisionprint_functionN)Event)_get_hub_noargs)sleep) copy_globals)_NONE)EBADFwin32c6|s|s|sdSt||||S)N)rr)_real_original_select)rwxts 8/usr/local/lib/python3.11/dist-packages/gevent/select.py_original_selectrs3  1 <$Q1a000 @selectpollerrorr)names_to_ignoredunder_names_to_keepcHt|tr|}na t|}n>#ttt f$r$t d|dwxYw|dkr"t d||S)NzInvalid file object: {!r}rzInvalid file descriptor: {}) isinstanceintfilenoAttributeError TypeError ValueErrorformat)fileobjfds r get_filenor/Es'3?  ?W^^%%&&BB :6 ? ? ?$$*F7OO55:> ? ? Avv6==bAABBB Is !<;A7cZeZdZdZedZedZedZdZ dS) SelectResultrc$fd}||_|S)Nc||dSN)appendcloseset)r.watchereventready_collections rcbz'SelectResult._make_callback..cbXs5  # #B ' ' ' MMOOO IIKKKKKr)mask)r:r9r<r;s`` r_make_callbackzSelectResult._make_callbackVs0       rctj}|j}|j}|D][\}}|D]S}|t ||j} || _|| | ||| T\dSr4) get_hubloopioMAXPRIr/r<priorityr5start) clswatchersfd_cbr@rArBfdlistcallbackr.r8s r_make_watcherszSelectResult._make_watchers_syy~ W % 5 5 FH 5 5"Z^^X];;#) ((( hG4444  5 5 5rcj|D]*}||+|dd=dSr4)stopr6)rFr8s r _closeallzSelectResult._closeallls<  G LLNNN MMOOOO QQQKKKrcfg}g}g}t}|||t}|||t} ||||f|| f||||gf||S#||wxYw)Ntimeout)rr=_EV_READ _EV_WRITErJwaitrM) selfrlistwlistrPrFreadwriter9add_read add_writes rr zSelectResult.selectss&&tUH==''ui@@  %   !& 1!& 2 4 4 4 JJwJ ' ' '? NN8 $ $ $ $DNN8 $ $ $ $s 5BB0N) __name__ __module__ __qualname__ __slots__ staticmethodr= classmethodrJrMr rrrr1r1SswI\ 5 5[ 5\ %%%%%rr1c||dkrtdt|ttfr|nt|}t|ttfr|nt|}t |||d}|ds|ds|ds||dkrt |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_sleepr1r )rUrVxlistrP sel_resultsresults rr r sw{{7888  e}55 FEE4;;Ee}55 FEE4;;E#5%::K1~Q;q>g>QV]abVbVb   ^^F ==w / //rc$eZdZdZdZdZdZdS) PollResult)eventsr9cRt|_t|_dSr4)r7rjrr9rTs r__init__zPollResult.__init__see WW rc|dkrt}n'd}|tzrt}|tzr |tz}|j||f|jdS)Nr) POLLNVALrQPOLLINrRPOLLOUTrjaddr9r7)rTrjr. result_flagss r add_eventzPollResult.add_eventsq A::#LLL  &%  ! ('  \*+++ rcH|j|tfdSr4)rjrrro)rTr.s radd_error_before_iozPollResult.add_error_before_ios  X'''''rN)r[r\r]r^rmrtrvrrrririsF#I   (((((rric<eZdZdZdZefdZdZdZd dZ dZ dS) 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. cDi|_tj|_dSr4)fdsr?r@rls rrmz poll.__init__s IIN rc|turttz}n'd}|tzrt}|tzr |tz}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 rQrRrprqr/ry)rTr. eventmaskflagsr(s rregisterz poll.registersh   y(EEE6! ! 7" #"B rc2|||dS)zA Change the set of events being watched on *fd*. N)r})rTr.r{s rmodifyz poll.modifys b)$$$$$rcg}|jj}|jj}|j} |jD]\}} |||}n=#t $r0} | jtkr| |Yd} ~ Hd} ~ wwxYw| |||_ | ||dn3#|D]*} | | +xYw|S)NT) pass_events)r@rArBrtryitemsOSErrorerrnor rvr5rCrDrLr6) rT poll_resultrFrArB watcher_cbr.r|r8exawatchers r_get_started_watcherszpoll._get_started_watchers s) Y\! *  !X^^-- @ @ E bUmmGGx5((33B777HHHH  (((#)  j"$ ???? @ $ ! !     s5C AC B &B?CB  8C0C2Nct}||} ||dkrd}n|r|dz}|j|t |j|D]*}||+S#|D]*}||+wxYw)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@@rO)rirr9rSrbrjrLr6)rTrPrgrFrs rr!z poll.poll:s--f55 !"Q;;#GG&v%G L  g  . . . &&$ ! !      !H ! !      !s AB/Cc4t|}|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/ry)rTr.r(s r unregisterzpoll.unregistercsB HV   rr4) r[r\r]__doc__rmr r}rrr!rrrrr!r!s  ###&+!!!!:%%% 4'!'!'!'!R     rc|jd}||r|dddddSdS)N aggressiveepollkqueuekeventdevpoll) patch_kwargsdefault_patch_items remove_item) patch_requestrs r_gevent_do_monkey_patchrosc+L9J%%'''   !!            rr4)2r __future__rrrsysr __select__ gevent.eventr gevent.hubrr?rrd gevent._utilr r rr rplatform startswithrrpPOLLPRIrqPOLLERRPOLLHUPro POLLRDNORM POLLRDBAND POLLWRNORM POLLWRBAND__implements__hasattrr5 __extra____all__r"globals __imports__rQrRr/objectr1rir!rrrrrsvA@@@@@@@@@ 111111((((((%%%%%%")<7##-1111-             7:v&!!!! I )n $ l:wwyy+202444      ;%;%;%;%;%6;%;%;%|:0:0:0:0|((((((((0EEEEE6EEEP     r