_1hddlmZddlZddlmZddlmZddlmZddl Z ddl m Z m Z erddl mZmZmZmZdd lmZdd lmZe dd ZGd d ZddZe ddZy)) annotationsN) OrderedDict)contextmanager) TYPE_CHECKING)ConflictDetectoris_main_thread) AsyncIteratorCallable GeneratorIterable) FrameType)Selfc#.Ki} t|D]}tj||||<d|jD]\}}tj||y#|jD]\}}tj||wxYwwN)setsignalitems)signalshandleroriginal_handlerssignumoriginal_handlers K/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/trio/_signals.py_signal_handlerr6s 4'l GF(. fg(F f % G (9(?(?(A 4 $F$ MM&"2 3 4(9(?(?(A 4 $F$ MM&"2 3 4sB-A"/B"0BBc4eZdZddZddZddZd dZd dZy) SignalReceiverct|_tjj |_t d|_d|_y)Nz8only one task can iterate on a signal receiver at a timeF) r_pendingtriolowlevel ParkingLot_lotr_conflict_detector_closedselfs r__init__zSignalReceiver.__init__Fs80;  MM,,. "2 F#  c|jrtj|yd|j|<|jj yr)r%r raise_signalrr#unpark)r'rs r_addzSignalReceiver._addOs5 <<    '$(DMM& ! II   r)c2d_dfd y)NTcjr=jjd\}} tj|yy#wxYw)NFlast)rpopitemrr+)r_ deliver_nextr's rr4z9SignalReceiver._redeliver_remaining..deliver_next^sK}} MM11u1= #''/ N  !Ns A AreturnNone)r%)r'r4s`@r_redeliver_remainingz#SignalReceiver._redeliver_remainingVs  # r)c|Srr&s r __aiter__zSignalReceiver.__aiter__hs r)cpK|jr td|j5|js#|jj d{n&t jjd{|jjd\}}|cdddS7U70#1swYyxYww)Nz)open_signal_receiver block already exitedFr0) r% RuntimeErrorr$rr#parkr r! checkpointr2)r'rr3s r __anext__zSignalReceiver.__anext__ks <<JK K $ $ ==iinn&&&mm..000 --5-9IFA   &0   s@$B6*B*B&&B*7B(8$B* B6&B*(B**B3/B6Nr5)rintr6r7)r6r)r6rA)__name__ __module__ __qualname__r(r-r8r;r@r:r)rrrEs$ r)rcPt|tsJt|jS)z/Helper for tests, not public or otherwise used.) isinstancerlenr)recs rget_pending_signal_countrIzs# c> ** * s|| r)c'HK|s tdts tdtjj t dfd } t||5dddjy#1swYxYw#jwxYww)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 threadcBjj|dy)NT) idempotent) run_sync_soonr-)rframequeuetokens rrz%open_signal_receiver..handlers EJJ4@r)N)rrArNzFrameType | Noner6r7) TypeErrorr r=r r!current_trio_tokenrrr8)rrrOrPs @@ropen_signal_receiverrSsL 233   /   MM , , .E  EA% Wg . K  ""$   ""$s6AB" B #B(B 0B"B B BB")rz Iterable[int]rzHCallable[[int, FrameType | None], object] | int | signal.Handlers | Noner6zGenerator[None, None, None])rHzAsyncIterator[int]r6rA)rzsignal.Signals | intr6z)Generator[AsyncIterator[int], None, None]) __future__rr collectionsr contextlibrtypingrr _utilrr collections.abcr r r r typesrtyping_extensionsrrrrIrSr:r)rr\s" #% 3LL&L 4  4 U 4! 4 422j7%"7%.7%7%r)