+
    Di                    l  a  0 t $ ^ RIHt ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	t	^ RI
HtHtHtHtHtHtHtHt ^ RIHt ^ RIHt ^ RIHt ^ RIHt ^ RIHt ^ R	IHtHt ^ R
IHt ^ RIH t H!t!H"t"H#t#H$t$H%t%H&t&H't' ^ RI(t)^ RI*t)^ RI+H,t,H-t-H.t. ^ RI*H/t/H0t0H1t1H2t2H3t3 ^ RI4H5t6 ^ RI7H8t8 ^RI9H:t:H;t;H<t<H=t=H>t>H?t?H@t@ ^RIAHBtB ^RICHDtDHEtEHFtFHGtG ^RIHHItI ^RIJHKtK ^RILHMtN ^RILHOtP ^RILHQtR ^RILHStSHTtT ^RILHUtV ^RIWHXtY ^RI@HZtZH[t[H\t\ ^RI]H^t^H_t_ ^RI`Hata ]!'       d   ^ RIbHctc ]P                  R\8  d   ^ RIHete M^ RIfHete ]P                  R]8  d
   ^ R IHgtgHhth M^ R!IiHjtj ^ R IfHgtgHhth ]%! R"4      tk]%! R#4      tl]%! R$]m]Z4      tn]g! R%4      to]e! R&4      tp])P                  P                  tr ! R' R(]Y4      tX ! R) R*]@P                  4      ts]! R+R,7       ! R- R.]@P                  4      4       tu]! R+R,7       ! R/ R0]@P                  4      4       tw]! R+R,7       ! R1 R2]@P                  4      4       tx ! R3 R4])P                  P                  4      tz]r! R54      t{R6]|R5&   R7 R8 lt} ! R9 R:]#]n,          4      t~ ! R; R<]~]@P                  4      t ! R= R>]]@EP                   4      t ! R? R@]~]@EP                  4      t ! RA RB]~]@EP                  4      t ! RC RD]~]Z,          ]@EP                  4      t ! RE RF]~]Z,          ]@EP
                  4      t ! RG RH]~]m,          ]@EP                  4      t ! RI RJ]~]m,          ]@EP                  4      t ! RK RL]P4      tO ! RM RN]R4      tQ ! RO RP]V4      tU ! RQ RR]N4      tM]r! RS4      tR6]|RS&    ! RT RU4      t ! RV RW]@EP                  4      t ! RX RY]>4      t ! RZ R[]^4      t]tR# )^    )annotationsN)AsyncGeneratorAsyncIterator	AwaitableCallable
Collection	CoroutineIterableSequence)AbstractContextManager)	dataclass)IOBase)PathLike)Signals)AddressFamily
SocketKind)TracebackType)IOTYPE_CHECKINGAnyGenericNoReturnTypeVarcastoverload)ErrorOutcomeValue)current_root_taskcurrent_tasknotify_closingwait_readablewait_writable)
SocketType)run_sync)CapacityLimiterStatisticsEventStatisticsLockStatisticsRunFinishedErrorTaskInfo
WouldBlockabc)claim_worker_thread)BrokenResourceErrorBusyResourceErrorClosedResourceErrorEndOfStream)convert_ipv6_sockaddr)create_memory_object_streamCapacityLimiterEventLock)ResourceGuardSemaphoreStatistics	SemaphoreCancelScope)IPSockAddrTypeUDPPacketTypeUNIXDatagramPacketType)AsyncBackendStrOrBytesPath)MemoryObjectSendStream)FileDescriptorLike)	ParamSpec)TypeVarTupleUnpack)BaseExceptionGroupTT_Retval
T_SockAddrPosArgsTPc                  
   ] tR t^utRR R lltRR R lltR R ltR R	 ltRR
 R llt]	R R l4       t
]
P                  R R l4       t
]	R R l4       t]	R R l4       t]	R R l4       t]P                  R R l4       tRtR# )r?   Nc               $    V ^8  d   QhRRRRRR/# )   originaltrio.CancelScope | Nonekwargsobjectreturnr?    )formats   "s/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/anyio/_backends/_trio.py__annotate__CancelScope.__annotate__v   s$     # #.#AG#	#    c                	,    \         P                  V 4      # NrV   __new__)clsrS   rU   s   &&,rZ   ra   CancelScope.__new__v   s     ~~c""r]   c               $    V ^8  d   QhRRRRRR/# )rR   rS   rT   rU   r   rW   NonerX   )rY   s   "rZ   r[   r\   {   s(     A A!8 A3 ASW Ar]   c                	P    T;'       g    \         P                  ! R/ VB V n        R # NrX   )trior?   _CancelScope__original)selfrS   rU   s   &&,rZ   __init__CancelScope.__init__{   s    "@@d&6&6&@&@r]   c                   V ^8  d   QhRR/# )rR   rW   r?   rX   )rY   s   "rZ   r[   r\   ~   s      ; r]   c                	:    V P                   P                  4        V # r_   )ri   	__enter__rj   s   &rZ   ro   CancelScope.__enter__~   s    !!#r]   c               (    V ^8  d   QhRRRRRRRR/# 	rR   exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NonerW   boolrX   )rY   s   "rZ   r[   r\      8     C C,C &C %	C
 
Cr]   c                	:    V P                   P                  WV4      # r_   )ri   __exit__rj   rt   rv   rx   s   &&&&rZ   r}   CancelScope.__exit__   s     ''6BBr]   c                    V ^8  d   QhRRRR/# )rR   reasonz
str | NonerW   re   rX   )rY   s   "rZ   r[   r\      s     ' 'Z '4 'r]   c                	<    V P                   P                  V4       R # r_   )ri   cancel)rj   r   s   &&rZ   r   CancelScope.cancel   s    v&r]   c                   V ^8  d   QhRR/# rR   rW   floatrX   )rY   s   "rZ   r[   r\      s     ( (% (r]   c                	.    V P                   P                  # r_   ri   deadlinerp   s   &rZ   r   CancelScope.deadline   s    '''r]   c                    V ^8  d   QhRRRR/# rR   valuer   rW   re   rX   )rY   s   "rZ   r[   r\      s     ) )e ) )r]   c                	&    WP                   n        R # r_   r   rj   r   s   &&rZ   r   r      s    #( r]   c                   V ^8  d   QhRR/# rR   rW   rz   rX   )rY   s   "rZ   r[   r\      s     - -t -r]   c                	.    V P                   P                  # r_   )ri   cancel_calledrp   s   &rZ   r   CancelScope.cancel_called   s    ,,,r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r\      s     0 0$ 0r]   c                	.    V P                   P                  # r_   )ri   cancelled_caughtrp   s   &rZ   r   CancelScope.cancelled_caught       ///r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r\      s     & & &r]   c                	.    V P                   P                  # r_   ri   shieldrp   s   &rZ   r   CancelScope.shield   s    %%%r]   c                    V ^8  d   QhRRRR/# )rR   r   rz   rW   re   rX   )rY   s   "rZ   r[   r\      s     ' 'D 'T 'r]   c                	&    WP                   n        R # r_   r   r   s   &&rZ   r   r      s    !&r]   
__originalr_   )__name__
__module____qualname____firstlineno__ra   rk   ro   r}   r   propertyr   setterr   r   r   __static_attributes__rX   r]   rZ   r?   r?   u   s    #
AC' ( ( __) ) - - 0 0 & & ]]' 'r]   r?   c                  b    ] tR t^tR R ltR R ltR R ltRR/R	 R
 lltRR/R R lltRt	R# )	TaskGroupc                   V ^8  d   QhRR/# rR   rW   re   rX   )rY   s   "rZ   r[   TaskGroup.__annotate__   s     ! !$ !r]   c                	Z    R V n         \        P                  ! RR7      V n        RV n        R# )FT)strict_exception_groupsN)_activerh   open_nursery_nursery_managercancel_scoperp   s   &rZ   rk   TaskGroup.__init__   s$     $ 1 1$ O r]   c                   V ^8  d   QhRR/# )rR   rW   r   rX   )rY   s   "rZ   r[   r      s      ) r]   c                	   "   R V n         V P                  P                  4       G Rj  xL
 V n        \	        V P                  P
                  4      V n        V #  L/5i)TN)r   r   
__aenter___nurseryr?   r   rp   s   &rZ   r   TaskGroup.__aenter__   sG     "33>>@@'(B(BC As   %AA0Ac               (    V ^8  d   QhRRRRRRRR/# rs   rX   )rY   s   "rZ   r[   r      s2     ! !,! &! %	!
 
!r]   c                	D  "    V P                   P                  WV4      G R j  xL
 ??RV n        #  L  \         dR   pTP	                  \
        P                  4      ^,          '       g    \
        P                  P                  4       Thh R p?ii ; i  ??RT n        i ; i5i)NF)r   	__aexit__r   rJ   splitrh   	Cancelled_create)rj   rt   rv   rx   excs   &&&& rZ   r   TaskGroup.__aexit__   s     
	!..88FSS  DL T! 	99T^^,Q//nn,,.C7		  DLs=   B 3 13 
B 3 BAB

