+
    ~j  c                  P  a  0 t $ ^ RIHt ^ RIt^ RIHu 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/t0^ RI1t0^ RI2H3t3H4t4H5t5 ^ RI1H6t6H7t7H8t8H9t9H:t: ^ RI;H<t= ^ RI>H?t? ^RI@HAtAHBtBHCtCHDtDHEtEHFtFHGtG ^RIHHItI ^RIJHKtKHLtLHMtMHNtN ^RIOHPtP ^RIQHRtR ^RISHTtU ^RISHVtW ^RISHXtY ^RISHZtZH[t[ ^RISH\t] ^RI^H_t` ^RIGHataHbtbHctc ^RIdHeteHftf ^RIgHhth ]''       d   ^ RIiHjtj ]P                  R[8  d
   ^ RI%HltlHmtm M^ R InHoto ^ RIpHltlHmtm ],! R!4      tq],! R"4      tr],! R#]s]a4      tt]l! R$4      tu]+! R%4      tv]0P                  P                  tx ! R& R']`4      t_ ! R( R)]GP                  4      ty]! R*R+7       ! R, R-]GP                  4      4       t{]! R*R+7       ! R. R/]GP                  4      4       t}]! R*R+7       ! R0 R1]GP                  4      4       t~ ! R2 R3]0P                  P                  4      t]x! R44      tR5]R4&   R6 R7 lt ! R8 R9])]t,          4      t ! R: R;]]GEP
                  4      t ! R< R=]]GEP                  4      t ! R> R?]]GEP                  4      t ! R@ RA]]GEP                  4      t ! RB RC]]a,          ]GEP                  4      t ! RD RE]]a,          ]GEP                  4      t ! RF RG]]s,          ]GEP                  4      t ! RH RI]]s,          ]GEP                  4      t ! RJ RK]W4      tV ! RL RM]Y4      tX ! RN RO]]4      t\ ! RP RQ]U4      tT]x! RR4      tR5]RR&    ! RS RT4      t ! RU RV]GEP                   4      t ! RW RX]E4      t ! RY RZ]e4      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   "j/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anyio/_backends/_trio.py__annotate__CancelScope.__annotate__r   s$     # #.#AG#	#    c                	,    \         P                  V 4      # NrU   __new__)clsrR   rT   s   &&,rY   r`   CancelScope.__new__r   s     ~~c""r\   c               $    V ^8  d   QhRRRRRR/# )rQ   rR   rS   rT   r   rV   NonerW   )rX   s   "rY   rZ   r[   w   s(     A A!8 A3 ASW Ar\   c                	P    T;'       g    \         P                  ! R/ VB V n        R # NrW   )trior?   _CancelScope__original)selfrR   rT   s   &&,rY   __init__CancelScope.__init__w   s    "@@d&6&6&@&@r\   c                   V ^8  d   QhRR/# )rQ   rV   r?   rW   )rX   s   "rY   rZ   r[   z   s      ; r\   c                	:    V P                   P                  4        V # r^   )rh   	__enter__ri   s   &rY   rn   CancelScope.__enter__z   s    !!#r\   c               (    V ^8  d   QhRRRRRRRR/# 	rQ   exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NonerV   boolrW   )rX   s   "rY   rZ   r[   ~   8     C C,C &C %	C
 
Cr\   c                	:    V P                   P                  WV4      # r^   )rh   __exit__ri   rs   ru   rw   s   &&&&rY   r|   CancelScope.__exit__~   s     ''6BBr\   c                    V ^8  d   QhRRRR/# )rQ   reasonz
str | NonerV   rd   rW   )rX   s   "rY   rZ   r[      s     ' 'Z '4 'r\   c                	<    V P                   P                  V4       R # r^   )rh   cancel)ri   r   s   &&rY   r   CancelScope.cancel   s    v&r\   c                   V ^8  d   QhRR/# rQ   rV   floatrW   )rX   s   "rY   rZ   r[      s     ( (% (r\   c                	.    V P                   P                  # r^   rh   deadlinero   s   &rY   r   CancelScope.deadline   s    '''r\   c                    V ^8  d   QhRRRR/# rQ   valuer   rV   rd   rW   )rX   s   "rY   rZ   r[      s     ) )e ) )r\   c                	&    WP                   n        R # r^   r   ri   r   s   &&rY   r   r      s    #( r\   c                   V ^8  d   QhRR/# rQ   rV   ry   rW   )rX   s   "rY   rZ   r[      s     - -t -r\   c                	.    V P                   P                  # r^   )rh   cancel_calledro   s   &rY   r   CancelScope.cancel_called   s    ,,,r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r[      s     0 0$ 0r\   c                	.    V P                   P                  # r^   )rh   cancelled_caughtro   s   &rY   r   CancelScope.cancelled_caught       ///r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r[      s     & & &r\   c                	.    V P                   P                  # r^   rh   shieldro   s   &rY   r   CancelScope.shield   s    %%%r\   c                    V ^8  d   QhRRRR/# )rQ   r   ry   rV   rd   rW   )rX   s   "rY   rZ   r[      s     ' 'D 'T 'r\   c                	&    WP                   n        R # r^   r   r   s   &&rY   r   r      s    !&r\   
__originalr^   )__name__
__module____qualname____firstlineno__r`   rj   rn   r|   r   propertyr   setterr   r   r   __static_attributes__rW   r\   rY   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/# rQ   rV   rd   rW   )rX   s   "rY   rZ   TaskGroup.__annotate__   s     ! !$ !r\   c                	Z    R V n         \        P                  ! RR7      V n        RV n        R# )FT)strict_exception_groupsN)_activerg   open_nursery_nursery_managercancel_scopero   s   &rY   rj   TaskGroup.__init__   s$     $ 1 1$ O r\   c                   V ^8  d   QhRR/# )rQ   rV   r   rW   )rX   s   "rY   rZ   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   ro   s   &rY   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/# rr   rW   )rX   s   "rY   rZ   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   rI   splitrg   	Cancelled_create)ri   rs   ru   rw   excs   &&&& rY   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/# )	rQ   funcz,Callable[[Unpack[PosArgsT]], Awaitable[Any]]argszUnpack[PosArgsT]r   rU   rV   rd   rW   )rX   s   "rY   rZ   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ri   r   r   r   s   &&$*rY   r   TaskGroup.start_soon   s;     |||M  	  8848r\   c               (    V ^8  d   QhRRRRRRRR/# )rQ   r   zCallable[..., Awaitable[Any]]r   rU   r   rV   r   rW   )rX   s   "rY   rZ   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   &&$*rY   r   TaskGroup.start   sG      |||M  ]]((@@4@@@@s   AA
AA
)r   r   r   r   )
r   r   r   r   rj   r   r   r   r   r   rW   r\   rY   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/# )rQ   	max_bytes
int | NonerV   bytesrW   )rX   s   "rY   rZ   !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_somerg   r0   	__cause__r.   r   r1   ri   r   datar   s   &&  rY   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   rW   )rX   s   "rY   rZ   r           $ $d $r\   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5ir^   r   aclosero   s   &rY   r   ReceiveStreamWrapper.aclose        ll!!###   )')rW   r^   )r   r   r   r   __annotations__r   r   r   rW   r\   rY   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/# rQ   itemr   rV   rd   rW   )rX   s   "rY   rZ   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_allrg   r0   r   r.   ri   r   r   s   && rY   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   rW   )rX   s   "rY   rZ   r     r   r\   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5ir^   r   ro   s   &rY   r   SendStreamWrapper.aclose  r   r   rW   N)r   r   r   r   r   r   r   r   rW   r\   rY   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   rW   )rX   s   "rY   rZ   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killro   s   &rY   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/# rQ   rV   intrW   )rX   s   "rY   rZ   r    s     * *C *r\   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir^   )r   r  ro   s   &rY   r  Process.wait  s     ]]''))))   '%'c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r  "  s     " "4 "r\   c                	:    V P                   P                  4        R # r^   )r   	terminatero   s   &rY   r  Process.terminate"  s    !r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r  %  s      d r\   c                	:    V P                   P                  4        R # r^   )r   r  ro   s   &rY   r  Process.kill%  s    r\   c                    V ^8  d   QhRRRR/# )rQ   signalr   rV   rd   rW   )rX   s   "rY   rZ   r  (  s     * *' *d *r\   c                	<    V P                   P                  V4       R # r^   )r   send_signal)ri   r  s   &&rY   r  Process.send_signal(  s    !!&)r\   c                   V ^8  d   QhRR/# r	  rW   )rX   s   "rY   rZ   r  ,  s     ! !S !r\   c                	.    V P                   P                  # r^   )r   pidro   s   &rY   r  Process.pid+  s    }}   r\   c                   V ^8  d   QhRR/# rQ   rV   r   rW   )rX   s   "rY   rZ   r  0  s     ( (J (r\   c                	.    V P                   P                  # r^   )r   
returncodero   s   &rY   r!  Process.returncode/  s    }}'''r\   c                   V ^8  d   QhRR/# )rQ   rV   r   rW   )rX   s   "rY   rZ   r  4  s      0 r\   c                	    V P                   # r^   )r   ro   s   &rY   stdinProcess.stdin3  s    {{r\   c                   V ^8  d   QhRR/# rQ   rV   r   rW   )rX   s   "rY   rZ   r  8        4 r\   c                	    V P                   # r^   )r   ro   s   &rY   stdoutProcess.stdout7      ||r\   c                   V ^8  d   QhRR/# r(  rW   )rX   s   "rY   rZ   r  <  r)  r\   c                	    V P                   # r^   )r   ro   s   &rY   stderrProcess.stderr;  r-  r\   rW   N)r   r   r   r   r   r   r  r  r  r  r   r  r!  r%  r+  r0  r   rW   r\   rY   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   rW   )rX   s   "rY   rZ   +_ProcessPoolShutdownInstrument.__annotate__A  s      4 r\   c                	$   < \         SV `  4        R # r^   )super	after_run)ri   	__class__s   &rY   r8  (_ProcessPoolShutdownInstrument.after_runA  s    r\   rW   )r   r   r   r   r8  r   __classcell__r9  s   @rY   r3  r3  @  s     r\   r3  &current_default_worker_process_limiterztrio.lowlevel.RunVarc                    V ^8  d   QhRRRR/# rQ   workerszset[abc.Process]rV   rd   rW   )rX   s   "rY   rZ   rZ   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  )	rg   sleepmathinfr   r!  r  r?   r   )r@  processs   & rY   _shutdown_process_poolrF  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/# rQ   trio_socketTrioSocketTyperV   rd   rW   )rX   s   "rY   rZ   _TrioSocketMixin.__annotate__]  s      N t r\   c                	     Wn         R V n        R# FN)_trio_socket_closed)ri   rK  s   &&rY   rj   _TrioSocketMixin.__init__]  s    'r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rM  a  s     & &t &r\   c                	    V P                   '       d   \        hV P                  P                  4       ^ 8  d   \        hR# r   N)rQ  r0   rP  filenor.   ro   s   &rY   _check_closed_TrioSocketMixin._check_closeda  s3    <<<%%##%)%% *r\   c                   V ^8  d   QhRR/# )rQ   rV   socket.socketrW   )rX   s   "rY   rZ   rM  h  s     ' '] 'r\   c                	.    V P                   P                  # r^   )rP  _sockro   s   &rY   _raw_socket_TrioSocketMixin._raw_socketg  s      &&&r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rM  k  s     & &d &r\   c                	   "   V P                   P                  4       ^ 8  d$   RV n        V P                   P                  4        R# R# 5i)r   TN)rP  rV  rQ  closero   s   &rY   r   _TrioSocketMixin.aclosek  s:     ##%*DL##% +s   AAc                    V ^8  d   QhRRRR/# )rQ   r   r  rV   r   rW   )rX   s   "rY   rZ   rM  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rU  )
isinstancerg   r0   rP  rV  rQ  OSErrorr.   ri   r   s   &&rY   _convert_socket_error&_TrioSocketMixin._convert_socket_errorp  s^    c43344%3.%%'!+%4/W%%%3.Ir\   )rQ  rP  N)r   r   r   r   rj   rW  r   r]  r   rh  r   rW   r\   rY   rH  rH  \  s/    & ' '&
 r\   rH  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/# rJ  rW   )rX   s   "rY   rZ   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r7  rj   r:   _receive_guard_send_guardri   rK  r9  s   &&rY   rj   SocketStream.__init__|  *    %+N;(6r\   c                    V ^8  d   QhRRRR/# )rQ   r   r
  rV   r   rW   )rX   s   "rY   rZ   rm    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^   )rt  rP  recvr  rh  r1   r   s   &&  rY   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   rW   )rX   s   "rY   rZ   rm    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^   )ru  
memoryviewrP  r   r  rh  )ri   r   view
bytes_sentr   s   &&   rY   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   rW   )rX   s   "rY   rZ   rm    s     3 3 3r\   c                	`   "   V P                   P                  \        P                  4       R # 5ir^   )rP  shutdownsocketSHUT_WRro   s   &rY   send_eofSocketStream.send_eof  s     ""6>>2s   ,.rt  ru  )   )
r   r   r   r   rj   r   r   r  r   r;  r<  s   @rY   rk  rk  {  s!    7 7

"	)3 3r\   rk  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/# )rQ   msglenr
  maxfdsrV   ztuple[bytes, list[int]]rW   )rX   s   "rY   rZ   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 = )re  r
  
