+
    Xj                      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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-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I^Hata ^RIGHbtbHctcHdtd ^RIeHftfHgtg ^R IhHitiHjtjHktk ^R!IlHmtm ]&'       d   ^ R"InHoto ]P                  Rf8  d
   ^ R#I$HqtqHrtr M^ R$IsHttt ^ R#IuHqtqHrtr ],! R%4      tv],! R&4      tw],! R'R(R)7      tx],! R*]y]b4      tz]q! R+4      t{]+! R,4      t|R- R. lt}]0P                  P                  t ! R/ R0]`4      t_]! 4       t ! R1 R2](]i,          ]GEP                  ]i,          4      t ! R3 R4]GEP                  4      t]! R5R67       ! R7 R8]GEP
                  4      4       t]! R5R67       ! R9 R:]GEP                  4      4       t]! R5R67       ! R; R<]GEP                  4      4       t ! R= R>]0P                  EP                  4      t]! R?4      tR@]R?&   RA RB lt ! RC RD](]z,          4      t ! RE RF]]GEP                   4      t ! RG RH]]GEP"                  4      t ! RI RJ]]GEP$                  4      t ! RK RL]]GEP$                  4      t ! RM RN]]b,          ]GEP*                  4      t ! RO RP]]b,          ]GEP,                  4      t ! RQ RR]]y,          ]GEP.                  4      t ! RS RT]]y,          ]GEP0                  4      t ! RU RV]W4      tV ! RW RX]Y4      tX ! RY RZ]]4      t\ ! R[ R\]U4      tT]! R]4      tR@]R]&    ! R^ R_4      t ! R` Ra]GEP6                  4      t ! Rb Rc]E4      t ! Rd Re]f4      t]tR# )g    )annotationsN)AsyncGeneratorAsyncIterator	AwaitableCallable
Collection	CoroutineIterableSequence)AbstractContextManager)Context)	dataclass)partialwraps)IOBase)PathLike)Signals)AddressFamily
SocketKind)TracebackType)
IOTYPE_CHECKINGAnyGenericLiteral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)
TaskHandle)IPSockAddrTypeUDPPacketTypeUNIXDatagramPacketType)AsyncBackendStrOrBytesPath)T_contracall_for_coroutineget_callable_name)MemoryObjectSendStream)FileDescriptorLike)TypeVarTupleUnpack)BaseExceptionGroupTT_RetvalT_coT)	covariant
T_SockAddrPosArgsTPc                    V ^8  d   QhRRRR/# )   func Callable[P, Awaitable[T_Retval]]returnz*Callable[P, Coroutine[Any, Any, T_Retval]] )formats   "q   /Users/wind/Downloads/Coruna-main学习资料A/backend/venv/lib/python3.14/site-packages/anyio/_backends/_trio.py__annotate__rb   k   s      
*/    c                6   a  \        S 4      R  V 3R ll4       pV# )c               $    V ^8  d   QhRRRRRR/# )r[   argsP.argskwargsP.kwargsr^   zCoroutine[Any, Any, T_Retval]r_   )r`   s   "ra   rb   )ensure_returns_coro.<locals>.__annotate__o   s"     # #v # #6S #rc   c                    <a S! V / VB o\        S\        4      '       d   S# \        S\        4      '       g   S# \        S4      R  V3R ll4       pV! 4       # )c                   V ^8  d   QhRR/# r[   r^   rT   r_   )r`   s   "ra   rb   :ensure_returns_coro.<locals>.wrapper.<locals>.__annotate__{   s     ' ' 'rc   c                 $   <"   S G R j  xL
 #  L5iNr_   )	awaitables   ra   inner_wrapper;ensure_returns_coro.<locals>.wrapper.<locals>.inner_wrapperz   s     &&s   )
isinstancer	   r   r   )rf   rh   rr   rq   r\   s   *, @ra   wrapper$ensure_returns_coro.<locals>.wrappern   s\    $)&)	i++Iy11  4[' ' !?"rc   )r   )r\   ru   s   f ra   ensure_returns_cororw   k   s"     4[# #" Nrc   c                     ] tR t^tRt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# )rD   Nc               $    V ^8  d   QhRRRRRR/# )r[   originaltrio.CancelScope | Nonerh   objectr^   rD   r_   )r`   s   "ra   rb   CancelScope.__annotate__   s$     # #.#AG#	#rc   c                	,    \         P                  V 4      # rp   r|   __new__)clsrz   rh   s   &&,ra   r   CancelScope.__new__   s     ~~c""rc   c               $    V ^8  d   QhRRRRRR/# )r[   rz   r{   rh   r   r^   Noner_   )r`   s   "ra   rb   r}      s(     A A!8 A3 ASW Arc   c                	P    T;'       g    \         P                  ! R/ VB V n        R # Nr_   )triorD   _CancelScope__original)selfrz   rh   s   &&,ra   __init__CancelScope.__init__   s    "@@d&6&6&@&@rc   c                   V ^8  d   QhRR/# )r[   r^   rD   r_   )r`   s   "ra   rb   r}      s      ; rc   c                	:    V P                   P                  4        V # rp   )r   	__enter__r   s   &ra   r   CancelScope.__enter__   s    !!#rc   c               (    V ^8  d   QhRRRRRRRR/# 	r[   exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Noner^   boolr_   )r`   s   "ra   rb   r}      8     C C,C &C %	C
 
Crc   c                	:    V P                   P                  WV4      # rp   )r   __exit__r   r   r   r   s   &&&&ra   r   CancelScope.__exit__   s     ''6BBrc   c                    V ^8  d   QhRRRR/# )r[   reasonz
str | Noner^   r   r_   )r`   s   "ra   rb   r}      s     ' 'Z '4 'rc   c                	<    V P                   P                  V4       R # rp   )r   cancel)r   r   s   &&ra   r   CancelScope.cancel   s    v&rc   c                   V ^8  d   QhRR/# r[   r^   floatr_   )r`   s   "ra   rb   r}      s     ( (% (rc   c                	.    V P                   P                  # rp   r   deadliner   s   &ra   r   CancelScope.deadline   s    '''rc   c                    V ^8  d   QhRRRR/# r[   valuer   r^   r   r_   )r`   s   "ra   rb   r}      s     ) )e ) )rc   c                	&    WP                   n        R # rp   r   r   r   s   &&ra   r   r      s    #( rc   c                   V ^8  d   QhRR/# r[   r^   r   r_   )r`   s   "ra   rb   r}      s     - -t -rc   c                	.    V P                   P                  # rp   )r   cancel_calledr   s   &ra   r   CancelScope.cancel_called   s    ,,,rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r}      s     0 0$ 0rc   c                	.    V P                   P                  # rp   )r   cancelled_caughtr   s   &ra   r   CancelScope.cancelled_caught       ///rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r}      s     & & &rc   c                	.    V P                   P                  # rp   r   shieldr   s   &ra   r   CancelScope.shield   s    %%%rc   c                    V ^8  d   QhRRRR/# )r[   r   r   r^   r   r_   )r`   s   "ra   rb   r}      s     ' 'D 'T 'rc   c                	&    WP                   n        R # rp   r   r   s   &&ra   r   r      s    !&rc   
__originalrp   )__name__
__module____qualname____firstlineno__	__slots__r   r   r   r   r   propertyr   setterr   r   r   __static_attributes__r_   rc   ra   rD   rD      s    I#
AC' ( ( __) ) - - 0 0 & & ]]' 'rc   rD   c                  D    ] tR t^t$ ]tR]R&   RtR]R&   R	R R lltRt	R# )
_TrioTaskStatuszT_contra | objectearly_start_valueNz'trio.TaskStatus[T_contra | None] | Nonereal_task_statusc                    V ^8  d   QhRRRR/# )r[   r   zT_contra | Noner^   r   r_   )r`   s   "ra   rb   _TrioTaskStatus.__annotate__   s     1 1_ 1 1rc   c                	    V P                   f(   V P                  \        Jd   \        R4      hWn        R # V P                   P	                  V4       R # )Nz.called 'started' twice on the same task status)r   r   empty_start_valueRuntimeErrorstartedr   s   &&ra   r   _TrioTaskStatus.started   sC      (%%->>"#STT%*"!!))%0rc   )r   rp   )
r   r   r   r   r   r   __annotations__r   r   r   r_   rc   ra   r   r      s$    +<(<@D=D1 1rc   r   c                  z    ] tR t^tR R ltR R ltR R ltRR R	 lltR
RRR/R R lltR
RRR/R R llt	Rt
R# )	TaskGroupc                   V ^8  d   QhRR/# r[   r^   r   r_   )r`   s   "ra   rb   TaskGroup.__annotate__   s     ! !$ !rc   c                	h    R V n         R V n        \        P                  ! RR7      V n        RV n        R# )FT)strict_exception_groupsN)_entered_activer   open_nursery_nursery_managercancel_scoper   s   &ra   r   TaskGroup.__init__   s+     $ 1 1$ O rc   c                   V ^8  d   QhRR/# )r[   r^   r   r_   )r`   s   "ra   rb   r      s      ) rc   c                	   "   V P                   '       d   \        R 4      hRV n         RV n        V P                  P	                  4       G Rj  xL
 V n        \        V P
                  P                  4      V n        V #  L/5i)z*TaskGroup cannot be entered more than onceTN)r   r   r   r   
