<|h3dZddlmZmZmZddlZddlZddlm Z ddl m Z ddl m ZddlmZddlmZdd lmZdd lmZdd lmZej Zej0j3d rd ZneZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dgZ%e&edre%jOdndgZ(dge%zZ)ejTZ*eee+e)dZ,dZ-dZ.dZ/Gdde0Z1d$dZGd d!e0Z2Gd"de0Z3d#Z4y)%z Waiting for I/O completion. )absolute_importdivisionprint_functionN)Event)_get_hub_noargs)sleep) integer_types) iteritems) copy_globals)_NONE)EINTRwin32c,|s|s|syt||||S)Nrr)_real_original_select)rwxts L/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/select.py_original_selectrs1$Q1a00 @selectpollerrorr)names_to_ignoredunder_names_to_keepc |j}|S#t$r#t|tst d||cYSwxYw)Nz4argument must be an int, or have a fileno() method: )filenoAttributeError isinstancer TypeError)objfileno_fs r get_filenor/BsI:: : #}-X[]^ ^ s )AAcFeZdZdZedZedZedZdZ y) SelectResultrc$fd}||_|S)Nchj||jjyN)appendcloseset)fdwatchereventready_collections rcbz'SelectResult._make_callback..cbQs#  # #B ' MMO IIKr)mask)r;r:r=r<s`` r_make_callbackzSelectResult._make_callbackOs  rcTtj}|j}|j}|D]T\}} |D]I}|t ||j } || _|j| | j||| KVy#t$r} t| jd} ~ wwxYwr4) get_hubloopioMAXPRIr/r=priorityr5startIOErrorr%args) clswatchersfd_cbrArBrCfdlistcallbackr8r9exs r_make_watcherszSelectResult._make_watchersXsy~~ WW % & FH & 9B B?G'-G$OOG,MM(B8 9 & &RWWo% &sAB B'B""B'c\|D]"}|j|j$|dd=yr4)stopr6)rIr9s r _closeallzSelectResult._closeallhs, G LLN MMO  QKrc*g}g}g}t}|j||t}|j||t} |j |||f|| f|j |||gf|j |S#|j |wxYw)Ntimeout)rr>_EV_READ _EV_WRITErNwaitrQ) selfrlistwlistrTrIreadwriter:add_read add_writes rr#zSelectResult.selectos&&tUH=''ui@  %   !& 1!& 2 4 JJwJ '? NN8 $DNN8 $s -A??BN) __name__ __module__ __qualname__ __slots__ staticmethodr> classmethodrNrQr#rrrr1r1LsFI & & %rr1c||dkr tdt|ttfr|n t|}t|ttfr|n t|}d} t |||d}|ds|ds |ds||dk(r t|St}|j|||S#t $r2}t |ddxs|jd}|tk7rYd}~ud}~wwxYw)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%getattrrGr _g_sleepr1r#)rYrZxlistrT sel_resultseenumberresults rr#r#sw{788  e}5E4;Ee}5E4;EK&ueUA> 1~Q;q>g>QV]abVb   ^F ==w /// !Wd+8qvvay e   sB)) C$2(CC$ceZdZdZdZdZy) PollResult)eventsr:c@t|_t|_yr4)r7rsrr:rXs r__init__zPollResult.__init__se W rc|dkrt}n#d}|tzrt}|tzr |tz}|j j ||f|jjy)Nr) POLLNVALrUPOLLINrVPOLLOUTrsaddr:r7)rXrsr8 result_flagss r add_eventzPollResult.add_eventsU A:#LL %  !'  \*+ rN)r_r`rarbrvr}rrrrrrrs#I rrrc:eZdZdZdZefdZdZdZd dZ dZ y) 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|_yr4)fdsr@rArus rrvz poll.__init__s INN rc|turttz}n#d}|tzrt}|tzr |tz}t |}||j |<y)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 rUrVryrzr/r)rXr8 eventmaskflagsr)s rregisterz poll.registersS  y(EE6! 7""B rc(|j||y)zA Change the set of events being watched on *fd*. N)r)rXr8rs rmodifyz poll.modifys b)$rcdg}|jj}|jj} t|jD]:\}}|||}|j |||_|j||d< |S#|D]"}|j|j$xYw)NT) pass_events) rArBrCr rr5rDrErPr6) rX watcher_cbrIrBrCr8rr9awatchers r_get_started_watcherszpoll._get_started_watcherss YY\\!! &txx0 @ ER-(#)  j"$ ?  @  $ !   ! s AB*B/Ncxt}|j|j} ||dkrd}n|r|dz}|jj |t |j |D]"}|j|j$S#|D]"}|j|j$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@@rS) rrrr}r:rWrhrsrPr6)rXrTrprIrs rr$z poll.poll1s--f.>.>? !"Q;#Gv%G LL  g  . &$ !   !H !   !s AB)B9c4t|}|j|=y)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/r)rXr8r)s r unregisterzpoll.unregisterZsB HHV rr4) r_r`ra__doc__rvr rrrr$rrrrr$r$s+ #&+!:% &'!R rcp|jd}|j|r|jddddyy)N aggressiveepollkqueuekeventdevpoll) patch_kwargsdefault_patch_items remove_item) patch_requestrs r_gevent_do_monkey_patchrfsB++L9J%%' !!      rr4)5r __future__rrrsysr# __select__ gevent.eventr gevent.hubrr@rrkgevent._compatr r gevent._utilr r rfr rplatform startswithrryPOLLPRIrzPOLLERRPOLLHUPrx POLLRDNORM POLLRDBAND POLLWRNORM POLLWRBAND__implements__hasattrr5 __extra____all__r%globals __imports__rUrVr/objectr1rrr$rrrrrs6A@ 1(($%"))<<7#1-             :v&! I )n $:wy+2024   >%6>%B@0H(~6~B r