+
    @i                    4  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'H(t( ^ RI)t*^ RI+t*^ RI,H-t-H.t.H/t/ ^ RI+H0t0H1t1H2t2H3t3H4t4 ^ RI5H6t7 ^ RI8H9t9 ^RI:H;t;H<t<H=t=H>t>H?t?H@t@HAtA ^RIBHCtC ^RIDHEtEHFtFHGtGHHtH ^RIIHJtJ ^RIKHLtL ^RIMHNtO ^RIMHPtQ ^RIMHRtS ^RIMHTtTHUtU ^RIMHVtW ^RIXHYtZ ^RIAH[t[H\t\H]t] ^RI^H_t_H`t` ^RIaHbtb ]!'       d   ^ RIcHdtd ]P                  R[8  d
   ^ RIHftfHgtg M^ R IhHiti ^ RIjHftfHgtg ]&! R!4      tk]&! R"4      tl]&! R#]m][4      tn]f! R$4      to]%! R%4      tp]*P                  P                  tr ! R& R']Z4      tY ! R( R)]AP                  4      ts]! R*R+7       ! R, R-]AP                  4      4       tu]! R*R+7       ! R. R/]AP                  4      4       tw]! R*R+7       ! R0 R1]AP                  4      4       tx ! R2 R3]*P                  P                  4      tz]r! R44      t{R5]|R4&   R6 R7 lt} ! R8 R9]#]n,          4      t~ ! R: R;]~]AP                  4      t ! R< R=]]AEP                   4      t ! R> R?]~]AEP                  4      t ! R@ RA]~]AEP                  4      t ! RB RC]~][,          ]AEP                  4      t ! RD RE]~][,          ]AEP
                  4      t ! RF RG]~]m,          ]AEP                  4      t ! RH RI]~]m,          ]AEP                  4      t ! RJ RK]Q4      tP ! RL RM]S4      tR ! RN RO]W4      tV ! RP RQ]O4      tN]r! RR4      tR5]|RR&    ! RS RT4      t ! RU RV]AEP                  4      t ! RW RX]?4      t ! RY RZ]_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	ParamSpec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)TypeVarTupleUnpack)BaseExceptionGroupTT_Retval
T_SockAddrPosArgsTPc                  
   ] tR t^qt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/var/www/html/photoedit/myenv/lib/python3.14/site-packages/anyio/_backends/_trio.py__annotate__CancelScope.__annotate__r   s$     # #.#AG#	#    c                	,    \         P                  V 4      # NrV   __new__)clsrS   rU   s   &&,rZ   ra   CancelScope.__new__r   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\   w   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__w   s    "@@d&6&6&@&@r]   c                   V ^8  d   QhRR/# )rR   rW   r@   rX   )rY   s   "rZ   r[   r\   z   s      ; r]   c                	:    V P                   P                  4        V # r_   )ri   	__enter__rj   s   &rZ   ro   CancelScope.__enter__z   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@   q   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   r1   	__cause__r/   r   r2   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   r1   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  ,  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  0  s     ( (J (r]   c                	.    V P                   P                  # r_   )r   
returncoderp   s   &rZ   r"  Process.returncode/  s    }}'''r]   c                   V ^8  d   QhRR/# )rR   rW   r   rX   )rY   s   "rZ   r[   r  4  s      0 r]   c                	    V P                   # r_   )r   rp   s   &rZ   stdinProcess.stdin3  s    {{r]   c                   V ^8  d   QhRR/# rR   rW   r   rX   )rY   s   "rZ   r[   r  8        4 r]   c                	    V P                   # r_   )r   rp   s   &rZ   stdoutProcess.stdout7      ||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# )_ProcessPoolShutdownInstrumenti@  c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   +_ProcessPoolShutdownInstrument.__annotate__A  s      4 r]   c                	$   < \         SV `  4        R # r_   )super	after_run)rj   	__class__s   &rZ   r9  (_ProcessPoolShutdownInstrument.after_runA  s    r]   rX   )r   r   r   r   r9  r   __classcell__r:  s   @rZ   r4  r4  @  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[   J  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  J  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__]  s      N t r]   c                	     Wn         R V n        R# FN)_trio_socket_closed)rj   rL  s   &&rZ   rk   _TrioSocketMixin.__init__]  s    'r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   rN  a  s     & &t &r]   c                	    V P                   '       d   \        hV P                  P                  4       ^ 8  d   \        hR# r   N)rR  r1   rQ  filenor/   rp   s   &rZ   _check_closed_TrioSocketMixin._check_closeda  s3    <<<%%##%)%% *r]   c                   V ^8  d   QhRR/# )rR   rW   socket.socketrX   )rY   s   "rZ   r[   rN  h  s     ' '] 'r]   c                	.    V P                   P                  # r_   )rQ  _sockrp   s   &rZ   _raw_socket_TrioSocketMixin._raw_socketg  s      &&&r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   rN  k  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.aclosek  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  p  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   r1   rQ  rW  rR  OSErrorr/   rj   r   s   &&rZ   _convert_socket_error&_TrioSocketMixin._convert_socket_errorp  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  r2   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itemsizer2   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  recvfromr3   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   rB   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   rC   rX   )rY   s   "rZ   r[   r  /  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.receive/  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   rC   rW   re   rX   )rY   s   "rZ   r[   r  7  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.send7  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# )	ConnectedUNIXDatagramSocketi?  c                    V ^8  d   QhRRRR/# rK  rX   )rY   s   "rZ   r[   (ConnectedUNIXDatagramSocket.__annotate__B  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__B  ry  r]   c                   V ^8  d   QhRR/# r  rX   )rY   s   "rZ   r[   r  G  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.receiveG  r  r  c                    V ^8  d   QhRRRR/# r   rX   )rY   s   "rZ   r[   r  N  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.sendN  r  r   r  r  r=  s   @rZ   r  r  ?  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# )r8   i[  c                   V ^8  d   QhRR/# )rR   rW   r8   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  _  s     ' '$ 'r]   c                	:    \         P                  ! 4       V n        R # r_   )rh   r8   _Event__originalrp   s   &rZ   rk   Event.__init___  s    **,r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  b       ( ( (r]   c                	6    V P                   P                  4       # r_   )r"  is_setrp   s   &rZ   r'  Event.is_setb      %%''r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  e  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.waite  s     __))++++r  c                   V ^8  d   QhRR/# )rR   rW   r(   rX   )rY   s   "rZ   r[   r  h  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.statisticsh  s%    //446_-J-JKKr]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  l  s      T r]   c                	:    V P                   P                  4        R # r_   )r"  setrp   s   &rZ   r6  	Event.setl  s    r]   r   N)r   r   r   r   ra   rk   r'  r  r0  r6  r   rX   r]   rZ   r8   r8   [  s&    #'(,L r]   r8   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# )r:   ip  fast_acquireFc                    V ^8  d   QhRRRR/# rR   r9  rz   rW   r:   rX   )rY   s   "rZ   r[   Lock.__annotate__q  s     # #d #t #r]   c               	,    \         P                  V 4      # r_   r`   rb   r9  s   &$rZ   ra   Lock.__new__q  r  r]   c                    V ^8  d   QhRRRR/# )rR   r9  rz   rW   re   rX   )rY   s   "rZ   r[   r<  t  s     & & & &r]   c               	F    Wn         \        P                  ! 4       V n        R # r_   )_fast_acquirerh   r:   _Lock__original)rj   r9  s   &$rZ   rk   Lock.__init__t  s    )))+r]   c                    V ^8  d   QhRRRR/# )rR   r   r   rW   re   rX   )rY   s   "rZ   r[   r<  y  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_msgx  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   r:   r:   p  sN    #U #&u & F F(("
 