__aenter___nurseryrD   r   r   s   &ra   r   TaskGroup.__aenter__   sc     ===KLL"33>>@@'(B(BC As   A	A=A;0A=c               (    V ^8  d   QhRRRRRRRR/# r   r_   )r`   s   "ra   rb   r      s2     ! !,! &! %	!
 
!rc   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   rR   splitr   	Cancelled_create)r   r   r   r   excs   &&&& ra   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 Nc                    V ^8  d   QhRRRR/# )r[   corozCoroutine | Noner^   r   r_   )r`   s   "ra   rb   r      s      "2 d rc   c                	h    V P                   '       g    Ve   VP                  4        \        R4      hR # )Nz;This task group is not active; no new tasks can be started.)r   closer   )r   r   s   &&ra   _check_activeTaskGroup._check_active   s/    |||

M 	 rc   namecontextc               (    V ^8  d   QhRRRRRRRR/# )	r[   r   zCoroutine[Any, Any, T_co]r   r|   r   zContext | Noner^   zTaskHandle[T_co]r_   )r`   s   "ra   rb   r     s2      ' 	
   
rc   c               	   \        V\        4      '       g#   \        R VP                  P                   24      hV P                  V4       \        W4      pVeH   VP                  \        V P                  P                  VP                  VP                  R7      4       V# V P                  P                  VP                  VP                  R7       V# )zexpected a coroutine, got r   )rt   r	   	TypeError	__class__r   r   rE   runr   r   
start_soon	_run_coror   )r   r   r   r   handles   &&$$ ra   create_taskTaskGroup.create_task  s     $	**89T9T8UVWW4 D'KK00&2B2BU  MM$$V%5%5FKK$Hrc   return_handleFc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r[   r\   7Callable[[Unpack[PosArgsT]], Coroutine[Any, Any, T_co]]rf   zUnpack[PosArgsT]r   r|   r  zLiteral[False] | Literal[True]r^   r   r_   )r`   s   "ra   rb   r     s<        E     	 
 6  
 rc   c               	   aaaa"   R  VVVV3R llpV P                  4        \        SS4      pV P                  P                  WVR7      G Rj  xL
 pV'       d
   VSn        S# V#  L5i)c                    V ^8  d   QhRRRR/# )r[   task_statusztrio.TaskStatus[Any]r^   r   r_   )r`   s   "ra   rb   %TaskGroup.start.<locals>.__annotate__!  s     	% 	%0	%	%rc   c                   <"   \        4       p\        SSVR 7      pVP                  \        Jd   V P	                  VP                  4       MWn        \        VS4      oSP                  4       G Rj  xL
  R#  L5i))r	  N)r   rL   r   r   r   r   rE   r   )r	  wrapper_task_statusr   rf   r\   r  r   s   $  ra   run_coro_with_task_status2TaskGroup.start.<locals>.run_coro_with_task_status!  sh      #2"3%dD>QRD"44<MM##$7$I$IJ7B4d+F""$$$s   A.A:1A82A:r   N)r   rM   r   start_start_value)	r   r\   r   r  rf   r  
final_namestart_valuer  s	   &fd$j   @ra   r  TaskGroup.start  sh     	% 	% 	&tT2
 MM//% 0 
 
 "-FM
s   AA(A&A(A()r   r   r   r   r   rp   )r   r   r   r   r   r   r   r   r  r  r   r_   rc   ra   r   r      sM    !!$ 	
 #'*  	 
 9>   rc   r   F)eqc                  >    ] tR tRt$ R]R&   R
R R lltR R ltR	tR# )ReceiveStreamWrapperi@  ztrio.abc.ReceiveStream_streamNc                    V ^8  d   QhRRRR/# )r[   	max_bytes
int | Noner^   bytesr_   )r`   s   "ra   rb   !ReceiveStreamWrapper.__annotate__D  s      z U rc   c                	b  "   Ve   V^8  d   \        R4      h 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)N$max_bytes must be a positive integer)	
ValueErrorr  receive_somer   r5   	__cause__r3   r  r6   r   r  datar   s   &&  ra   receiveReceiveStreamWrapper.receiveD  s      Y]CDD	9229==D ; >'' 	9%3==8'' 	9%3==8	9sO   B/A AA B/B/A B,-A>>B,B,B''B,,B/c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r  T       $ $d $rc   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5irp   r  acloser   s   &ra   r*  ReceiveStreamWrapper.acloseT       ll!!###   )')r_   rp   )r   r   r   r   r   r$  r*  r   r_   rc   ra   r  r  @  s    ## $ $rc   r  c                  :    ] tR tRt$ R]R&   R R ltR R ltRtR	# )
SendStreamWrapperiX  ztrio.abc.SendStreamr  c                    V ^8  d   QhRRRR/# r[   itemr  r^   r   r_   )r`   s   "ra   rb   SendStreamWrapper.__annotate__\  s     9 9u 9 9rc   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rp   )r  send_allr   r5   r!  r3   r   r2  r   s   && ra   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   r_   )r`   s   "ra   rb   r3  d  r'  rc   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5irp   r)  r   s   &ra   r*  SendStreamWrapper.aclosed  r,  r-  r_   N)r   r   r   r   r   r7  r*  r   r_   rc   ra   r/  r/  X  s      9$ $rc   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# )Processih  ztrio.Process_processabc.ByteSendStream | None_stdinabc.ByteReceiveStream | None_stdout_stderrc                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   Process.__annotate__o  s      d rc   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)rD   r@  r*  rB  rC  waitBaseExceptionkillr   s   &ra   r*  Process.acloseo  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/# r[   r^   intr_   )r`   s   "ra   rb   rE    s     * *C *rc   c                	R   "   V P                   P                  4       G R j  xL
 #  L5irp   )r>  rH  r   s   &ra   rH  Process.wait  s     ]]''))))   '%'c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   rE    s     " "4 "rc   c                	:    V P                   P                  4        R # rp   )r>  	terminater   s   &ra   rT  Process.terminate  s    !rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   rE    s      d rc   c                	:    V P                   P                  4        R # rp   )r>  rJ  r   s   &ra   rJ  Process.kill  s    rc   c                    V ^8  d   QhRRRR/# )r[   signalr   r^   r   r_   )r`   s   "ra   rb   rE    s     * *' *d *rc   c                	<    V P                   P                  V4       R # rp   )r>  send_signal)r   rZ  s   &&ra   r\  Process.send_signal  s    !!&)rc   c                   V ^8  d   QhRR/# rM  r_   )r`   s   "ra   rb   rE    s     ! !S !rc   c                	.    V P                   P                  # rp   )r>  pidr   s   &ra   r`  Process.pid  s    }}   rc   c                   V ^8  d   QhRR/# r[   r^   r  r_   )r`   s   "ra   rb   rE    s     ( (J (rc   c                	.    V P                   P                  # rp   )r>  