BB BB nameNc               (    V ^8  d   QhRRRRRRRR/# )	rR   funcz,Callable[[Unpack[PosArgsT]], Awaitable[Any]]argszUnpack[PosArgsT]r   rV   rW   re   rX   )rY   s   "rZ   r[   r      s2     9 9:9  9 	9
 
9r]   c               	    V P                   '       g   \        R 4      hV P                  P                  ! V.VO5RV/  R# z;This task group is not active; no new tasks can be started.r   N)r   RuntimeErrorr   
start_soonrj   r   r   r   s   &&$*rZ   r   TaskGroup.start_soon   s;     |||M  	  8848r]   c               (    V ^8  d   QhRRRRRRRR/# )rR   r   zCallable[..., Awaitable[Any]]r   rV   r   rW   r   rX   )rY   s   "rZ   r[   r      s2     A A1A:@AHNA	Ar]   c               	   "   V P                   '       g   \        R 4      hV P                  P                  ! V.VO5RV/ G Rj  xL
 #  L5ir   )r   r   r   startr   s   &&$*rZ   r   TaskGroup.start   sG      |||M  ]]((@@4@@@@s   AA
AA
)r   r   r   r   )
r   r   r   r   rk   r   r   r   r   r   rX   r]   rZ   r   r      s5    !
!$9 	9AQUA Ar]   r   F)eqc                  >    ] tR t^t$ R]R&   R	R R lltR R ltRtR# )
ReceiveStreamWrapperztrio.abc.ReceiveStream_streamNc                    V ^8  d   QhRRRR/# )rR   	max_bytes
int | NonerW   bytesrX   )rY   s   "rZ   r[   !ReceiveStreamWrapper.__annotate__   s      z U r]   c                	6  "    V P                   P                  V4      G R j  xL
 pT'       d   \        T4      # \        h L  \        P                   d   p\        TP                  hR p?i\        P
                   d   p\
        TP                  hR p?ii ; i5ir_   )r   receive_somerh   r0   	__cause__r.   r   r1   rj   r   datar   s   &&  rZ   receiveReceiveStreamWrapper.receive   sw     	9229==D ; >'' 	9%3==8'' 	9%3==8	9sN   BA A A BB A BA((B?B BBBc                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r           $ $d $r]   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5ir_   r   acloserp   s   &rZ   r   ReceiveStreamWrapper.aclose        ll!!###   )')rX   r_   )r   r   r   r   __annotations__r   r   r   rX   r]   rZ   r   r      s    ##$ $r]   r   c                  :    ] tR t^t$ R]R&   R R ltR R ltRtR# )	SendStreamWrapperztrio.abc.SendStreamr   c                    V ^8  d   QhRRRR/# rR   itemr   rW   re   rX   )rY   s   "rZ   r[   SendStreamWrapper.__annotate__   s     9 9u 9 9r]   c                	  "    V P                   P                  V4      G R j  xL
  R #  L  \        P                   d   p\        TP                  hR p?i\        P
                   d   p\
        TP                  hR p?ii ; i5ir_   )r   send_allrh   r0   r   r.   rj   r   r   s   && rZ   sendSendStreamWrapper.send   s^     	9,,''---'' 	9%3==8'' 	9%3==8	9sC   B+ )+ B+ A? AA?(A?)A::A??Bc                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r     r   r]   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5ir_   r   rp   s   &rZ   r   SendStreamWrapper.aclose  r   r   rX   N)r   r   r   r   r   r   r   r   rX   r]   rZ   r   r      s      9$ $r]   r   c                      ] tR tRt$ R]R&   R]R&   R]R&   R]R&   R	 R
 ltR R ltR R ltR R ltR R lt	]
R R l4       t]
R R l4       t]
R R l4       t]
R R l4       t]
R R l4       tRtR# )Processi  ztrio.Process_processabc.ByteSendStream | None_stdinabc.ByteReceiveStream | None_stdout_stderrc                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   Process.__annotate__  s      d r]   c                	  "   \        R R7      ;_uu_ 4        V P                  '       d#   V P                  P                  4       G Rj  xL
  V P                  '       d#   V P                  P                  4       G Rj  xL
  V P                  '       d#   V P                  P                  4       G Rj  xL
  RRR4        V P                  4       G Rj  xL
  R#  L L] L+  + '       g   i     L1; i L  \         d\    T P                  4        \        R R7      ;_uu_ 4        T P                  4       G Rj  xL 
  RRR4       h   + '       g   i     h ; ii ; i5i)Tr   N)r?   r   r   r   r   waitBaseExceptionkillrp   s   &rZ   r   Process.aclose  s     %%{{{kk((***|||ll))+++|||ll))+++ &	))+ +++ &%  	IIKD))iik!! * *)		s   E0CCCC;C<CC/C0C4E=C2 C0C2 ECCCC-	(E0C2 2/E!E5D8
6E;	EE	EEc                   V ^8  d   QhRR/# rR   rW   intrX   )rY   s   "rZ   r[   r  #  s     * *C *r]   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir_   )r   r  rp   s   &rZ   r  Process.wait#  s     ]]''))))   '%'c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  &  s     " "4 "r]   c                	:    V P                   P                  4        R # r_   )r   	terminaterp   s   &rZ   r  Process.terminate&  s    !r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  )  s      d r]   c                	:    V P                   P                  4        R # r_   )r   r  rp   s   &rZ   r  Process.kill)  s    r]   c                    V ^8  d   QhRRRR/# )rR   signalr   rW   re   rX   )rY   s   "rZ   r[   r  ,  s     * *' *d *r]   c                	<    V P                   P                  V4       R # r_   )r   send_signal)rj   r  s   &&rZ   r  Process.send_signal,  s    !!&)r]   c                   V ^8  d   QhRR/# r
  rX   )rY   s   "rZ   r[   r  0  s     ! !S !r]   c                	.    V P                   P                  # r_   )r   pidrp   s   &rZ   r  Process.pid/  s    }}   r]   c                   V ^8  d   QhRR/# rR   rW   r   rX   )rY   s   "rZ   r[   r  4  s     ( (J (r]   c                	.    V P                   P                  # r_   )r   
returncoderp   s   &rZ   r"  Process.returncode3  s    }}'''r]   c                   V ^8  d   QhRR/# )rR   rW   r   rX   )rY   s   "rZ   r[   r  8  s      0 r]   c                	    V P                   # r_   )r   rp   s   &rZ   stdinProcess.stdin7  s    {{r]   c                   V ^8  d   QhRR/# rR   rW   r   rX   )rY   s   "rZ   r[   r  <        4 r]   c                	    V P                   # r_   )r   rp   s   &rZ   stdoutProcess.stdout;      ||r]   c                   V ^8  d   QhRR/# r)  rX   )rY   s   "rZ   r[   r  @  r*  r]   c                	    V P                   # r_   )r   rp   s   &rZ   stderrProcess.stderr?  r.  r]   rX   N)r   r   r   r   r   r   r  r  r  r  r   r  r"  r&  r,  r1  r   rX   r]   rZ   r   r     s    %%))))"*"* ! ! ( (      r]   r   c                  .   a  ] tR tRtR V 3R lltRtV ;t# )_ProcessPoolShutdownInstrumentiD  c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   +_ProcessPoolShutdownInstrument.__annotate__E  s      4 r]   c                	$   < \         SV `  4        R # r_   )super	after_run)rj   	__class__s   &rZ   r9  (_ProcessPoolShutdownInstrument.after_runE  s    r]   rX   )r   r   r   r   r9  r   __classcell__r:  s   @rZ   r4  r4  D  s     r]   r4  &current_default_worker_process_limiterztrio.lowlevel.RunVarc                    V ^8  d   QhRRRR/# rR   workerszset[abc.Process]rW   re   rX   )rY   s   "rZ   r[   r[   N  s     
' 
'*: 
't 
'r]   c                  "    \         P                  ! \        P                  4      G R j  xL
  R #  L  \         P                   d    T  F#  pTP
                  e   K  TP                  4        K%  	  \        RR7      ;_uu_ 4        T  F  pTP                  4       G R j  xL 
  K  	  R R R 4        R #   + '       g   i      R # ; ii ; i5i)NTr  )	rh   sleepmathinfr   r"  r  r?   r   )rA  processs   & rZ   _shutdown_process_poolrG  N  s     	'jj""">> 'G!!)  %%"nn&&& # &%%%'sa   C'4 24 C4 %C
(C
B4B" 	B4)C
1C4C?C
CC

Cc                  \    ] tR tRtR R ltR R lt]R R l4       tR R	 ltR
 R lt	Rt
R# )_TrioSocketMixini`  c                    V ^8  d   QhRRRR/# rR   trio_socketTrioSocketTyperW   re   rX   )rY   s   "rZ   r[   _TrioSocketMixin.__annotate__a  s      N t r]   c                	     Wn         R V n        R# FN)_trio_socket_closed)rj   rL  s   &&rZ   rk   _TrioSocketMixin.__init__a  s    'r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   rN  e  s     & &t &r]   c                	    V P                   '       d   \        hV P                  P                  4       ^ 8  d   \        hR# r   N)rR  r0   rQ  filenor.   rp   s   &rZ   _check_closed_TrioSocketMixin._check_closede  s3    <<<%%##%)%% *r]   c                   V ^8  d   QhRR/# )rR   rW   socket.socketrX   )rY   s   "rZ   r[   rN  l  s     ' '] 'r]   c                	.    V P                   P                  # r_   )rQ  _sockrp   s   &rZ   _raw_socket_TrioSocketMixin._raw_socketk  s      &&&r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   rN  o  s     & &d &r]   c                	   "   V P                   P                  4       ^ 8  d$   RV n        V P                   P                  4        R# R# 5i)r   TN)rQ  rW  rR  closerp   s   &rZ   r   _TrioSocketMixin.acloseo  s:     ##%*DL##% +s   AAc                    V ^8  d   QhRRRR/# )rR   r   r  rW   r   rX   )rY   s   "rZ   r[   rN  t  s       8 r]   c                	    \        V\        P                  4      '       d   \        VhV P                  P	                  4       ^ 8  d   V P
                  '       d   \        Rh\        V\        4      '       d   \        VhVhrV  )
isinstancerh   r0   rQ  rW  rR  OSErrorr.   rj   r   s   &&rZ   _convert_socket_error&_TrioSocketMixin._convert_socket_errort  s^    c43344%3.%%'!+%4/W%%%3.Ir]   )rR  rQ  N)r   r   r   r   rk   rX  r   r^  r   ri  r   rX   r]   rZ   rI  rI  `  s/    & ' '&
 r]   rI  c                  V   a  ] tR tRtR V 3R lltRR R lltR R ltR R	 ltR