r]   r:   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# )$r6   i  NrS   c               $    V ^8  d   QhRRRRRR/# )rR   total_tokensfloat | NonerS   trio.CapacityLimiter | NonerW   r6   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   r6   )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   r6   r6     s    # 15	# #
A 15	
A 
A2C , , - - / / 0 0)>(=)>
 
r]   r6   _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# )_SignalReceiveri2  zAsyncIterator[int]	_iteratorc                   V ^8  d   QhRR/# )rR   signalsztuple[Signals, ...]rX   )rY   s   "rZ   r[   _SignalReceiver.__annotate__5  s         3  r]   c                	    Wn         R # r_   )_signals)rj   r  s   &&rZ   rk   _SignalReceiver.__init__5  s    r]   c                   V ^8  d   QhRR/# rR   rW   r  rX   )rY   s   "rZ   r[   r  8  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__8  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  =  s2     < <,< &< %	<
 
<r]   c                	:    V P                   P                  WV4      # r_   )r  r}   r~   s   &&&&rZ   r}   _SignalReceiver.__exit__=  s     xx  F;;r]   c                   V ^8  d   QhRR/# r  rX   )rY   s   "rZ   r[   r  E  s      ? r]   c                	    V # r_   rX   rp   s   &rZ   	__aiter___SignalReceiver.__aiter__E  s    r]   c                   V ^8  d   QhRR/# )rR   rW   r   rX   )rY   s   "rZ   r[   r  H  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__H  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  2  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# )
TestRunneriR  c                    V ^8  d   QhRRRR/# )rR   optionsr   rW   re   rX   )rY   s   "rZ   r[   TestRunner.__annotate__S  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__S  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  Z  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__Z  sM     ##%##/  $$&( 0 r]   c                   V ^8  d   QhRR/# r   rX   )rY   s   "rZ   r[   r  e  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)r4   r  r  r   r  r   )rj   receive_streamcorooutcome_holderretvalr   s   &     rZ   _run_tests_and_fixtures"TestRunner._run_tests_and_fixturese  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  p  s     ! !6 !d !r]   c                	    R V n         R # r_   )r  )rj   r  s   &&rZ   _main_task_finishedTestRunner._main_task_finishedp  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  s  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_tasks  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  R  s1     	)	9!*0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_   r7   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  r9   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   r6   rX   )rY   s   "rZ   r[   r3    s     - -5 -_ -r]   c                	    \        V4      # r_   r5   )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   r6   )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  9  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   rE   rW   strrX   )rY   s   "rZ   r[   .TrioBackend.open_process.<locals>.__annotate__B  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_itemB  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_process8  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  b  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_shutdowna  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  f  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_tcpe  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  x  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_unixw  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   sockaddrrA   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   objrG   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   r1   with_traceback__traceback__r0   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   r1   r  r  r0   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   r6   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  LookupErrorr6   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  5  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_blocked4  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/  )      )__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   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/   r0   r1   r2   _core._socketsr3   _core._streamsr4   _core._synchronizationr6   BaseCapacityLimiterr8   	BaseEventr:   BaseLockr;   r<   r>   BaseSemaphore_core._tasksr@   BaseCancelScoperA   rB   rC   abc._eventlooprD   rE   streams.memoryrF   	_typeshedrG   version_inforH   rI   exceptiongrouprJ   typing_extensionsrK   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)r9  s   @rZ   <module>r^     sI   " "   	  
  	 	 	 . !    , 
 
 
   ) )  5 #   3  3 8 8 5 @ 9 G G 9 3,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 @U7 U7p8 $@%, @%F r]   