returncoder   s   &ra   re  Process.returncode  s    }}'''rc   c                   V ^8  d   QhRR/# )r[   r^   r?  r_   )r`   s   "ra   rb   rE    s      0 rc   c                	    V P                   # rp   )r@  r   s   &ra   stdinProcess.stdin  s    {{rc   c                   V ^8  d   QhRR/# r[   r^   rA  r_   )r`   s   "ra   rb   rE          4 rc   c                	    V P                   # rp   )rB  r   s   &ra   stdoutProcess.stdout      ||rc   c                   V ^8  d   QhRR/# rl  r_   )r`   s   "ra   rb   rE    rm  rc   c                	    V P                   # rp   )rC  r   s   &ra   stderrProcess.stderr  rq  rc   r_   N)r   r   r   r   r   r*  rH  rT  rJ  r\  r   r`  re  ri  ro  rt  r   r_   rc   ra   r=  r=  h  s    %%))))"*"* ! ! ( (      rc   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   r_   )r`   s   "ra   rb   +_ProcessPoolShutdownInstrument.__annotate__  s      4 rc   c                	$   < \         SV `  4        R # rp   )super	after_run)r   r   s   &ra   r|  (_ProcessPoolShutdownInstrument.after_run  s    rc   r_   )r   r   r   r   r|  r   __classcell__r   s   @ra   rw  rw    s     rc   rw  &current_default_worker_process_limiterztrio.lowlevel.RunVarc                    V ^8  d   QhRRRR/# r[   workerszset[abc.Process]r^   r   r_   )r`   s   "ra   rb   rb     s     
' 
'*: 
't 
'rc   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)NTrG  )	r   sleepmathinfr   re  rJ  rD   r*  )r  processs   & ra   _shutdown_process_poolr    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/# r[   trio_socketTrioSocketTyper^   r   r_   )r`   s   "ra   rb   _TrioSocketMixin.__annotate__  s      N t rc   c                	     Wn         R V n        R# FN)_trio_socket_closed)r   r  s   &&ra   r   _TrioSocketMixin.__init__  s    'rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r    s     & &t &rc   c                	    V P                   '       d   \        hV P                  P                  4       ^ 8  d   \        hR# r   N)r  r5   r  filenor3   r   s   &ra   _check_closed_TrioSocketMixin._check_closed  s3    <<<%%##%)%% *rc   c                   V ^8  d   QhRR/# )r[   r^   socket.socketr_   )r`   s   "ra   rb   r    s     ' '] 'rc   c                	.    V P                   P                  # rp   )r  _sockr   s   &ra   _raw_socket_TrioSocketMixin._raw_socket  s      &&&rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r    s     & &d &rc   c                	   "   V P                   P                  4       ^ 8  d$   RV n        V P                   P                  4        R# R# 5i)r   TN)r  r  r  r   r   s   &ra   r*  _TrioSocketMixin.aclose  s:     ##%*DL##% +s   AAc                    V ^8  d   QhRRRR/# )r[   r   rI  r^   r   r_   )r`   s   "ra   rb   r    s       8 rc   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r  )rt   r   r5   r  r  r  OSErrorr3   r   r   s   &&ra   _convert_socket_error&_TrioSocketMixin._convert_socket_error  s^    c43344%3.%%'!+%4/W%%%3.Irc   )r  r  N)r   r   r   r   r   r  r   r  r*  r  r   r_   rc   ra   r  r    s/    & ' '&
 rc   r  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/# r  r_   )r`   s   "ra   rb   SocketStream.__annotate__       7 7N 7t 7rc   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# reading from
writing toNr{  r   r?   _receive_guard_send_guardr   r  r   s   &&ra   r   SocketStream.__init__  *    %+N;(6rc   c                    V ^8  d   QhRRRR/# )r[   r  rN  r^   r  r_   )r`   s   "ra   rb   r    s     " "s "u "rc   c                	R  "   V^8  d   \        R4      h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  N)r  r  r  recvrI  r  r6   r"  s   &&  ra   r$  SocketStream.receive  s     q=CDD   0!..33I>>  !  "! ?  0**3//0 !  sc   'B'BA*	A(
A*BBB'"B(A**B5BBBBB$		B'c                    V ^8  d   QhRRRR/# r1  r_   )r`   s   "ra   rb   r    s     	) 	)u 	) 	)rc   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rp   )r  
memoryviewr  r7  rI  r  )r   r2  view
bytes_sentr   s   &&   ra   r7  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   r_   )r`   s   "ra   rb   r    s     3 3 3rc   c                	`   "   V P                   P                  \        P                  4       R # 5irp   )r  shutdownsocketSHUT_WRr   s   &ra   send_eofSocketStream.send_eof  s     ""6>>2s   ,.r  r  )   )
r   r   r   r   r   r$  r7  r  r   r~  r  s   @ra   r  r    s!    7 7
"	)3 3rc   r  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/# )r[   msglenrN  maxfdsr^   ztuple[bytes, list[int]]r_   )r`   s   "ra   rb   UNIXSocketStream.__annotate__  s"     " " "S "=T "rc   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 = )rt   rN  r  arrayr   lowlevel
checkpointr  r  recvmsgr  CMSG_LENitemsizer6   rI  r  
SOL_SOCKET
SCM_RIGHTSr   	frombyteslenlist)r   r  r  fdsmessageancdataflagsaddrr   
cmsg_level	cmsg_type	cmsg_datas   &&&         ra   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/# )r[   r  r  r  zCollection[int | IOBase]r^   r   r_   )r`   s   "ra   rb   r  "  s"     4 4e 42J 4t 4rc   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  rt   rN  appendr   r  r  r   r  r  r  r  sendmsgr  r  r  rI  r  )r   r  r  filenosfdfdarrayr   s   &&&    ra   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:r_   N)r   r   r   r   r  r  r   r_   rc   ra   r  r     s    "B4 4rc   r  c                  :   a  ] tR tRtR V 3R lltR R ltRtV ;t# )TCPSocketListeneriC  c                   V ^8  d   QhRR/# r[   
raw_socketr  r_   )r`   s   "ra   rb   TCPSocketListener.__annotate__D       I I= Irc   c                	   < \         SV `  \        P                  P	                  V4      4       \        R 4      V n        R# zaccepting connections fromNr{  r   r   r  from_stdlib_socketr?   _accept_guardr   r  r   s   &&ra   r   TCPSocketListener.__init__D  -    77
CD*+GHrc   c                   V ^8  d   QhRR/# )r[   r^   r  r_   )r`   s   "ra   rb   r  H  s     ) )l )rc   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rp   )
r  r  acceptrI  r  
setsockoptr  IPPROTO_TCPTCP_NODELAYr  r   r  _addrr   s   &   ra   r  TCPSocketListener.acceptH  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   r   r  r   r~  r  s   @ra   r  r  C  s    I I) )rc   r  c                  :   a  ] tR tRtR V 3R lltR R ltRtV ;t# )UNIXSocketListeneriS  c                   V ^8  d   QhRR/# r  r_   )r`   s   "ra   rb   UNIXSocketListener.__annotate__T  r  rc   c                	   < \         SV `  \        P                  P	                  V4      4       \        R 4      V n        R# r  r  r   s   &&ra   r   UNIXSocketListener.__init__T  r  rc   c                   V ^8  d   QhRR/# )r[   r^   r  r_   )r`   s   "ra   rb   r  X  s     - -. -rc   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rp   )r  r  r  rI  r  r  r	  s   &   ra   r  UNIXSocketListener.acceptX  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   @ra   r  r  S  s    I I- -rc   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# )		UDPSocketib  c                    V ^8  d   QhRRRR/# r  r_   )r`   s   "ra   rb   UDPSocket.__annotate__c  r  rc   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# r  r  r  s   &&ra   r   UDPSocket.__init__c  r  rc   c                   V ^8  d   QhRR/# )r[   r^   ztuple[bytes, IPSockAddrType]r_   )r`   s   "ra   rb   r  h  s     0 0; 0rc   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)r  r  recvfromr7   rI  r  r   r#  r  r   s   &   ra   r$  UDPSocket.receiveh  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/# )r[   r2  rG   r^   r   r_   )r`   s   "ra   rb   r  p  s     0 0} 0 0rc   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rp   r  r  sendtorI  r  r6  s   && ra   r7  UDPSocket.sendp  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   r   r$  r7  r   r~  r  s   @ra   r  r  b      7 7
00 0rc   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# )	ConnectedUDPSocketix  c                    V ^8  d   QhRRRR/# r  r_   )r`   s   "ra   rb   ConnectedUDPSocket.__annotate__y  r  rc   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# r  r  r  s   &&ra   r   ConnectedUDPSocket.__init__y  r  rc   c                   V ^8  d   QhRR/# r[   r^   r  r_   )r`   s   "ra   rb   r/  ~       0 0u 0rc   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  r  r  rI  r  r  s   & ra   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/# r1  r_   )r`   s   "ra   rb   r/         0 0u 0 0rc   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rp   r  r  r7  rI  r  r6  s   && ra   r7  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   @ra   r-  r-  x  s    7 7
00 0rc   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/# r  r_   )r`   s   "ra   rb   UNIXDatagramSocket.__annotate__  r  rc   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# r  r  r  s   &&ra   r   UNIXDatagramSocket.__init__  r  rc   c                   V ^8  d   QhRR/# )r[   r^   rH   r_   )r`   s   "ra   rb   rD    s     0 05 0rc   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  )r  r  r   rI  r  r!  s   &   ra   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/# )r[   r2  rH   r^   r   r_   )r`   s   "ra   rb   rD    s     0 05 0$ 0rc   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rp   r%  r6  s   && ra   r7  UNIXDatagramSocket.send  r(  r)  r  r*  r  s   @ra   rB  rB    r+  rc   rB  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/# r  r_   )r`   s   "ra   rb   (ConnectedUNIXDatagramSocket.__annotate__  r  rc   c                	f   < \         SV `  V4       \        R 4      V n        \        R4      V n        R# r  r  r  s   &&ra   r   $ConnectedUNIXDatagramSocket.__init__  r  rc   c                   V ^8  d   QhRR/# r3  r_   )r`   s   "ra   rb   rP    r4  rc   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  r6  r  s   & ra   r$  #ConnectedUNIXDatagramSocket.receive  r8  r9  c                    V ^8  d   QhRRRR/# r1  r_   )r`   s   "ra   rb   rP    r;  rc   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rp   r=  r6  s   && ra   r7   ConnectedUNIXDatagramSocket.send  r?  r@  r  r*  r  s   @ra   rN  rN    s    7 7
00 0rc   rN  c                  b    ] tR 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# )r<   i  c                   V ^8  d   QhRR/# )r[   r^   r<   r_   )r`   s   "ra   rb   Event.__annotate__  s     # # #rc   c                	,    \         P                  V 4      # rp   r   r   s   &ra   r   Event.__new__      ~~c""rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r[    s     ' '$ 'rc   c                	:    \         P                  ! 4       V n        R # rp   )r   r<   _Event__originalr   s   &ra   r   Event.__init__  s    **,rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r[         ( ( (rc   c                	6    V P                   P                  4       # rp   )rb  is_setr   s   &ra   rg  Event.is_set      %%''rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r[         , ,D ,rc   c                	R   "   V P                   P                  4       G R j  xL
 #  L5irp   )rb  rH  r   s   &ra   rH  
Event.wait  s     __))++++rQ  c                   V ^8  d   QhRR/# )r[   r^   r,   r_   )r`   s   "ra   rb   r[    s     L LO Lrc   c                	b    V P                   P                  4       p\        VP                  R 7      # ))tasks_waiting)rb  
statisticsr,   rp  r   orig_statisticss   & ra   rq  Event.statistics  s%    //446_-J-JKKrc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r[    s      T rc   c                	:    V P                   P                  4        R # rp   )rb  setr   s   &ra   rw  	Event.set  s    rc   r   N)r   r   r   r   r   r   r   rg  rH  rq  rw  r   r_   rc   ra   r<   r<     s+    I#'(,L rc   r<   c                      ] tR 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>   i  fast_acquireFc                    V ^8  d   QhRRRR/# r[   rz  r   r^   r>   r_   )r`   s   "ra   rb   Lock.__annotate__  s     # #d #t #rc   c               	,    \         P                  V 4      # rp   r   r   rz  s   &$ra   r   Lock.__new__  r_  rc   c                    V ^8  d   QhRRRR/# )r[   rz  r   r^   r   r_   )r`   s   "ra   rb   r}    s     & & & &rc   c               	F    Wn         \        P                  ! 4       V n        R # rp   )_fast_acquirer   r>   _Lock__original)r   rz  s   &$ra   r   Lock.__init__  s    )))+rc   c                    V ^8  d   QhRRRR/# )r[   r   r   r^   r   r_   )r`   s   "ra   rb   r}    s     F F F Frc   c                	:    V P                   R8X  d
   RV n         R# R# )*attempt to re-acquire an already held LockN)r  )z)Attempted to acquire an already held Lock)rf   )r   s   &ra   _convert_runtime_error_msgLock._convert_runtime_error_msg  s    88FFECH Grc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r}    s      t rc   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rp   )r  r  acquirer   r  r   r  checkpoint_if_cancelledacquire_nowaitr0   _lotparkr  s   & ra   r  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   r_   )r`   s   "ra   rb   r}    s       rc   c                	     V P                   P                  4        R #   \        P                   d	    \        R h\         d   pT P                  T4       h R p?ii ; irp   )r  r  r   r0   r   r  r  s   & ra   r  Lock.acquire_nowait  sL    	OO**, 	'$& 	++C0	s    $AAAAc                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r}    re  rc   c                	6    V P                   P                  4       # rp   )r  lockedr   s   &ra   r  Lock.locked  ri  rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r}         " " "rc   c                	:    V P                   P                  4        R # rp   )r  releaser   s   &ra   r  Lock.release      !rc   c                   V ^8  d   QhRR/# )r[   r^   r-   r_   )r`   s   "ra   rb   r}    s     
 
N 
rc   c                	    V P                   P                  4       pVP                  '       d   \        VP                  4      MR p\	        VP
                  W!P                  4      # rp   )r  rq  ownerTrioTaskInfor-   r  rp  )r   rs  r  s   &  ra   rq  Lock.statistics  sP    //4467F7L7L7L_223RV""E+H+H
 	
rc   )r   r  N)r  r   )r   r   r   r   r   r   r   staticmethodr  r  r  r  r  rq  r   r_   rc   ra   r>   r>     sS    -I#U #&u & F F(("
 
rc   r>   c                     a  ] tR 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# )rB   i  	max_valueNrz  Fc               (    V ^8  d   QhRRRRRRRR/# )	r[   initial_valuerN  r  r  rz  r   r^   rB   r_   )r`   s   "ra   rb   Semaphore.__annotate__  s2     # ## 	#
 # 
#rc   c               	,    \         P                  V 4      # rp   r   r   r  r  rz  s   &&$$ra   r   Semaphore.__new__  s     ~~c""rc   c               (    V ^8  d   QhRRRRRRRR/# )	r[   r  rN  r  r  rz  r   r^   r   r_   )r`   s   "ra   rb   r    s8     M MM 	M
 M 
Mrc   c               	b   < \         SV `  WVR 7       \        P                  ! WR7      V n        R# )r  rz  )r  N)r{  r   r   rB   _Semaphore__original)r   r  r  rz  r   s   &&$$ra   r   Semaphore.__init__  s'     	,W..Lrc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r  &  s     
. 
.t 
.rc   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rp   )
r  r  r  r   r  r  r  r0   r  r  r   s   &ra   r  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   r_   )r`   s   "ra   rb   r  2       ' ' 'rc   c                	|     V P                   P                  4        R #   \        P                   d	    \        R hi ; irp   )r  r  r   r0   r   s   &ra   r  Semaphore.acquire_nowait2  2    	'OO**, 	'$&	'    ;c                   V ^8  d   QhRR/# rc  r_   )r`   s   "ra   rb   r  9  s     ) ): )rc   c                	.    V P                   P                  # rp   )r  r  r   s   &ra   r  Semaphore.max_value8  s    (((rc   c                   V ^8  d   QhRR/# rM  r_   )r`   s   "ra   rb   r  =  s     % %s %rc   c                	.    V P                   P                  # rp   )r  r   r   s   &ra   r   Semaphore.value<  s    $$$rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r  @  r  rc   c                	:    V P                   P                  4        R # rp   )r  r  r   s   &ra   r  Semaphore.release@  r  rc   c                   V ^8  d   QhRR/# )r[   r^   r@   r_   )r`   s   "ra   rb   r  C  s     B B/ Brc   c                	`    V P                   P                  4       p\        VP                  4      # rp   )r  rq  r@   rp  rr  s   & ra   rq  Semaphore.statisticsC  s%    //446"?#@#@AArc   r   )r   r   r   r   r   r   r   r  r  r   r  r   r  rq  r   r~  r  s   @ra   rB   rB     s    I# !%	#
 ##M !%	M
 #M M
.' ) ) % %"B Brc   rB   c                  "   ] tR 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# )$r:   iH  Nrz   c               $    V ^8  d   QhRRRRRR/# )r[   total_tokensfloat | Nonerz   trio.CapacityLimiter | Noner^   r:   r_   )r`   s   "ra   rb   CapacityLimiter.__annotate__K  s(     # #"# .	#
 
#rc   c               	,    \         P                  V 4      # rp   r   )r   r  rz   s   &&$ra   r   CapacityLimiter.__new__K  s     ~~c""rc   c               $    V ^8  d   QhRRRRRR/# )r[   r  r  rz   r  r^   r   r_   )r`   s   "ra   rb   r  S  s-     
A 
A"
A .	
A
 

Arc   c               	`    Ve	   W n         R # Vf   Q h\        P                  ! V4      V n         R # rp   )_CapacityLimiter__originalr   r:   )r   r  rz   s   &&$ra   r   CapacityLimiter.__init__S  s-     &O+++"22<@DOrc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r  _  s     2 2$ 2rc   c                	R   "   V P                   P                  4       G R j  xL
 #  L5irp   )r  r   r   s   &ra   r   CapacityLimiter.__aenter___  s     __//1111rQ  c               (    V ^8  d   QhRRRRRRRR/# )	r[   r   r   r   r   r   r   r^   r   r_   )r`   s   "ra   rb   r  b  r   rc   c                	Z   "   V P                   P                  WV4      G R j  xL
  R #  L5irp   )r  r   r   s   &&&&ra   r   CapacityLimiter.__aexit__b  s!      oo''6BBBs    +)+c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r  k  s     , ,e ,rc   c                	.    V P                   P                  # rp   r  r  r   s   &ra   r  CapacityLimiter.total_tokensj  s    +++rc   c                    V ^8  d   QhRRRR/# r   r_   )r`   s   "ra   rb   r  o  s     - -% -D -rc   c                	&    WP                   n        R # rp   r  r   s   &&ra   r  r  n  s    ',$rc   c                   V ^8  d   QhRR/# rM  r_   )r`   s   "ra   rb   r  s  s     / / /rc   c                	.    V P                   P                  # rp   )r  borrowed_tokensr   s   &ra   r  CapacityLimiter.borrowed_tokensr  s    ...rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r  w  s     0 0% 0rc   c                	.    V P                   P                  # rp   )r  available_tokensr   s   &ra   r   CapacityLimiter.available_tokensv  r   rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r  z  r  rc   c                	|     V P                   P                  4        R #   \        P                   d	    \        R hi ; irp   )r  r  r   r0   r   s   &ra   r  CapacityLimiter.acquire_nowaitz  r  r  c                    V ^8  d   QhRRRR/# r[   borrowerr|   r^   r   r_   )r`   s   "ra   rb   r    s     ' 'F 't 'rc   c                	~     V P                   P                  V4       R #   \        P                   d	    \        R hi ; irp   )r  acquire_on_behalf_of_nowaitr   r0   r   r  s   &&ra   r  +CapacityLimiter.acquire_on_behalf_of_nowait  s4    	'OO77A 	'$&	's    <c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r    s     ( (t (rc   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5irp   )r  r  r   s   &ra   r  CapacityLimiter.acquire  s     oo%%'''r-  c                    V ^8  d   QhRRRR/# r  r_   )r`   s   "ra   rb   r    s     = =6 =d =rc   c                	X   "   V P                   P                  V4      G R j  xL
  R #  L5irp   )r  acquire_on_behalf_ofr  s   &&ra   r  $CapacityLimiter.acquire_on_behalf_of  s     oo228<<<s   *(*c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r    s     ) ) )rc   c                	6    V P                   P                  4       # rp   )r  r  r   s   &ra   r  CapacityLimiter.release  s    &&((rc   c                    V ^8  d   QhRRRR/# r  r_   )r`   s   "ra   rb   r    s     > >V > >rc   c                	8    V P                   P                  V4      # rp   )r  release_on_behalf_ofr  s   &&ra   r  $CapacityLimiter.release_on_behalf_of  s    33H==rc   c                   V ^8  d   QhRR/# )r[   r^   r+   r_   )r`   s   "ra   rb   r    s     
 