tV ;t	# )SocketStreami  c                    V ^8  d   QhRRRR/# rK  rX   )rY   s   "rZ   r[   SocketStream.__annotate__       7 7N 7t 7r]   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# reading from
writing toNr8  rk   r:   _receive_guard_send_guardrj   rL  r:  s   &&rZ   rk   SocketStream.__init__  *    %+N;(6r]   c                    V ^8  d   QhRRRR/# )rR   r   r  rW   r   rX   )rY   s   "rZ   r[   rn    s     
" 
"s 
"u 
"r]   c                	.  "   V P                   ;_uu_ 4         V P                  P                  V4      G R j  xL
 pX'       d   VuuR R R 4       # \
        h L  \         d   pT P	                  T4        R p?L=R p?ii ; i  + '       g   i     R # ; i5ir_   )ru  rQ  recvr  ri  r1   r   s   &&  rZ   r   SocketStream.receive  sx        0!..33I>>  !  "! ?  0**3//0 !  s`   BBAAABBBBAA>#A94B9A>>BB		Bc                    V ^8  d   QhRRRR/# r   rX   )rY   s   "rZ   r[   rn    s     	) 	)u 	) 	)r]   c                	D  "   V P                   ;_uu_ 4        \        V4      pV'       d,    V P                  P                  V4      G R j  xL
 pVXR  pK3   R R R 4       R #  L  \         d   pT P                  T4        R p?L5R p?ii ; i  + '       g   i     R # ; i5ir_   )rv  
memoryviewrQ  r   r  ri  )rj   r   view
bytes_sentr   s   &&   rZ   r   SocketStream.send  s     d#D4'+'8'8'='=d'C!CJ JK(   "D$ 4..s334 sW   B BA#
A!A#B
B !A##B	.B?BB		BB		B c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   rn    s     3 3 3r]   c                	`   "   V P                   P                  \        P                  4       R # 5ir_   )rQ  shutdownsocketSHUT_WRrp   s   &rZ   send_eofSocketStream.send_eof  s     ""6>>2s   ,.ru  rv  )   )
r   r   r   r   rk   r   r   r  r   r<  r=  s   @rZ   rl  rl    s!    7 7

"	)3 3r]   rl  c                  .    ] tR tRtR R ltR R ltRtR# )UNIXSocketStreami  c               $    V ^8  d   QhRRRRRR/# )rR   msglenr  maxfdsrW   ztuple[bytes, list[int]]rX   )rY   s   "rZ   r[   UNIXSocketStream.__annotate__  s"     " " "S "=T "r]   c           	     	  "   \        V\        4      '       d   V^ 8  d   \        R4      h\        V\        4      '       d   V^8  d   \        R4      h\        P                  ! R4      p\        P
                  P                  4       G Rj  xL
  V P                  ;_uu_ 4          V P                  P                  V\        P                  ! W#P                  ,          4      4      G Rj  xL
 w  rErgV'       g   V'       g   \        h RRR4       X F  w  rpT	\        P                   8w  g   T
\        P"                  8w  d   \%        RX: RT	 RT
 24      hTP'                  TR\)        T4      \)        T4      TP                  ,          ,
           4       K  	  X\+        T4      3#  EL L  \         d   pT P                  T4        Rp?EK*  Rp?ii ; i  + '       g   i     L; i5i)r   z%msglen must be a non-negative integerz!maxfds must be a positive integeriNz.Received unexpected ancillary data; message = z, cmsg_level = z, cmsg_type = )rf  r  
ValueErrorarrayrh   lowlevel
checkpointru  rQ  recvmsgr  CMSG_LENitemsizer1   r  ri  
SOL_SOCKET
SCM_RIGHTSr   	frombyteslenlist)rj   r  r  fdsmessageancdataflagsaddrr   
cmsg_level	cmsg_type	cmsg_datas   &&&         rZ   receive_fdsUNIXSocketStream.receive_fds  s    &#&&&1*DEE&#&&&1*@AAkk#mm&&(((   
:>:K:K:S:S0E F; 51Ge #7)) ! 18,J9V...)v?P?P2P"DWK P$$.<~i[J 
 MM)$Vc)nI8U&VWX 18 S	!!1 	)5 % 4..s334 ! sn   BG)
F&G)#G&AF+)F)*F+1GGBG))F++G6GGGGG&	!G)c               $    V ^8  d   QhRRRRRR/# )rR   r  r   r  zCollection[int | IOBase]rW   re   rX   )rY   s   "rZ   r[   r    s"     4 4e 42J 4t 4r]   c                	  "   V'       g   \        R 4      hV'       g   \        R4      h. pV Fc  p\        V\        4      '       d   VP                  V4       K,  \        V\        4      '       g   KD  VP                  VP                  4       4       Ke  	  \        P                  ! RV4      p\        P                  P                  4       G Rj  xL
  V P                  ;_uu_ 4          V P                  P                  V.\        P                  \        P                  V3.4      G Rj  xL
   RRR4       R#  Lk L  \          d   pT P#                  T4        Rp?Kx  Rp?ii ; i  + '       g   i     R# ; i5i)zmessage must not be emptyzfds must not be emptyr  N)r  rf  r  appendr   rW  r  rh   r  r  rv  rQ  sendmsgr  r  r  r  ri  )rj   r  r  filenosfdfdarrayr   s   &&&    rZ   send_fdsUNIXSocketStream.send_fds  s/    899455B"c""r"B''ryy{+	  ++c7+mm&&(((4++33 	 !' 1 1 & 1 1 '	 	 	   	)	 % 4..s334 ss   E:AE:1AE:D8E:%E&(A D<(D:)D<-E&.E::D<<E#EE&E##E&&E7	1	E:rX   N)r   r   r   r   r  r  r   rX   r]   rZ   r  r    s    "B4 4r]   r  c                  :   a  ] tR tRtR V 3R lltR R ltRtV ;t# )TCPSocketListeneri  c                   V ^8  d   QhRR/# rR   
raw_socketr[  rX   )rY   s   "rZ   r[   TCPSocketListener.__annotate__       I I= Ir]   c                	   < \         SV `  \        P                  P	                  V4      4       \        R 4      V n        R# zaccepting connections fromNr8  rk   rh   r  from_stdlib_socketr:   _accept_guardrj   r  r:  s   &&rZ   rk   TCPSocketListener.__init__  -    77
CD*+GHr]   c                   V ^8  d   QhRR/# )rR   rW   rl  rX   )rY   s   "rZ   r[   r    s     ) )l )r]   c                	~  "   V P                   ;_uu_ 4         V P                  P                  4       G R j  xL
 w  rR R R 4       XP                  \        P                  \        P                  ^4       \        V4      #  LH  \         d   pT P	                  T4        R p?LeR p?ii ; i  + '       g   i     Lu; i5ir_   )