ValueErrorarrayrg   lowlevel
checkpointrt  rP  recvmsgr  CMSG_LENitemsizer1   r  rh  
SOL_SOCKET
SCM_RIGHTSr   	frombyteslenlist)ri   r  r  fdsmessageancdataflagsaddrr   
cmsg_level	cmsg_type	cmsg_datas   &&&         rY   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/# )rQ   r  r   r  zCollection[int | IOBase]rV   rd   rW   )rX   s   "rY   rZ   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  re  r
  appendr   rV  r  rg   r  r  ru  rP  sendmsgr  r  r  r  rh  )ri   r  r  filenosfdfdarrayr   s   &&&    rY   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:rW   N)r   r   r   r   r  r  r   rW   r\   rY   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/# rQ   
raw_socketrZ  rW   )rX   s   "rY   rZ   TCPSocketListener.__annotate__       I I= Ir\   c                	   < \         SV `  \        P                  P	                  V4      4       \        R 4      V n        R# zaccepting connections fromNr7  rj   rg   r  from_stdlib_socketr:   _accept_guardri   r  r9  s   &&rY   rj   TCPSocketListener.__init__  -    77
CD*+GHr\   c                   V ^8  d   QhRR/# )rQ   rV   rk  rW   )rX   s   "rY   rZ   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  rP  acceptr  rh  
setsockoptr  IPPROTO_TCPTCP_NODELAYrk  ri   rK  _addrr   s   &   rY   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   rj   r  r   r;  r<  s   @rY   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  rW   )rX   s   "rY   rZ   UNIXSocketListener.__annotate__  r  r\   c                	   < \         SV `  \        P                  P	                  V4      4       \        R 4      V n        R# r  r  r  s   &&rY   rj   UNIXSocketListener.__init__  r  r\   c                   V ^8  d   QhRR/# )rQ   rV   r  rW   )rX   s   "rY   rZ   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  rP  r  r  rh  r  r  s   &   rY   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   @rY   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/# rJ  rW   )rX   s   "rY   rZ   UDPSocket.__annotate__  rn  r\   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rp  rs  rv  s   &&rY   rj   UDPSocket.__init__  rx  r\   c                   V ^8  d   QhRR/# )rQ   rV   ztuple[bytes, IPSockAddrType]rW   )rX   s   "rY   rZ   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)rt  rP  recvfromr2   r  rh  ri   r   r  r   s   &   rY   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/# )rQ   r   rA   rV   rd   rW   )rX   s   "rY   rZ   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^   ru  rP  sendtor  rh  r   s   && rY   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   rj   r   r   r   r;  r<  s   @rY   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/# rJ  rW   )rX   s   "rY   rZ   ConnectedUDPSocket.__annotate__  rn  r\   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rp  rs  rv  s   &&rY   rj   ConnectedUDPSocket.__init__  rx  r\   c                   V ^8  d   QhRR/# rQ   rV   r   rW   )rX   s   "rY   rZ   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  rt  rP  r{  r  rh  rg  s   & rY   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   rW   )rX   s   "rY   rZ   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^   ru  rP  r   r  rh  r   s   && rY   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   @rY   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/# rJ  rW   )rX   s   "rY   rZ   UNIXDatagramSocket.__annotate__*  rn  r\   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rp  rs  rv  s   &&rY   rj   UNIXDatagramSocket.__init__*  rx  r\   c                   V ^8  d   QhRR/# )rQ   rV   rB   rW   )rX   s   "rY   rZ   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  )rt  rP  r  r  rh  r  s   &   rY   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/# )rQ   r   rB   rV   rd   rW   )rX   s   "rY   rZ   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   && rY   r   UNIXDatagramSocket.send7  r  r  r  r  r<  s   @rY   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/# rJ  rW   )rX   s   "rY   rZ   (ConnectedUNIXDatagramSocket.__annotate__B  rn  r\   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# rp  rs  rv  s   &&rY   rj   $ConnectedUNIXDatagramSocket.__init__B  rx  r\   c                   V ^8  d   QhRR/# r  rW   )rX   s   "rY   rZ   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  rg  s   & rY   r   #ConnectedUNIXDatagramSocket.receiveG  r  r  c                    V ^8  d   QhRRRR/# r   rW   )rX   s   "rY   rZ   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   && rY   r    ConnectedUNIXDatagramSocket.sendN  r  r  r  r  r<  s   @rY   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# )r7   i[  c                   V ^8  d   QhRR/# )rQ   rV   r7   rW   )rX   s   "rY   rZ   Event.__annotate__\  s     # # #r\   c                	,    \         P                  V 4      # r^   r_   ra   s   &rY   r`   Event.__new__\      ~~c""r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r  _  s     ' '$ 'r\   c                	:    \         P                  ! 4       V n        R # r^   )rg   r7   _Event__originalro   s   &rY   rj   Event.__init___  s    **,r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r  b       ( ( (r\   c                	6    V P                   P                  4       # r^   )r!  is_setro   s   &rY   r&  Event.is_setb      %%''r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r  e  s     , ,D ,r\   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir^   )r!  r  ro   s   &rY   r  
Event.waite  s     __))++++r  c                   V ^8  d   QhRR/# )rQ   rV   r'   rW   )rX   s   "rY   rZ   r  h  s     L LO Lr\   c                	b    V P                   P                  4       p\        VP                  R 7      # ))tasks_waiting)r!  
statisticsr'   r.  ri   orig_statisticss   & rY   r/  Event.statisticsh  s%    //446_-J-JKKr\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r  l  s      T r\   c                	:    V P                   P                  4        R # r^   )r!  setro   s   &rY   r5  	Event.setl  s    r\   r   N)r   r   r   r   r`   rj   r&  r  r/  r5  r   rW   r\   rY   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   ip  fast_acquireFc                    V ^8  d   QhRRRR/# rQ   r8  ry   rV   r9   rW   )rX   s   "rY   rZ   Lock.__annotate__q  s     # #d #t #r\   c               	,    \         P                  V 4      # r^   r_   ra   r8  s   &$rY   r`   Lock.__new__q  r  r\   c                    V ^8  d   QhRRRR/# )rQ   r8  ry   rV   rd   rW   )rX   s   "rY   rZ   r;  t  s     & & & &r\   c               	F    Wn         \        P                  ! 4       V n        R # r^   )_fast_acquirerg   r9   _Lock__original)ri   r8  s   &$rY   rj   Lock.__init__t  s    )))+r\   c                    V ^8  d   QhRRRR/# )rQ   r   r   rV   rd   rW   )rX   s   "rY   rZ   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)rF  )z)Attempted to acquire an already held Lock)r   )r   s   &rY   _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   rW   )rX   s   "rY   rZ   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^   )rA  rB  acquirer   rG  rg   r  checkpoint_if_cancelledacquire_nowaitr+   _lotparkrg  s   & rY   rK  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   rW   )rX   s   "rY   rZ   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^   )rB  rM  rg   r+   r   rG  rg  s   & rY   rM  Lock.acquire_nowait  sL    	OO**, 	'$& 	++C0	s    $AAAAc                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r;    r$  r\   c                	6    V P                   P                  4       # r^   )rB  lockedro   s   &rY   rV  Lock.locked  r(  r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r;         " " "r\   c                	:    V P                   P                  4        R # r^   )rB  releasero   s   &rY   r[  Lock.release      !r\   c                   V ^8  d   QhRR/# )rQ   rV   r(   rW   )rX   s   "rY   rZ   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^   )rB  r/  ownerTrioTaskInfor(   rV  r.  )ri   r1  r`  s   &  rY   r/  Lock.statistics  sP    //4467F7L7L7L_223RV""E+H+H
 	