5 
rc   c                	    V P                   P                  4       p\        VP                  VP                  \        VP                  4      VP                  R 7      # ))r  r  	borrowersrp  )r  rq  r+   r  r  tupler  rp  )r   origs   & ra   rq  CapacityLimiter.statistics  sH    ))+( 00**DNN+,,	
 	
rc   r   rp   )r   r   r   r   r   r   r   r   r   r   r  r   r  r  r  r  r  r  r  r  rq  r   r_   rc   ra   r:   r:   H  s    I# 15	# #
A 15	
A 
A2C , , - - / / 0 0''(=)>
 
rc   r:   _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# )_SignalReceiveri  zAsyncIterator[int]	_iteratorc                   V ^8  d   QhRR/# )r[   signalsztuple[Signals, ...]r_   )r`   s   "ra   rb   _SignalReceiver.__annotate__  s         3  rc   c                	    Wn         R # rp   )_signals)r   r  s   &&ra   r   _SignalReceiver.__init__  s    rc   c                   V ^8  d   QhRR/# r[   r^   r  r_   )r`   s   "ra   rb   r    s      ? rc   c                	    \         P                  ! V P                  !  V n        V P                  P	                  4       V n        V # rp   )r   open_signal_receiverr  _cmr   r	  r   s   &ra   r   _SignalReceiver.__enter__  s1    ,,dmm<++-rc   c               (    V ^8  d   QhRRRRRRRR/# )	r[   r   r   r   r   r   r   r^   zbool | Noner_   )r`   s   "ra   rb   r    s2     < <,< &< %	<
 