r  rQ  acceptr  ri  
setsockoptr  IPPROTO_TCPTCP_NODELAYrl  rj   rL  _addrr   s   &   rZ   r  TCPSocketListener.accept  s     0+/+<+<+C+C+E%E"   	v1163E3EqIK(( &F  0**3//0  sO   B=B*BA?BAB=?BB'B"B*"B''B**B:	5B=r  r   r   r   r   rk   r  r   r<  r=  s   @rZ   r  r    s    I I) )r]   r  c                  :   a  ] tR tRtR V 3R lltR R ltRtV ;t# )UNIXSocketListeneri  c                   V ^8  d   QhRR/# r  rX   )rY   s   "rZ   r[   UNIXSocketListener.__annotate__  r  r]   c                	   < \         SV `  \        P                  P	                  V4      4       \        R 4      V n        R# r  r  r  s   &&rZ   rk   UNIXSocketListener.__init__  r  r]   c                   V ^8  d   QhRR/# )rR   rW   r  rX   )rY   s   "rZ   r[   r    s     - -. -r]   c                	   "   V P                   ;_uu_ 4         V P                  P                  4       G R j  xL
 w  rR R R 4       \        X4      #  L  \         d   pT P	                  T4        R p?L6R p?ii ; i  + '       g   i     LF; i5ir_   )r  rQ  r  r  ri  r  r  s   &   rZ   r  UNIXSocketListener.accept  sq     0+/+<+<+C+C+E%E"    ,,	 &F  0**3//0  sN   BA;AAABAA8A3.A;3A88A;;B	Br  r  r=  s   @rZ   r  r    s    I I- -r]   r  c                  F   a  ] tR tRtR V 3R lltR R ltR R ltRtV ;t# )		UDPSocketi  c                    V ^8  d   QhRRRR/# rK  rX   )rY   s   "rZ   r[   UDPSocket.__annotate__  ro  r]   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rq  rt  rw  s   &&rZ   rk   UDPSocket.__init__  ry  r]   c                   V ^8  d   QhRR/# )rR   rW   ztuple[bytes, IPSockAddrType]rX   )rY   s   "rZ   r[   r    s     0 0; 0r]   c                	B  "   V P                   ;_uu_ 4         V P                  P                  R 4      G Rj  xL
 w  rV\        V4      3uuRRR4       #  L  \         d   pT P                  T4        Rp?MRp?ii ; i RRR4       R#   + '       g   i     R# ; i5ir  N)ru  rQ  recvfromr2   r  ri  rj   r   r  r   s   &   rZ   r   UDPSocket.receive  s|        0#'#4#4#=#=e#DD
2488 ! D  0**3//0/ !   sU   BBAAA
BAA="A83B8A==B
BB		Bc                    V ^8  d   QhRRRR/# )rR   r   rA   rW   re   rX   )rY   s   "rZ   r[   r    s     0 0} 0 0r]   c                	  "   V P                   ;_uu_ 4         V P                  P                  ! V!  G R j  xL
  R R R 4       R #  L  \         d   pT P	                  T4        R p?L-R p?ii ; i  + '       g   i     R # ; i5ir_   rv  rQ  sendtor  ri  r   s   && rZ   r   UDPSocket.send  g     0''..555 5  0**3//0 N   BA0AAA
BAA-A(#A0(A--A00B	;	Br  	r   r   r   r   rk   r   r   r   r<  r=  s   @rZ   r  r        7 7
00 0r]   r  c                  F   a  ] tR tRtR V 3R lltR R ltR R ltRtV ;t# )	ConnectedUDPSocketi  c                    V ^8  d   QhRRRR/# rK  rX   )rY   s   "rZ   r[   ConnectedUDPSocket.__annotate__  ro  r]   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rq  rt  rw  s   &&rZ   rk   ConnectedUDPSocket.__init__  ry  r]   c                   V ^8  d   QhRR/# rR   rW   r   rX   )rY   s   "rZ   r[   r         0 0u 0r]   c                	$  "   V P                   ;_uu_ 4         V P                  P                  R 4      G Rj  xL
 uuRRR4       #  L  \         d   pT P	                  T4        Rp?MRp?ii ; i RRR4       R#   + '       g   i     R# ; i5ir  ru  rQ  r|  r  ri  rh  s   & rZ   r   ConnectedUDPSocket.receive  j        0!..33E:: ! :  0**3//0/	 !   T   BA<AAABAA.A)$A<)A..A<2
B<B		Bc                    V ^8  d   QhRRRR/# r   rX   )rY   s   "rZ   r[   r  %       0 0u 0 0r]   c                	  "   V P                   ;_uu_ 4         V P                  P                  V4      G R j  xL
  R R R 4       R #  L  \         d   pT P	                  T4        R p?L-R p?ii ; i  + '       g   i     R # ; i5ir_   rv  rQ  r   r  ri  r   s   && rZ   r   ConnectedUDPSocket.send%  g     0'',,T222 2  0**3//0 N   BA1AAA
BAA.A)$A1)A..A11B	<	Br  r  r=  s   @rZ   r  r    s    7 7
00 0r]   r  c                  F   a  ] tR tRtR V 3R lltR R ltR R ltRtV ;t# )	UNIXDatagramSocketi-  c                    V ^8  d   QhRRRR/# rK  rX   )rY   s   "rZ   r[   UNIXDatagramSocket.__annotate__.  ro  r]   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rq  rt  rw  s   &&rZ   rk   UNIXDatagramSocket.__init__.  ry  r]   c                   V ^8  d   QhRR/# )rR   rW   rB   rX   )rY   s   "rZ   r[   r  3  s     0 05 0r]   c                	.  "   V P                   ;_uu_ 4         V P                  P                  R 4      G Rj  xL
 w  rW3uuRRR4       #  L  \         d   pT P	                  T4        Rp?MRp?ii ; i RRR4       R#   + '       g   i     R# ; i5ir  )ru  rQ  r  r  ri  r  s   &   rZ   r   UNIXDatagramSocket.receive3  ss        0#'#4#4#=#=e#DD
z ! D  0**3//0/ !   sU   BBAAA BAA3A.)B.A33B7
BB		Bc                    V ^8  d   QhRRRR/# )rR   r   rB   rW   re   rX   )rY   s   "rZ   r[   r  ;  s     0 05 0$ 0r]   c                	  "   V P                   ;_uu_ 4         V P                  P                  ! V!  G R j  xL
  R R R 4       R #  L  \         d   pT P	                  T4        R p?L-R p?ii ; i  + '       g   i     R # ; i5ir_   r  r   s   && rZ   r   UNIXDatagramSocket.send;  r  r  r  r  r=  s   @rZ   r  r  -  r  r]   r  c                  F   a  ] tR tRtR V 3R lltR R ltR R ltRtV ;t# )	ConnectedUNIXDatagramSocketiC  c                    V ^8  d   QhRRRR/# rK  rX   )rY   s   "rZ   r[   (ConnectedUNIXDatagramSocket.__annotate__F  ro  r]   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rq  rt  rw  s   &&rZ   rk   $ConnectedUNIXDatagramSocket.__init__F  ry  r]   c                   V ^8  d   QhRR/# r  rX   )rY   s   "rZ   r[   r  K  r  r]   c                	$  "   V P                   ;_uu_ 4         V P                  P                  R 4      G Rj  xL
 uuRRR4       #  L  \         d   pT P	                  T4        Rp?MRp?ii ; i RRR4       R#   + '       g   i     R# ; i5ir  r  rh  s   & rZ   r   #ConnectedUNIXDatagramSocket.receiveK  r  r  c                    V ^8  d   QhRRRR/# r   rX   )rY   s   "rZ   r[   r  R  r  r]   c                	  "   V P                   ;_uu_ 4         V P                  P                  V4      G R j  xL
  R R R 4       R #  L  \         d   pT P	                  T4        R p?L-R p?ii ; i  + '       g   i     R # ; i5ir_   r  r   s   && rZ   r    ConnectedUNIXDatagramSocket.sendR  r  r   r  r  r=  s   @rZ   r  r  C  s    7 7
00 0r]   r  c                  ^    ] tR tRtR R ltR R ltR R ltR R	 ltR
 R ltR R lt	Rt
R# )r7   i_  c                   V ^8  d   QhRR/# )rR   rW   r7   rX   )rY   s   "rZ   r[   Event.__annotate__`  s     # # #r]   c                	,    \         P                  V 4      # r_   r`   rb   s   &rZ   ra   Event.__new__`      ~~c""r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  c  s     ' '$ 'r]   c                	:    \         P                  ! 4       V n        R # r_   )rh   r7   _Event__originalrp   s   &rZ   rk   Event.__init__c  s    **,r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  f       ( ( (r]   c                	6    V P                   P                  4       # r_   )r"  is_setrp   s   &rZ   r'  Event.is_setf      %%''r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  i  s     , ,D ,r]   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir_   )r"  r  rp   s   &rZ   r  
Event.waiti  s     __))++++r  c                   V ^8  d   QhRR/# )rR   rW   r'   rX   )rY   s   "rZ   r[   r  l  s     L LO Lr]   c                	b    V P                   P                  4       p\        VP                  R 7      # ))tasks_waiting)r"  
statisticsr'   r/  rj   orig_statisticss   & rZ   r0  Event.statisticsl  s%    //446_-J-JKKr]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  p  s      T r]   c                	:    V P                   P                  4        R # r_   )r"  setrp   s   &rZ   r6  	Event.setp  s    r]   r   N)r   r   r   r   ra   rk   r'  r  r0  r6  r   rX   r]   rZ   r7   r7   _  s&    #'(,L r]   r7   c                      ] tR tRtRR/R R lltRR/R R llt]R R	 l4       tR
 R ltR R lt	R R lt
R R ltR R ltRtR# )r9   it  fast_acquireFc                    V ^8  d   QhRRRR/# rR   r9  rz   rW   r9   rX   )rY   s   "rZ   r[   Lock.__annotate__u  s     # #d #t #r]   c               	,    \         P                  V 4      # r_   r`   rb   r9  s   &$rZ   ra   Lock.__new__u  r  r]   c                    V ^8  d   QhRRRR/# )rR   r9  rz   rW   re   rX   )rY   s   "rZ   r[   r<  x  s     & & & &r]   c               	F    Wn         \        P                  ! 4       V n        R # r_   )_fast_acquirerh   r9   _Lock__original)rj   r9  s   &$rZ   rk   Lock.__init__x  s    )))+r]   c                    V ^8  d   QhRRRR/# )rR   r   r   rW   re   rX   )rY   s   "rZ   r[   r<  }  s     F F F Fr]   c                	:    V P                   R8X  d
   RV n         R# R# )*attempt to re-acquire an already held LockN)rG  )z)Attempted to acquire an already held Lock)r   )r   s   &rZ   _convert_runtime_error_msgLock._convert_runtime_error_msg|  s    88FFECH Gr]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r<    s      t r]   c                	"  "   V P                   '       g&    V P                  P                  4       G R j  xL
  R # \
        P                  P                  4       G R j  xL
   V P                  P                  4        R #  LI  \         d   pT P	                  T4       h R p?ii ; i LH  \
        P                   d2    T P                  P                  P                  4       G R j  xL 
   R # \         d   pT P	                  T4       h R p?ii ; i5ir_   )rB  rC  acquirer   rH  rh   r  checkpoint_if_cancelledacquire_nowaitr+   _lotparkrh  s   & rZ   rL  Lock.acquire  s     !!!oo--///
  mm33555	OO**, 0 //4 	6  	.//&&++--- 	++C0	s   DA? A=A? #DB$D!B& ;D=A? ?B!
BB!!D&<D"C%#D(D+D4D5DDDc                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r<    s       r]   c                	     V P                   P                  4        R #   \        P                   d	    \        R h\         d   pT P                  T4       h R p?ii ; ir_   )rC  rN  rh   r+   r   rH  rh  s   & rZ   rN  Lock.acquire_nowait  sL    	OO**, 	'$& 	++C0	s    $AAAAc                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r<    r%  r]   c                	6    V P                   P                  4       # r_   )rC  lockedrp   s   &rZ   rW  Lock.locked  r)  r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r<         " " "r]   c                	:    V P                   P                  4        R # r_   )rC  releaserp   s   &rZ   r\  Lock.release      !r]   c                   V ^8  d   QhRR/# )rR   rW   r(   rX   )rY   s   "rZ   r[   r<    s     
 
N 
r]   c                	    V P                   P                  4       pVP                  '       d   \        VP                  4      MR p\	        VP
                  W!P                  4      # r_   )rC  r0  ownerTrioTaskInfor(   rW  r/  )rj   r2  ra  s   &  rZ   r0  Lock.statistics  sP    //4467F7L7L7L_223RV""E+H+H
 	
r]   )r   rB  N)r   r   r   r   ra   rk   staticmethodrH  rL  rN  rW  r\  r0  r   rX   r]   rZ   r9   r9   t  sN    #U #&u & F F(("
 
r]   r9   c                     a  ] tR tRtRRRR/R R lltRRRR/R V 3R	 llltR
 R ltR R lt]R R l4       t	]R R l4       t
R R ltR R ltRtV ;t# )r=   i  	max_valueNr9  Fc               (    V ^8  d   QhRRRRRRRR/# )	rR   initial_valuer  rf  r   r9  rz   rW   r=   rX   )rY   s   "rZ   r[   Semaphore.__annotate__  s2     # ## 	#
 # 
#r]   c               	,    \         P                  V 4      # r_   r`   rb   rh  rf  r9  s   &&$$rZ   ra   Semaphore.__new__  s     ~~c""r]   c               (    V ^8  d   QhRRRRRRRR/# )	rR   rh  r  rf  r   r9  rz   rW   re   rX   )rY   s   "rZ   r[   ri    s8     M MM 	M
 M 