r\   )r   rA  N)r   r   r   r   r`   rj   staticmethodrG  rK  rM  rV  r[  r/  r   rW   r\   rY   r9   r9   p  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_valueNr8  Fc               (    V ^8  d   QhRRRRRRRR/# )	rQ   initial_valuer
  re  r   r8  ry   rV   r=   rW   )rX   s   "rY   rZ   Semaphore.__annotate__  s2     # ## 	#
 # 
#r\   c               	,    \         P                  V 4      # r^   r_   ra   rg  re  r8  s   &&$$rY   r`   Semaphore.__new__  s     ~~c""r\   c               (    V ^8  d   QhRRRRRRRR/# )	rQ   rg  r
  re  r   r8  ry   rV   rd   rW   )rX   s   "rY   rZ   rh    s8     M MM 	M
 M 
Mr\   c               	b   < \         SV `  WVR 7       \        P                  ! WR7      V n        R# )re  r8  )re  N)r7  rj   rg   r=   _Semaphore__original)ri   rg  re  r8  r9  s   &&$$rY   rj   Semaphore.__init__  s'     	,W..Lr\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rh    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^   )
rA  ro  rK  rg   r  rL  rM  r+   rN  rO  ro   s   &rY   rK  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   rW   )rX   s   "rY   rZ   rh    s     ' ' 'r\   c                	|     V P                   P                  4        R #   \        P                   d	    \        R hi ; ir^   )ro  rM  rg   r+   ro   s   &rY   rM  Semaphore.acquire_nowait  s2    	'OO**, 	'$&	's    ;c                   V ^8  d   QhRR/# r  rW   )rX   s   "rY   rZ   rh    s     ) ): )r\   c                	.    V P                   P                  # r^   )ro  re  ro   s   &rY   re  Semaphore.max_value  s    (((r\   c                   V ^8  d   QhRR/# r	  rW   )rX   s   "rY   rZ   rh    s     % %s %r\   c                	.    V P                   P                  # r^   )ro  r   ro   s   &rY   r   Semaphore.value  s    $$$r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rh    rY  r\   c                	:    V P                   P                  4        R # r^   )ro  r[  ro   s   &rY   r[  Semaphore.release  r]  r\   c                   V ^8  d   QhRR/# )rQ   rV   r;   rW   )rX   s   "rY   rZ   rh    s     B B/ Br\   c                	`    V P                   P                  4       p\        VP                  4      # r^   )ro  r/  r;   r.  r0  s   & rY   r/  Semaphore.statistics  s%    //446"?#@#@AAr\   r   )r   r   r   r   r`   rj   rK  rM  r   re  r   r[  r/  r   r;  r<  s   @rY   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  NrR   c               $    V ^8  d   QhRRRRRR/# )rQ   total_tokensfloat | NonerR   trio.CapacityLimiter | NonerV   r5   rW   )rX   s   "rY   rZ   CapacityLimiter.__annotate__  s(     # #"# .	#
 
