fddlmZddlZddlmZddlmZddlmZddl Z ddl m Z m Z m Z erddlmZmZmZmZdd lmZdd lmZeddZGddZddZeddZdS)) annotationsN) OrderedDict)contextmanager) TYPE_CHECKING)ConflictDetectoris_main_thread signal_raise) AsyncIteratorCallable GeneratorIterable) FrameType)Selfsignals Iterable[int]handlerHCallable[[int, FrameType | None], object] | int | signal.Handlers | NonereturnGenerator[None, None, None]c#2Ki} t|D]}tj||||<dV|D]\}}tj||dS#|D]\}}tj||wxYwN)setsignalitems)rroriginal_handlerssignumoriginal_handlers P/var/www/api.educacionweb.es/myenv/lib/python3.11/site-packages/trio/_signals.py_signal_handlerr 6s 4'll G GF(. fg(F(F f % % (9(?(?(A(A 4 4 $F$ M&"2 3 3 3 3 4 4(9(?(?(A(A 4 4 $F$ M&"2 3 3 3 3 4s .A%%1Bc6eZdZd dZd dZd dZdd Zdd Zd S)SignalReceiverrNonect|_tj|_t d|_d|_dS)Nz8only one task can iterate on a signal receiver at a timeF) r_pendingtriolowlevel ParkingLot_lotr_conflict_detector_closedselfs r__init__zSignalReceiver.__init__FsD0;  M,,.. "2 F# #  rintc||jrt|dSd|j|<|jdSr)r+r r%r)unpark)r-rs r_addzSignalReceiver._addOsF <   $(DM& ! I       r/c:d_dfd dS)NTrr#cjrIjd\}} t|dS#wxYwdS)NFlast)r%popitemr )r_ deliver_nextr-s rr:z9SignalReceiver._redeliver_remaining..deliver_next^se} # M11u1== # ((( LNNNNNLLNNNN  # #s A Arr#)r+)r-r:s`@r_redeliver_remainingz#SignalReceiver._redeliver_remainingVsA  # # # # # # #  r/rc|Srr,s r __aiter__zSignalReceiver.__aiter__hs r/cJK|jrtd|j5|js |jd{Vn$t jd{V|j d\}}|cdddS#1swxYwYdS)Nz)open_signal_receiver block already exitedFr6) r+ RuntimeErrorr*r%r)parkr&r' checkpointr8)r-rr9s r __anext__zSignalReceiver.__anext__ks < LJKK K $  = 1inn&&&&&&&&&&m..000000000 --5-99IFA                   sA+BBBNr;)rr0rr#)rr)rr0)__name__ __module__ __qualname__r.r3r<r?rDr>r/rr"r"Esx$      r/r"recAsyncIterator[int]r0cXt|tsJt|jS)z/Helper for tests, not public or otherwise used.) isinstancer"lenr%)rHs rget_pending_signal_countrMzs* c> * **** s|  r/signal.Signals | int)Generator[AsyncIterator[int], None, None]c'K|stdtstdtjt d fd } t||5Vd d d n #1swxYwYd S#wxYw) aA context manager for catching signals. Entering this context manager starts listening for the given signals and returns an async iterator; exiting the context manager stops listening. The async iterator blocks until a signal arrives, and then yields it. Note that if you leave the ``with`` block while the iterator has unextracted signals still pending inside it, then they will be re-delivered using Python's regular signal handling logic. This avoids a race condition when signals arrives just before we exit the ``with`` block. Args: signals: the signals to listen for. Raises: TypeError: if no signals were provided. RuntimeError: if you try to use this anywhere except Python's main thread. (This is a Python limitation.) Example: A common convention for Unix daemons is that they should reload their configuration when they receive a ``SIGHUP``. Here's a sketch of what that might look like using :func:`open_signal_receiver`:: with trio.open_signal_receiver(signal.SIGHUP) as signal_aiter: async for signum in signal_aiter: assert signum == signal.SIGHUP reload_configuration() zNo signals were providedz]Sorry, open_signal_receiver is only possible when running in Python interpreter's main threadrr0frameFrameType | Nonerr#cBj|ddS)NT) idempotent) run_sync_soonr3)rrQqueuetokens rrz%open_signal_receiver..handlers& EJ4@@@@@r/N)rr0rQrRrr#) TypeErrorr rAr&r'current_trio_tokenr"r r<)rrrVrWs @@ropen_signal_receiverrZs6L 42333     /    M , , . .E   EAAAAAAA% Wg . .  KKK                ""$$$$$""$$$$s0'B)7B< B)B  B)B B))B?)rrrrrr)rHrIrr0)rrNrrO) __future__rr collectionsr contextlibrtypingrr&_utilrr r collections.abcr r r rtypesrtyping_extensionsrr r"rMrZr>r/rrcsU"""""" ######%%%%%% AAAAAAAAAA'LLLLLLLLLLLL&&&&&&L 4 4 4 422222222j7%7%7%7%7%7%r/