Mr]   c               	b   < \         SV `  WVR 7       \        P                  ! WR7      V n        R# )rf  r9  )rf  N)r8  rk   rh   r=   _Semaphore__original)rj   rh  rf  r9  r:  s   &&$$rZ   rk   Semaphore.__init__  s'     	,W..Lr]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   ri    s     
. 
.t 
.r]   c                	  "   V P                   '       g%   V P                  P                  4       G R j  xL
  R # \        P                  P                  4       G R j  xL
   V P                  P                  4        R #  LI L#  \        P                   d2    T P                  P                  P                  4       G R j  xL 
   R # i ; i5ir_   )
rB  rp  rL  rh   r  rM  rN  r+   rO  rP  rp   s   &rZ   rL  Semaphore.acquire  s     !!!//))+++ mm33555	.OO**, , 	6  	.//&&++---	.sQ   0C	A<'C	A>C	 B  :C	>C	 <C<B?=CC	CC	c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   ri    s     ' ' 'r]   c                	|     V P                   P                  4        R #   \        P                   d	    \        R hi ; ir_   )rp  rN  rh   r+   rp   s   &rZ   rN  Semaphore.acquire_nowait  s2    	'OO**, 	'$&	's    ;c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   ri    s     ) ): )r]   c                	.    V P                   P                  # r_   )rp  rf  rp   s   &rZ   rf  Semaphore.max_value  s    (((r]   c                   V ^8  d   QhRR/# r
  rX   )rY   s   "rZ   r[   ri    s     % %s %r]   c                	.    V P                   P                  # r_   )rp  r   rp   s   &rZ   r   Semaphore.value  s    $$$r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   ri    rZ  r]   c                	:    V P                   P                  4        R # r_   )rp  r\  rp   s   &rZ   r\  Semaphore.release  r^  r]   c                   V ^8  d   QhRR/# )rR   rW   r;   rX   )rY   s   "rZ   r[   ri    s     B B/ Br]   c                	`    V P                   P                  4       p\        VP                  4      # r_   )rp  r0  r;   r/  r1  s   & rZ   r0  Semaphore.statistics  s%    //446"?#@#@AAr]   r   )r   r   r   r   ra   rk   rL  rN  r   rf  r   r\  r0  r   r<  r=  s   @rZ   r=   r=     s    # !%	#
 ##M !%	M
 #M M
.' ) ) % %"B Br]   r=   c                     ] tR tRtR#RR/R R llltR#RR/R R llltR R	 ltR
 R lt]R R l4       t	]	P                  R R l4       t	]R R l4       t]R R l4       tR R ltR R ltR R ltR R ltR R ltR R ltR  R! ltR"tR# )$r5   i  NrS   c               $    V ^8  d   QhRRRRRR/# )rR   total_tokensfloat | NonerS   trio.CapacityLimiter | NonerW   r5   rX   )rY   s   "rZ   r[   CapacityLimiter.__annotate__  s(     # #"# .	#
 
#r]   c               	,    \         P                  V 4      # r_   r`   )rb   r  rS   s   &&$rZ   ra   CapacityLimiter.__new__  s     ~~c""r]   c               $    V ^8  d   QhRRRRRR/# )rR   r  r  rS   r  rW   re   rX   )rY   s   "rZ   r[   r    s-     
A 
A"
A .	
A
 

Ar]   c               	`    Ve	   W n         R # Vf   Q h\        P                  ! V4      V n         R # r_   )_CapacityLimiter__originalrh   r5   )rj   r  rS   s   &&$rZ   rk   CapacityLimiter.__init__  s-     &O+++"22<@DOr]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r    s     2 2$ 2r]   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir_   )r  r   rp   s   &rZ   r   CapacityLimiter.__aenter__  s     __//1111r  c               (    V ^8  d   QhRRRRRRRR/# )	rR   rt   ru   rv   rw   rx   ry   rW   re   rX   )rY   s   "rZ   r[   r    r{   r]   c                	Z   "   V P                   P                  WV4      G R j  xL
  R #  L5ir_   )r  r   r~   s   &&&&rZ   r   CapacityLimiter.__aexit__  s!      oo''6BBBs    +)+c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r    s     , ,e ,r]   c                	.    V P                   P                  # r_   r  r  rp   s   &rZ   r  CapacityLimiter.total_tokens  s    +++r]   c                    V ^8  d   QhRRRR/# r   rX   )rY   s   "rZ   r[   r    s     - -% -D -r]   c                	&    WP                   n        R # r_   r  r   s   &&rZ   r  r    s    ',$r]   c                   V ^8  d   QhRR/# r
  rX   )rY   s   "rZ   r[   r    s     / / /r]   c                	.    V P                   P                  # r_   )r  borrowed_tokensrp   s   &rZ   r  CapacityLimiter.borrowed_tokens
  s    ...r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r    s     0 0% 0r]   c                	.    V P                   P                  # r_   )r  available_tokensrp   s   &rZ   r   CapacityLimiter.available_tokens  r   r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r    s     ) ) )r]   c                	:    V P                   P                  4        R # r_   )r  rN  rp   s   &rZ   rN  CapacityLimiter.acquire_nowait  s    &&(r]   c                    V ^8  d   QhRRRR/# rR   borrowerrV   rW   re   rX   )rY   s   "rZ   r[   r    s     > >F >t >r]   c                	<    V P                   P                  V4       R # r_   )r  acquire_on_behalf_of_nowaitrj   r  s   &&rZ   r  +CapacityLimiter.acquire_on_behalf_of_nowait  s    33H=r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r    s     ( (t (r]   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5ir_   )r  rL  rp   s   &rZ   rL  CapacityLimiter.acquire  s     oo%%'''r   c                    V ^8  d   QhRRRR/# r  rX   )rY   s   "rZ   r[   r    s     = =6 =d =r]   c                	X   "   V P                   P                  V4      G R j  xL
  R #  L5ir_   )r  acquire_on_behalf_ofr  s   &&rZ   r  $CapacityLimiter.acquire_on_behalf_of  s     oo228<<<s   *(*c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r    s     ) ) )r]   c                	6    V P                   P                  4       # r_   )r  r\  rp   s   &rZ   r\  CapacityLimiter.release  s    &&((r]   c                    V ^8  d   QhRRRR/# r  rX   )rY   s   "rZ   r[   r  !  s     > >V > >r]   c                	8    V P                   P                  V4      # r_   )r  release_on_behalf_ofr  s   &&rZ   r  $CapacityLimiter.release_on_behalf_of!  s    33H==r]   c                   V ^8  d   QhRR/# )rR   rW   r&   rX   )rY   s   "rZ   r[   r  $  s     
 
5 
r]   c                	    V P                   P                  4       p\        VP                  VP                  \        VP                  4      VP                  R 7      # ))r  r  	borrowersr/  )r  r0  r&   r  r  tupler  r/  )rj   origs   & rZ   r0  CapacityLimiter.statistics$  sH    ))+( 00**DNN+,,	
 	
r]   r   r_   )r   r   r   r   ra   rk   r   r   r   r  r   r  r  rN  r  rL  r  r\  r  r0  r   rX   r]   rZ   r5   r5     s    # 15	# #
A 15	
A 
A2C , , - - / / 0 0)>(=)>
 
r]   r5   _capacity_limiter_wrapperc                  ^    ] tR tRt$ R]R&   R R ltR R ltR R	 ltR
 R ltR R lt	Rt
R# )_SignalReceiveri6  zAsyncIterator[int]	_iteratorc                   V ^8  d   QhRR/# )rR   signalsztuple[Signals, ...]rX   )rY   s   "rZ   r[   _SignalReceiver.__annotate__9  s         3  r]   c                	    Wn         R # r_   )_signals)rj   r  s   &&rZ   rk   _SignalReceiver.__init__9  s    r]   c                   V ^8  d   QhRR/# rR   rW   r  rX   )rY   s   "rZ   r[   r  <  s      ? r]   c                	    \         P                  ! V P                  !  V n        V P                  P	                  4       V n        V # r_   )rh   open_signal_receiverr  _cmro   r  rp   s   &rZ   ro   _SignalReceiver.__enter__<  s1    ,,dmm<++-r]   c               (    V ^8  d   QhRRRRRRRR/# )	rR   rt   ru   rv   rw   rx   ry   rW   zbool | NonerX   )rY   s   "rZ   r[   r  A  s2     < <,< &< %	<
 
<r]   c                	:    V P                   P                  WV4      # r_   )r  r}   r~   s   &&&&rZ   r}   _SignalReceiver.__exit__A  s     xx  F;;r]   c                   V ^8  d   QhRR/# r  rX   )rY   s   "rZ   r[   r  I  s      ? r]   c                	    V # r_   rX   rp   s   &rZ   	__aiter___SignalReceiver.__aiter__I  s    r]   c                   V ^8  d   QhRR/# )rR   rW   r   rX   )rY   s   "rZ   r[   r  L  s       r]   c                	h   "   V P                   P                  4       G R j  xL
 p\        V4      #  L5ir_   )r  	__anext__r   )rj   signums   & rZ   r  _SignalReceiver.__anext__L  s)     ~~//11v 2s   202)r  r  r  N)r   r   r   r   r   rk   ro   r}   r  r  r   rX   r]   rZ   r  r  6  s&    !! 
< r]   r  c                  v    ] tR tRtR R ltR R ltR R ltR R	 ltR
 R ltR R lt	R R lt
R R ltRtR# )
TestRunneriV  c                    V ^8  d   QhRRRR/# )rR   optionsr   rW   re   rX   )rY   s   "rZ   r[   TestRunner.__annotate__W  s        #  $  r]   c                	D    ^ RI Hp V! 4       V n        RV n        Wn        R# )r   )QueueN)queuer  _call_queue_send_stream_options)rj   r  r  s   &, rZ   rk   TestRunner.__init__W  s    8=;?r]   c               (    V ^8  d   QhRRRRRRRR/# )	rR   rt   ru   rv   rw   rx   ztypes.TracebackType | NonerW   re   rX   )rY   s   "rZ   r[   r  ^  s2     	) 	),	) &	) +		)
 
	)r]   c                	    V P                   '       dL   V P                   P                  4        V P                   e"   V P                  P                  4       ! 4        K/  R # R # r_   )r  rb  r  getr~   s   &&&&rZ   r}   TestRunner.__exit__^  sM     ##%##/  $$&( 0 r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  i  s     	9 	9t 	9r]   c           	     	^  "   \        ^4      w  V n        pT;_uu_ 4        V  Rj  xL
  w  r# VG Rj  xL
 pVP                  \        V4      4       K3   L. L"  \         d&   pTP                  \        T4      4        Rp?Kb  Rp?ii ; iDd RRR4       R#   + '       g   i     R# ; i5i)   N)r3   r  r  r   r  r   )rj   receive_streamcorooutcome_holderretvalr   s   &     rZ   _run_tests_and_fixtures"TestRunner._run_tests_and_fixturesi  s     ,G,J)>^.< 9 9*d9#'ZF #))%-89'$ 6"))%*556 /= ^^^sn   B-BBA
BBAA
ABBAB
	%B	?BB
	
B
B-B*	$	B-c                    V ^8  d   QhRRRR/# )rR   outcomerV   rW   re   rX   )rY   s   "rZ   r[   r  t  s     ! !6 !d !r]   c                	    R V n         R # r_   )r  )rj   r  s   &&rZ   _main_task_finishedTestRunner._main_task_finishedt  s
     r]   c               (    V ^8  d   QhRRRRRRRR/# )	rR   r   z Callable[P, Awaitable[T_Retval]]r   zP.argsrU   zP.kwargsrW   rL   rX   )rY   s   "rZ   r[   r  w  s2     * *.* * 	*
 
*r]   c                	   V P                   f   \        P                  P                  ! V P                  3RV P
                  P                  RV P                  /V P                  B  V P                   f"   V P
                  P                  4       ! 4        K/  . pV P                   P                  V! V/ VB V34       V'       g"   V P
                  P                  4       ! 4        K)  V^ ,          P                  4       # )Nrun_sync_soon_threadsafedone_callback)r  rh   r  start_guest_runr  r  putr  r  r  send_nowaitunwrap)rj   r   r   rU   r  s   &&*, rZ   _call_in_runner_taskTestRunner._call_in_runner_taskw  s     $MM)),,)-)9)9)=)= #66 --	 ##+  $$&((*%%tT'<V'<n&MN   "$a ''))r]   c               $    V ^8  d   QhRRRRRR/# )rR   fixture_funcz,Callable[..., AsyncGenerator[T_Retval, Any]]rU   dict[str, Any]rW   zIterable[T_Retval]rX   )rY   s   "rZ   r[   r    s-     G GBG G 
	Gr]   c              #  	  "   V! R/ VB pV P                  VP                  R 4      pVx   V P                  VP                  R 4       V P                  VP                  4       \        R4      h  \         d     R # i ; i5i)Nz$Async generator fixture did not stoprX   )r  asendr   r   StopAsyncIteration)rj   r  rU   asyncgenfixturevalues   &&&  rZ   run_asyncgen_fixtureTestRunner.run_asyncgen_fixture  s}     
  )&)!%!:!:8>>4!P	G%%hnnd; %%hoo6EFF	 " 		s(   )B A. &B .A=9B <A==B c               $    V ^8  d   QhRRRRRR/# )rR   r  z,Callable[..., Coroutine[Any, Any, T_Retval]]rU   r  rW   rL   rX   )rY   s   "rZ   r[   r    s-     A ABA A 
	Ar]   c                	(    V P                   ! V3/ VB # r_   r  )rj   r  rU   s   &&&rZ   run_fixtureTestRunner.run_fixture  s    
 ((@@@r]   c               $    V ^8  d   QhRRRRRR/# )rR   	test_funcz'Callable[..., Coroutine[Any, Any, Any]]rU   r  rW   re   rX   )rY   s   "rZ   r[   r    s$     7 7@7JX7	7r]   c                	,    V P                   ! V3/ VB  R # r_   r  )rj   r  rU   s   &&&rZ   run_testTestRunner.run_test  s     	!!)6v6r]   )r  r  r  N)r   r   r   r   rk   r}   r  r  r  r  r  r  r   rX   r]   rZ   r  r  V  s1     	)	9!*.G$A7 7r]   r  c                  :   a  ] tR tRtR V 3R lltR R ltRtV ;t# )rb  i  c                   V ^8  d   QhRR/# )rR   taskztrio.lowlevel.TaskrX   )rY   s   "rZ   r[   TrioTaskInfo.__annotate__  s     ) )/ )r]   c                	8  < R pVP                   '       d<   VP                   P                  '       d    \        VP                   P                  4      p\        SV `  \        V4      W!P
                  VP                  4       \        P                  ! V4      V n	        R # r_   )
parent_nurseryparent_taskidr8  rk   r   r  weakrefproxy_task)rj   r  	parent_idr:  s   && rZ   rk   TrioTaskInfo.__init__  sh    	4#6#6#B#B#B4..::;ID9iiC]]4(
r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r    s      $ r]   c                	h     V P                   P                  P                  #   \         d     R # i ; i)F)r$  _cancel_statuseffectively_cancelledReferenceErrorrp   s   &rZ   has_pending_cancellation%TrioTaskInfo.has_pending_cancellation  s1    	::,,BBB 	 	s   " 11)r$  )r   r   r   r   rk   r,  r   r<  r=  s   @rZ   rb  rb    s    ) ) r]   rb  c            	         ] tR tRt]R R l4       t]R R l4       t]R R l4       t]R R	 l4       t]R
 R l4       t	]R R l4       t
]R R l4       t]R R l4       t]R]P                  RR/R R ll4       t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]RR R!R/R" R# ll4       t]R$ R% l4       t]RkR& R' ll4       t]R( R) l4       t]R* R+ l4       t]R, R- l4       t]R. R/ l4       t]R0 R1 l4       t]RlR2 R3 ll4       t]R4 R5 l4       t]R6 R7 l4       t]R8 R9 l4       t]R: R; l4       t ]]!R< R= l4       4       t"]]!R> R? l4       4       t"]R@ RA l4       t"]RB^ RC^ RD^ RE^ /RF RG ll4       t#]RmRH RI ll4       t$]RJ RK l4       t%]RL RM l4       t&]RN RO l4       t']RP RQ l4       t(]RR RS l4       t)]RT RU l4       t*]RV RW l4       t+]RX RY l4       t,]RZ R[ l4       t-]R\ R] l4       t.]R^ R_ l4       t/]R` Ra l4       t0]Rb Rc l4       t1]Rd Re l4       t2]Rf Rg l4       t3]Rh Ri l4       t4Rjt5R # )nTrioBackendi  c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
rR   r   1Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]]r   tuple[Unpack[PosArgsT]]rU   r  r  rW   rL   rX   )rY   s   "rZ   r[   TrioBackend.__annotate__  s<     % %?% &% 	%
  % 
