iddlmZddlZddlmZddlmZddlmZddl Z ddl m Z m Z erddl mZmZmZmZdd lmZdd lmZeddZGddZddZeddZdS)) annotationsN) OrderedDict)contextmanager) TYPE_CHECKING)ConflictDetectoris_main_thread) 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 Y/var/www/html/nodeJS/PythonScripts/venv3.11/lib/python3.11/site-packages/trio/_signals.py_signal_handlerr6s 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|jrtj|dSd|j|<|jdSr)r*r raise_signalr$r(unpark)r,rs r_addzSignalReceiver._addOsI <    ' ' ' ' '$(DM& ! I       r.c:d_dfd dS)NTrr"cjrNjd\}} tj|dS#wxYwdS)NFlast)r$popitemrr1)r_ deliver_nextr,s rr:z9SignalReceiver._redeliver_remaining..deliver_next^sh} # 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;)rr/rr")rr)rr/)__name__ __module__ __qualname__r-r3r<r?rDr>r.rr!r!Esx$      r.r!recAsyncIterator[int]r/cXt|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 threadrr/frameFrameType | Nonerr"cBj|ddS)NT) idempotent) run_sync_soonr3)rrQqueuetokens rrz%open_signal_receiver..handlers& EJ4@@@@@r.N)rr/rQrRrr") TypeErrorr rAr%r&current_trio_tokenr!rr<)rrrVrWs @@ropen_signal_receiverrZs6L 42333     /    M , , . .E   EAAAAAAA% Wg . .  KKK                ""$$$$$""$$$$s0'B)7B< B)B  B)B B))B?)rrrrrr)rHrIrr/)rrNrrO) __future__rr collectionsr contextlibrtypingrr%_utilrr collections.abcr r r r typesrtyping_extensionsrrr!rMrZr>r.rrcsO"""""" ######%%%%%% 33333333'LLLLLLLLLLLL&&&&&&L 4 4 4 422222222j7%7%7%7%7%7%r.