<rc   c                	:    V P                   P                  WV4      # rp   )r  r   r   s   &&&&ra   r   _SignalReceiver.__exit__  s     xx  F;;rc   c                   V ^8  d   QhRR/# r  r_   )r`   s   "ra   rb   r    s      ? rc   c                	    V # rp   r_   r   s   &ra   	__aiter___SignalReceiver.__aiter__  s    rc   c                   V ^8  d   QhRR/# )r[   r^   r   r_   )r`   s   "ra   rb   r    s       rc   c                	h   "   V P                   P                  4       G R j  xL
 p\        V4      #  L5irp   )r	  	__anext__r   )r   signums   & ra   r  _SignalReceiver.__anext__  s)     ~~//11v 2s   202)r  r	  r  N)r   r   r   r   r   r   r   r   r  r  r   r_   rc   ra   r  r    s&    !! 
< rc   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 R lt
R R ltR R ltRtR# )
TestRunneri  c                    V ^8  d   QhRRRR/# )r[   optionsr   r^   r   r_   )r`   s   "ra   rb   TestRunner.__annotate__  s        #  $  rc   c                	D    ^ RI Hp V! 4       V n        RV n        Wn        R# )r   )QueueN)queuer(  _call_queue_send_stream_options)r   r%  r(  s   &, ra   r   TestRunner.__init__  s#    8=  	  rc   c               (    V ^8  d   QhRRRRRRRR/# )	r[   r   r   r   r   r   ztypes.TracebackType | Noner^   r   r_   )r`   s   "ra   rb   r&    s2     	) 	),	) &	) +		)
 
	)rc   c                	    V P                   '       dL   V P                   P                  4        V P                   e"   V P                  P                  4       ! 4        K/  R # R # rp   )r+  r   r*  getr   s   &&&&ra   r   TestRunner.__exit__  sM     ##%##/  $$&( 0 rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r&    rk  rc   c                	>    \         P                  P                  4       # rp   )r   r  in_trio_taskr   s   &ra   
