i64dZddlmZddlmZddlmZddlZddlmZddlmZddl m Z dd l m Z dd l m Z dd lmZdd lmZed jed<ded<e jed<e jed<e jed<gdZGddeZGddeZd%dZd&dZea dZ!dZ"d'dZ#de dfdZ$de fdZ%de e fd Z&de e fd!Z'd"Z(e(dd#l m)Z)e)e*d$dS)(z{ A collection of primitives used by the hub, and suitable for compilation with Cython because of their frequency of use. )absolute_import)division)print_functionN)InvalidSwitchError)ConcurrentObjectUseError)_greenlet_primitives)_waiter)_NONE)get_hub_noargs)Timeoutgreenlet getcurrentcdSNrA/usr/local/lib/python3.11/dist-packages/gevent/_hub_primitives.pyrsDr greenlet_initWaiterMultipleWaiterSwitchOutGreenletWithLoop)WaitOperationsGreenletiwait_on_objectswait_on_objects wait_read wait_writewait_readwritec.eZdZdZdZdZddZdZdS) rc >t|}||j| |}||ur+t dt d|d|d|d|d  |dS#|wxYw)z Wait until the *watcher* (which must not be started) is ready. The current greenlet will be unscheduled during this time. zInvalid switch into z: got z (expected z ; waiting on z with )N)rstartswitchgetrrstop)selfwatcherwaiterresults rwaitzWaitOperationsGreenlet.wait.s  fmV,,, ZZ\\FV##(("  $ LLNNNNNGLLNNNNs ABBcg}|D]6}||j|!||7|r%|j|j||||dS||dSr)callbackcloseappendloop run_callback_cancel_waits_then)r&watchersexc_kindthen then_argsdeferredr's rcancel_waits_close_and_thenz2WaitOperationsGreenlet.cancel_waits_close_and_thenEs ) )G' ((((   I " "4#:HhPTV_ ` ` ` ` ` D)    rcH|D]}|||d||dS)NT) _cancel_wait)r&r2r3r4r5r's rr1z)WaitOperationsGreenlet._cancel_waits_thenSs? 7 7G   gx 6 6 6 6 irFc|dS|j$|j|j|||dS|r|dSdS)a Cancel an in-progress call to :meth:`wait` by throwing the given *error* in the waiting greenlet. .. versionchanged:: 1.3a1 Added the *close_watcher* parameter. If true, the watcher will be closed after the exception is thrown. The watcher should then be discarded. Closing the watcher is important to release native resources. .. versionchanged:: 1.3a2 Allow the *watcher* to be ``None``. No action is taken in that case. N)r,r/r0r9r-)r&r'error close_watchers r cancel_waitz"WaitOperationsGreenlet.cancel_waitXs` ? F   ' I " "4#4gum T T T F   MMOOOOO  rc|j}|j}|r||r*t|dd}|||dSdSdS)N__self__)activer,r-getattrthrow)r&r'r;r<r@cbglets rr9z#WaitOperationsGreenlet._cancel_waitqsq     MMOOO  "2z400D 5!!!!!  " " rN)F)__name__ __module__ __qualname__r*r7r1r=r9rrrrr,sd.    2"""""rrc<eZdZdZdZdZdZeZdZdZ dZ dS) _WaitIteratorc||_t||_|jj|_||_||_d|_d|_|t|nt|t||_ dS)NF) _hubrr r#_switch_timeout_objects_timer_begunlenmin_count)r&objectshubtimeoutcounts r__init__z_WaitIterator.__init__sk %c** |*     ',mc'lllUCLL9Q9Q rc|jrdSd|_|jD]}||j|jM|jj|jd|_|j |j|dSdS)NT)priority) rPrNrawlinkrLrMrKr/timerrOr")r&objs r_beginz_WaitIterator._begins ;  F = & &C KK % % % % = $)...t}r.JJDK K  dlD 1 1 1 1 1 % $rc|Srrr&s r__iter__z_WaitIterator.__iter__ rc||jdkr"|t|xjdzc_ |j}|j||ur"|t|S#|xYw)Nr)r_rS_cleanup StopIterationr r$clear)r&items r__next__z_WaitIterator.__next__s ;!   MMOOO// ! q  <##%%D L   t|| #oo%K  MMOOO s AB--Cc|j |jd|_|j}d|_|D]A}t|dd}|, ||j'#t jY>xYwBdS)Nrunlink)rOr-rNrArL traceback print_exc)r&objsaobjrls rrfz_WaitIterator._cleanups ; " K     DK}  * *DT8T22F!*F4<((((*'))))) " * *s AA6c|Srrras r __enter__z_WaitIterator.__enter__rcrc.|dSr)rf)r&typvaluetbs r__exit__z_WaitIterator.__exit__s rN) rErFrGrXr_rbrjnextrfrrrwrrrrIrIs R R R 2 2 2* D * * *rrIctt}|||gSt||||S)a Iteratively yield *objects* as they are ready, until all (or *count*) are ready or *timeout* expired. If you will only be consuming a portion of the *objects*, you should do so inside a ``with`` block on this object to avoid leaking resources:: with gevent.iwait((a, b, c)) as it: for i in it: if i is a: break :param objects: A sequence (supporting :func:`len`) containing objects implementing the wait protocol (rawlink() and unlink()). :keyword int count: If not `None`, then a number specifying the maximum number of objects to wait for. If ``None`` (the default), all objects are waited for. :keyword float timeout: If given, specifies a maximum number of seconds to wait. If the timeout expires before the desired waited-for objects are available, then this method returns immediately. .. seealso:: :func:`wait` .. versionchanged:: 1.1a1 Add the *count* parameter. .. versionchanged:: 1.1a2 No longer raise :exc:`LoopExit` if our caller switches greenlets in between items yielded by this function. .. versionchanged:: 1.4 Add support to use the returned object as a context manager. NrV)get_hubjoinrIrTrVrWrUs rrrs>B ))C))** #w 6 66rc|$t}||Stt|||S)af Wait for *objects* to become ready or for event loop to finish. If *objects* is provided, it must be a list containing objects implementing the wait protocol (rawlink() and unlink() methods): - :class:`gevent.Greenlet` instance - :class:`gevent.event.Event` instance - :class:`gevent.lock.Semaphore` instance - :class:`gevent.subprocess.Popen` instance If *objects* is ``None`` (the default), ``wait()`` blocks until the current event loop has nothing to do (or until *timeout* passes): - all greenlets have finished - all servers were stopped - all event loop watchers were stopped. If *count* is ``None`` (the default), wait for all *objects* to become ready. If *count* is a number, wait for (up to) *count* objects to become ready. (For example, if count is ``1`` then the function exits when any object in the list is ready). If *timeout* is provided, it specifies the maximum number of seconds ``wait()`` will block. Returns the list of ready objects, in the order in which they were ready. .. seealso:: :func:`iwait` Nrz)r{r|listrr}s rrrsBDiixxx(((  '599 : ::rc |adSr)_timeout_error)es rset_default_timeout_errorr#s NNNrcR|jtd|j|t}|||dSt j||t us||ntd}|5||ddddS#1swxYwYdS)Nz1This socket is already used by another greenlet: z timed out)r,rr{r*r _start_new_or_dummyr rr'rV timeout_excrUs r_primitive_waitr's#&&*1*:*:(>?? ? {ii ) u $ $ [)) ,,G  s9BB #B cv||tdt||j||nt|jdS)Nz6The socket has already been closed by another greenlet)rrrVr rU)socketr'rs rwait_on_socketr=sO ~''_```GV^#.#:KKJ     rc*t||||dS)a wait(watcher, timeout=None, [timeout_exc=None]) -> None Block the current greenlet until *watcher* is ready. If *timeout* is non-negative, then *timeout_exc* is raised after *timeout* second has passed. If :func:`cancel_wait` is called on *watcher* by another greenlet, raise an exception in this blocking greenlet (``socket.error(EBADF, 'File descriptor was closed in another greenlet')`` by default). :param watcher: An event loop watcher, most commonly an IO watcher obtained from :meth:`gevent.core.loop.io` :keyword timeout_exc: The exception to raise if the timeout expires. By default, a :class:`socket.timeout` exception is raised. If you pass a value for this keyword, it is interpreted as for :class:`gevent.timeout.Timeout`. :raises ~gevent.hub.ConcurrentObjectUseError: If the *watcher* is already started. N)rrs rwait_on_watcherrFs0GWk377777rct}|j|d} t|||||S#|wxYw)a wait_read(fileno, timeout=None, [timeout_exc=None]) -> None Block the current greenlet until *fileno* is ready to read. For the meaning of the other parameters and possible exceptions, see :func:`wait`. .. seealso:: :func:`cancel_wait` rer{r/iorr-)filenorVrrUrs rrrasY ))C VQ  Br7K==   AA'ct}|j|d} t|||||S#|wxYw)a wait_write(fileno, timeout=None, [timeout_exc=None]) -> None Block the current greenlet until *fileno* is ready to write. For the meaning of the other parameters and possible exceptions, see :func:`wait`. .. deprecated:: 1.1 The keyword argument *event* is ignored. Applications should not pass this parameter. In the future, doing so will become an error. .. seealso:: :func:`cancel_wait` rrrVreventrUrs rrrtsY ))C VQ  Br7K==   rct}|j|d} t|||||S#|wxYw)a wait_readwrite(fileno, timeout=None, [timeout_exc=None]) -> None Block the current greenlet until *fileno* is ready to read or write. For the meaning of the other parameters and possible exceptions, see :func:`wait`. .. deprecated:: 1.1 The keyword argument *event* is ignored. Applications should not pass this parameter. In the future, doing so will become an error. .. seealso:: :func:`cancel_wait` rrs rrrsY" ))C VQ  Br7K==   rc"tdSr)rrrr_initrsOOOOOr)import_c_accelzgevent.__hub_primitives)NN)NNNr)+__doc__ __future__rrrrmgevent.exceptionsrrgeventrr gevent._utilr gevent._hub_localr r{gevent.timeoutr __import__rlocalsrrr__all__robjectrIrr Exceptionrrrrrrrrrrglobalsrrrrs '&&&&&%%%%%%000000666666''''''777777"""""" $J//:(L^$3 (<(V $%   T"T"T"T"T"6T"T"T"nMMMMMFMMM`$7$7$7$7N%;%;%;%;N,    &*u$88886#& $e0$(U%2''''''wwyy344444r