#r\   c               	,    \         P                  V 4      # r^   r_   )ra   r  rR   s   &&$rY   r`   CapacityLimiter.__new__  s     ~~c""r\   c               $    V ^8  d   QhRRRRRR/# )rQ   r  r  rR   r  rV   rd   rW   )rX   s   "rY   rZ   r    s-     
A 
A"
A .	
A
 

Ar\   c               	   Ve	   W n         R # R q1VJqD'       g   \        P                  ! RV3RW34      RR\        P                  ! 4       9   g   \        P
                  ! V4      '       d   \        P                  ! V4      MRR\        P                  ! V4      /,          pRRV/,          p\        \        P                  ! V4      4      hR ;rC\        P                  ! V4      V n         R # )Npy0r  py3zassert %(py5)spy5)is not)z%(py0)s is not %(py3)s)_CapacityLimiter__original
@pytest_ar_call_reprcompare@py_builtinslocals_should_repr_global_name	_safereprAssertionError_format_explanationrg   r5   )ri   r  rR   @py_assert2@py_assert1@py_format4@py_format6s   &&$    rY   rj   CapacityLimiter.__init__  s     &O'++t+++++<++++++<++++<+++t++++++++"22<@DOr\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r    s     2 2$ 2r\   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir^   )r  r   ro   s   &rY   r   CapacityLimiter.__aenter__  s     __//1111r  c               (    V ^8  d   QhRRRRRRRR/# )	rQ   rs   rt   ru   rv   rw   rx   rV   rd   rW   )rX   s   "rY   rZ   r    rz   r\   c                	Z   "   V P                   P                  WV4      G R j  xL
  R #  L5ir^   )r  r   r}   s   &&&&rY   r   CapacityLimiter.__aexit__  s!      oo''6BBBs    +)+c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r    s     , ,e ,r\   c                	.    V P                   P                  # r^   r  r  ro   s   &rY   r  CapacityLimiter.total_tokens  s    +++r\   c                    V ^8  d   QhRRRR/# r   rW   )rX   s   "rY   rZ   r    s     - -% -D -r\   c                	&    WP                   n        R # r^   r  r   s   &&rY   r  r    s    ',$r\   c                   V ^8  d   QhRR/# r	  rW   )rX   s   "rY   rZ   r    s     / / /r\   c                	.    V P                   P                  # r^   )r  borrowed_tokensro   s   &rY   r  CapacityLimiter.borrowed_tokens  s    ...r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r    s     0 0% 0r\   c                	.    V P                   P                  # r^   )r  available_tokensro   s   &rY   r   CapacityLimiter.available_tokens
  r   r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r    s     ) ) )r\   c                	:    V P                   P                  4        R # r^   )r  rM  ro   s   &rY   rM  CapacityLimiter.acquire_nowait  s    &&(r\   c                    V ^8  d   QhRRRR/# rQ   borrowerrU   rV   rd   rW   )rX   s   "rY   rZ   r    s     > >F >t >r\   c                	<    V P                   P                  V4       R # r^   )r  acquire_on_behalf_of_nowaitri   r  s   &&rY   r  +CapacityLimiter.acquire_on_behalf_of_nowait  s    33H=r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r    s     ( (t (r\   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5ir^   )r  rK  ro   s   &rY   rK  CapacityLimiter.acquire  s     oo%%'''r   c                    V ^8  d   QhRRRR/# r  rW   )rX   s   "rY   rZ   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   &&rY   r  $CapacityLimiter.acquire_on_behalf_of  s     oo228<<<s   *(*c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   r    s     ) ) )r\   c                	6    V P                   P                  4       # r^   )r  r[  ro   s   &rY   r[  CapacityLimiter.release  s    &&((r\   c                    V ^8  d   QhRRRR/# r  rW   )rX   s   "rY   rZ   r    s     > >V > >r\   c                	8    V P                   P                  V4      # r^   )r  release_on_behalf_ofr  s   &&rY   r  $CapacityLimiter.release_on_behalf_of  s    33H==r\   c                   V ^8  d   QhRR/# )rQ   rV   r&   rW   )rX   s   "rY   rZ   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  r/  r&   r  r  tupler  r.  )ri   origs   & rY   r/  CapacityLimiter.statistics   sH    ))+( 00**DNN+,,	
 	