%r]   c                	2    \         P                  ! V.VO5!  # r_   )rh   run)rb   r   r   rU   r  s   &&&&&rZ   r5  TrioBackend.run  s     xx$t$$r]   c                   V ^8  d   QhRR/# )rR   rW   rV   rX   )rY   s   "rZ   r[   r3    s     2 2f 2r]   c                	>    \         P                  P                  4       # r_   )rh   r  current_trio_tokenr  s   &rZ   current_tokenTrioBackend.current_token  s    }}//11r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r3    s     # #U #r]   c                	,    \         P                  ! 4       # r_   )rh   current_timer  s   &rZ   r>  TrioBackend.current_time  s      ""r]   c                   V ^8  d   QhRR/# )rR   rW   ztype[BaseException]rX   )rY   s   "rZ   r[   r3    s      *= r]   c                	"    \         P                  # r_   )rh   r   r  s   &rZ   cancelled_exception_class%TrioBackend.cancelled_exception_class  s    ~~r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r3    s     ) ) )r]   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5ir_   )rh   r  r  r  s   &rZ   r  TrioBackend.checkpoint  s     mm&&(((   "-+-c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r3    s     6 6d 6r]   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5ir_   )rh   r  rM  r  s   &rZ   rM  #TrioBackend.checkpoint_if_cancelled  s     mm33555rG  c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r3    s     9 9 9r]   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5ir_   )rh   r  cancel_shielded_checkpointr  s   &rZ   rM  &TrioBackend.cancel_shielded_checkpoint  s     mm66888rG  c                    V ^8  d   QhRRRR/# )rR   delayr   rW   re   rX   )rY   s   "rZ   r[   r3    s          $  r]   c                	N   "   \         P                  ! V4      G R j  xL
  R #  L5ir_   )rh   rC  )rb   rP  s   &&rZ   rC  TrioBackend.sleep  s     jjs   %#%r   r   Fc               $    V ^8  d   QhRRRRRR/# )rR   r   r   r   rz   rW   zabc.CancelScoperX   )rY   s   "rZ   r[   r3    s$     = ==48=	=r]   c               	    \        WR 7      # ))r   r   r>   )rb   r   r   s   &$$rZ   create_cancel_scopeTrioBackend.create_cancel_scope  s     H<<r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r3    s     1 15 1r]   c                	,    \         P                  ! 4       # r_   )rh   current_effective_deadliner  s   &rZ   rY  &TrioBackend.current_effective_deadline  s    ..00r]   c                   V ^8  d   QhRR/# )rR   rW   zabc.TaskGrouprX   )rY   s   "rZ   r[   r3    s      - r]   c                	    \        4       # r_   )r   r  s   &rZ   create_task_groupTrioBackend.create_task_group  s
    {r]   c                   V ^8  d   QhRR/# )rR   rW   z	abc.EventrX   )rY   s   "rZ   r[   r3    s      Y r]   c                	    \        4       # r_   r6   r  s   &rZ   create_eventTrioBackend.create_event  s	    wr]   c                    V ^8  d   QhRRRR/# r;  rX   )rY   s   "rZ   r[   r3    s     / /$ /4 /r]   c               	    \        VR 7      # ))r9  r8   r>  s   &$rZ   create_lockTrioBackend.create_lock  s    ..r]   rf  Nr9  c               (    V ^8  d   QhRRRRRRRR/# )	rR   rh  r  rf  r   r9  rz   rW   zabc.SemaphorerX   )rY   s   "rZ   r[   r3    s8     X XX 	X
 X 
