<|h6dZddlmZddlmZddlmZddlZddlmZddlmZddl m Z dd l m Z dd l m Z dd lmZdd lmZed j(ed<ded<e j,ed<e j.ed<e j0ed<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$y)(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 getcurrentcyNrU/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/_hub_primitives.pyrsr greenlet_initWaiterMultipleWaiterSwitchOutGreenletWithLoop)WaitOperationsGreenletiwait_on_objectswait_on_objects wait_read wait_writewait_readwritec,eZdZdZdZdZddZdZy)rc t|}|j|j| |j}||ur#t dt d|d|d|d|d  |j y#|j 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.st  fmmV, ZZ\FV#("  $ LLNGLLNs 7A22Bcg}|D]3}||j|j#|j|5|r*|jj |j ||||y||yr)callbackcloseappendloop run_callback_cancel_waits_then)r&watchersexc_kindthen then_argsdeferredr's rcancel_waits_close_and_thenz2WaitOperationsGreenlet.cancel_waits_close_and_thenEsn )G' (  )  II " "4#:#:HhPTV_ ` ) rcB|D]}|j||d||y)NT) _cancel_wait)r&r2r3r4r5r's rr1z)WaitOperationsGreenlet._cancel_waits_thenSs+ 7G   gx 6 7 irc|y|j)|jj|j|||y|r|j yy)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_waitXsL ?     ' II " "4#4#4gum T   MMO rc|j}|j}|r|j|r"t|dd}||j |yyy)N__self__)activer,r-getattrthrow)r&r'r;r<r@cbglets rr9z#WaitOperationsGreenlet._cancel_waitqsQ     MMO 2z40D 5!  rN)F)__name__ __module__ __qualname__r*r7r1r=r9rrrrr,s.  2"rrc:eZdZdZdZdZdZeZdZdZ dZ y) _WaitIteratorc||_t||_|jj|_||_||_d|_d|_|t||_ yt|t||_ y)NF) _hubrr r#_switch_timeout_objects_timer_begunlenmin_count)r&objectshubtimeoutcounts r__init__z_WaitIterator.__init__sd %c* ||**     ',mc'l UCL9Q rcV|jryd|_|jD]}|j|j|j]|j j j|jd|_|jj|j|yy)NT)priority) rPrNrawlinkrLrMrKr/timerrOr")r&objs r_beginz_WaitIterator._begins ;;  == &C KK % & == $))....t}}r.JDK KK  dllD 1 %rc|Srrr&s r__iter__z_WaitIterator.__iter__ rct|j|jdk(r|jt|xjdzc_ |jj }|jj ||ur|jt|S#|jxYw)Nr)r_rS_cleanup StopIterationr r$clear)r&items r__next__z_WaitIterator.__next__s ;;!  MMO/ ! q  <<##%D LL   t| #o%K  MMO s AB$$B7c|j!|jjd|_|j}d|_|D]%}t|dd}| ||j'y#t j YAxYw)Nrunlink)rOr-rNrArL traceback print_exc)r&objsaobjrls rrfz_WaitIterator._cleanupsz ;; " KK   DK}}  *DT8T2F!*4<<(  * *'')s A,,Bc|Srrras r __enter__z_WaitIterator.__enter__rcrc$|jyr)rf)r&typvaluetbs r__exit__z_WaitIterator.__exit__s  rN) rErFrGrXr_rbrjnextrfrrrwrrrrIrIs- R 2* D *rrIc\t}||j|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. rV)get_hubjoinrIrTrVrWrUs rrrs6B )C)** #w 66rcj|t}|j|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` rz)r{r|listrr}s rrrs7Dixxx((  '59 ::rc|ayr)_timeout_error)es rset_default_timeout_errorr#sNrc2|jtd|j| t}||j|yt j ||t us||n td}|5|j|dddy#1swYyxYw)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*:*:(>? ? {i )) u $ [) ,G  s 2B  Bcv|| tdt||j||nt|jy)Nz6The socket has already been closed by another greenlet)rrrVr rU)socketr'rs rwait_on_socketr=s: ~''_``GV^^#.#:KJJ rc t||||y)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_watcherrFs0GWk37rct}|jj|d} t|||||j S#|j 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 rrrasE )C VQ Br7K=   AAct}|jj|d} t|||||j S#|j 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 rrrtsE )C VQ Br7K=   rct}|jj|d} t|||||j S#|j 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 rrrsE" )C VQ Br7K=   rctyr)rrrr_initrsOr)import_c_accelzgevent.__hub_primitives)NN)NNNr)+__doc__ __future__rrrrmgevent.exceptionsrrgeventrr gevent._utilr gevent._hub_localr r{gevent.timeoutr __import__rlocalsrrr__all__robjectrIrr Exceptionrrrrrrrrrrglobalsrrrrs" '%06'7" $J/::(^^$33 (<(V(V $% T"6T"nMFM`$7N%;N, &*u$86#& $e0$(U%2'wy34r