r\   r   r^   )r   r   r   r   r`   rj   r   r   r   r  r   r  r  rM  r  rK  r  r[  r  r/  r   rW   r\   rY   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# )_SignalReceiveri2  zAsyncIterator[int]	_iteratorc                   V ^8  d   QhRR/# )rQ   signalsztuple[Signals, ...]rW   )rX   s   "rY   rZ   _SignalReceiver.__annotate__5  s         3  r\   c                	    Wn         R # r^   )_signals)ri   r  s   &&rY   rj   _SignalReceiver.__init__5  s    r\   c                   V ^8  d   QhRR/# rQ   rV   r  rW   )rX   s   "rY   rZ   r  8  s      ? r\   c                	    \         P                  ! V P                  !  V n        V P                  P	                  4       V n        V # r^   )rg   open_signal_receiverr  _cmrn   r  ro   s   &rY   rn   _SignalReceiver.__enter__8  s1    ,,dmm<++-r\   c               (    V ^8  d   QhRRRRRRRR/# )	rQ   rs   rt   ru   rv   rw   rx   rV   zbool | NonerW   )rX   s   "rY   rZ   r  =  s2     < <,< &< %	<
 
<r\   c                	:    V P                   P                  WV4      # r^   )r  r|   r}   s   &&&&rY   r|   _SignalReceiver.__exit__=  s     xx  F;;r\   c                   V ^8  d   QhRR/# r  rW   )rX   s   "rY   rZ   r  E  s      ? r\   c                	    V # r^   rW   ro   s   &rY   	__aiter___SignalReceiver.__aiter__E  s    r\   c                   V ^8  d   QhRR/# )rQ   rV   r   rW   )rX   s   "rY   rZ   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   )ri   signums   & rY   r  _SignalReceiver.__anext__H  s)     ~~//11v 2s   202)r  r  r  N)r   r   r   r   r   rj   rn   r|   r  r  r   rW   r\   rY   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/# )rQ   optionsr   rV   rd   rW   )rX   s   "rY   rZ   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)ri   r  r  s   &, rY   rj   TestRunner.__init__S  s    8=;?r\   c               (    V ^8  d   QhRRRRRRRR/# )	rQ   rs   rt   ru   rv   rw   ztypes.TracebackType | NonerV   rd   rW   )rX   s   "rY   rZ   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  ra  r  getr}   s   &&&&rY   r|   TestRunner.__exit__Z  sM     ##%##/  $$&( 0 r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   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)r3   r  r  r   r  r   )ri   receive_streamcorooutcome_holderretvalr   s   &     rY   _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/# )rQ   outcomerU   rV   rd   rW   )rX   s   "rY   rZ   r  p  s     ! !6 !d !r\   c                	    R V n         R # r^   )r  )ri   r  s   &&rY   _main_task_finishedTestRunner._main_task_finishedp  s
     r\   c               (    V ^8  d   QhRRRRRRRR/# )	rQ   r   z Callable[P, Awaitable[T_Retval]]r   zP.argsrT   zP.kwargsrV   rK   rW   )rX   s   "rY   rZ   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  rg   r  start_guest_runr  r  putr	  r  r  send_nowaitunwrap)ri   r   r   rT   r  s   ""*, rY   _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/# )rQ   fixture_funcz,Callable[..., AsyncGenerator[T_Retval, Any]]rT   dict[str, Any]rV   zIterable[T_Retval]rW   )rX   s   "rY   rZ   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 stoprW   )r  asendr   r   StopAsyncIteration)ri   r  rT   asyncgenfixturevalues   &&&  rY   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/# )rQ   r  z,Callable[..., Coroutine[Any, Any, T_Retval]]rT   r  rV   rK   rW   )rX   s   "rY   rZ   r    s-     A ABA A 
	Ar\   c                	(    V P                   ! V3/ VB # r^   r  )ri   r  rT   s   &&&rY   run_fixtureTestRunner.run_fixture  s    
 ((@@@r\   c               $    V ^8  d   QhRRRRRR/# )rQ   	test_funcz'Callable[..., Coroutine[Any, Any, Any]]rT   r  rV   rd   rW   )rX   s   "rY   rZ   r    s$     7 7@7JX7	7r\   c                	,    V P                   ! V3/ VB  R # r^   r!  )ri   r%  rT   s   &&&rY   run_testTestRunner.run_test  s     	!!)6v6r\   )r  r  r  N)r   r   r   r   rj   r|   r  r	  r  r  r"  r'  r   rW   r\   rY   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# )ra  i  c                   V ^8  d   QhRR/# )rQ   taskztrio.lowlevel.TaskrW   )rX   s   "rY   rZ   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idr7  rj   r   r  weakrefproxy_task)ri   r+  	parent_idr9  s   && rY   rj   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   rW   )rX   s   "rY   rZ   r,    s      $ r\   c                	h     V P                   P                  P                  #   \         d     R # i ; i)F)r3  _cancel_statuseffectively_cancelledReferenceErrorro   s   &rY   has_pending_cancellation%TrioTaskInfo.has_pending_cancellation  s1    	::,,BBB 	 	s   " 11)r3  )r   r   r   r   rj   r;  r   r;  r<  s   @rY   ra  ra    s    ) ) r\   ra  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	/# )
rQ   r   1Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]]r   tuple[Unpack[PosArgsT]]rT   r  r  rV   rK   rW   )rX   s   "rY   rZ   TrioBackend.__annotate__  s<     % %?% &% 	%
  % 
%r\   c                	2    \         P                  ! V.VO5!  # r^   )rg   run)ra   r   r   rT   r  s   &&&&&rY   rD  TrioBackend.run  s     xx$t$$r\   c                   V ^8  d   QhRR/# )rQ   rV   rU   rW   )rX   s   "rY   rZ   rB    s     2 2f 2r\   c                	>    \         P                  P                  4       # r^   )rg   r  current_trio_tokenr  s   &rY   current_tokenTrioBackend.current_token  s    }}//11r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rB    s     # #U #r\   c                	,    \         P                  ! 4       # r^   )rg   current_timer  s   &rY   rM  TrioBackend.current_time  s      ""r\   c                   V ^8  d   QhRR/# )rQ   rV   ztype[BaseException]rW   )rX   s   "rY   rZ   rB    s      *= r\   c                	"    \         P                  # r^   )rg   r   r  s   &rY   cancelled_exception_class%TrioBackend.cancelled_exception_class  s    ~~r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rB    s     ) ) )r\   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5ir^   )rg   r  r  r  s   &rY   r  TrioBackend.checkpoint  s     mm&&(((   "-+-c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rB    s     6 6d 6r\   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5ir^   )rg   r  rL  r  s   &rY   rL  #TrioBackend.checkpoint_if_cancelled  s     mm33555rV  c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rB    s     9 9 9r\   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5ir^   )rg   r  cancel_shielded_checkpointr  s   &rY   r\  &TrioBackend.cancel_shielded_checkpoint  s     mm66888rV  c                    V ^8  d   QhRRRR/# )rQ   delayr   rV   rd   rW   )rX   s   "rY   rZ   rB    s          $  r\   c                	N   "   \         P                  ! V4      G R j  xL
  R #  L5ir^   )rg   rB  )ra   r_  s   &&rY   rB  TrioBackend.sleep  s     jjs   %#%r   r   Fc               $    V ^8  d   QhRRRRRR/# )rQ   r   r   r   ry   rV   zabc.CancelScoperW   )rX   s   "rY   rZ   rB    s$     = ==48=	=r\   c               	    \        WR 7      # ))r   r   r>   )ra   r   r   s   &$$rY   create_cancel_scopeTrioBackend.create_cancel_scope  s     H<<r\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rB    s     1 15 1r\   c                	,    \         P                  ! 4       # r^   )rg   current_effective_deadliner  s   &rY   rh  &TrioBackend.current_effective_deadline  s    ..00r\   c                   V ^8  d   QhRR/# )rQ   rV   zabc.TaskGrouprW   )rX   s   "rY   rZ   rB    s      - r\   c                	    \        4       # r^   )r   r  s   &rY   create_task_groupTrioBackend.create_task_group  s
    {r\   c                   V ^8  d   QhRR/# )rQ   rV   z	abc.EventrW   )rX   s   "rY   rZ   rB    s      Y r\   c                	    \        4       # r^   r6   r  s   &rY   create_eventTrioBackend.create_event  s	    wr\   c                    V ^8  d   QhRRRR/# r:  rW   )rX   s   "rY   rZ   rB    s     / /$ /4 /r\   c               	    \        VR 7      # ))r8  r8   r=  s   &$rY   create_lockTrioBackend.create_lock  s    ..r\   re  Nr8  c               (    V ^8  d   QhRRRRRRRR/# )	rQ   rg  r
  re  r   r8  ry   rV   zabc.SemaphorerW   )rX   s   "rY   rZ   rB    s8     X XX 	X
 X 
Xr\   c               	    \        WVR 7      # )rn  r<   rj  s   &&$$rY   create_semaphoreTrioBackend.create_semaphore  s     ,WWr\   c                    V ^8  d   QhRRRR/# )rQ   r  r   rV   r5   rW   )rX   s   "rY   rZ   rB    s     - -5 -_ -r\   c                	    \        V4      # r^   r4   )ra   r  s   &&rY   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
/# )rQ   r   &Callable[[Unpack[PosArgsT]], T_Retval]r   rA  abandon_on_cancelry   limiterzabc.CapacityLimiter | NonerV   rK   rW   )rX   s   "rY   rZ   rB    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/# )rQ   rV   rK   rW   )rX   s   "rY   rZ   ;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   rY   wrapper6TrioBackend.run_sync_in_worker_thread.<locals>.wrapper  s&    $[%88T{ 9888s   +<	)r  r  N)r>  rI  r%   r   rg   r5   )ra   r   r   r  r  r  r  s   &ff&& @rY   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   rW   )rX   s   "rY   rZ   rB    s     + + +r\   c                	B    \         P                  P                  4        R # r^   )rg   from_threadcheck_cancelledr  s   &rY   r  TrioBackend.check_cancelled  s    ((*r\   c               (    V ^8  d   QhRRRRRRRR/# )	rQ   r   r@  r   rA  r  rU   rV   rK   rW   )rX   s   "rY   rZ   rB    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   rg   r  rD  r)   ra   r   r   r  r  s   &&&& rY   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/# )	rQ   r   r  r   rA  r  rU   rV   rK   rW   )rX   s   "rY   rZ   rB  ,  s2     
- 
-4
- &
- 	
-
 

-r\   c                	    \        R V4      p \        P                  P                  ! V.VO5RV/ #   \        P                   d	    \        Rhi ; ir  )r   rg   r  r%   r)   r  s   &&&& rY   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
/# )rQ   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]r%  zint | IO[Any] | Noner+  r0  rT   r   rV   r   rW   )rX   s   "rY   rZ   rB  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/# )rQ   r   rD   rV   strrW   )rX   s   "rY   rZ   .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fspathre  r  fsdecode)r   str_or_bytess   & rY   convert_item.TrioBackend.open_process.<locals>.convert_itemB  s1    99T?L,,,##{{<00r\   r%  r+  r0  shellTNF)re  r  r   r   rg   r  open_processr%  r   r+  r   r0  r   )ra   r  r%  r+  r0  rT   r  rE  r   stdin_streamstdout_streamstderr_streams   &&$$$,      rY   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?  rW   )rX   s   "rY   rZ   rB  b  s     I I:J It Ir\   c                	N    \         P                  P                  \        V4       R # r^   )rg   r  spawn_system_taskrF  )ra   r@  s   &&rY   #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/# )	rQ   hostr  portr
  local_addressIPSockAddrType | NonerV   rk  rW   )rX   s   "rY   rZ   rB  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_INETrg   r  r  r  bindconnectr  ra  rk  )ra   r  r  r  familyrK  s   &&&&  rY   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/# )rQ   pathstr | bytesrV   zabc.UNIXSocketStreamrW   )rX   s   "rY   rZ   rB  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^   )rg   r  AF_UNIXr  r  ra  r  )ra   r  rK  s   && rY   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/# rQ   sockrZ  rV   zabc.SocketListenerrW   )rX   s   "rY   rZ   rB    s     ' '} '9K 'r\   c                	    \        V4      # r^   r  ra   r  s   &&rY   create_tcp_listenerTrioBackend.create_tcp_listener  s     &&r\   c                    V ^8  d   QhRRRR/# r  rW   )rX   s   "rY   rZ   rB    s     ( ( (:L (r\   c                	    \        V4      # r^   )r  r  s   &&rY   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	/# )
rQ   r  zsocket.AddressFamilyr  r  remote_address
reuse_portry   rV   zUDPSocket | ConnectedUDPSocketrW   )rX   s   "rY   rZ   rB    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)
rg   r  
SOCK_DGRAMr  r  SO_REUSEPORTr  r  r  r  )ra   r  r  r  r  rK  s   &&&&& rY   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/# )rQ   r  rZ  remote_pathrd   rV   zabc.UNIXDatagramSocketrW   )rX   s   "rY   rZ   rB    s$     % %&%59%	%r\   c                	   "   R # 5ir^   rW   ra   r  r  s   &&&rY   create_unix_datagram_socket'TrioBackend.create_unix_datagram_socket  s
      "%   c               $    V ^8  d   QhRRRRRR/# )rQ   r  rZ  r  r  rV   zabc.ConnectedUNIXDatagramSocketrW   )rX   s   "rY   rZ   rB    s$     . .&.5@.	(.r\   c                	   "   R # 5ir^   rW   r  s   &&&rY   r  r    s
      +.r  c               $    V ^8  d   QhRRRRRR/# )rQ   r  rZ  r  zstr | bytes | NonerV   z8abc.UNIXDatagramSocket | abc.ConnectedUNIXDatagramSocketrW   )rX   s   "rY   rZ   rB    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^   )rg   r  r  r  r  r  )ra   r  r  rK  s   &&& rY   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/# )rQ   r  zbytes | str | Noner  zstr | int | Noner  zint | AddressFamilyr  zint | SocketKindr  r
  r  rV   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]rW   )rX   s   "rY   rZ   rB    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^   )rg   r  getaddrinfo)ra   r  r  r  r  r  r  s   &&&$$$$rY   r  TrioBackend.getaddrinfo  s&     & [[,,TuTTTTs   %.,.c               $    V ^8  d   QhRRRRRR/# )rQ   sockaddrr@   r  r
  rV   ztuple[str, str]rW   )rX   s   "rY   rZ   rB    s$     > >%>.1>	>r\   c                	\   "   \         P                  P                  W4      G R j  xL
 #  L5ir^   )rg   r  getnameinfo)ra   r  r  s   &&&rY   r  TrioBackend.getnameinfo  s"      [[,,X====s   #,*,c                    V ^8  d   QhRRRR/# rQ   objrF   rV   rd   rW   )rX   s   "rY   rZ   rB    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)Nrq  )r"   rg   r0   with_traceback__traceback__r/   ra   r  r   s   && rY   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  rW   )rX   s   "rY   rZ   rB    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#   rg   r0   r  r  r/   r  s   && rY   r#   TrioBackend.wait_writable  se     	<$$$'' 	T%'66s7H7HItS%% 	<#L1t;	<r  c                    V ^8  d   QhRRRR/# r  rW   )rX   s   "rY   rZ   rB    s      !3  r\   c                	    \        V4       R # r^   )r!   )ra   r  s   &&rY   r!   TrioBackend.notify_closing  s
    sr\   c                    V ^8  d   QhRRRR/# r  rW   )rX   s   "rY   rZ   rB    s     ' 'm '@R 'r\   c                	    "   \        V4      # 5ir^   r  r  s   &&rY   wrap_listener_socket TrioBackend.wrap_listener_socket  s      &&s   c                    V ^8  d   QhRRRR/# )rQ   r  rZ  rV   rk  rW   )rX   s   "rY   rZ   rB    s     ' 'M 'l 'r\   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir^   )rg   r  r  rk  ra   r  	trio_socks   && rY   wrap_stream_socketTrioBackend.wrap_stream_socket  s$     KK2248	I&&   +-c                    V ^8  d   QhRRRR/# )rQ   r  rZ  rV   r  rW   )rX   s   "rY   rZ   rB    s     + + +CS +r\   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir^   )rg   r  r  r  r  s   && rY   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/# )rQ   r  rZ  rV   r  rW   )rX   s   "rY   rZ   rB    s     $ $ $9 $r\   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir^   )rg   r  r  r  r  s   && rY   wrap_udp_socketTrioBackend.wrap_udp_socket  s$     KK2248	##r  c                    V ^8  d   QhRRRR/# )rQ   r  rZ  rV   r  rW   )rX   s   "rY   rZ   rB         - -= -EW -r\   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir^   )rg   r  r  r  r  s   && rY   wrap_connected_udp_socket%TrioBackend.wrap_connected_udp_socket  $     KK2248	!),,r  c                    V ^8  d   QhRRRR/# )rQ   r  rZ  rV   r  rW   )rX   s   "rY   rZ   rB    r  r\   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir^   )rg   r  r  r  r  s   && rY   wrap_unix_datagram_socket%TrioBackend.wrap_unix_datagram_socket  r  r  c                    V ^8  d   QhRRRR/# )rQ   r  rZ  rV   r  rW   )rX   s   "rY   rZ   rB    s     6 6 6	$6r\   c                	^   "   \         P                  P                  V4      p\        V4      # 5ir^   )rg   r  r  r  r  s   && rY   #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/# )rQ   rV   r5   rW   )rX   s   "rY   rZ   rB    s       r\   c                	     \         P                  4       #   \         dC    \        \        P
                  P                  4       R 7      p\         P                  T4       Tu # i ; i))rR   )r  r  LookupErrorr5   rg   	to_threadcurrent_default_thread_limiterr5  )ra   r  s   & rY   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/# )rQ   r  r   rV   z.AbstractContextManager[AsyncIterator[Signals]]rW   )rX   s   "rY   rZ   rB    s     ( ((	7(r\   c                	    \        V4      # r^   )r  )ra   r  s   &*rY   r   TrioBackend.open_signal_receiver  s     w''r\   c                   V ^8  d   QhRR/# )rQ   rV   r*   rW   )rX   s   "rY   rZ   rB    s     " " "r\   c                	,    \        4       p\        V4      # r^   )r    ra  )ra   r+  s   & rY   get_current_taskTrioBackend.get_current_task  s    ~D!!r\   c                   V ^8  d   QhRR/# )rQ   rV   zSequence[TaskInfo]rW   )rX   s   "rY   rZ   rB  $  s      "4 r\   c                	   \        4       pV'       gw   RRR\        P                  ! 4       9   g   \        P                  ! V4      '       d   \        P
                  ! V4      MR/,          p\        \        P                  ! V4      4      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# ) zassert %(py0)sr  	root_task)r   r  r  r  r  r  r  r  ra  child_nurserieschild_tasksr  extend)ra   r3  @py_format1
task_infos	nurseriesnew_nurseriesnurseryr+  s   &       rY   get_running_tasksTrioBackend.get_running_tasks#  s    %'	yy"9-.
--	02M$#//D%%l4&89!(()=)=> 0 %
 &Ir\   c                   V ^8  d   QhRR/# r   rW   )rX   s   "rY   rZ   rB  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@  )ra   r@  s   & rY   r@  "TrioBackend.wait_all_tasks_blocked4  s     7$&&&s   c                    V ^8  d   QhRRRR/# )rQ   r  r  rV   r  rW   )rX   s   "rY   rZ   rB  ;  s     % % %J %r\   c                	    \        R/ VB # rf   )r  )ra   r  s   &&rY   create_test_runnerTrioBackend.create_test_runner:  s    $G$$r\   rW   rO  r^   )r   )6r   r   r   r   classmethodrD  rI  rM  rQ  r  rL  r\  rB  rC  rD  rd  rh  rl  rp  rt  rx  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.  r<  r@  rE  r   rW   r\   rY   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   builtinsr  _pytest.assertion.rewrite	assertionrewriter  r  rC  r  r  systypesr1  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_threadrg   trio.lowlevelr  r   r   r   r   r    r!   r"   r#   trio.socketr$   rL  trio.to_threadr%   r2  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   rH   exceptiongrouprI   typing_extensionsrJ   rK   r  rL   rM   rN   r  RunVarr   ByteReceiveStreamr   ByteSendStreamr   r   
Instrumentr3  r=  r   rF  rH  rk  r  SocketListenerr  r  r  r  r  r  r  r  r  ra  r>  backend_class)rJ  s   @rY   <module>rr     sM   " "     	  
  	 	 	 . !    , 
 
 
   ) )  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\   