Xr]   c               	    \        WVR 7      # )ro  r<   rk  s   &&$$rZ   create_semaphoreTrioBackend.create_semaphore  s     ,WWr]   c                    V ^8  d   QhRRRR/# )rR   r  r   rW   r5   rX   )rY   s   "rZ   r[   r3    s     - -5 -_ -r]   c                	    \        V4      # r_   r4   )rb   r  s   &&rZ   create_capacity_limiter#TrioBackend.create_capacity_limiter  s    |,,r]   c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )rR   r   &Callable[[Unpack[PosArgsT]], T_Retval]r   r2  abandon_on_cancelrz   limiterzabc.CapacityLimiter | NonerW   rL   rX   )rY   s   "rZ   r[   r3    s<     
 
4
 &
  	

 ,
 

r]   c                	   aaa"   R  VVV3R llp\         P                  4       o\        VV\        \        P
                  V4      R7      G Rj  xL
 #  L5i)c                   V ^8  d   QhRR/# )rR   rW   rL   rX   )rY   s   "rZ   r[   ;TrioBackend.run_sync_in_worker_thread.<locals>.__annotate__  s     	# 	# 	#r]   c                 ~   < \        \        S4      ;_uu_ 4        S! S !  uuR R R 4       #   + '       g   i     R # ; ir_   )r-   r/  )r   r   tokens   rZ   wrapper6TrioBackend.run_sync_in_worker_thread.<locals>.wrapper  s&    $[%88T{ 9888s   +<	)rq  rr  N)r/  r:  r%   r   rh   r5   )rb   r   r   rq  rr  rx  rw  s   &ff&& @rZ   run_sync_in_worker_thread%TrioBackend.run_sync_in_worker_thread
  sM     	# 	# ))+/--w7
 
 	
 
s   A	AAAc                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r3    s     + + +r]   c                	B    \         P                  P                  4        R # r_   )rh   from_threadcheck_cancelledr  s   &rZ   r  TrioBackend.check_cancelled  s    ((*r]   c               (    V ^8  d   QhRRRRRRRR/# )	rR   r   r1  r   r2  rw  rV   rW   rL   rX   )rY   s   "rZ   r[   r3  "  s2     
- 
-?
- &
- 	
-
 

-r]   c                	    \        R V4      p \        P                  P                  ! V.VO5RV/ #   \        P                   d	    \        Rhi ; iztrio.lowlevel.TrioToken | None
trio_tokenN)r   rh   r~  r5  r)   rb   r   r   rw  r  s   &&&& rZ   run_async_from_thread!TrioBackend.run_async_from_thread!  sT     :EB
	-##''KtK
KK$$ 	-",	-	   #2 Ac               (    V ^8  d   QhRRRRRRRR/# )	rR   r   rp  r   r2  rw  rV   rW   rL   rX   )rY   s   "rZ   r[   r3  /  s2     
- 
-4
- &
- 	
-
 

-r]   c                	    \        R V4      p \        P                  P                  ! V.VO5RV/ #   \        P                   d	    \        Rhi ; ir  )r   rh   r~  r%   r)   r  s   &&&& rZ   run_sync_from_thread TrioBackend.run_sync_from_thread.  sT     :EB
	-##,,TPDPZPP$$ 	-",	-r  c               0    V ^8  d   QhRRRRRRRRRRR	R
/# )rR   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]r&  zint | IO[Any] | Noner,  r1  rU   r   rW   r   rX   )rY   s   "rZ   r[   r3  <  sN     &L &L:&L $	&L
 %&L %&L &L 
&Lr]   c               	t  "   R  R lp\        V\        \        \        34      '       d9   \        P
                  P                  ! V! V4      3RVRVRVRR/VB G Rj  xL
 pMF\        P
                  P                  ! V Uu. uF
  q! V4      NK  	  up3RVRVRVRR/VB G Rj  xL
 pVP                  '       d   \        VP                  4      MRp	VP                  '       d   \        VP                  4      MRp