is_runningTestRunner.is_running  s    }}))++rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   r&    s     9 9t 9rc   c           	     	  "   \         \        \        \        ,          \        \
        ,          3,          ,          ! ^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)r  N)r8   r  r   r   r  r"   r+  r  r#   rI  r!   )r   receive_streamrq   outcome_holderretvalr   s   &     ra   _run_tests_and_fixtures"TestRunner._run_tests_and_fixtures  s     ,G)C.$w-/0-

-)> ^3A 9 9/i9#,_F #))%-89,$ 6"))%*556 4B ^^^sx   AC CC B	
C C#B(B
)B-C	C BB=	B8	2C8B=	=C
C C		C c                    V ^8  d   QhRRRR/# )r[   outcomer|   r^   r   r_   )r`   s   "ra   rb   r&    s     ! !6 !d !rc   c                	    R V n         R # rp   )r+  )r   r?  s   &&ra   _main_task_finishedTestRunner._main_task_finished  s
     rc   c               (    V ^8  d   QhRRRRRRRR/# )	r[   r\   r]   rf   rg   rh   ri   r^   rT   r_   )r`   s   "ra   rb   r&    s2     * *.* 	*
 * 
*rc   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+  r   r  start_guest_runr<  r*  putrA  r,  r0  send_nowaitunwrap)r   r\   rf   rh   r:  s   ""*, ra   _call_in_runner_taskTestRunner._call_in_runner_task  s     $MM)),,)-)9)9)=)= #66 --	 ##+  $$&((*%%tT'<V'<n&MN   "$a ''))rc   c               $    V ^8  d   QhRRRRRR/# )r[   fixture_funcz,Callable[..., AsyncGenerator[T_Retval, Any]]rh   dict[str, Any]r^   zIterable[T_Retval]r_   )r`   s   "ra   rb   r&    s-     G GBG G 
	Grc   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 stopr_   )rK  asendr*  r   StopAsyncIteration)r   rN  rh   asyncgenfixturevalues   &&&  ra   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/# )r[   rN  z,Callable[..., Coroutine[Any, Any, T_Retval]]rh   rO  r^   rT   r_   )r`   s   "ra   rb   r&    s-     A ABA A 
	Arc   c                	(    V P                   ! V3/ VB # rp   rK  )r   rN  rh   s   &&&ra   run_fixtureTestRunner.run_fixture  s    
 ((@@@rc   c               $    V ^8  d   QhRRRRRR/# )r[   	test_funcz'Callable[..., Coroutine[Any, Any, Any]]rh   rO  r^   r   r_   )r`   s   "ra   rb   r&    s$     7 7@7JX7	7rc   c                	,    V P                   ! V3/ VB  R # rp   rY  )r   r]  rh   s   &&&ra   run_testTestRunner.run_test  s     	!!)6v6rc   )r*  r,  r+  N)r   r   r   r   r   r   r5  r<  rA  rK  rU  rZ  r_  r   r_   rc   ra   r#  r#    s6     	),9!*0G$A7 7rc   r#  c                  :   a  ] tR tRtR V 3R lltR R ltRtV ;t# )r  i#  c                   V ^8  d   QhRR/# )r[   taskztrio.lowlevel.Taskr_   )r`   s   "ra   rb   TrioTaskInfo.__annotate__$  s     ) )/ )rc   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 # rp   )
parent_nurseryparent_taskidr{  r   r   r   weakrefproxy_task)r   rc  	parent_idr   s   && ra   r   TrioTaskInfo.__init__$  sh    	4#6#6#B#B#B4..::;ID9iiC]]4(
rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   rd  ,  s      $ rc   c                	h     V P                   P                  P                  #   \         d     R # i ; i)F)rk  _cancel_statuseffectively_cancelledReferenceErrorr   s   &ra   has_pending_cancellation%TrioTaskInfo.has_pending_cancellation,  s1    	::,,BBB 	 	s   " 11)rk  )r   r   r   r   r   rs  r   r~  r  s   @ra   r  r  #  s    ) ) rc   r  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TrioBackendi5  c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r[   r\   z1Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]]rf   tuple[Unpack[PosArgsT]]rh   rO  r%  r^   rT   r_   )r`   s   "ra   rb   TrioBackend.__annotate__7  sC     E E?E &E 	E
  E 
Erc   c                	f    V'       d   Q R 4       h\         P                  ! \        V4      .VO5/ VB # )z&unreachable, and not supported by Trio)r   r   rw   )r   r\   rf   rh   r%  s   &&&&&ra   r   TrioBackend.run6  s1     CCCzxx+D1DDDGDDrc   c                   V ^8  d   QhRR/# )r[   r^   r|   r_   )r`   s   "ra   rb   ry  B  s     2 2f 2rc   c                	>    \         P                  P                  4       # rp   )r   r  current_trio_tokenr]  s   &ra   current_tokenTrioBackend.current_tokenA  s    }}//11rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   ry  F  s     # #U #rc   c                	,    \         P                  ! 4       # rp   )r   current_timer]  s   &ra   r  TrioBackend.current_timeE  s      ""rc   c                   V ^8  d   QhRR/# )r[   r^   ztype[BaseException]r_   )r`   s   "ra   rb   ry  J  s      *= rc   c                	"    \         P                  # rp   )r   r   r]  s   &ra   cancelled_exception_class%TrioBackend.cancelled_exception_classI  s    ~~rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   ry  N  s     ) ) )rc   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5irp   )r   r  r  r]  s   &ra   r  TrioBackend.checkpointM  s     mm&&(((   "-+-c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   ry  R  s     6 6d 6rc   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5irp   )r   r  r  r]  s   &ra   r  #TrioBackend.checkpoint_if_cancelledQ  s     mm33555r  c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   ry  V  s     9 9 9rc   c                	^   "   \         P                  P                  4       G R j  xL
  R #  L5irp   )r   r  cancel_shielded_checkpointr]  s   &ra   r  &TrioBackend.cancel_shielded_checkpointU  s     mm66888r  c                    V ^8  d   QhRRRR/# )r[   delayr   r^   r   r_   )r`   s   "ra   rb   ry  Z  s          $  rc   c                	N   "   \         P                  ! V4      G R j  xL
  R #  L5irp   )r   r  )r   r  s   &&ra   r  TrioBackend.sleepY  s     jjs   %#%r   r   Fc               $    V ^8  d   QhRRRRRR/# )r[   r   r   r   r   r^   zabc.CancelScoper_   )r`   s   "ra   rb   ry  ^  s$     = ==48=	=rc   c               	    \        WR 7      # ))r   r   rC   )r   r   r   s   &$$ra   create_cancel_scopeTrioBackend.create_cancel_scope]  s     H<<rc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   ry  d  s     1 15 1rc   c                	,    \         P                  ! 4       # rp   )r   current_effective_deadliner]  s   &ra   r  &TrioBackend.current_effective_deadlinec  s    ..00rc   c                   V ^8  d   QhRR/# )r[   r^   zabc.TaskGroupr_   )r`   s   "ra   rb   ry  h  s      - rc   c                	    \        4       # rp   )r   r]  s   &ra   create_task_groupTrioBackend.create_task_groupg  s
    {rc   c                   V ^8  d   QhRR/# )r[   r^   z	abc.Eventr_   )r`   s   "ra   rb   ry  l  s      Y rc   c                	    \        4       # rp   r;   r]  s   &ra   create_eventTrioBackend.create_eventk  s	    wrc   c                    V ^8  d   QhRRRR/# r|  r_   )r`   s   "ra   rb   ry  p  s     / /$ /4 /rc   c               	    \        VR 7      # ))rz  r=   r  s   &$ra   create_lockTrioBackend.create_locko  s    ..rc   r  Nrz  c               (    V ^8  d   QhRRRRRRRR/# )	r[   r  rN  r  r  rz  r   r^   zabc.Semaphorer_   )r`   s   "ra   rb   ry  t  s8     X XX 	X
 X 
Xrc   c               	    \        WVR 7      # )r  rA   r  s   &&$$ra   create_semaphoreTrioBackend.create_semaphores  s     ,WWrc   c                    V ^8  d   QhRRRR/# )r[   r  r   r^   r:   r_   )r`   s   "ra   rb   ry  ~  s     - -5 -_ -rc   c                	    \        V4      # rp   r9   )r   r  s   &&ra   create_capacity_limiter#TrioBackend.create_capacity_limiter}  s    |,,rc   c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r[   r\   &Callable[[Unpack[PosArgsT]], T_Retval]rf   rx  abandon_on_cancelr   limiterzabc.CapacityLimiter | Noner^   rT   r_   )r`   s   "ra   rb   ry    s<     
 
4
 &
  	

 ,
 

rc   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/# rm   r_   )r`   s   "ra   rb   ;TrioBackend.run_sync_in_worker_thread.<locals>.__annotate__  s     	# 	# 	#rc   c                 ~   < \        \        S4      ;_uu_ 4        S! S !  uuR R R 4       #   + '       g   i     R # ; irp   )r2   rv  )rf   r\   tokens   ra   ru   6TrioBackend.run_sync_in_worker_thread.<locals>.wrapper  s&    $[%88T{ 9888s   +<	)r  r  N)rv  r  r*   r   r   r:   )r   r\   rf   r  r  ru   r  s   &ff&& @ra   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   r_   )r`   s   "ra   rb   ry    s     + + +rc   c                	B    \         P                  P                  4        R # rp   )r   from_threadcheck_cancelledr]  s   &ra   r  TrioBackend.check_cancelled  s    ((*rc   c               (    V ^8  d   QhRRRRRRRR/# )	r[   r\   r  rf   rx  r  r|   r^   rU   r_   )r`   s   "ra   rb   ry    s2     
- 
-E
- &
- 	
-
 

-rc   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   r   r  r   r.   r   r\   rf   r  r  s   &&&& ra   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/# )	r[   r\   r  rf   rx  r  r|   r^   rT   r_   )r`   s   "ra   rb   ry    s2     
- 
-4
- &
- 	
-
 

-rc   c                	    \        R V4      p \        P                  P                  ! V.VO5RV/ #   \        P                   d	    \        Rhi ; ir  )r   r   r  r*   r.   r  s   &&&& ra   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
/# )r[   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]ri  zint | IO[Any] | Nonero  rt  rh   r   r^   r=  r_   )r`   s   "ra   rb   ry    sN     &L &L:&L $	&L
 %&L %&L &L 
&Lrc   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/# )r[   r2  rJ   r^   strr_   )r`   s   "ra   rb   .TrioBackend.open_process.<locals>.__annotate__  s     	1 	1~ 	1# 	1rc   c                    \         P                  ! V 4      p\        V\        4      '       d   V# \         P                  ! V4      # rp   )osfspathrt   r  fsdecode)r2  str_or_bytess   & ra   convert_item.TrioBackend.open_process.<locals>.convert_item  s1    99T?L,,,##{{<00rc   ri  ro  rt  shellTNF)rt   r  r  r   r   r  open_processri  r/  ro  r  rt  r=  )r   r  ri  ro  rt  rh   r  r  r2  stdin_streamstdout_streamstderr_streams   &&$$$,      ra   r  TrioBackend.open_process  s?    	1 gUH566 MM66W%  	
   G !MM66078d#8  	
   G <C===(7d@G,W^^<TX@G,W^^<TXwmKK+ 9sB   AD8D/#D8 D1D8#D6$D8:(D8#(D8$D81D8c                    V ^8  d   QhRRRR/# r  r_   )r`   s   "ra   rb   ry    s     I I:J It Irc   c                	N    \         P                  P                  \        V4       R # rp   )r   r  spawn_system_taskr  )r   r  s   &&ra   #setup_process_pool_exit_at_shutdown/TrioBackend.setup_process_pool_exit_at_shutdown  s    ''(>Hrc   c               (    V ^8  d   QhRRRRRRRR/# )	r[   hostr  portrN  local_addressIPSockAddrType | Noner^   r  r_   )r`   s   "ra   rb   ry    s,     ) ))!)2G)	)rc   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_INETr   r  r  r  bindconnectrI  r   r  )r   r  r  r  familyr  s   &&&&  ra   connect_tcpTrioBackend.connect_tcp  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/# )r[   pathstr | bytesr^   zabc.UNIXSocketStreamr_   )r`   s   "ra   rb   ry    s     - -k -6J -rc   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rp   )r   r  AF_UNIXr  rI  r   r  )r   r  r  s   && ra   connect_unixTrioBackend.connect_unix  se     kk((8	%%d+++
  ,, , 		s.   .A7A AA 
A7A A44A7c                    V ^8  d   QhRRRR/# r[   sockr  r^   zabc.SocketListenerr_   )r`   s   "ra   rb   ry    s     ' '} '9K 'rc   c                	    \        V4      # rp   )r  r   r   s   &&ra   create_tcp_listenerTrioBackend.create_tcp_listener  s     &&rc   c                    V ^8  d   QhRRRR/# r  r_   )r`   s   "ra   rb   ry    s     ( ( (:L (rc   c                	    \        V4      # rp   )r  r  s   &&ra   create_unix_listener TrioBackend.create_unix_listener   s    !$''rc   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r[   r  zsocket.AddressFamilyr  r  remote_address
reuse_portr   r^   zUDPSocket | ConnectedUDPSocketr_   )r`   s   "ra   rb   ry    s<     * *$* -* .	*
 * 
(*rc   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)
r   r  
SOCK_DGRAMr  r  SO_REUSEPORTr  r  r-  r  )r   r  r  r
  r  r  s   &&&&& ra   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/# )r[   r  r  remote_pathr   r^   zabc.UNIXDatagramSocketr_   )r`   s   "ra   rb   ry    s$     % %&%59%	%rc   c                	   "   R # 5irp   r_   r   r  r  s   &&&ra   create_unix_datagram_socket'TrioBackend.create_unix_datagram_socket  s
      "%   c               $    V ^8  d   QhRRRRRR/# )r[   r  r  r  r  r^   zabc.ConnectedUNIXDatagramSocketr_   )r`   s   "ra   rb   ry  "  s$     . .&.5@.	(.rc   c                	   "   R # 5irp   r_   r  s   &&&ra   r  r     s
      +.r  c               $    V ^8  d   QhRRRRRR/# )r[   r  r  r  zstr | bytes | Noner^   z8abc.UNIXDatagramSocket | abc.ConnectedUNIXDatagramSocketr_   )r`   s   "ra   rb   ry  '  s$     	3 	3&	35G	3	A	3rc   c                	   "   \         P                  P                  V4      pV'       d%   VP                  V4      G R j  xL
  \	        V4      # \        V4      #  L5irp   )r   r  r  r  rN  rB  )r   r  r  r  s   &&& ra   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/# )r[   r  zbytes | str | Noner  zstr | int | Noner  zint | AddressFamilyr  zint | SocketKindr  rN  r  r^   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]r_   )r`   s   "ra   rb   ry  3  sY     U U U U
 $U U U U
Urc   c               	`   "   \         P                  P                  WW4WV4      G R j  xL
 #  L5irp   )r   r  getaddrinfo)r   r  r  r  r  r  r  s   &&&$$$$ra   r   TrioBackend.getaddrinfo2  s&     & [[,,TuTTTTs   %.,.c               $    V ^8  d   QhRRRRRR/# )r[   sockaddrrF   r  rN  r^   ztuple[str, str]r_   )r`   s   "ra   rb   ry  H  s$     > >%>.1>	>rc   c                	\   "   \         P                  P                  W4      G R j  xL
 #  L5irp   )r   r  getnameinfo)r   r#  r  s   &&&ra   r%  TrioBackend.getnameinfoG  s"      [[,,X====s   #,*,c                    V ^8  d   QhRRRR/# r[   objrO   r^   r   r_   )r`   s   "ra   rb   ry  N  s     > >&8 >T >rc   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)Nr  )r'   r   r5   with_traceback__traceback__r4   r   r)  r   s   && ra   r'   TrioBackend.wait_readableM  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(  r_   )r`   s   "ra   rb   ry  W  s     < <&8 <T <rc   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)Nr  )r(   r   r5   r+  r,  r4   r-  s   && ra   r(   TrioBackend.wait_writableV  se     	<$$$'' 	T%'66s7H7HItS%% 	<#L1t;	<r/  c                    V ^8  d   QhRRRR/# r(  r_   )r`   s   "ra   rb   ry  `  s      !3  rc   c                	    \        V4       R # rp   )r&   )r   r)  s   &&ra   r&   TrioBackend.notify_closing_  s
    src   c                    V ^8  d   QhRRRR/# r  r_   )r`   s   "ra   rb   ry  d  s     ' 'm '@R 'rc   c                	   "   \        \        R 4      '       d+   VP                  \        P                  8X  d   \	        V4      # \        V4      # 5i)r  )hasattrr  r  r  r  r  r  s   &&ra   wrap_listener_socket TrioBackend.wrap_listener_socketc  s7     69%%$++*G%d++ &&s   AAc                    V ^8  d   QhRRRR/# )r[   r   r  r^   r  r_   )r`   s   "ra   rb   ry  k  s     ' 'M 'l 'rc   c                	^   "   \         P                  P                  V4      p\        V4      # 5irp   )r   r  r  r  r   r   	trio_socks   && ra   wrap_stream_socketTrioBackend.wrap_stream_socketj  s$     KK2248	I&&   +-c                    V ^8  d   QhRRRR/# )r[   r   r  r^   r  r_   )r`   s   "ra   rb   ry  p  s     + + +CS +rc   c                	^   "   \         P                  P                  V4      p\        V4      # 5irp   )r   r  r  r  r=  s   && ra   wrap_unix_stream_socket#TrioBackend.wrap_unix_stream_socketo  s$     KK2248		**rA  c                    V ^8  d   QhRRRR/# )r[   r   r  r^   r  r_   )r`   s   "ra   rb   ry  u  s     $ $ $9 $rc   c                	^   "   \         P                  P                  V4      p\        V4      # 5irp   )r   r  r  r  r=  s   && ra   wrap_udp_socketTrioBackend.wrap_udp_sockett  s$     KK2248	##rA  c                    V ^8  d   QhRRRR/# )r[   r   r  r^   r-  r_   )r`   s   "ra   rb   ry  z       - -= -EW -rc   c                	^   "   \         P                  P                  V4      p\        V4      # 5irp   )r   r  r  r-  r=  s   && ra   wrap_connected_udp_socket%TrioBackend.wrap_connected_udp_sockety  $     KK2248	!),,rA  c                    V ^8  d   QhRRRR/# )r[   r   r  r^   rB  r_   )r`   s   "ra   rb   ry    rK  rc   c                	^   "   \         P                  P                  V4      p\        V4      # 5irp   )r   r  r  rB  r=  s   && ra   wrap_unix_datagram_socket%TrioBackend.wrap_unix_datagram_socket~  rO  rA  c                    V ^8  d   QhRRRR/# )r[   r   r  r^   rN  r_   )r`   s   "ra   rb   ry    s     6 6 6	$6rc   c                	^   "   \         P                  P                  V4      p\        V4      # 5irp   )r   r  r  rN  r=  s   && ra   #wrap_connected_unix_datagram_socket/TrioBackend.wrap_connected_unix_datagram_socket  s&      KK2248	*955rA  c                   V ^8  d   QhRR/# )r[   r^   r:   r_   )r`   s   "ra   rb   ry    s       rc   c                	     \         P                  4       #   \         dC    \        \        P
                  P                  4       R 7      p\         P                  T4       Tu # i ; i))rz   )r  r0  LookupErrorr:   r   	to_threadcurrent_default_thread_limiterrw  )r   r  s   & ra   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/# )r[   r  r   r^   z.AbstractContextManager[AsyncIterator[Signals]]r_   )r`   s   "ra   rb   ry    s     ( ((	7(rc   c                	    \        V4      # rp   )r  )r   r  s   &*ra   r   TrioBackend.open_signal_receiver  s     w''rc   c                   V ^8  d   QhRR/# )r[   r^   r/   r_   )r`   s   "ra   rb   ry    s     " " "rc   c                	,    \        4       p\        V4      # rp   )r%   r  )r   rc  s   & ra   get_current_taskTrioBackend.get_current_task  s    ~D!!rc   c                   V ^8  d   QhRR/# )r[   r^   zSequence[TaskInfo]r_   )r`   s   "ra   rb   ry    s      "4 rc   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# rp   )r$   r  child_nurserieschild_tasksr  extend)r   	root_task
task_infos	nurseriesnew_nurseriesnurseryrc  s   &      ra   get_running_tasksTrioBackend.get_running_tasks  s    %'	y"9-.
--	02M$#//D%%l4&89!(()=)=> 0 %
 &Irc   c                   V ^8  d   QhRR/# r   r_   )r`   s   "ra   rb   ry    s     ' 'T 'rc   c                	<   "   ^ RI Hp V! 4       G Rj  xL
  R#  L5i)r   )wait_all_tasks_blockedN)trio.testingrs  )r   rs  s   & ra   rs  "TrioBackend.wait_all_tasks_blocked  s     7$&&&s   c                    V ^8  d   QhRRRR/# )r[   r%  rO  r^   r#  r_   )r`   s   "ra   rb   ry    s     % % %J %rc   c                	    \        R/ VB # r   )r#  )r   r%  s   &&ra   create_test_runnerTrioBackend.create_test_runner  s    $G$$rc   r_   r  rp   )r   )6r   r   r   r   classmethodr   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%  r'   r(   r&   r9  r?  rD  rH  rM  rR  rV  r\  r  rc  ro  rs  rx  r   r_   rc   ra   rv  rv  5  s   E E 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   ( (
 " "    ' '
 % %rc   rv  )      )__conditional_annotations__
__future__r   r  r  r  r  systypesri  collections.abcr   r   r   r   r   r	   r
   r   
contextlibr   contextvarsr   dataclassesr   	functoolsr   r   ior   r   rZ  r   r   r   r   typingr   r   r   r   r   r   r   r   r   r    trio.from_threadr   trio.lowlevelr?  r!   r"   r#   r$   r%   r&   r'   r(   trio.socketr)   r  trio.to_threadr*    r+   r,   r-   r.   r/   r0   r1   _core._eventloopr2   _core._exceptionsr3   r4   r5   r6   _core._socketsr7   _core._streamsr8   _core._synchronizationr:   BaseCapacityLimiterr<   	BaseEventr>   BaseLockr?   r@   rB   BaseSemaphore_core._tasksrD   BaseCancelScoperE   rF   rG   rH   abc._eventlooprI   rJ   
abc._tasksrK   rL   rM   streams.memoryrN   	_typeshedrO   version_inforP   rQ   exceptiongrouprR   typing_extensionsrS   rT   rU   r  rW   rX   rY   rw   r  RunVarr|   r   
TaskStatusr   r   ByteReceiveStreamr  ByteSendStreamr/  r=  
Instrumentrw  r  r   r  r  r  r  SocketListenerr  r  r  r-  rB  rN  r  r  r#  r  rv  backend_class)r}  s   @ra   <module>r     s   " "   	  
  	 	 	 .  ! $    ,      ) )  5 #   3  3 8 8 5 @ 9 % G G 9 H H 3,w++16CL:v&\37

#cN8 
		0'/ 0'n H 1gh')A 1a aR e$300 $ $. e$** $ $ e5ckk 5 5pTXX%8%8 
 @F,@ &(< 

'$wz* >!3#S%5%5 !3H@4|S%9%9 @4F)(#*<*< ) -)3+=+= -0 0#-- 0,0).93;Q;Q 0*0)#.0F0F 0,0S3::08I .7
8 7
t5B 5BpQ
) Q
h 399T2U / U @\7 \7~8 $D%, D%N rc   