VP                  '       d   \        VP                  4      MRp\        WyW4      #  Lu upi  L5i)	c                    V ^8  d   QhRRRR/# )rR   r   rD   rW   strrX   )rY   s   "rZ   r[   .TrioBackend.open_process.<locals>.__annotate__E  s     	1 	1~ 	1# 	1r]   c                    \         P                  ! V 4      p\        V\        4      '       d   V# \         P                  ! V4      # r_   )osfspathrf  r  fsdecode)r   str_or_bytess   & rZ   convert_item.TrioBackend.open_process.<locals>.convert_itemE  s1    99T?L,,,##{{<00r]   r&  r,  r1  shellTNF)rf  r  r   r   rh   r  open_processr&  r   r,  r   r1  r   )rb   r  r&  r,  r1  rU   r  rF  r   stdin_streamstdout_streamstderr_streams   &&$$$,      rZ   r  TrioBackend.open_process;  s?    	1 gUH566 MM66W%  	
   G !MM66078d#8  	
   G <C===(7d@G,W^^<TX@G,W^^<TXwmKK+ 9sB   AD8D/#D8 D1D8#D6$D8:(D8#(D8$D81D8c                    V ^8  d   QhRRRR/# r@  rX   )rY   s   "rZ   r[   r3  e  s     I I:J It Ir]   c                	N    \         P                  P                  \        V4       R # r_   )rh   r  spawn_system_taskrG  )rb   rA  s   &&rZ   #setup_process_pool_exit_at_shutdown/TrioBackend.setup_process_pool_exit_at_shutdownd  s    ''(>Hr]   c               (    V ^8  d   QhRRRRRRRR/# )	rR   hostr  portr  local_addressIPSockAddrType | NonerW   rl  rX   )rY   s   "rZ   r[   r3  i  s,     ) ))!)2G)	)r]   c                	  "   R V9   d   \         P                  M\         P                  p\        P                   P                  V4      pVP	                  \         P
                  \         P                  ^4       V'       d   VP                  V4      G Rj  xL
   VP                  W34      G Rj  xL
  \        T4      #  L* L  \         d    TP                  4        h i ; i5i):N)r  AF_INET6AF_INETrh   r  r  r  bindconnectr  rb  rl  )rb   r  r  r  familyrL  s   &&&&  rZ   connect_tcpTrioBackend.connect_tcph  s      %(4KV^^kk((0v1163E3EqI""=111	%%tl333
 K(( 2 4 		sB   A=C# C#B?C#C /C0C 4C#C C  C#c                    V ^8  d   QhRRRR/# )rR   pathstr | bytesrW   zabc.UNIXSocketStreamrX   )rY   s   "rZ   r[   r3  {  s     - -k -6J -r]   c                	   "   \         P                  P                  \        P                  4      p VP                  V4      G R j  xL
  \        T4      #  L  \         d    TP                  4        h i ; i5ir_   )rh   r  AF_UNIXr  r  rb  r  )rb   r  rL  s   && rZ   connect_unixTrioBackend.connect_unixz  se     kk((8	%%d+++
  ,, , 		s.   .A7A AA 
A7A A44A7c                    V ^8  d   QhRRRR/# rR   sockr[  rW   zabc.SocketListenerrX   )rY   s   "rZ   r[   r3    s     ' '} '9K 'r]   c                	    \        V4      # r_   r  rb   r  s   &&rZ   create_tcp_listenerTrioBackend.create_tcp_listener  s     &&r]   c                    V ^8  d   QhRRRR/# r  rX   )rY   s   "rZ   r[   r3    s     ( ( (:L (r]   c                	    \        V4      # r_   )r  r  s   &&rZ   create_unix_listener TrioBackend.create_unix_listener  s    !$''r]   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
rR   r  zsocket.AddressFamilyr  r  remote_address
reuse_portrz   rW   zUDPSocket | ConnectedUDPSocketrX   )rY   s   "rZ   r[   r3    s<     * *$* -* .	*
 * 
(*r]   c                	  "   \         P                  P                  V\        P                  R 7      pV'       d0   VP                  \        P                  \        P
                  ^4       V'       d   VP                  V4      G Rj  xL
  V'       d%   VP                  V4      G Rj  xL
  \        V4      # \        V4      #  L; L5i))r  typeN)
rh   r  
SOCK_DGRAMr  r  SO_REUSEPORTr  r  r  r  )rb   r  r  r  r  rL  s   &&&&& rZ   create_udp_socketTrioBackend.create_udp_socket  s      kk((V=N=N(O""6#4#4f6I6I1M""=111%%n555%k22[)) 2 6s0   A.C1CCCC&C'CCc               $    V ^8  d   QhRRRRRR/# )rR   r  r[  remote_pathre   rW   zabc.UNIXDatagramSocketrX   )rY   s   "rZ   r[   r3    s$     % %&%59%	%r]   c                	   "   R # 5ir_   rX   rb   r  r  s   &&&rZ   create_unix_datagram_socket'TrioBackend.create_unix_datagram_socket  s
      "%   c               $    V ^8  d   QhRRRRRR/# )rR   r  r[  r  r  rW   zabc.ConnectedUNIXDatagramSocketrX   )rY   s   "rZ   r[   r3    s$     . .&.5@.	(.r]   c                	   "   R # 5ir_   rX   r  s   &&&rZ   r  r    s
      +.r  c               $    V ^8  d   QhRRRRRR/# )rR   r  r[  r  zstr | bytes | NonerW   z8abc.UNIXDatagramSocket | abc.ConnectedUNIXDatagramSocketrX   )rY   s   "rZ   r[   r3    s$     	3 	3&	35G	3	A	3r]   c                	   "   \         P                  P                  V4      pV'       d%   VP                  V4      G R j  xL
  \	        V4      # \        V4      #  L5ir_   )rh   r  r  r  r  r  )rb   r  r  rL  s   &&& rZ   r  r    sM      kk44Z@%%k222.{;;%k22 3s   <AAAr  r  protor  c               4    V ^8  d   QhRRRRRRRRR	R
RR
RR/# )rR   r  zbytes | str | Noner  zstr | int | Noner  zint | AddressFamilyr  zint | SocketKindr  r  r  rW   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]rX   )rY   s   "rZ   r[   r3    sY     U U U U
 $U U U U
Ur]   c               	`   "   \         P                  P                  WW4WV4      G R j  xL
 #  L5ir_   )rh   r  getaddrinfo)rb   r  r  r  r  r  r  s   &&&$$$$rZ   r  TrioBackend.getaddrinfo  s&     & [[,,TuTTTTs   %.,.c               $    V ^8  d   QhRRRRRR/# )rR   sockaddrr@   r  r  rW   ztuple[str, str]rX   )rY   s   "rZ   r[   r3    s$     > >%>.1>	>r]   c                	\   "   \         P                  P                  W4      G R j  xL
 #  L5ir_   )rh   r  getnameinfo)rb   r  r  s   &&&rZ   r  TrioBackend.getnameinfo  s"      [[,,X====s   #,*,c                    V ^8  d   QhRRRR/# rR   objrF   rW   re   rX   )rY   s   "rZ   r[   r3    s     > >&8 >T >r]   c                	   "    \        V4      G R j  xL
  R #  L  \        P                   d*   p\        4       P                  TP                  4      R hR p?i\        P
                   d    \        R4      R hi ; i5i)Nrr  )r"   rh   r0   with_traceback__traceback__r/   rb   r  r   s   && rZ   r"   TrioBackend.wait_readable  se     	>$$$'' 	T%'66s7H7HItS%% 	>#N3=	>6   A<  A< A9$AA9+A99A<c                    V ^8  d   QhRRRR/# r  rX   )rY   s   "rZ   r[   r3    s     < <&8 <T <r]   c                	   "    \        V4      G R j  xL
  R #  L  \        P                   d*   p\        4       P                  TP                  4      R hR p?i\        P
                   d    \        R4      R hi ; i5i)Nrs  )r#   rh   r0   r  r  r/   r  s   && rZ   r#   TrioBackend.wait_writable  se     	<$$$'' 	T%'66s7H7HItS%% 	<#L1t;	<r  c                    V ^8  d   QhRRRR/# r  rX   )rY   s   "rZ   r[   r3    s      !3  r]   c                	    \        V4       R # r_   )r!   )rb   r  s   &&rZ   r!   TrioBackend.notify_closing  s
    sr]   c                    V ^8  d   QhRRRR/# r  rX   )rY   s   "rZ   r[   r3    s     ' 'm '@R 'r]   c                	    "   \        V4      # 5ir_   r  r  s   &&rZ   wrap_listener_socket TrioBackend.wrap_listener_socket  s      &&s   c                    V ^8  d   QhRRRR/# )rR   r  r[  rW   rl  rX   )rY   s   "rZ   r[   r3    s     ' 'M 'l 'r]   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir_   )rh   r  r  rl  rb   r  	trio_socks   && rZ   wrap_stream_socketTrioBackend.wrap_stream_socket  s$     KK2248	I&&   +-c                    V ^8  d   QhRRRR/# )rR   r  r[  rW   r  rX   )rY   s   "rZ   r[   r3    s     + + +CS +r]   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir_   )rh   r  r  r  r  s   && rZ   wrap_unix_stream_socket#TrioBackend.wrap_unix_stream_socket  s$     KK2248		**r  c                    V ^8  d   QhRRRR/# )rR   r  r[  rW   r  rX   )rY   s   "rZ   r[   r3    s     $ $ $9 $r]   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir_   )rh   r  r  r  r  s   && rZ   wrap_udp_socketTrioBackend.wrap_udp_socket  s$     KK2248	##r  c                    V ^8  d   QhRRRR/# )rR   r  r[  rW   r  rX   )rY   s   "rZ   r[   r3          - -= -EW -r]   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir_   )rh   r  r  r  r  s   && rZ   wrap_connected_udp_socket%TrioBackend.wrap_connected_udp_socket  $     KK2248	!),,r  c                    V ^8  d   QhRRRR/# )rR   r  r[  rW   r  rX   )rY   s   "rZ   r[   r3    r  r]   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir_   )rh   r  r  r  r  s   && rZ   wrap_unix_datagram_socket%TrioBackend.wrap_unix_datagram_socket  r  r  c                    V ^8  d   QhRRRR/# )rR   r  r[  rW   r  rX   )rY   s   "rZ   r[   r3  
  s     6 6 6	$6r]   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir_   )rh   r  r  r  r  s   && rZ   #wrap_connected_unix_datagram_socket/TrioBackend.wrap_connected_unix_datagram_socket	  s&      KK2248	*955r  c                   V ^8  d   QhRR/# )rR   rW   r5   rX   )rY   s   "rZ   r[   r3    s       r]   c                	     \         P                  4       #   \         dC    \        \        P
                  P                  4       R 7      p\         P                  T4       Tu # i ; i))rS   )r  r  LookupErrorr5   rh   	to_threadcurrent_default_thread_limiterr6  )rb   rr  s   & rZ   r  *TrioBackend.current_default_thread_limiter  sT    	,0022 	%FFHG &))'2N	s    A
A#"A#c                    V ^8  d   QhRRRR/# )rR   r  r   rW   z.AbstractContextManager[AsyncIterator[Signals]]rX   )rY   s   "rZ   r[   r3    s     ( ((	7(r]   c                	    \        V4      # r_   )r  )rb   r  s   &*rZ   r   TrioBackend.open_signal_receiver  s     w''r]   c                   V ^8  d   QhRR/# )rR   rW   r*   rX   )rY   s   "rZ   r[   r3  "  s     " " "r]   c                	,    \        4       p\        V4      # r_   )r    rb  )rb   r  s   & rZ   get_current_taskTrioBackend.get_current_task!  s    ~D!!r]   c                   V ^8  d   QhRR/# )rR   rW   zSequence[TaskInfo]rX   )rY   s   "rZ   r[   r3  '  s      "4 r]   c                	   \        4       pV'       g   Q h\        V4      .pVP                  pV'       dX   . pV FK  pVP                   F8  pVP	                  \        V4      4       VP                  VP                  4       K:  	  KM  	  TpK_  V# r_   )r   rb  child_nurserieschild_tasksr  extend)rb   	root_task
task_infos	nurseriesnew_nurseriesnurseryr  s   &      rZ   get_running_tasksTrioBackend.get_running_tasks&  s    %'	y"9-.
--	02M$#//D%%l4&89!(()=)=> 0 %
 &Ir]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r3  8  s     ' 'T 'r]   c                	<   "   ^ RI Hp V! 4       G Rj  xL
  R#  L5i)r   )wait_all_tasks_blockedN)trio.testingr/  )rb   r/  s   & rZ   r/  "TrioBackend.wait_all_tasks_blocked7  s     7$&&&s   c                    V ^8  d   QhRRRR/# )rR   r  r  rW   r  rX   )rY   s   "rZ   r[   r3  >  s     % % %J %r]   c                	    \        R/ VB # rg   )r  )rb   r  s   &&rZ   create_test_runnerTrioBackend.create_test_runner=  s    $G$$r]   rX   rP  r_   )r   )6r   r   r   r   classmethodr5  r:  r>  rB  r  rM  rM  rC  rD  rE  rU  rY  r]  ra  re  ri  rm  rz  r  r  r  r  r  r  r  r  r  r  r   r  r  r  r"   r#   r!   r  r  r   r  r	  r  r  r  r  r  r+  r/  r4  r   rX   r]   rZ   r/  r/    s   % % 2 2 # #   ) ) 6 6 9 9     ="&((=;@= =
 1 1     / / X !%	X
 #X X - - 
 
$ + + 
- 
- 
- 
- &L &LP I I ) )" - - ' ' ( ( * ** %  % .  . 	3 	3 U
 '(U "#U U U U( > >
 > > < <   ' ' ' ' + + $ $ - - - - 6 6   ( (
 " "    ' '
 % %r]   r/  )   
   )r7     )__conditional_annotations__
__future__r   r  rD  r  r  systypesr"  collections.abcr   r   r   r   r   r	   r
   r   
contextlibr   dataclassesr   ior   r   r  r   r   r   r   typingr   r   r   r   r   r   r   r   trio.from_threadrh   trio.lowlevelr  r   r   r   r   r    r!   r"   r#   trio.socketr$   rM  trio.to_threadr%    r&   r'   r(   r)   r*   r+   r,   _core._eventloopr-   _core._exceptionsr.   r/   r0   r1   _core._socketsr2   _core._streamsr3   _core._synchronizationr5   BaseCapacityLimiterr7   	BaseEventr9   BaseLockr:   r;   r=   BaseSemaphore_core._tasksr?   BaseCancelScoper@   rA   rB   abc._eventlooprC   rD   streams.memoryrE   	_typeshedrF   version_inforG   typing_extensionsrH   rI   exceptiongrouprJ   rK   rL   r  rM   rN   rO   r  RunVarr   ByteReceiveStreamr   ByteSendStreamr   r   
Instrumentr4  r>  r   rG  rI  rl  r  SocketListenerr  r  r  r  r  r  r  r  r  rb  r/  backend_class)r:  s   @rZ   <module>r_     s]   " "   	  
  	 	 	 . !    , 	 	 	   ) )  5 #   3  3 8 8 5 @ 9 G G 9 3,w +w++16CL:\37

#cN 
		.'/ .'l3A 3Av e$300 $ $( e$** $ $ e5ckk 5 5pTXX%8%8 
 @F,@ &(< 

'$wz* >3#S%5%5 3B@4|S%9%9 @4F)(#*<*< ) -)3+=+= -0 0#-- 0,0).93;Q;Q 0*0)#.0F0F 0,0S3::08I *5
8 5
p3B 3BlI
) I
X 399T2U / U @T7 T7n8 $@%, @%F r]   