+
    Di/                   	  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t^ RIt^ RIt^ RIHtHtHtHtHtHtHt ^ RIHt ^ RIHtH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%H&t& ^ R	IH't'H(t( ^ R
I)H*t*H+t+ ^ RI,H-t-H.t. ^ RI/H0t0H1t1H2t2H3t3 ^ RI4H5t5 ^ RI	H6t6 ^ RI7H8t8 ^ RI9H:t: ^ RI
H;t;H<t< ^ RIH=t= ^ RI>H?t?H@t@ ^ RIAHBtBHCtCHDtDHEtEHFtFHGtG ^ RIHHtH ^RIIHJtJHKtKHLtLHMtMHNtN ^RIOHPtPHQtQHRtR ^RISHTtTHUtUHVtVHWtWHXtXHYtYHZtZ ^RI[H\t\ ^RI]H^t^ ^RI_H`ta ^RI_Hbtc ^RI_Hdte ^RI_HftfHgtg ^RI_Hhti ^R IjHktl ^R!INHmtmHntnHotoHptpHqtq ^R"IrHsts ^R#ItHutu ^R$IvHwtwHxtx ]C'       d   ^ R%IyHztz M]{tz]P                  R8  d   ^ R&IAH}t} M^ R&I~H}t} ]P                  R8  d   ^ R'IHt ^ R(IAHtHt MR^ RIt^ RIt^ RI9t9^ R)IHtHtHtHt ^ R*IHt ^ R(I~HtHt  ! R+ R,]EP                  4      t ! R- R.4      tR/ R0 ltR1 R2 lt]F! R34      t]F! R4R5R67      t]! R74      t]}! R84      t]u! R94      tR:]R9&   R; R< ltR= R> lt]H! 4       tR?]R@&   RA RB ltRC RD lt ! RE RF]l4      tk ! RG RH4      t]H! 4       tRI]RJ&    ! RK RL]NEP4                  4      t]P                  R8  d   ]EP8                  EP:                  tRM]RN&   MRt ! RO RP]NEP>                  4      t]]E],          ]E],          3,          t ! RQ RR]=4      t]u! RS4      tRT]RS&   ]u! RU4      tRV]RU&   ]*! RWRX7       ! RY RZ]NEPL                  4      4       t]*! RWRX7       ! R[ R\]NEPP                  4      4       t]*! RWRX7       ! R] R^]NEPT                  4      4       tR_ R` ltRa Rb lt ! Rc Rd]EPZ                  4      t ! Re Rf]EP^                  4      t ! Rg Rh]NEP`                  4      t ! Ri Rj4      t ! Rk Rl]]NEPd                  4      t ! Rm Rn]NP                  4      t ! Ro Rp]NP                  4      t ! Rq Rr]NEPj                  4      t ! Rs Rt]NEPl                  4      t ! Ru Rv]]NEPn                  4      t ! Rw Rx]]NEPp                  4      t]u! Ry4      tRz]R{&   ]u! R|4      tRz]R}&    ! R~ R]c4      tb ! R R]e4      td ! R R]i4      th ! R R]a4      t`]u! R4      tR]R&    ! R R4      t ! R R]M4      t ! R R]NEP|                  4      t ! R R]m4      t]tR# )    )annotationsN)AbstractEventLoopCancelledError	all_taskscreate_taskcurrent_taskget_running_loopsleep)_run_until_complete_cb)OrderedDictdeque)AsyncGeneratorAsyncIterator	AwaitableCallable
Collection	CoroutineIterableSequence)Future)AbstractContextManagersuppress)Contextcopy_context)	dataclassfield)partialwraps)CORO_RUNNINGCORO_SUSPENDEDgetcoroutinestateiscoroutine)IOBase)PathLike)Queue)Signals)AddressFamily
SocketKind)Thread)CodeTypeTracebackType)IOTYPE_CHECKINGAnyOptionalTypeVarcast)WeakKeyDictionary)CapacityLimiterStatisticsEventStatisticsLockStatisticsTaskInfoabc)claim_worker_threadset_current_async_librarythreadlocals)BrokenResourceErrorBusyResourceErrorClosedResourceErrorEndOfStreamRunFinishedError
WouldBlockiterate_exceptions)convert_ipv6_sockaddr)create_memory_object_streamCapacityLimiterEventLock)ResourceGuardSemaphoreStatistics	SemaphoreCancelScope)AsyncBackendIPSockAddrTypeSocketListenerUDPPacketTypeUNIXDatagramPacketType)StrOrBytesPath)RunVar)MemoryObjectReceiveStreamMemoryObjectSendStream)FileDescriptorLike)	ParamSpec)Runner)TypeVarTupleUnpack)
coroutinesevents
exceptionstasks)BaseExceptionGroupc                  "    ] tR t^tRtRtRtRtR# )_Statecreatedinitializedclosed N)__name__
__module____qualname____firstlineno__CREATEDINITIALIZEDCLOSED__static_attributes__rh       v/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/anyio/_backends/_asyncio.pyrd   rd      s    #rq   rd   c                      ] tR t^tRRRR/R R lltR R ltR R	 ltR
 R ltR R ltRR/R R llt	R R lt
R R ltRtR# )r[   debugNloop_factoryc                    V ^8  d   QhRRRR/# )   rt   bool | Noneru   &Callable[[], AbstractEventLoop] | Nonerh   )formats   "rr   __annotate__Runner.__annotate__   s!     	) 	) 	) A		)rq   c               	    \         P                  V n        Wn        W n        R V n        R V n        ^ V n        RV n        R # )NF)	rd   rm   _state_debug_loop_factory_loop_context_interrupt_count_set_event_loop)selfrt   ru   s   &$$rr   __init__Runner.__init__   s8     !..DKK!-37DJ DM$%D!#(D rq   c                   V ^8  d   QhRR/# )rw   returnr[   rh   )rz   s   "rr   r{   r|      s     	 	v 	rq   c                	&    V P                  4        V # N)
_lazy_initr   s   &rr   	__enter__Runner.__enter__   s    OOKrq   c               (    V ^8  d   QhRRRRRRRR/# 	rw   exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Noner   Nonerh   )rz   s   "rr   r{   r|      s2     	 	0	 *	 )		
 	rq   c                	&    V P                  4        R # r   )closer   r   r   r   s   &&&&rr   __exit__Runner.__exit__   s     JJLrq   c                   V ^8  d   QhRR/# rw   r   r   rh   )rz   s   "rr   r{   r|      s     	, 	,4 	,rq   c                   V P                   pV P                  \        P                  Jg   Vf   R#  \	        V4       VP                  VP                  4       4       \        VR4      '       d!   VP                  VP                  4       4       MVP                  \        V4      4       V P                  '       d   \        P                  ! R4       VP                  4        RV n         \        P                  V n        R#   T P                  '       d   \        P                  ! R4       TP                  4        RT n         \        P                  T n        i ; i)zShutdown and close event loop.Nshutdown_default_executor)r   r~   rd   rn   _cancel_all_tasksrun_until_completeshutdown_asyncgenshasattrr   _shutdown_default_executorr   r_   set_event_loopr   ro   r   loops   & rr   r   Runner.close   s    ::D{{&"4"44,!$'''(?(?(AB4!<==++D,J,J,LM++,Ft,LM'''))$/

!
$mm	 '''))$/

!
$mms   A6C> >AEc                   V ^8  d   QhRR/# rw   r   r   rh   )rz   s   "rr   r{   r|      s     	 	/ 	rq   c                :    V P                  4        V P                  # )zReturn embedded event loop.)r   r   r   s   &rr   get_loopRunner.get_loop   s    OO::rq   contextc                    V ^8  d   QhRRRR/# )rw   corozCoroutine[T_Retval]r   T_Retvalrh   )rz   s   "rr   r{   r|      s     .	M .	M/ .	MX .	Mrq   c                  \         P                  ! V4      '       g   \        RV: 24      h\        P                  ! 4       e   \        R4      hV P                  4        Vf   V P                  pVP                  V P                  P                  V4      p\        P                  ! 4       \        P                  ! 4       J du   \        P                  ! \        P                   4      \        P"                  J d?   \%        V P&                  VR7      p \        P                  ! \        P                   V4       MRp^ V n         V P                  P+                  V4      Ve^   \        P                  ! \        P                   4      VJ d5   \        P                  ! \        P                   \        P"                  4       # # #   \         d    Rp Li ; i  \,        P.                   d7    T P(                  ^ 8  d$   \1        TRR4      pTe   T! 4       ^ 8X  d   \2        hh i ; i  Te^   \        P                  ! \        P                   4      TJ d5   \        P                  ! \        P                   \        P"                  4       i i i ; i)z/Run a coroutine inside the embedded event loop.za coroutine was expected, got Nz7Runner.run() cannot be called from a running event loop)	main_taskuncancel)r^   r"   
ValueErrorr_   _get_running_loopRuntimeErrorr   r   runr   r   	threadingcurrent_threadmain_threadsignal	getsignalSIGINTdefault_int_handlerr   
_on_sigintr   r   r`   r   getattrKeyboardInterrupt)r   r   r   tasksigint_handlerr   s   &&$   rr   r   
Runner.run   s   ))$// #A$!JKK'')5"M  OO--;;tzz55t<D ((*i.C.C.EE$$V]]3v7Q7QQ!(D!I*MM&--@ "&$%D!Mzz44T: #.((7>IMM&--1K1KL J /' " * &*N	* ,, ((1,&tZ>H+
a// #.((7>IMM&--1K1KL J /s,   %F: >G :G
	G
AHH A#I>c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r|      s     	- 	- 	-rq   c                	J   V P                   \        P                  J d   \        R 4      hV P                   \        P                  J d   R# V P
                  fU   \        P                  ! 4       V n        V P                  '       g(   \        P                  ! V P                  4       RV n	        MV P                  4       V n        V P                  e&   V P                  P                  V P                  4       \        P                  ! 4       V n        \        P                  V n         R# )zRunner is closedNT)r~   rd   ro   r   rn   r   r_   new_event_loopr   r   r   r   	set_debugcontextvarsr   r   r   s   &rr   r   Runner._lazy_init   s    {{fmm+"#566{{f000!!)#224
+++ ))$**5+/D(!//1
{{&

$$T[[1'446DM ,,DKrq   c                    V ^8  d   QhRRRR/# )rw   r   asyncio.Taskr   r   rh   )rz   s   "rr   r{   r|      s     	& 	&| 	& 	&rq   c                	    V ;P                   ^,          un         V P                   ^8X  dE   VP                  4       '       g/   VP                  4        V P                  P	                  R 4       R# \        4       h)   c                     R # r   rh   rh   rq   rr   <lambda>#Runner._on_sigint.<locals>.<lambda>  s    rq   N)r   donecancelr   call_soon_threadsafer   )r   signumframer   s   &&&&rr   r   Runner._on_sigint   sW    !!Q&!$$))..2B2B  "

//=#%%rq   )r   r   r   r   r   r   r~   )ri   rj   rk   rl   r   r   r   r   r   r   r   r   rp   rh   rq   rr   r[   r[      sO    	) "&	) DH		)			,&	
.	MD .	M`	-&	& 	&rq   r[   c                    V ^8  d   QhRRRR/# rw   r   r   r   r   rh   )rz   s   "rr   r{   r{     s       1 d rq   c           	     v   \         P                  ! V 4      pV'       g   R # V F  pVP                  4        K  	  V P                  \         P                  ! VRR/ 4       V FT  pVP                  4       '       d   K  VP                  4       f   K/  V P                  RRRVP                  4       RV/4       KV  	  R # )Nreturn_exceptionsTmessagez1unhandled exception during asyncio.run() shutdown	exceptionr   )ra   r   r   r   gather	cancelledr   call_exception_handler)r   	to_cancelr   s   &  rr   r   r     s    OOD)	DKKM  	i P4 PQD~~~~+++!#V#T^^%5	 rq   c                    V ^8  d   QhRRRR/# r   rh   )rz   s   "rr   r{   r{     s      /@ T rq   c                $  a "   R V 3R llpRS n         S P                  f   R# S P                  4       p\        P                  ! W3R7      pVP                  4         VG Rj  xL
  VP                  4        R#  L  TP                  4        i ; i5i)z.Schedule the shutdown of the default executor.c                    V ^8  d   QhRRRR/# )rw   futurezasyncio.futures.Futurer   r   rh   )rz   s   "rr   r{   0_shutdown_default_executor.<locals>.__annotate__  s     	D 	D!7 	DD 	Drq   c                   <  SP                   P                  R R7       SP                  V P                  R4       R#   \         d(   pSP                  T P
                  T4        Rp?R# Rp?ii ; i)T)waitN)_default_executorshutdownr   
set_result	Exceptionset_exception)r   exr   s   & rr   _do_shutdown0_shutdown_default_executor.<locals>._do_shutdown  sa    D&&//T/:))&*;*;TB D))&*>*>CCDs   8= A/A**A/TN)targetargs)_executor_shutdown_calledr   create_futurer   r)   startjoin)r   r   r   threads   f   rr   r   r     sx     	D 	D *.&!!)##%!!IF	LLKKM KKMs0   ABA; "A9#A; 'B9A; ;BBr   T_contraT)contravariantPosArgsTP
_root_taskzRunVar[asyncio.Task | None]c                   V ^8  d   QhRR/# )rw   r   r   rh   )rz   s   "rr   r{   r{   :  s       rq   c                    \         P                  R 4      p V e   V P                  4       '       g   V # \        4        F  pVP                  '       g   K  VP                  4       '       d   K/  VP                   UUu. uF  w  r#VNK	  	  pppV F:  pV\
        J g   \        VRR 4      R8X  g   K!  \         P                  V4       Vu u # 	  K  	  \        \        P                  \        4       4      p\        P                  V4      pV'       dY   VP                  pV'       d   VP                  e   VP                  pK$  Ve%   \        \        P                  VP                  4      # V# u uppi )Nrj   zuvloop.loop)r   getr   r   
_callbacksr   r   setr1   asyncioTaskr   _task_statescancel_scope_parent_scope
_host_task)	root_taskr   cbr   	callbacksstater  s          rr   find_root_taskr  :  s   t$IY^^%5%5 ???499;;/3?I?00r<6-GNN4(K    ln-DT"E))|99E'55L#l&=&=>>K) @s   :E'c                    V ^8  d   QhRRRR/# )rw   funcr   r   strrh   )rz   s   "rr   r{   r{   Y  s     : :H : :rq   c                    \        V R R4      p\        V RR4      pRP                  W3 Uu. uF  q3'       g   K  VNK  	  up4      # u upi )rj   Nrk   .)r   r   )r  modulequalnamexs   &   rr   get_callable_namer  Y  sH    T<.Ft^T2H88 28 21aQQ 28998s
   	AAz1WeakKeyDictionary[asyncio.AbstractEventLoop, Any]	_run_varsc                    V ^8  d   QhRRRR/# )rw   r   r   r   boolrh   )rz   s   "rr   r{   r{   f  s     
Y 
Y 
Y 
Yrq   c                    V P                  4       pVf   Q h \        V4      \        \        39   #   \         d    \        RT  R24      Rhi ; i)zBReturn ``True`` if the task has been started and has not finished.NzCannot determine if task z has started or not)get_coror!   r   r    AttributeErrorr   )r   r   s   & rr   _task_startedr  f  s`     ==?DY &<*HHH Y3D69LMNTXXYs	   0 Ac                    V ^8  d   QhRRRR/# )rw   excr   r   r  rh   )rz   s   "rr   r{   r{   x  s      ~ $ rq   c                *    V P                   '       dR   \        V P                   ^ ,          \        4      '       d+   V P                   ^ ,          P                  R4      '       d   R # \        V P                  \
        4      '       d   V P                  p K  R# )TCancelled via cancel scope F)r   
isinstancer  
startswith__context__r   )r!  s   &rr   is_anyio_cancellationr'  x  sb     HHH388A;,,&&'DEEcoo~66//Crq   c                     ] tR tRtR]P
                  RR/R R llt]P
                  R3R R 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 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# )(rO   i  deadlineshieldFc               $    V ^8  d   QhRRRRRR/# rw   r)  floatr*  r  r   rO   rh   )rz   s   "rr   r{   CancelScope.__annotate__  s$     # ##48#	#rq   c               	,    \         P                  V 4      # r   object__new__clsr)  r*  s   &$$rr   r2  CancelScope.__new__  s     ~~c""rq   c                    V ^8  d   QhRRRR/# )rw   r)  r-  r*  r  rh   )rz   s   "rr   r{   r.    s     1 1 14 1rq   c                	   Wn         W n        R V n        \        4       V n        RV n        R V n        RV n        RV n        R V n	        R V n
        \        4       V n        R V n        \        P                  R8  d
   ^ V n        R # R V n        R # )NF      )	_deadline_shieldr	  r  _child_scopes_cancel_called_cancel_reason_cancelled_caught_active_timeout_handle_cancel_handle_tasksr
  sysversion_info_pending_uncancellations)r   r)  r*  s   &&&rr   r   CancelScope.__init__  s{    !15/2u#*.!&;?59),/3w&89D),0D)rq   c                   V ^8  d   QhRR/# )rw   r   rO   rh   )rz   s   "rr   r{   r.    s      ; rq   c                	   V P                   '       d   \        R 4      h\        \        P                  \        4       4      ;V n        pV P                  P                  V4        \        V,          pVP                  V n        Wn
        V P                  eK   V P                  P                  P                  V 4       V P                  P                  P                  V4       T P!                  4        RT n         T P"                  '       d   T P%                  T 4       T #   \         d    \        RT 4      pT\        T&    L^i ; i)z;Each CancelScope may only be used for a single 'with' blockNT)rA  r   r1   r  r  r   r
  rD  addr  r  r	  r=  discardKeyError	TaskState_timeoutr>  _deliver_cancellation)r   	host_task
task_states   &  rr   r   CancelScope.__enter__  s   <<<M  '+7<<&HH)	"	=%i0J
 ",!8!8D&*#!!- ""0044T:""))11)< &&t,'  	1"4.J&0L#	1s   #D  D>=D>c               (    V ^8  d   QhRRRRRRRR/# 	rw   r   r   r   r   r   r   r   r  rh   )rz   s   "rr   r{   r.    s8     J J,J &J %	J
 
Jrq   c                	   ?V P                   '       g   \        R 4      h\        4       V P                  Jd   \        R4      hV P                  f   Q h\        P                  V P                  4      pVe   VP                  V Jd   \        R4      h RV n         V P                  '       d"   V P                  P                  4        RV n        V P                  P                  V P                  4       V P                  eU   V P                  P                  P                  V 4       V P                  P                  P                  V P                  4       V P                  Vn        V P                  4        V P                  '       d   V P                   '       g   V P"                  '       d6   V P                  P%                  4        V ;P"                  ^,          un        KG  RpVeE   \'        V4       F5  p\)        V\*        4      '       d   \-        V4      '       d
   RV n        K3  RpK7  	  V P.                  ;'       d    V'       *  RV n        ?# V P"                  '       d_   V P                  f   Q hV P                  P"                  f   Q hV P                  ;P"                  V P"                  ,          un        ^ V n         RV n        ?R#   RT n        ?i ; i)zThis cancel scope is not activezIAttempted to exit cancel scope in a different task than it was entered inNzTAttempted to exit a cancel scope that isn't the current tasks's current cancel scopeFT)rA  r   r   r
  r  r  r  rB  r   rD  remover	  r=  rK  _restart_cancellation_in_parentr>  %_parent_cancellation_is_visible_to_usrG  r   rA   r$  r   r'  r@  )r   r   r   r   host_task_statecannot_swallow_exc_valr!  s   &&&&   rr   r   CancelScope.__exit__  sd    |||@AA>0 
 ***&**4??;"o&B&B$&N' 
2	 DL###$$++-'+$KKt/!!-""0077=""))--doo>+/+=+=O( 002
 """4+U+U+U333OO,,.11Q61 */&&1':%c>::?T@ @ 6:D2592  ; --LL6L2LL #DO 000--999--FFRRR&&??55? 56D1"DO #DOs9   K *CK K K )BK ;K K AK 
Kc                   V ^8  d   QhRR/# rw   r   r  rh   )rz   s   "rr   r{   r.    s       rq   c                	~    T pVe7   VP                   '       d   R# VP                  '       d   R# VP                  pK:  R# )NTF)r>  r*  r	  )r   r  s   & rr   _effectively_cancelled"CancelScope._effectively_cancelled  s9    +/&***"""'55Lrq   c                   V ^8  d   QhRR/# r^  rh   )rz   s   "rr   r{   r.    s     
 
t 
rq   c                	    V P                   R J;'       d0    V P                  '       * ;'       d    V P                   P                  # r   )r	  r*  r`  r   s   &rr   rY  1CancelScope._parent_cancellation_is_visible_to_us  sC     d* : :KK: :""99	
rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r.  $  s     S S$ Srq   c                	   V P                   \        P                  8w  dj   \        4       pVP	                  4       V P                   8  d   V P                  R 4       R# VP                  V P                   V P                  4      V n        R# R# )zdeadline exceededN)	r;  mathinfr	   timer   call_atrO  rB  r   s   & rr   rO  CancelScope._timeout$  sY    >>TXX%#%Dyy{dnn,/0'+||DNNDMM'R$ &rq   c                    V ^8  d   QhRRRR/# )rw   originrO   r   r  rh   )rz   s   "rr   r{   r.  ,  s     , ,K ,D ,rq   c                   Rp\        4       pV P                   F  pRpVP                  '       d   K  WCJg   K   W@P                  J g   \	        V4      '       g   KB  VP
                  p\        V\        P                  4      '       d   VP                  4       '       d   K  VP                  VP                  4       WAP                  J g   K  VP                  f   K  V;P                  ^,          un        K  	  V P                   FF  pVP                  '       d   K  VP                  '       d   K+  VP!                  V4      ;'       g    TpKH  	  WJ d;   V'       d,   \#        4       P%                  V P                   V4      V n        V# RV n        V# )a*  
Deliver cancellation to directly contained tasks and nested cancel scopes.

Schedule another run at the end if we still have tasks eligible for
cancellation.

:param origin: the cancel scope that originated the cancellation
:return: ``True`` if the delivery needs to be retried on the next cycle

FTN)r   rD  _must_cancelr
  r  _fut_waiterr$  r  r   r   r   r?  rG  r=  r<  cancel_calledrP  r	   	call_soonrC  )r   rm  should_retrycurrentr   waiterscopes   &&     rr   rP  !CancelScope._deliver_cancellation,  s0    .KKDL    "(?=QUCVCV))!&'..99KK 5 56 1 11";;G771<7  $ ''E===)<)<)<$::6BRRl (
 >&6&8&B&B..'#  '+#rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r.  Z  s     ( ( (rq   c                    V P                   pVeV   VP                  '       d"   VP                  f   VP                  V4       R# VP                  '       d   R# VP                   pKY  R# )zR
Restart the cancellation effort in the closest directly cancelled parent scope.

N)r	  r>  rC  rP  r<  r   rv  s   & rr   rX  +CancelScope._restart_cancellation_in_parentZ  s\    
 ""###''///6 }}}''E  rq   Nc                    V ^8  d   QhRRRR/# )rw   reasonz
str | Noner   r   rh   )rz   s   "rr   r{   r.  m  s     1 1Z 14 1rq   c                	   V P                   '       g   V P                  '       d"   V P                  P                  4        R V n        RV n         R\        V 4      R 2V n        \        4       ;p'       d   V ;P                  RV 2,          un        V'       d   V ;P                  RV 2,          un        V P                  e   V P                  V 4       R # R # R # )NTr#  r  z by z
; reason: )r>  rB  r   idr?  r   r
  rP  )r   r}  r   s   && rr   r   CancelScope.cancelm  s    """###$$++-'+$"&D$?4|"LD#~%t%##dV}4###F8'<<#***40 + #rq   c                   V ^8  d   QhRR/# rw   r   r-  rh   )rz   s   "rr   r{   r.    s      % rq   c                	    V P                   # r   )r;  r   s   &rr   r)  CancelScope.deadline~  s    ~~rq   c                    V ^8  d   QhRRRR/# rw   valuer-  r   r   rh   )rz   s   "rr   r{   r.    s      e  rq   c                	    \        V4      V n        V P                  e"   V P                  P                  4        R V n        V P                  '       d'   V P
                  '       g   V P                  4        R # R # R # r   )r-  r;  rB  r   rA  r>  rO  r   r  s   &&rr   r)  r    sW    u+  '')#'D <<< 3 3 3MMO !4<rq   c                   V ^8  d   QhRR/# r^  rh   )rz   s   "rr   r{   r.    s     # #t #rq   c                	    V P                   # r   )r>  r   s   &rr   rq  CancelScope.cancel_called  s    """rq   c                   V ^8  d   QhRR/# r^  rh   )rz   s   "rr   r{   r.    s     & &$ &rq   c                	    V P                   # r   )r@  r   s   &rr   cancelled_caughtCancelScope.cancelled_caught  s    %%%rq   c                   V ^8  d   QhRR/# r^  rh   )rz   s   "rr   r{   r.    s       rq   c                	    V P                   # r   )r<  r   s   &rr   r*  CancelScope.shield      ||rq   c                    V ^8  d   QhRRRR/# )rw   r  r  r   r   rh   )rz   s   "rr   r{   r.    s     7 7D 7T 7rq   c                	l    V P                   V8w  d#   Wn         V'       g   V P                  4        R # R # R # r   )r<  rX  r  s   &&rr   r*  r    s,    <<5  L446  !rq   )rA  r>  rC  r?  r@  r=  r;  r
  r	  rG  r<  rD  rB  r   )ri   rj   rk   rl   rg  rh  r2  r   r   r   propertyr`  rY  rO  rP  rX  r   r)  setterrq  r  r*  rp   rh   rq   rr   rO   rO     s    #"&((#;@#
 *.% 1$>JX   
 
S,\(&1"   __  # # & &   ]]7 7rq   rO   c                  *    ] tR tRtRtRtR R ltRtR# )rN  i  z
Encapsulates auxiliary task information that cannot be added to the Task instance
itself because there are no guarantees about its implementation.
c                    V ^8  d   QhRRRR/# )rw   	parent_id
int | Noner  CancelScope | Nonerh   )rz   s   "rr   r{   TaskState.__annotate__  s     ) )* )<N )rq   c                	    Wn         W n        R # r   r  r  )r   r  r  s   &&&rr   r   TaskState.__init__  s    "(rq   )r  r  N)r  r  __weakref__)ri   rj   rk   rl   __doc__	__slots__r   rp   rh   rq   rr   rN  rN    s    
 ;I) )rq   rN  z*WeakKeyDictionary[asyncio.Task, TaskState]r  c                  2    ] tR tRtR R ltRR R lltRtR# )	_AsyncioTaskStatusi  c                    V ^8  d   QhRRRR/# )rw   r   asyncio.Futurer  intrh   )rz   s   "rr   r{   _AsyncioTaskStatus.__annotate__  s     $ $~ $# $rq   c                	    Wn         W n        R # r   _future
_parent_id)r   r   r  s   &&&rr   r   _AsyncioTaskStatus.__init__  s    #rq   Nc                    V ^8  d   QhRRRR/# )rw   r  zT_contra | Noner   r   rh   )rz   s   "rr   r{   r    s     
7 
7_ 
7 
7rq   c                	H    V P                   P                  V4       \        \        P                  \        4       4      pV P                  \        V,          n        R#   \        P                   d0    T P                   P	                  4       '       g   \        R 4      Rh Li ; i)z.called 'started' twice on the same task statusN)r  r   r  InvalidStateErrorr   r   r1   r  r   r  r  r  )r   r  r   s   && rr   started_AsyncioTaskStatus.started  s    	LL##E* GLL,.1'+T$ (( 	<<))++"D ,	s   A 4B!B! B!r  r   )ri   rj   rk   rl   r   r  rp   rh   rq   rr   r  r    s    $
7 
7rq   r  zCodeType | None_eager_task_factory_codec                  r    ] tR tRtR R ltR R ltR R ltRR	 R
 lltRR/R R lltRR/R R llt	Rt
R# )	TaskGroupi  c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   TaskGroup.__annotate__  s     C C$ Crq   c                	l    \        4       V n        R V n        . V n        \	        4       V n        RV n        R# FN)rO   r  rA  _exceptionsr  rD  _on_completed_futr   s   &rr   r   TaskGroup.__init__  s,    )402),>Brq   c                   V ^8  d   QhRR/# )rw   r   r  rh   )rz   s   "rr   r{   r    s      ) rq   c                	P   "   V P                   P                  4        R V n        V # 5iT)r  r   rA  r   s   &rr   
__aenter__TaskGroup.__aenter__  s#     ##%   $&c               (    V ^8  d   QhRRRRRRRR/# rU  rh   )rz   s   "rr   r{   r    s2     =2 =2,=2 &=2 %	=2
 
=2rq   c                	H  "    VeL   V P                   P                  4        \        V\        4      '       g   V P                  P                  V4       \        4       p V P                  '       dc   \        4       ;_uu_ 4       pV P                  '       d4   VP                  4       V n
         V P                  G R j  xL
  R V n
        KE   R R R 4       M\        P                  4       G R j  xL
  RV n        V P                  '       d   \!        RV P                  4      R hV'       d   Vh T P                   P%                  YT4      ??T =#  L  \         dY   pRTn        T P                   P                  4        Te(   \        T\        4      '       d   \        T4      '       g   Tp R p?LR p?ii ; i  + '       g   i     L; i L  \"         dF   pT P                   P%                  \'        T4      YfP(                  4      '       d    R p???T =R# h R p?ii ; i  ??T =i ; i5i)NTFzunhandled errors in a TaskGroup)r  r   r$  r   r  appendr	   rD  rO   r   r  r*  r'  AsyncIOBackendcancel_shielded_checkpointrA  rb   BaseExceptionr   type__traceback__)r   r   r   r   r   
wait_scoper!  s   &&&&   rr   	__aexit__TaskGroup.__aexit__  s    7	2"!!((*!'>::$$++G4#%D,;;;$*"kkk595G5G5ID22&*&<&< < <  6:D2) * '2 )CCEEE$###
 -94;K;K  !M  $$--hH!1S !=#1 2 59
 1 $ 1 1 8 8 :
 $+?$.w$G$G,A#,F,F.1G2 '2 F ! $$--d3i>O>OPP !1	 	 !1s   H"AH $G F1F1+E:E	;E?	F1	 G )G*G G &G (H H"	EF.AF)$F1)F..F11G	<	G H5HH 
H"HHH HH"Nc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )rw   r  ,Callable[[Unpack[PosArgsT]], Awaitable[Any]]r   tuple[Unpack[PosArgsT]]namer1  task_status_futureasyncio.Future | Noner   r   rh   )rz   s   "rr   r{   r    sC     b b:b &b 	b
 2b 
brq   c                	  a aa R  V VV3R llpS P                   '       g   \        R4      h/ pS'       dA   \        \        4       4      p\	        S\        S P
                  P                  4      4      VR&   M\        S P
                  P                  4      pV! V/ VB p\        V4      '       gC   \        VR4      '       d   VP                   R2MRp	\        RV	 VP                   RV: R	24      hVf   \        V4      M
\        V4      p\        P                  ! 4       p
V
P!                  4       ;p'       dI   \#        VRR
4      \$        J d4   \#        VRR
4      ;p'       d   V^ ,          P&                  pV! WVR7      oM\)        WR7      o\+        VS P
                  R7      \,        S&   S P
                  P.                  P1                  S4       S P.                  P1                  S4       \2        P4                  R8  dD   S P
                  P                  e,   \        P6                  ! SS P
                  P                  4       SP9                  V4       S# )c                    V ^8  d   QhRRRR/# )rw   _taskr   r   r   rh   )rz   s   "rr   r{   &TaskGroup._spawn.<locals>.__annotate__%  s     -	 -	\ -	d -	rq   c                  < \         P                  R8  dD   SP                  P                  e,   \        P
                  ! V SP                  P                  4       \        V ,          pVP                  f   Q hWP                  P                  9   g   Q hVP                  P                  P                  V 4       SP                  P                  S4       \        V  SP                  e/   SP                  '       g    SP                  P                  R4        V P                  4       pVe   Se   SP!                  4       '       d   R# Se   SP#                  4       '       dl   \        V\        4      '       g   SP$                  P'                  V4       SP                  P(                  '       g   SP                  P+                  4        R# R# SP-                  V4       R# Se5   SP#                  4       '       g   SP-                  \/        R4      4       R# R# R#   \        P                   d     ELi ; i  \         d<   p\        TP                  \        4      '       d   TP                  pK.  Tp Rp?ELORp?ii ; i)r9  Nz2Child exited without calling task_status.started()r9     )rE  rF  r  r
  r  future_discard_from_awaited_byr  rD  rW  r  r   r  r   r   r$  r&  r   r   r  r  r`  r   r   r   )r  rR  r!  er   r   r  s   &   rr   	task_done#TaskGroup._spawn.<locals>.task_done%  s   7*t/@/@/K/K/W664,,77 &e,J**66633:::::##**11%8KKt$U#%%1$+++**55d;oo'  &16H6R6R6T6T%-1C1H1H1J1J%c>::((//4,,CCC))002 D '44S9#/8J8O8O8Q8Q"00 !UV 9R/5 00 
 "  ??A	s*   ;H H5 H21H25I; 0I66I;z;This task group is not active; no new tasks can be started.task_statusrj   r   z	Expected z0() to return a coroutine, but the return value (z) is not a coroutine objectN__code____closure__)r   r  r  r  r  )rA  r   r  r   r  r  r
  r"   r   rj   	TypeErrorrk   r  r  r  r	   get_task_factoryr   r  cell_contentsr   rN  r  rD  rK  rE  rF  future_add_to_awaited_byadd_done_callback)r   r  r   r  r  r  kwargsr  r   prefixr   factoryclosurecustom_task_constructorr   s   f&&&f         @rr   _spawnTaskGroup._spawn  s   -	 -	^ |||M  <>*I$6"Bt'8'8'C'C$D%F=! 4,,778IT$V$4  .5dL.I.I(*rFF8D$5$5#6 7%%)H,GI 
 +/, &CI'')--//W/T26NN#G]DAAA&-aj&>&>#*4FDt/D 'd.?.?
T 	  $$T*w&4+<+<+G+G+S,,T43D3D3O3OPy)rq   r  c               (    V ^8  d   QhRRRRRRRR/# )	rw   r  r  r   zUnpack[PosArgsT]r  r1  r   r   rh   )rz   s   "rr   r{   r    s2     & &:&  & 	&
 
&rq   c               	*    V P                  WV4       R # r   )r  )r   r  r  r   s   &&$*rr   
start_soonTaskGroup.start_soon  s     	D%rq   c               (    V ^8  d   QhRRRRRRRR/# )rw   r  zCallable[..., Awaitable[Any]]r   r1  r  r   r.   rh   )rz   s   "rr   r{   r    s,      1:@HN	rq   c          
     	  "   \         P                  ! 4       pV P                  WW$4      p VG R j  xL
 #  L  \         d    TP	                  4        \        RR7      ;_uu_ 4        \        \        4      ;_uu_ 4        TG R j  xL 
  R R R 4       M  + '       g   i     M; iR R R 4       h   + '       g   i     h ; ii ; i5i)NTr*  )r  r   r  r   r   rO   r   )r   r  r  r   r   r   s   &&$*  rr   r   TaskGroup.start  s      ")!1{{4t4	<< 	KKMD))8N+C+C

 ,D+C+C+C)  *) 	sa   (C7 57 C7 /C&B/>BBB
	B/B#B/&	C/B?:	CC)rA  r  r  rD  r  r   )ri   rj   rk   rl   r   r  r  r  r  r   rp   rh   rq   rr   r  r    s;    C
=2~bH& 	&QU rq   r  c                  Z   a  ] tR tRt^
tR V 3R lltR R ltR R ltRR R	 lltR
t	V ;t
# )WorkerThreadi  c               $    V ^8  d   QhRRRRRR/# )rw   r  r   workerszset[WorkerThread]idle_workerszdeque[WorkerThread]rh   )rz   s   "rr   r{   WorkerThread.__annotate__  s(       # *	rq   c                	   < \         SV `  R R7       Wn        W n        W0n        VP
                  V n        \        ^4      V n        \        P                  4       V n        RV n        R# )zAnyIO worker threadr  FN)superr   r  r  r  r   r   r%   queuer  current_time
idle_sincestopping)r   r  r  r  	__class__s   &&&&rr   r   WorkerThread.__init__  sZ     	34"(OO	 !H 	
 )557rq   c               (    V ^8  d   QhRRRRRRRR/# )	rw   r   r  resultr.   r!  r   r   r   rh   )rz   s   "rr   r{   r    s,     * *$*.1*8L*	*rq   c                	d   \         P                  4       V n        V P                  '       g   V P                  P                  V 4       VP                  4       '       gT   Ve=   \        V\        4      '       d   \        R4      pW4n
        TpVP                  V4       R # VP                  V4       R # R # )Nzcoroutine raised StopIteration)r  r  r  r  r  r  r   r$  StopIterationr   	__cause__r   r   )r   r   r	  r!  new_excs   &&&& rr   _report_resultWorkerThread._report_result  s     )557}}}$$T*!!c=11*+KLG(+%!C$$S)!!&) "rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s     D DT Drq   c                	p   \        \        V P                  4      ;_uu_ 4         V P                  P	                  4       pVf    RRR4       R# Vw  r#rEpVP                  4       '       gt   RpRpV\        n         VP                  ! V.VO5!  p\        =V P                  P                  4       '       g(   V P                  P                  V P                  WWV4       ??V P                  P                  4        ??????K    \         d   p	T	p Rp	?	LRp	?	ii ; i  \        =i ; i  + '       g   i     R# ; iTN)r8   r  r   r  r  r   r:   current_cancel_scoper   r  	is_closedr   r  r  )
r   itemr   r  r   r   r  r	  r   r!  s
   &         rr   r   WorkerThread.run  s    ;;zz~~'< <; =A9t\''))!F6:I8DL5>!(T!9D!9 )=99..00		66 // 	

$$&'4v| ) ($'	( )=# <;;sN   !D$+D$:C?%D$4AD$?D
DDDDD!!D$$D5	c                    V ^8  d   QhRRRR/# )rw   fzasyncio.Task | Noner   r   rh   )rz   s   "rr   r{   r    s      ) T rq   c                	    R V n         V P                  P                  R4       V P                  P	                  V 4        V P
                  P                  V 4       R#   \         d     R# i ; ir  )r  r  
put_nowaitr  rL  r  rW  r   )r   r  s   &&rr   stopWorkerThread.stop  sX    

d#T"	$$T* 		s   A A+*A+)r  r  r   r  r  r  r  r   )ri   rj   rk   rl   MAX_IDLE_TIMEr   r  r   r  rp   __classcell__r  s   @rr   r  r    s'    M "*$D< rq   r  _threadpool_idle_workerszRunVar[deque[WorkerThread]]_threadpool_workerszRunVar[set[WorkerThread]]F)eqc                  >    ] tR tRt$ R]R&   R
R R lltR R ltRtR	# )StreamReaderWrapperi  zasyncio.StreamReader_streamc                    V ^8  d   QhRRRR/# rw   	max_bytesr  r   bytesrh   )rz   s   "rr   r{    StreamReaderWrapper.__annotate__  s      s u rq   c                	t   "   V P                   P                  V4      G R j  xL
 pV'       d   V# \        h L5ir   )r%  readr>   )r   r(  datas   && rr   receiveStreamReaderWrapper.receive  s/     \\&&y11K	 2s   868	8c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r*  
  s     * *d *rq   c                	   "   V P                   P                  \        4       4       \        P	                  4       G R j  xL
  R #  L5ir   )r%  r   r=   r  
checkpointr   s   &rr   acloseStreamReaderWrapper.aclose
  s-     ""#6#89'')))s   ;AAArh   N   )ri   rj   rk   rl   __annotations__r.  r3  rp   rh   rq   rr   r$  r$    s    !!* *rq   r$  c                  X    ] tR tRt$ R]R&   ]! RRR7      tR]R&   R R	 ltR
 R ltRt	R# )StreamWriterWrapperi  zasyncio.StreamWriterr%  F)initdefaultr  _closedc                    V ^8  d   QhRRRR/# rw   r  r)  r   r   rh   )rz   s   "rr   r{    StreamWriterWrapper.__annotate__  s     > >u > >rq   c                	  "   \         P                  4       G R j  xL
  V P                  P                  P                  p V P                  P                  V4       V P                  P                  4       G R j  xL
  T'       g   \         P                  4       G R j  xL
  R # R #  L L.  \        \        \        3 dG   pT P                  '       d   \        ThT P                  P                  4       '       d   \        Thh R p?ii ; i Lk5ir   )r  checkpoint_if_cancelledr%  	_protocol_pausedwritedrainConnectionResetErrorBrokenPipeErrorr   r<  r=   
is_closingr;   r  )r   r  stream_pausedr!  s   &&  rr   sendStreamWriterWrapper.send  s     44666..66	LLt$,,$$&&&  ;;=== ! 	7 '$o|D 		 |||)s2((**)s2		 >s]   D
B%$D
 8B) 8B'9B) =D
D
D	D
'B) )D?8D 8D  DD
c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r?  (  s     * *d *rq   c                	   "   R V n         V P                  P                  4        \        P	                  4       G Rj  xL
  R#  L5ir  )r<  r%  r   r  r2  r   s   &rr   r3  StreamWriterWrapper.aclose(  s.     '')))s   9AAA)r<  N)
ri   rj   rk   rl   r7  r   r<  rJ  r3  rp   rh   rq   rr   r9  r9    s(    !!ue4GT4>(* *rq   r9  c                      ] tR tRt$ R]R&   R]R&   R]R&   R]R&   R	 R
 ltR R ltR R ltR R ltR R lt	]
R R l4       t]
R R l4       t]
R R l4       t]
R R l4       t]
R R l4       tRtR# )Processi.  zasyncio.subprocess.Process_processzStreamWriterWrapper | None_stdinzStreamReaderWrapper | None_stdout_stderrc                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   Process.__annotate__5  s      d rq   c                	z  "   \        R R7      ;_uu_ 4       p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Vn         V P                  4       G Rj  xL
   RRR4       R#  L Le L3 L  \         d3    R Tn        T P                  4        T P                  4       G Rj  xL 
  h i ; i  + '       g   i     R# ; i5i)Tr  NF)	rO   rR  r3  rS  rT  r*  r   r  killrz  s   & rr   r3  Process.aclose5  s     %%{{{kk((***|||ll))+++|||ll))+++ ELiik!! &%*++ "  #		iik!!	 &%%s   D;0D'CD'D';C!<D'D'/C#0D'<C'C%C'
D;D'!D'#D'%C''5D$D
D$$D''D8	2	D;c                   V ^8  d   QhRR/# rw   r   r  rh   )rz   s   "rr   r{   rV  G  s     * *C *rq   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir   )rQ  r   r   s   &rr   r   Process.waitG  s     ]]''))))s   '%'c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rV  J  s     " "4 "rq   c                	:    V P                   P                  4        R # r   )rQ  	terminater   s   &rr   r`  Process.terminateJ  s    !rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rV  M  s      d rq   c                	:    V P                   P                  4        R # r   )rQ  rX  r   s   &rr   rX  Process.killM  s    rq   c                    V ^8  d   QhRRRR/# )rw   r   r  r   r   rh   )rz   s   "rr   r{   rV  P  s     * *# *$ *rq   c                	<    V P                   P                  V4       R # r   )rQ  send_signal)r   r   s   &&rr   rg  Process.send_signalP  s    !!&)rq   c                   V ^8  d   QhRR/# r[  rh   )rz   s   "rr   r{   rV  T  s     ! !S !rq   c                	.    V P                   P                  # r   )rQ  pidr   s   &rr   rk  Process.pidS  s    }}   rq   c                   V ^8  d   QhRR/# rw   r   r  rh   )rz   s   "rr   r{   rV  X  s     ( (J (rq   c                	.    V P                   P                  # r   )rQ  
returncoder   s   &rr   rp  Process.returncodeW  s    }}'''rq   c                   V ^8  d   QhRR/# )rw   r   zabc.ByteSendStream | Nonerh   )rz   s   "rr   r{   rV  \  s      0 rq   c                	    V P                   # r   )rR  r   s   &rr   stdinProcess.stdin[      {{rq   c                   V ^8  d   QhRR/# rw   r   zabc.ByteReceiveStream | Nonerh   )rz   s   "rr   r{   rV  `        4 rq   c                	    V P                   # r   )rS  r   s   &rr   stdoutProcess.stdout_  r  rq   c                   V ^8  d   QhRR/# rx  rh   )rz   s   "rr   r{   rV  d  ry  rq   c                	    V P                   # r   )rT  r   s   &rr   stderrProcess.stderrc  r  rq   rh   N)ri   rj   rk   rl   r7  r3  r   r`  rX  rg  r  rk  rp  rt  r{  r  rp   rh   rq   rr   rP  rP  .  s    ((&&''''$*"* ! ! ( (      rq   rP  c               $    V ^8  d   QhRRRRRR/# )rw   r  zset[Process]r  r1  r   r   rh   )rz   s   "rr   r{   r{   h  s$     < <<"(<	<rq   c                j   Rp\         P                  R8  d%    \        P                  ! 4       P	                  4       pV P                  4        F  pVP                  f   K  VP                  P                  P                  P                  4        VP                  P                  P                  P                  4        VP                  P                  P                  P                  4        VP                  4        V'       g   K  VP                  VP                   4       K  	  R#   \
         d     Li ; i)zC
Forcibly shuts down worker processes belonging to this event loop.Nr9     )rE  rF  r  get_event_loop_policyget_child_watcherNotImplementedErrorcopyrp  rR  r%  
_transportr   rS  rT  rX  remove_child_handlerrk  )r  r  child_watcherprocesss   &&  rr   '_forcibly_shutdown_process_pool_on_exitr  h  s    
 :>M
'!	#99;MMOM
 <<>%))//1**002**002=..w{{; "	 # 		s   #D$ $D21D2c                    V ^8  d   QhRRRR/# rw   r  zset[abc.Process]r   r   rh   )rz   s   "rr   r{   r{     s     # #2B #t #rq   c                D  "    \        \        P                  4      G Rj  xL
  R#  L  \        P                   d`    T P                  4       p T  F#  pTP                  e   K  TP                  4        K%  	  T  F  pTP                  4       G Rj  xL 
  K  	   R# i ; i5i)z
Shuts down worker processes belonging to this event loop.

NOTE: this only works when the event loop was started using asyncio.run() or
anyio.run().

N)	r
   rg  rh  r  r   r  rp  rX  r3  )r  r  s   & rr   _shutdown_process_pool_on_exitr    su     	#DHHo!! #,,.G!!)  G..""" #sC   B ) ') B ) 5B#,BB	BB BB c                      ] tR tRt$ R]R&   R]R&   R]R&   RtR]R	&   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 R ltRtR# )StreamProtocoli  zdeque[bytes]
read_queueasyncio.Event
read_eventwrite_eventNException | Noner   Fr  	is_at_eofc                    V ^8  d   QhRRRR/# rw   	transportzasyncio.BaseTransportr   r   rh   )rz   s   "rr   r{   StreamProtocol.__annotate__  s     F F)> F4 Frq   c                	   \        4       V n        \        P                  ! 4       V n        \        P                  ! 4       V n        V P
                  P                  4        \        \        P                  V4      P                  ^ 4       R# r   N)
r   r  r  rG   r  r  r  r1   	Transportset_write_buffer_limitsr   r  s   &&rr   connection_madeStreamProtocol.connection_made  sS    '!--/"==?W	*BB1Erq   c                    V ^8  d   QhRRRR/# rw   r!  r  r   r   rh   )rz   s   "rr   r{   r    s      #3  rq   c                	    V'       d    \        4       V n        WP                  n        V P                  P	                  4        V P
                  P	                  4        R # r   )r;   r   r  r  r  r  r   r!  s   &&rr   connection_lostStreamProtocol.connection_lost  s;    02DN'*NN$rq   c                    V ^8  d   QhRRRR/# )rw   r-  r)  r   r   rh   )rz   s   "rr   r{   r    s      % D rq   c                	    V P                   P                  \        V4      4       V P                  P	                  4        R # r   )r  r  r)  r  r  )r   r-  s   &&rr   data_receivedStreamProtocol.data_received  s(    uT{+rq   c                   V ^8  d   QhRR/# )rw   r   rx   rh   )rz   s   "rr   r{   r    s      k rq   c                	H    R V n         V P                  P                  4        R # r  )r  r  r  r   s   &rr   eof_receivedStreamProtocol.eof_received  s    rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s     + +t +rq   c                	:    \         P                  ! 4       V n        R # r   )r  rG   r  r   s   &rr   pause_writingStreamProtocol.pause_writing  s    "==?rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r           rq   c                	:    V P                   P                  4        R # r   r  r  r   s   &rr   resume_writingStreamProtocol.resume_writing      rq   )r   r  r  r  r  )ri   rj   rk   rl   r7  r   r  r  r  r  r  r  r  rp   rh   rq   rr   r  r    sM    "&I&ItF

+ rq   r  c                      ] tR tRt$ R]R&   R]R&   R]R&   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 R ltRtR# )DatagramProtocoli  z#deque[tuple[bytes, IPSockAddrType]]r  r  r  r  Nr  r   c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   DatagramProtocol.__annotate__  s      )> 4 rq   c                	    \        ^dR7      V n        \        P                  ! 4       V n        \        P                  ! 4       V n        V P
                  P                  4        R# )d   )maxlenN)r   r  r  rG   r  r  r  r  s   &&rr   r   DatagramProtocol.connection_made  s;    s+!--/"==?rq   c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   r    s      #3  rq   c                	n    V P                   P                  4        V P                  P                  4        R # r   )r  r  r  r  s   &&rr   r   DatagramProtocol.connection_lost  s$    rq   c               $    V ^8  d   QhRRRRRR/# )rw   r-  r)  addrrQ   r   r   rh   )rz   s   "rr   r{   r    s!      e > d rq   c                	    \        V4      pV P                  P                  W34       V P                  P	                  4        R # r   )rB   r  r  r  r  )r   r-  r  s   &&&rr   datagram_received"DatagramProtocol.datagram_received  s0    $T*|,rq   c                    V ^8  d   QhRRRR/# )rw   r!  r   r   r   rh   )rz   s   "rr   r{   r    s      )  rq   c                	    Wn         R # r   )r   r  s   &&rr   error_receivedDatagramProtocol.error_received  s    rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s     ! !t !rq   c                	:    V P                   P                  4        R # r   )r  clearr   s   &rr   r  DatagramProtocol.pause_writing  s     rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    r  rq   c                	:    V P                   P                  4        R # r   r  r   s   &rr   r  DatagramProtocol.resume_writing  r  rq   )r   r  r  r  )ri   rj   rk   rl   r7  r   r  r  r  r  r  r  rp   rh   rq   rr   r  r    sB    33"&I&
! rq   r  c                  l    ] tR tRtR R lt]R R l4       tRR R lltR R	 ltR
 R lt	R R lt
RtR# )SocketStreami  c                    V ^8  d   QhRRRR/# )rw   r  zasyncio.Transportprotocolr  rh   )rz   s   "rr   r{   SocketStream.__annotate__  s      "3 ~ rq   c                	l    Wn         W n        \        R 4      V n        \        R4      V n        RV n        R# reading from
writing toFNr  rB  rJ   _receive_guard_send_guardr<  r   r  r  s   &&&rr   r   SocketStream.__init__  s-    #!+N;(6rq   c                   V ^8  d   QhRR/# rw   r   socket.socketrh   )rz   s   "rr   r{   r         8 8] 8rq   c                	8    V P                   P                  R 4      # socketr  get_extra_infor   s   &rr   _raw_socketSocketStream._raw_socket      --h77rq   c                    V ^8  d   QhRRRR/# r'  rh   )rz   s   "rr   r{   r    s     ! !s !u !rq   c                	F  "   V P                   ;_uu_ 4        V P                  P                  P                  4       '       g   V P                  P                  4       '       g~   V P                  P                  '       gb   V P                  P                  4        V P                  P                  P                  4       G R j  xL
  V P                  P                  4        M\        P                  4       G R j  xL
   V P                  P                  P                  4       p\'        T4      T8  d.   TR T Y!R  r2T P                  P                  P)                  T4       T P                  P                  '       g%   T P                  P                  P+                  4        R R R 4       T#  L L  \         dU    T P                  '       d   \         R hT P                  P"                  '       d   T P                  P"                  R h\$        R hi ; i  + '       g   i     X# ; i5ir   )r  rB  r  is_setr  rH  r  resume_readingr   pause_readingr  r2  r  popleft
IndexErrorr<  r=   r   r>   len
appendleftr  )r   r(  chunkleftovers   &&  rr   r.  SocketStream.receive  s       NN--44662244000..0nn//44666--/$//11101199; 5zI%"'
"3U:5Fx))44X> >>,,,))//1= !@ 3 7 2  0<<<-47^^---..22<%4/0 ! @ sy   H!A
H"H>AH?F' 6H6F)7H<$F+ AH9$H
H!'H)H+H
"H
+H

HH		H!c                    V ^8  d   QhRRRR/# r>  rh   )rz   s   "rr   r{   r    s     4 4u 4 4rq   c                	B  "   V P                   ;_uu_ 4        \        P                  4       G R j  xL
  V P                  '       d   \        hV P
                  P                  e   V P
                  P                  h V P                  P                  V4       T P
                  P                  P                  4       G R j  xL
  R R R 4       R #  L  \         d.   pT P                  P                  4       '       d   \        Thh R p?ii ; i LK  + '       g   i     R # ; i5ir   )r  r  r2  r<  r=   rB  r   r  rD  r   rH  r;   r  r   )r   r  r!  s   && rr   rJ  SocketStream.send  s      ++---|||))))5nn...%%d+ ..,,11333! -   ??--//-36	 4! sb   DDCD4D;C'D=D	>D
DDD(DDDD		Dc                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  #  s       rq   c                	h   "    V P                   P                  4        R #   \         d     R # i ; i5ir   )r  	write_eofOSErrorr   s   &rr   send_eofSocketStream.send_eof#  s+     	OO%%' 		s   2  2/2/2c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  )  s     
$ 
$d 
$rq   c                	J  "   R V n         V P                  P                  4       '       ge    V P                  P                  4        V P                  P                  4        \        ^ 4      G Rj  xL
  V P                  P                  4        R# R#   \         d     LXi ; i L35ir  )r<  r  rH  r  r  r   r
   abortr   s   &rr   r3  SocketStream.aclose)  s     ))++))+ OO!!#(NNOO!!# ,   s4   (B#B (B#-B!."B#BB#BB#r<  rB  r  r  r  Nr5  )ri   rj   rk   rl   r   r  r  r.  rJ  r  r3  rp   rh   rq   rr   r  r    s5     8 8!F4&
$ 
$rq   r  c                  ~    ] tR tRt$ RtR]R&   RtR]R&   RtR R lt]	R	 R
 l4       t
R R ltR R ltR R ltRtR# )_RawSocketMixini6  Nr  _receive_future_send_futureFc                   V ^8  d   QhRR/# rw   
raw_socketr  rh   )rz   s   "rr   r{   _RawSocketMixin.__annotate__;  s     7 7= 7rq   c                	R    Wn         \        R 4      V n        \        R4      V n        R# )r  r  N)_RawSocketMixin__raw_socketrJ   r  r  r   r  s   &&rr   r   _RawSocketMixin.__init__;  s"    &+N;(6rq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r  A       ! !] !rq   c                	    V P                   # r   )r  r   s   &rr   r  _RawSocketMixin._raw_socket@         rq   c                    V ^8  d   QhRRRR/# rw   r   asyncio.AbstractEventLoopr   r  rh   )rz   s   "rr   r{   r  D        )B ~ rq   c                	   a a R  VV 3R llp\         P                  ! 4       ;pS n        SP                  S P                  VP
                  R4       VP                  V4       V# )c                    V ^8  d   QhRRRR/# rw   r  r1  r   r   rh   )rz   s   "rr   r{   :_RawSocketMixin._wait_until_readable.<locals>.__annotate__E       	2 	2 	24 	2rq   c                B   < S= SP                  SP                  4       R # r   )r  remove_readerr  r  r   r   s   &rr   callback6_RawSocketMixin._wait_until_readable.<locals>.callbackE  s    $t001rq   N)r  r   r  
add_readerr  r   r  r   r   r*  r  s   ff  rr   _wait_until_readable$_RawSocketMixin._wait_until_readableD  sP    	2 	2 $+>>#33D ))1<<>	H%rq   c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   r  N  r!  rq   c                	   a a R  VV 3R llp\         P                  ! 4       ;pS n        SP                  S P                  VP
                  R4       VP                  V4       V# )c                    V ^8  d   QhRRRR/# r$  rh   )rz   s   "rr   r{   :_RawSocketMixin._wait_until_writable.<locals>.__annotate__O  r&  rq   c                B   < S= SP                  SP                  4       R # r   )r  remove_writerr  r)  s   &rr   r*  6_RawSocketMixin._wait_until_writable.<locals>.callbackO  s    !t001rq   N)r  r   r  
add_writerr  r   r  r-  s   ff  rr   _wait_until_writable$_RawSocketMixin._wait_until_writableN  sP    	2 	2 !( 00D))1<<>	H%rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  X  s     	3 	3d 	3rq   c                	n  "   V P                   '       g   R V n         V P                  P                  4       R8w  d   V P                  P                  4        V P                  '       d   V P                  P                  R4       V P                  '       d   V P                  P                  R4       R# R# R# 5i)TN)_closingr  filenor   r  r   r  r   s   &rr   r3  _RawSocketMixin.acloseX  s     }}} DM  '')R/!!'')###$$//5   !!,,T2 ! s   A$B5',B5!B5)__raw_socketr=  r  r  r  r  )ri   rj   rk   rl   r  r7  r  r=  r   r  r  r.  r8  r3  rp   rh   rq   rr   r  r  6  sJ    -1O*1*.L'.H7
 ! !	3 	3rq   r  c                  V    ] tR tRtR R ltRR R lltR R ltR R	 ltR
 R ltRt	R# )UNIXSocketStreamid  c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   UNIXSocketStream.__annotate__e  s     6 6 6rq   c                	   "   V P                   ;_uu_ 4        V P                  P                  \        P                  4       R R R 4       R #   + '       g   i     R # ; i5ir   )r  r  r   r  SHUT_WRr   s   &rr   r  UNIXSocketStream.send_eofe  s7     %%fnn5 s   A*A
AA		Ac                    V ^8  d   QhRRRR/# r'  rh   )rz   s   "rr   r{   rD  i  s        s  u  rq   c                	  "   \        4       p\        P                  4       G R j  xL
  V P                  ;_uu_ 4          V P                  P                  V4      pV'       g   \        hVuuR R R 4       #  LP  \         d    T P                  T4      G R j  xL 
   Ka  \         d&   pT P                  '       d   \        R h\        ThR p?ii ; i  + '       g   i     R # ; i5ir   )r	   r  r2  r  r  recvr>   BlockingIOErrorr.  r  r=  r=   r;   )r   r(  r   r-  r!  s   &&   rr   r.  UNIXSocketStream.receivei  s     !'')))    ++00;D  )) !  	*
 ' :33D999 ;}}}1t;1s:	; !  sh   "C%A5C%C A7C*C%7CB
CCC(C) C		CCC"		C%c                    V ^8  d   QhRRRR/# r>  rh   )rz   s   "rr   r{   rD  }  s     - -u - -rq   c                	  "   \        4       p\        P                  4       G R j  xL
  V P                  ;_uu_ 4        \	        V4      pV'       d#    V P
                  P                  V4      pW4R  pK*   R R R 4       R #  LY  \         d    T P                  T4      G R j  xL 
   K_  \         d&   pT P                  '       d   \        R h\        ThR p?ii ; i  + '       g   i     R # ; i5ir   )r	   r  r2  r  
memoryviewr  rJ  rK  r8  r  r=  r=   r;   )r   r  r   view
bytes_sentr!  s   &&    rr   rJ  UNIXSocketStream.send}  s     !'')))d#D
-!%!1!1!6!6t!<J  ,D   	* ' :33D999 ;}}}1t;1s:	; sh   "C.A>C.CB -C4C. CB"
 C%C(C1C2 CCCC+	%	C.c               $    V ^8  d   QhRRRRRR/# )rw   msglenr  maxfdsr   ztuple[bytes, list[int]]rh   )rz   s   "rr   r{   rD    s"     %" %" %"S %"=T %"rq   c           	     	$  "   \        V\        4      '       d   V^ 8  d   \        R4      h\        V\        4      '       d   V^8  d   \        R4      h\        4       p\        P                  ! R4      p\
        P                  4       G Rj  xL
  V P                  ;_uu_ 4          V P                  P                  V\        P                  ! W$P                  ,          4      4      w  rVrxV'       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\1        T4      \1        T4      TP                  ,          ,
           4       K  	  X\3        T4      3#  EL  \         d     T P                  T4      G Rj  xL 
   EK&  \          d&   p	T P"                  '       d   \$        Rh\&        T	hRp	?	ii ; i  + '       g   i     E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 = )r$  r  r   r	   arrayr  r2  r  r  recvmsgr  CMSG_LENitemsizer>   rK  r.  r  r=  r=   r;   
SOL_SOCKET
SCM_RIGHTSr   	frombytesr  list)r   rT  rU  r   fdsr   ancdataflagsr  r!  
cmsg_level	cmsg_type	cmsg_datas   &&&          rr   receive_fdsUNIXSocketStream.receive_fds  s    &#&&&1*DEE&#&&&1*@AA!kk#'')))   484D4D4L4L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	!!; 	* ' :33D999 ;}}}1t;1s:	; !  st   BH
FH#G<&AF!)G<9G< BH!G9 G
G9G<
G9G9 G44G99G<<H		Hc               $    V ^8  d   QhRRRRRR/# )rw   r   r)  r`  zCollection[int | IOBase]r   r   rh   )rz   s   "rr   r{   rD    s"     ; ;e ;2J ;t ;rq   c                	D  "   V'       g   \        R 4      hV'       g   \        R4      h\        4       p. 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                  4       G Rj  xL
  V P                  ;_uu_ 4          V P                  P                  V.\        P                  \        P                  V3.4        RRR4       R#  Lc  \          d    T P#                  T4      G Rj  xL 
   Kt  \$         d&   pT P&                  '       d   \(        Rh\*        ThRp?ii ; i  + '       g   i     R# ; i5i)zmessage must not be emptyzfds must not be emptyrW  N)r   r	   r$  r  r  r#   r>  rX  r  r2  r  r  sendmsgr  r\  r]  rK  r8  r  r=  r=   r;   )r   r   r`  r   filenosfdfdarrayr!  s   &&&     rr   send_fdsUNIXSocketStream.send_fds  sA    899455!B"c""r"B''ryy{+	  ++c7+''))); $$,, 	V%6%68I8I7$S#T   	* ' :33D999 ;}}}1t;1s:	; sx   F AF ;AF D0F %F(=D2%F&F 2F	E
F	FF	#F	$ FF		FF		F rh   Nr5  )
ri   rj   rk   rl   r  r.  rJ  rf  rn  rp   rh   rq   rr   rB  rB  d  s!    6 (-$%"N; ;rq   rB  c                  d    ] tR tRt$ RtR]R&   RtR R lt]R R	 l4       t	R
 R lt
R R ltRtR# )TCPSocketListeneri  Nr  _accept_scopeFc                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   TCPSocketListener.__annotate__  s     I I= Irq   c                	    Wn         \        \        P                  \	        4       4      V n        \        R 4      V n        R# )accepting connections fromN)_TCPSocketListener__raw_socketr1   r  BaseEventLoopr	   r   rJ   _accept_guardr  s   &&rr   r   TCPSocketListener.__init__  s.    &'//1A1CD
*+GHrq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   rt    r  rq   c                	    V P                   # r   )rw  r   s   &rr   r  TCPSocketListener._raw_socket  r  rq   c                   V ^8  d   QhRR/# rw   r   abc.SocketStreamrh   )rz   s   "rr   r{   rt    s     1 1. 1rq   c           	     	z  "   V P                   '       d   \        hV P                  ;_uu_ 4        \        P	                  4       G R j  xL
  \        4       ;_uu_ 4       V n         V P                  P                  V P                  4      G R j  xL
 w  r R T n         R R R 4       R R R 4       XP                  \         P"                  \         P$                  ^4       T P                  P'                  \(        T4      G R j  xL
 w  r4\+        Y44      #  L L  \        P                   dZ     T P                  P                  T P                  4       M  \        \        3 d     Mi ; iT P                   '       d   \        R hh i ; i  R T n        i ; i  + '       g   i     L; i  + '       g   i     EL	; i L5ir   )r<  r=   ry  r  r2  rO   rr  r   sock_acceptr  r  r   r(  r   r  
setsockoptr  IPPROTO_TCPTCP_NODELAYconnect_accepted_socketr  r  )r   client_sock_addrr  r  s   &    rr   acceptTCPSocketListener.accept  sV    <<<%% ++---$"4./3zz/E/EdFVFV/W)W&K *.D&   & 	v1163E3EqI$(JJ$F$FK%
 
	 I00- . *X-- 


001A1AB&(;<  |||1t;
 *.D&   (
s   -F;F%DF%F	%(DDDF	F%%AF;?F9 F;F%DF+%E
FE%"F$E%%F:	FF	FF	F"F%%F6	0
F;c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rt    s     ! !d !rq   c                	t  "   V P                   '       d   R # RV n         V P                  '       dT    V P                  P                  V P                  4       V P                  P                  4        \        ^ 4      G R j  xL
  V P                  P                  4        R #   \
        \        3 d     L\i ; i L75i)NT)
r<  rr  r   r(  r  r   r  r   r
   r   r   s   &rr   r3  TCPSocketListener.aclose  s     <<<

(()9)9: %%'(NN   34  s4   -B8%B (B8>B6? B8B30B82B33B8)r@  ry  rr  r<  r   )ri   rj   rk   rl   rr  r7  r<  r   r  r  r  r3  rp   rh   rq   rr   rq  rq    s;    (,M%,GI
 ! !1:! !rq   rq  c                  P    ] tR tRtR R ltR R ltR R lt]R R	 l4       tR
t	R# )UNIXSocketListeneri  c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   UNIXSocketListener.__annotate__  s      = rq   c                	^    Wn         \        4       V n        \        R 4      V n        RV n        R# )rv  FN)_UNIXSocketListener__raw_socketr	   r   rJ   ry  r<  r  s   &&rr   r   UNIXSocketListener.__init__  s'    &%'
*+GHrq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r    s     ; ;. ;rq   c                	n  a "   \         P                  4       G R j  xL
  S P                  ;_uu_ 4          S P                  P	                  4       w  rVP                  R4       \        V4      uuR R R 4       #  L]  \         dk    \        P                  ! 4       pS P                  P                  S P                  TP                  R 4       TP                  T 3R l4       TG R j  xL 
   K  \         d&   pS P                  '       d   \         R h\"        ThR p?ii ; i  + '       g   i     R # ; i5i)NFc                N   < SP                   P                  SP                  4      # r   )r   r(  r  )_r   s   &rr   r   +UNIXSocketListener.accept.<locals>.<lambda>'  s    $**":":4;L;L"Mrq   )r  r2  ry  r  r  setblockingrB  rK  r  r   r   r,  r   r  r  r<  r=   r;   )r   r  r  r  r!  s   f    rr   r  UNIXSocketListener.accept  s     '')));%)%6%6%=%=%?NK++E2+K8   	* ' (/(8AJJ))$*;*;Q\\4P''M GG ;|||1t;1s:	;  sb   D5A9D5D!7A;.D5;A+D&C)
'D,D!/D8D9 DDD!!D2	,	D5c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  0  s     " "d "rq   c                	P   "   R V n         V P                  P                  4        R# 5ir  )r<  r  r   r   s   &rr   r3  UNIXSocketListener.aclose0  s     !r  c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r  5  r  rq   c                	    V P                   # r   )r  r   s   &rr   r  UNIXSocketListener._raw_socket4  r  rq   )r@  ry  r<  r   N)
ri   rj   rk   rl   r   r  r3  r  r  rp   rh   rq   rr   r  r    s%    ;*" ! !rq   r  c                  \    ] tR tRtR R lt]R R l4       tR R ltR R	 ltR
 R lt	Rt
R# )	UDPSocketi9  c                    V ^8  d   QhRRRR/# rw   r  zasyncio.DatagramTransportr  r  rh   )rz   s   "rr   r{   UDPSocket.__annotate__:        2>Nrq   c                	l    Wn         W n        \        R 4      V n        \        R4      V n        RV n        R# r  r  r  s   &&&rr   r   UDPSocket.__init__:  /     $!+N;(6rq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r  D  r  rq   c                	8    V P                   P                  R 4      # r  r  r   s   &rr   r  UDPSocket._raw_socketC  r  rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  G       $ $d $rq   c                	   "   R V n         V P                  P                  4       '       g   V P                  P                  4        R# R# 5ir  r<  r  rH  r   r   s   &rr   r3  UDPSocket.acloseG  4     ))++OO!!# ,   AAc                   V ^8  d   QhRR/# )rw   r   ztuple[bytes, IPSockAddrType]rh   )rz   s   "rr   r{   r  L  s     8 8; 8rq   c                	p  "   V P                   ;_uu_ 4        \        P                  4       G R j  xL
  V P                  P                  '       gq   V P
                  P                  4       '       gQ   V P                  P                  P                  4        V P                  P                  P                  4       G R j  xL
   V P                  P                  P                  4       uuR R R 4       #  L L5  \         d"    T P                  '       d   \        R h\        R hi ; i  + '       g   i     R # ; i5ir   r  r  r2  rB  r  r  rH  r  r  r   r  r  r<  r=   r;   r   s   &rr   r.  UDPSocket.receiveL  s         ++--- >>,,,T__5O5O5Q5Q))//1nn//446668~~0088: ! -
 7  8<<<-47-47	8 !  sc   D6D"C/D"D"0AD";C1<D"#C3$D6/D"1D"3DDD""D3	-	D6c                    V ^8  d   QhRRRR/# )rw   r  rS   r   r   rh   )rz   s   "rr   r{   r  ]  s     	. 	.} 	. 	.rq   c                	  "   V P                   ;_uu_ 4        \        P                  4       G R j  xL
  V P                  P                  P                  4       G R j  xL
  V P                  '       d   \        hV P                  P                  4       '       d   \        hV P                  P                  ! V!    R R R 4       R #  L Li  + '       g   i     R # ; i5ir   r  r  r2  rB  r  r   r<  r=   r  rH  r;   sendtor   r  s   &&rr   rJ  UDPSocket.send]  s      ++---..,,11333|||))++--))&&- -3 sJ   CCC+CCC2%C C9
CCCC		Cr  Nri   rj   rk   rl   r   r  r  r3  r.  rJ  rp   rh   rq   rr   r  r  9  s/     8 8$
8"	. 	.rq   r  c                  \    ] tR tRtR R lt]R R l4       tR R ltR R	 ltR
 R lt	Rt
R# )ConnectedUDPSocketii  c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   ConnectedUDPSocket.__annotate__j  r  rq   c                	l    Wn         W n        \        R 4      V n        \        R4      V n        RV n        R# r  r  r  s   &&&rr   r   ConnectedUDPSocket.__init__j  r  rq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r  t  r  rq   c                	8    V P                   P                  R 4      # r  r  r   s   &rr   r  ConnectedUDPSocket._raw_sockets  r  rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  w  r  rq   c                	   "   R V n         V P                  P                  4       '       g   V P                  P                  4        R# R# 5ir  r  r   s   &rr   r3  ConnectedUDPSocket.aclosew  r  r  c                   V ^8  d   QhRR/# rw   r   r)  rh   )rz   s   "rr   r{   r  |  s      u rq   c                	  "   V P                   ;_uu_ 4        \        P                  4       G R j  xL
  V P                  P                  '       gq   V P
                  P                  4       '       gQ   V P                  P                  P                  4        V P                  P                  P                  4       G R j  xL
   V P                  P                  P                  4       pT^ ,          uuR R R 4       #  L L>  \         d"    T P                  '       d   \        R h\        R hi ; i  + '       g   i     R # ; i5ir   r  )r   packets   & rr   r.  ConnectedUDPSocket.receive|  s         ++--- >>,,,T__5O5O5Q5Q))//1nn//44666822::< !9! ! -
 7  8<<<-47-47	8 !  si   D?D+C8D+D+0AD+;C:<D+$C<%D+-D?8D+:D+<D(D((D++D<	6	D?c                    V ^8  d   QhRRRR/# r>  rh   )rz   s   "rr   r{   r    s     	- 	-u 	- 	-rq   c                	  "   V P                   ;_uu_ 4        \        P                  4       G R j  xL
  V P                  P                  P                  4       G R j  xL
  V P                  '       d   \        hV P                  P                  4       '       d   \        hV P                  P                  V4        R R R 4       R #  L Lj  + '       g   i     R # ; i5ir   r  r  s   &&rr   rJ  ConnectedUDPSocket.send  s      ++---..,,11333|||))++--))&&t, -3 sJ   CCC+CCC2%C!C:
CCCC		Cr  Nr  rh   rq   rr   r  r  i  s/     8 8$
&	- 	-rq   r  c                  .    ] tR tRtR R ltR R ltRtR# )UNIXDatagramSocketi  c                   V ^8  d   QhRR/# )rw   r   rT   rh   )rz   s   "rr   r{   UNIXDatagramSocket.__annotate__  s        5  rq   c                	  "   \        4       p\        P                  4       G R j  xL
  V P                  ;_uu_ 4          V P                  P                  R4      pVuuR R R 4       #  LB  \         d    T P                  T4      G R j  xL 
   KS  \         d&   pT P                  '       d   \        R h\        ThR p?ii ; i  + '       g   i     R # ; i5iNr6  )r	   r  r2  r  r  recvfromrK  r.  r  r=  r=   r;   r   r   r-  r!  s   &   rr   r.  UNIXDatagramSocket.receive  s     !'')))   
 ++44U;D   !  	*
 ' :33D999 ;}}}1t;1s:	; !  h   "CA'CC A)CC)C B
	C CC C  B;;C  CC		Cc                    V ^8  d   QhRRRR/# )rw   r  rT   r   r   rh   )rz   s   "rr   r{   r    s      5 $ rq   c                	  "   \        4       p\        P                  4       G R j  xL
  V P                  ;_uu_ 4          V P                  P
                  ! V!    R R R 4       R #  L@  \         d    T P                  T4      G R j  xL 
   KQ  \         d&   pT P                  '       d   \        R h\        ThR p?ii ; i  + '       g   i     R # ; i5ir   )r	   r  r2  r  r  r  rK  r8  r  r=  r=   r;   r   r  r   r!  s   &&  rr   rJ  UNIXDatagramSocket.send  s     !'')))
$$++T2   	*
 ' :33D999 ;}}}1t;1s:	; sh   "CA%CC A'CC'B>B	
B>CB>B> B99B>>CC		Crh   Nri   rj   rk   rl   r.  rJ  rp   rh   rq   rr   r  r         " rq   r  c                  .    ] tR tRtR R ltR R ltRtR# )ConnectedUNIXDatagramSocketi  c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   (ConnectedUNIXDatagramSocket.__annotate__  s        u  rq   c                	  "   \        4       p\        P                  4       G R j  xL
  V P                  ;_uu_ 4          V P                  P                  R4      pVuuR R R 4       #  LB  \         d    T P                  T4      G R j  xL 
   KS  \         d&   pT P                  '       d   \        R h\        ThR p?ii ; i  + '       g   i     R # ; i5ir  )r	   r  r2  r  r  rJ  rK  r.  r  r=  r=   r;   r  s   &   rr   r.  #ConnectedUNIXDatagramSocket.receive  s     !'')))   
 ++007D   !  	*
 ' :33D999 ;}}}1t;1s:	; !  r  c                    V ^8  d   QhRRRR/# r>  rh   )rz   s   "rr   r{   r    s      u  rq   c                	  "   \        4       p\        P                  4       G R j  xL
  V P                  ;_uu_ 4          V P                  P                  V4        R R R 4       R #  LA  \         d    T P                  T4      G R j  xL 
   KR  \         d&   pT P                  '       d   \        R h\        ThR p?ii ; i  + '       g   i     R # ; i5ir   )r	   r  r2  r  r  rJ  rK  r8  r  r=  r=   r;   r  s   &&  rr   rJ   ConnectedUNIXDatagramSocket.send  s     !'')))
$$))$/   	*
 ' :33D999 ;}}}1t;1s:	; sh   "CA&CC A(CC(B?B

B?CB?B? B::B??CC		Crh   Nr  rh   rq   rr   r  r    r  rq   r  read_eventsz'RunVar[dict[int, asyncio.Future[bool]]]_read_eventswrite_events_write_eventsc                  ^    ] 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# )rG   i  c                   V ^8  d   QhRR/# )rw   r   rG   rh   )rz   s   "rr   r{   Event.__annotate__  s     # # #rq   c                	,    \         P                  V 4      # r   r0  r4  s   &rr   r2  Event.__new__      ~~c""rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s     & &$ &rq   c                	:    \         P                  ! 4       V n        R # r   )r  rG   _eventr   s   &rr   r   Event.__init__  s    mmorq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s      T rq   c                	:    V P                   P                  4        R # r   )r  r  r   s   &rr   r  	Event.set  s    rq   c                   V ^8  d   QhRR/# r^  rh   )rz   s   "rr   r{   r    s     $ $ $rq   c                	6    V P                   P                  4       # r   )r  r  r   s   &rr   r  Event.is_set  s    {{!!##rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s     % %D %rq   c                	   "   V P                  4       '       d   \        P                  4       G R j  xL
  R # V P                  P	                  4       G R j  xL
  R #  L* L5ir   )r  r  r2  r  r   r   s   &rr   r   
Event.wait  s@     ;;== ++---++""$$$ .$s!   .AA#AAAAc                   V ^8  d   QhRR/# )rw   r   r4   rh   )rz   s   "rr   r{   r    s     : :O :rq   c                	R    \        \        V P                  P                  4      4      # r   )r4   r  r  _waitersr   s   &rr   
statisticsEvent.statistics  s    s4;;#7#7899rq   )r  N)ri   rj   rk   rl   r2  r   r  r  r   r  rp   rh   rq   rr   rG   rG     s%    #&$%: :rq   rG   c                  z    ] tR tRtRR/R R lltRR/R R l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# )rI   i  fast_acquireFc                    V ^8  d   QhRRRR/# )rw   r  r  r   rI   rh   )rz   s   "rr   r{   Lock.__annotate__  s     # #d #t #rq   c               	,    \         P                  V 4      # r   r0  r4  r  s   &$rr   r2  Lock.__new__  r  rq   c                    V ^8  d   QhRRRR/# )rw   r  r  r   r   rh   )rz   s   "rr   r{   r    s     L L L Lrq   c               	>    Wn         R V n        \        4       V n        R # r   )_fast_acquire_owner_taskr   r  )r   r  s   &$rr   r   Lock.__init__  s    )04DIGrq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s      #  #t  #rq   c                	  "   \        \        P                  \        4       4      pV P                  fh   V P
                  '       gV   \        P                  4       G R j  xL
  Wn        V P                  '       g     \        P                  4       G R j  xL
  R # R # V P                  V8X  d   \        R4      h\        P                  ! 4       pW3pV P
                  P                  V4        VG R j  xL
  T P
                  P                  T4       R #  L L  \         d    T P                  4        h i ; i LE  \         d>    T P
                  P                  T4       T P                  TJ d   T P                  4        h i ; i5iNz)Attempted to acquire an already held Lock)r1   r  r  r   r  r  r  rA  r  r  r   releaser   r   r  rW  )r   r   futr  s   &   rr   acquireLock.acquire  s1    GLL,.1#DMMM 88:::# %%%(CCEEE
 t#JKK$+NN$4yT"	II 	T"; ; F% LLN  	MM  &4'	sn   AFFDF:D DD AF*D7 /D50D7 4FD D22F5D7 7AE??Fc                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  .  s     	 	 	rq   c                	    \        \        P                  \        4       4      pV P                  f   V P
                  '       g	   Wn        R # V P                  VJ d   \        R4      h\        hr  )r1   r  r  r   r  r  r   r@   )r   r   s   & rr   acquire_nowaitLock.acquire_nowait.  sQ    GLL,.1#DMMM#t#JKKrq   c                   V ^8  d   QhRR/# r^  rh   )rz   s   "rr   r{   r  9  s     , , ,rq   c                	    V P                   R J# r   )r  r   s   &rr   lockedLock.locked9  s    t++rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r  <  s     
  
  
 rq   c                	    V P                   \        4       8w  d   \        R 4      hV P                   F5  w  rVP	                  4       '       d   K  Wn         VP                  R4        R# 	  RV n         R# )z)The current task is not holding this lockN)r  r   r   r  r   r   )r   r   r  s   &  rr   r  Lock.release<  sX    |~-JKKID==??#' t$	 '  rq   c                   V ^8  d   QhRR/# )rw   r   r5   rh   )rz   s   "rr   r{   r  H  s     L LN Lrq   c                	    V P                   '       d   \        V P                   4      MR p\        V P                  4       V\	        V P
                  4      4      # r   )r  AsyncIOTaskInfor5   r#  r  r  )r   	task_infos   & rr   r  Lock.statisticsH  s=    9=9I9I9IOD$4$45t	dkkmYDMM8JKKrq   )r  r  r  N)ri   rj   rk   rl   r2  r   r  r  r#  r  r  rp   rh   rq   rr   rI   rI     s=    #U #Lu L
 #D	,
 L Lrq   rI   c                     a  ] tR tRtRRRR/R R lltRRRR/R V 3R	 llltR
 R ltR R ltR R lt]	R R l4       t
]	R R l4       tR R ltRtV ;t# )rM   iM  	max_valueNr  Fc               (    V ^8  d   QhRRRRRRRR/# )	rw   initial_valuer  r.  r  r  r  r   rM   rh   )rz   s   "rr   r{   Semaphore.__annotate__N  s2     # ## 	#
 # 
#rq   c               	,    \         P                  V 4      # r   r0  r4  r0  r.  r  s   &&$$rr   r2  Semaphore.__new__N  s     ~~c""rq   c               $    V ^8  d   QhRRRRRR/# )rw   r0  r  r.  r  r  r  rh   )rz   s   "rr   r{   r1  W  s(     = == 	=
 =rq   c               	j   < \         SV `  WR 7       Wn        W n        W0n        \        4       V n        R# ))r.  N)r  r   _value
_max_valuer  r   r  )r   r0  r.  r  r  s   &&$$rr   r   Semaphore.__init__W  s.     	<##)5:Wrq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r1  d  s      t rq   c                	  "   V P                   ^ 8  d{   V P                  '       gi   \        P                  4       G Rj  xL
  V ;P                   ^,          un         V P                  '       g     \        P                  4       G Rj  xL
  R# R# \        P                  ! 4       pV P                  P                  V4        VG Rj  xL
  R#  L LG  \         d    T P                  4        h i ; i L*  \         d@     T P                  P                  T4       h   \         d    T P                  4         h i ; ii ; i5ir  )r7  r  r  rA  r  r  r   r  r  r   r  rW  r   r   r  s   & rr   r  Semaphore.acquired  s     ;;?4=== 88:::KK1K %%%(CCEEE
 $+NN$4S!	II# ; F% LLN  	$$S)   	s   #D>D>C.D>.C CC 
4D>?C1 C/C1 	D>C C,,D>/C1 1D;=DD;D74D;6D77D;;D>c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r1    s       rq   c                	f    V P                   ^ 8X  d   \        hV ;P                   ^,          un         R# r  )r7  r@   r   s   &rr   r  Semaphore.acquire_nowait  s"    ;;!qrq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r1    s     
 
 
rq   c                	P   V P                   e'   V P                  V P                   8X  d   \        R4      hV P                   FH  pVP	                  4       '       d   K  VP                  R 4       V P                  P                  V4        R # 	  V ;P                  ^,          un        R # )Nz!semaphore released too many times)r8  r7  r   r  r   r   rW  r<  s   & rr   r  Semaphore.release  sq    ??&4;;$//+I@AA==C==??t$$$S)	 ! 	qrq   c                   V ^8  d   QhRR/# r[  rh   )rz   s   "rr   r{   r1    s      s rq   c                	    V P                   # r   )r7  r   s   &rr   r  Semaphore.value  rv  rq   c                   V ^8  d   QhRR/# rn  rh   )rz   s   "rr   r{   r1    s      : rq   c                	    V P                   # r   )r8  r   s   &rr   r.  Semaphore.max_value  s    rq   c                   V ^8  d   QhRR/# )rw   r   rK   rh   )rz   s   "rr   r{   r1    s     7 7/ 7rq   c                	>    \        \        V P                  4      4      # r   )rK   r  r  r   s   &rr   r  Semaphore.statistics  s    "3t}}#566rq   )r  r8  r7  r  )ri   rj   rk   rl   r2  r   r  r  r  r  r  r.  r  rp   r  r  s   @rr   rM   rM   M  s{    # !%	#
 ##= !%	=
 #= =8
    7 7rq   rM   c                  "   ] tR tRt$ ^ tR]R&   R R ltR R 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" R# ltR$tR%# )&rE   i  r-  _total_tokensc                    V ^8  d   QhRRRR/# )rw   total_tokensr-  r   rE   rh   )rz   s   "rr   r{   CapacityLimiter.__annotate__  s     # #5 #_ #rq   c                	,    \         P                  V 4      # r   r0  r4  rP  s   &&rr   r2  CapacityLimiter.__new__  r  rq   c                   V ^8  d   QhRR/# )rw   rP  r-  rh   )rz   s   "rr   r{   rQ    s     ) )U )rq   c                	N    \        4       V n        \        4       V n        Wn        R # r   )r  
_borrowersr   _wait_queuerP  )r   rP  s   &&rr   r   CapacityLimiter.__init__  s    $'E<GM(rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rQ    s      $ rq   c                	B   "   V P                  4       G R j  xL
  R #  L5ir   )r  r   s   &rr   r  CapacityLimiter.__aenter__  s     llns   c               (    V ^8  d   QhRRRRRRRR/# r   rh   )rz   s   "rr   r{   rQ    s2      , & %	
 
rq   c                	.   "   V P                  4        R # 5ir   )r  r   s   &&&&rr   r  CapacityLimiter.__aexit__  s      	s   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   rQ    s     " "e "rq   c                	    V P                   # r   )rN  r   s   &rr   rP  CapacityLimiter.total_tokens  s    !!!rq   c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   rQ    s     # #% #D #rq   c                	   \        V\        4      '       g(   \        P                  ! V4      '       g   \	        R 4      hV^ 8  d   \        R4      h\        WP                  ,
          ^ 4      pWn        V P                  '       dI   V'       d?   V P                  P                  RR7      ^,          pVP                  4        V^,          pKX  R# R# )z'total_tokens must be an int or math.infztotal_tokens must be >= 0FlastN)r$  r  rg  isinfr  r   maxrN  rX  popitemr  )r   r  waiters_to_notifyevents   &&  rr   rP  rb    s    %%%djj.?.?EFF19899(:(: :A>" #4$$,,%,8;EIIK" $5rq   c                   V ^8  d   QhRR/# r[  rh   )rz   s   "rr   r{   rQ    s     $ $ $rq   c                	,    \        V P                  4      # r   )r  rW  r   s   &rr   borrowed_tokensCapacityLimiter.borrowed_tokens  s    4??##rq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   rQ    s     9 9% 9rq   c                	N    V P                   \        V P                  4      ,
          # r   )rN  r  rW  r   s   &rr   available_tokens CapacityLimiter.available_tokens  s    !!C$888rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rQ    s      T rq   c                    V P                   '       d\   \        V P                  4      V P                  8  d6   V P                   P	                  RR7      ^,          pVP                  4        R# R# R# )zCNotify the next task in line if this limiter has free capacity now.Fre  N)rX  r  rW  rN  ri  r  )r   rk  s   & rr   _notify_next_waiter#CapacityLimiter._notify_next_waiter  sT    DOO 4t7I7I I$$,,%,8;EIIK !Jrq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rQ    s     9 9 9rq   c                	8    V P                  \        4       4       R # r   )acquire_on_behalf_of_nowaitr   r   s   &rr   r  CapacityLimiter.acquire_nowait  s    ((8rq   c                    V ^8  d   QhRRRR/# rw   borrowerr1  r   r   rh   )rz   s   "rr   r{   rQ    s     	& 	&F 	&t 	&rq   c                	    WP                   9   d   \        R 4      hV P                  '       g%   \        V P                   4      V P                  8  d   \
        hV P                   P                  V4       R# )zEthis borrower is already holding one of this CapacityLimiter's tokensN)rW  r   rX  r  rN  r@   rK  r   r~  s   &&rr   rz  +CapacityLimiter.acquire_on_behalf_of_nowait  sX    &W  s4??3t7I7IIH%rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rQ    s     ? ?t ?rq   c                	P   "   V P                  \        4       4      G R j  xL
 #  L5ir   )acquire_on_behalf_ofr   r   s   &rr   r  CapacityLimiter.acquire  s     ..|~>>>>   &$&c                    V ^8  d   QhRRRR/# r}  rh   )rz   s   "rr   r{   rQ    s      6 d rq   c                	f  "   \         P                  4       G R j  xL
   V P                  V4        \         P                  4       G R j  xL
  R #  L5 L  \         d    T P                  4        h i ; i  \         d    \        P                  ! 4       pY P                  T&    TP                  4       G R j  xL 
  MR  \         dE    T P                  P                  TR 4       TP                  4       '       d   T P                  4        h i ; iT P                  P                  T4        R # i ; i5ir   )r  rA  rz  r  r  r  r@   r  rG   rX  r   popr  rv  rW  rK  )r   r~  rk  s   && rr   r  $CapacityLimiter.acquire_on_behalf_of  s     44666	,,X6$??AAA% 	7$ B  !  	*MMOE).X&jjl""    $$Xt4<<>>,,. OO)	*s   D1AD1A4 A 	A
A D1A A11D14.D.#B=6B97B=<D.=<D:DD.*D1-D..D1c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   rQ     s     2 2 2rq   c                	8    V P                  \        4       4       R # r   )release_on_behalf_ofr   r   s   &rr   r  CapacityLimiter.release   s    !!,.1rq   c                    V ^8  d   QhRRRR/# r}  rh   )rz   s   "rr   r{   rQ    s     # #V # #rq   c                	     V P                   P                  V4       T P	                  4        R#   \         d    \        R 4      Rhi ; i)z@this borrower isn't holding any of this CapacityLimiter's tokensN)rW  rW  rM  r   rv  r  s   &&rr   r  $CapacityLimiter.release_on_behalf_of  sK    	OO""8, 	  "  	R	s	   / Ac                   V ^8  d   QhRR/# )rw   r   r3   rh   )rz   s   "rr   r{   rQ    s     
 
5 
rq   c                	    \        V P                  V P                  \        V P                  4      \        V P                  4      4      # r   )r3   rn  rP  tuplerW  r  rX  r   s   &rr   r  CapacityLimiter.statistics  s;    (  $//"  !	
 	
rq   )rW  rN  rX  rP  N)ri   rj   rk   rl   rN  r7  r2  r   r  r  r  rP  r  rn  rr  rv  r  rz  r  r  r  r  r  rp   rh   rq   rr   rE   rE     s    M5#)
 " " # #  $ $ 9 99	&?02#
 
rq   rE   _default_thread_limiterzRunVar[CapacityLimiter]c                  ^    ] tR tRtR R ltR R ltR R ltR R	 ltR
 R ltR R lt	Rt
R# )_SignalReceiveri  c                   V ^8  d   QhRR/# )rw   signalsztuple[Signals, ...]rh   )rz   s   "rr   r{   _SignalReceiver.__annotate__  s     4 4 3 4rq   c                	    Wn         \        4       V n        \        4       V n        \
        P                  ! 4       V n        \        4       V n	        R # r   )
_signalsr	   r   r   _signal_queuer  r   r  r  _handled_signals)r   r  s   &&rr   r   _SignalReceiver.__init__  s3    %'
-2W'.~~'7.1erq   c                    V ^8  d   QhRRRR/# )rw   r   r&   r   r   rh   )rz   s   "rr   r{   r  &  s     * *w *4 *rq   c                	    V P                   P                  V4       V P                  P                  4       '       g   V P                  P	                  R 4       R # R # r   )r  r  r  r   r   )r   r   s   &&rr   _deliver_SignalReceiver._deliver&  s@    !!&)||  ""LL##D) #rq   c                   V ^8  d   QhRR/# rw   r   r  rh   )rz   s   "rr   r{   r  +  s      ? rq   c                	    \        V P                  4       FD  pV P                  P                  WP                  V4       V P
                  P                  V4       KF  	  V # r   )r  r  r   add_signal_handlerr  r  rK  )r   sigs   & rr   r   _SignalReceiver.__enter__+  sH    t}}%CJJ))#}}cB!!%%c* & rq   c               (    V ^8  d   QhRRRRRRRR/# r   rh   )rz   s   "rr   r{   r  2  s2     2 2,2 &2 %	2
 
2rq   c                	b    V P                    F  pV P                  P                  V4       K   	  R # r   )r  r   remove_signal_handler)r   r   r   r   r  s   &&&& rr   r   _SignalReceiver.__exit__2  s&     ((CJJ,,S1 )rq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r  ;  s      ? rq   c                	    V # r   rh   r   s   &rr   	__aiter___SignalReceiver.__aiter__;  s    rq   c                   V ^8  d   QhRR/# )rw   r   r&   rh   )rz   s   "rr   r{   r  >  s     , , ,rq   c                	   "   \         P                  4       G R j  xL
  V P                  '       g/   \        P                  ! 4       V n        V P
                  G R j  xL
  V P                  P                  4       #  L^ L 5ir   )r  r2  r  r  r   r  r  r   s   &rr   	__anext___SignalReceiver.__anext__>  s]     '')))!!!">>+DL,,!!))++ 	* s&   A=A9A=)A=A;A=;A=)r  r  r   r  r  N)ri   rj   rk   rl   r   r  r   r   r  r  rp   rh   rq   rr   r  r    s%    4*
2, ,rq   r  c                  :   a  ] tR tRtR V 3R lltR R ltRtV ;t# )r*  iL  c                   V ^8  d   QhRR/# )rw   r   r   rh   )rz   s   "rr   r{   AsyncIOTaskInfo.__annotate__M  s     
' 
'\ 
'rq   c                	  < \         P                  V4      pVf   R pMVP                  pVP                  4       pVf   Q R4       h\        SV `  \        V4      W1P                  4       V4       \        P                  ! V4      V n
        R # )Nz&created TaskInfo from a completed Task)r  r  r  r  r  r   r  get_nameweakrefrefr  )r   r   rR  r  r   r  s   &&   rr   r   AsyncIOTaskInfo.__init__M  sq    !%%d+
I",,I}}I!IID9mmotD[[&
rq   c                   V ^8  d   QhRR/# r^  rh   )rz   s   "rr   r{   r  Y  s      $ rq   c                	t   V P                  4       ;p'       g   R # VP                  '       d   R# \        VP                  \        P
                  4      '       d#   VP                  P                  4       '       d   R# \        P                  V4      ;p'       d!   VP                  ;p'       d   VP                  # R # )FT)r  ro  r$  rp  r  r   r   r  r  r  r`  )r   r   rR  r  s   &   rr   has_pending_cancellation(AsyncIOTaskInfo.has_pending_cancellationY  s    

$$t''88  **,,%))$//:/)666|6#:::rq   )r  )ri   rj   rk   rl   r   r  rp   r  r  s   @rr   r*  r*  L  s    
' 
' rq   r*  c                      ] tR tRt$ R]R&   RRRRRR/R	 R
 l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 R ltR R ltRtR# ) 
TestRunnerim  zBMemoryObjectSendStream[tuple[Awaitable[Any], asyncio.Future[Any]]]_send_streamrt   N
use_uvloopFru   c               (    V ^8  d   QhRRRRRRRR/# )	rw   rt   rx   r  r  ru   ry   r   r   rh   )rz   s   "rr   r{   TestRunner.__annotate__p  s4     6 6 6 	6
 =6 
6rq   c               	    V'       d;   Vf7   \         P                  R8w  d   ^ R IpVP                  pM^ R IpVP                  p\        WR7      V n        . V n        R V n        R # )Nwin32rt   ru   )	rE  platformuvloopr   winloopr[   _runnerr  _runner_task)r   rt   r  ru   r  r  s   &$$$  rr   r   TestRunner.__init__p  sP     ,.||w&%44&55EE0215rq   c                   V ^8  d   QhRR/# )rw   r   r  rh   )rz   s   "rr   r{   r    s      : rq   c                	    V P                   P                  4        V P                  4       P                  V P                  4       V # r   )r  r   r   set_exception_handler_exception_handlerr   s   &rr   r   TestRunner.__enter__  s1     --d.E.EFrq   c               (    V ^8  d   QhRRRRRRRR/# r   rh   )rz   s   "rr   r{   r    s2     9 9,9 &9 %	9
 
9rq   c                	>    V P                   P                  WV4       R # r   )r  r   r   s   &&&&rr   r   TestRunner.__exit__  s     	h8rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s     ' '+ 'rq   c                	6    V P                   P                  4       # r   )r  r   r   s   &rr   r   TestRunner.get_loop  s    ||$$&&rq   c               $    V ^8  d   QhRRRRRR/# )rw   r   r   r   dict[str, Any]r   r   rh   )rz   s   "rr   r{   r    s$     4 4-48F4	4rq   c                	    \        VP                  R 4      \        4      '       d%   V P                  P	                  VR ,          4       R# VP                  V4       R# )r   N)r$  r  r   r  r  default_exception_handler)r   r   r   s   &&&rr   r  TestRunner._exception_handler  sA     gkk+.	::##GK$89**73rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r    s     	 	 	rq   c                	    V P                   '       dC   V P                   . uqn         \        V4      ^8X  d
   V^ ,          hV'       d   \        RV4      hR# R# )r   z6Multiple exceptions occurred in asynchronous callbacksN)r  r  rb   )r   r`   s   & rr   _raise_async_exceptions"TestRunner._raise_async_exceptions  sV    +/+;+;R(J(:!# m#(Lj  	 rq   c                    V ^8  d   QhRRRR/# )rw   receive_streamzOMemoryObjectReceiveStream[tuple[Awaitable[T_Retval], asyncio.Future[T_Retval]]]r   r   rh   )rz   s   "rr   r{   r    s      2 2
2
 
2rq   c                	  "   ^ RI Hp T;_uu_ 4        V P                  ;_uu_ 4        V  Rj  xL
  w  r4 VG Rj  xL
 pVP                  4       '       g   VP	                  V4       K@  KB   L= L1  \
         d7   pTP                  4       '       g   TP                  ! TP                  !   h Rp?i\         dL   pTP                  4       '       g   TP                  T4       \        T\        T34      '       g   h  Rp?K  Rp?ii ; iD RRR4       M  + '       g   i     M; iRRR4       R#   + '       g   i     R# ; i5i)r   )OutcomeExceptionN)_pytest.outcomesr  r  r   r   r   r   r   r  r   r$  r   )r   r  r  r   r   retvalr!  s   &&     rr   _run_tests_and_fixtures"TestRunner._run_tests_and_fixtures  s      	6^T...&4 2 2ld2#'ZF "++--))&1 .2'% !++--sxx0$ !++--,,S1%cI7G+HII J	 '5 /...^^^^s   ED1D	D	
A-D	
D	A1
A/A1
+D	-D	
/A1
1D<1B--D:D;A D;D	DD		D1D$D1'
E1E	<	Ec               (    V ^8  d   QhRRRRRRRR/# )	rw   r  z Callable[P, Awaitable[T_Retval]]r   zP.argsr  zP.kwargsr   r   rh   )rz   s   "rr   r{   r    s2      .  	
 
rq   c                	  "   V P                   '       gy   \        \        \        \        ,          \
        P                  3,          ,          ! ^4      w  V n        pV P                  4       P                  V P                  V4      4      V n         V! V/ VB pV P                  4       P                  4       pV P                  P                  WV34       VG Rj  xL
 #  L5i)r   N)r  rC   r  r   r.   r  r   r  r   r   r  r   send_nowait)r   r  r   r  r  r   r   s   &&*,   rr   _call_in_runner_taskTestRunner._call_in_runner_task  s         0Kingnn4511-D~ !% ; ;,,^<!D T$V$+/==?+H+H+J%%tn5||s   CCCCc               $    V ^8  d   QhRRRRRR/# )rw   fixture_funcz,Callable[..., AsyncGenerator[T_Retval, Any]]r  r  r   zIterable[T_Retval]rh   )rz   s   "rr   r{   r    s-     G GBG G 
	Grq   c              #  	  "   V! R/ VB pV P                  4       P                  V P                  VP                  R 4      4      pV P	                  4        Vx   V P                  4       P                  V P                  VP                  R 4      4       V P                  4       P                  VP                  4       4       \        R4      h  \         d    T P	                  4         R # i ; i5i)Nz$Async generator fixture did not stoprh   )r   r   r  asendr  r3  r   StopAsyncIteration)r   r  r  asyncgenfixturevalues   &&&  rr   run_asyncgen_fixtureTestRunner.run_asyncgen_fixture  s     
  )&)!%!C!C%%hnnd;"
 	$$&	GMMO..))(..$? MMO..x/@AEFF	 " 	+((*	+s*   AC,9C
 8C,
C)%C,(C))C,c               $    V ^8  d   QhRRRRRR/# )rw   r  z,Callable[..., Coroutine[Any, Any, T_Retval]]r  r  r   r   rh   )rz   s   "rr   r{   r    s(     	 	B	 	 
		rq   c                	    V P                  4       P                  V P                  ! V3/ VB 4      pV P                  4        V# r   )r   r   r  r  )r   r  r  r  s   &&& rr   run_fixtureTestRunner.run_fixture  s@    
 33%%l=f=
 	$$&rq   c               $    V ^8  d   QhRRRRRR/# )rw   	test_funcz'Callable[..., Coroutine[Any, Any, Any]]r  r  r   r   rh   )rz   s   "rr   r{   r    s$     
' 
'@
'JX
'	
'rq   c                	     V P                  4       P                  V P                  ! V3/ VB 4       V P                  4        R #   \         d&   pT P                  P                  T4        R p?L=R p?ii ; ir   )r   r   r  r   r  r  r  )r   r  r  r!  s   &&& rr   run_testTestRunner.run_test  se    	)MMO..)))>v> 	$$&  	)##C((	)s   0A A4A//A4)r  r  r  r  )ri   rj   rk   rl   r7  r   r   r   r   r  r  r  r  r  r  r  rp   rh   rq   rr   r  r  m  se    TT6 "6 !	6
 @D6*
9'4	26&G.	
' 
'rq   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]RgR& 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]RhR2 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       t!]R>^ R?^ R@^ RA^ /RB RC ll4       t"]RiRD RE ll4       t#]RF RG l4       t$]RH RI 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       t0]R` Ra l4       t1]Rb Rc l4       t2]Rd Re l4       t3Rft4R # )jr  i	  c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
rw   r  1Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]]r   r  r  r  optionsr   r   rh   )rz   s   "rr   r{   AsyncIOBackend.__annotate__	  s<     ) )?) &) 	)
  ) 
)rq   c                	  aa \        S4      R  VV3R ll4       pVP                  RR4      pVP                  RR4      pVfO   VP                  RR4      '       d7   \        P                  R8w  d   ^ RIpVP
                  pM^ RIp	V	P
                  p\        WgR7      ;_uu_ 4       p
V
P                  V! 4       4      uuRRR4       #   + '       g   i     R# ; i)	c                   V ^8  d   QhRR/# rw   r   r   rh   )rz   s   "rr   r{   (AsyncIOBackend.run.<locals>.__annotate__	  s     	' 	'x 	'rq   c                    <"   \        \        P                  \        4       4      p V P	                  \        S4      4       \        R R 4      \        V &    S! S!  G R j  xL
 \        V  #  L  \        T  i ; i5ir   )r1   r  r  r   set_namer  rN  r  )r   r   r  s    rr   wrapper#AsyncIOBackend.run.<locals>.wrapper	  s`     ln5DMM+D12!*4!6L'!4[( & ) &s0   AA7	A+ A)A+ !A7)A+ +	A44A7rt   Nru   r  Fr  r  )	r   r  rE  r  r  r   r  r[   r   )r4  r  r   r  r  r  rt   ru   r  r  runners   &ff&&      rr   r   AsyncIOBackend.run	  s     
t	' 	' 
	' GT*{{>48GKKe$D$D||w&%44&55%;;v::gi( <;;;s   %CC	c                   V ^8  d   QhRR/# )rw   r   r1  rh   )rz   s   "rr   r{   r	  )	  s     " "f "rq   c                	    \        4       # r   )r	   r  s   &rr   current_tokenAsyncIOBackend.current_token(	  s    !!rq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r	  -	  s     ) )U )rq   c                	2    \        4       P                  4       # r   )r	   ri  r  s   &rr   r  AsyncIOBackend.current_time,	  s    !&&((rq   c                   V ^8  d   QhRR/# )rw   r   ztype[BaseException]rh   )rz   s   "rr   r{   r	  1	  s      *= rq   c                	    \         # r   )r   r  s   &rr   cancelled_exception_class(AsyncIOBackend.cancelled_exception_class0	  s    rq   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r	  5	  s       rq   c                	8   "   \        ^ 4      G Rj  xL
  R#  L5ir  r
   r  s   &rr   r2  AsyncIOBackend.checkpoint4	  s     Ah   c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r	  9	  s     : :d :rq   c                	(  "   \        4       pVf   R #  \        V,          P                  pT'       dJ   TP                  '       d   \        ^ 4      G R j  xL
  K/  TP                  '       d   R # TP                  pKQ  R #   \         d     R # i ; i L<5ir   )r   r  r  rM  rq  r
   r*  r	  )r4  r   r  s   &  rr   rA  &AsyncIOBackend.checkpoint_if_cancelled8	  s}     ~<	'-::L )))Ah$$$+99   		
 sD   BA> BBBBB,B>B	BBBc                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r	  L	  s       rq   c                	   "   \        R R7      ;_uu_ 4        \        ^ 4      G Rj  xL
  RRR4       R#  L  + '       g   i     R# ; i5i)Tr  N)rO   r
   r  s   &rr   r  )AsyncIOBackend.cancel_shielded_checkpointK	  s1     %%(NN &% &%%s%   A757
A7A		Ac                    V ^8  d   QhRRRR/# )rw   delayr-  r   r   rh   )rz   s   "rr   r{   r	  Q	  s       $ rq   c                	8   "   \        V4      G R j  xL
  R #  L5ir   r!  )r4  r+  s   &&rr   r
   AsyncIOBackend.sleepP	  s     Elr#  r)  r*  Fc               $    V ^8  d   QhRRRRRR/# r,  rh   )rz   s   "rr   r{   r	  U	  s$     = ==48=	=rq   c               	    \        WR 7      # ))r)  r*  rN   r3  s   &$$rr   create_cancel_scope"AsyncIOBackend.create_cancel_scopeT	  s     H<<rq   c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   r	  [	  s      5 rq   c                	   \        4       ;pf   \        P                  #  \        V,          P                  p\        P                  pT'       d_   \        Y2P                  4      pTP                  '       d   \        P                  ) p T# TP                  '       d    T# TP                  pKf  T#   \
         d    \        P                  u # i ; ir   )r   rg  rh  r  r  rM  minr)  r>  r*  r	  )r4  r   r  r)  s   &   rr   current_effective_deadline)AsyncIOBackend.current_effective_deadlineZ	  s     N"D+88O	'-::L 888%:%:;H*** HH9  $$$   ,99  	88O	s   B/ /CCc                   V ^8  d   QhRR/# )rw   r   zabc.TaskGrouprh   )rz   s   "rr   r{   r	  r	  s      - rq   c                	    \        4       # r   )r  r  s   &rr   create_task_group AsyncIOBackend.create_task_groupq	  s
    {rq   c                   V ^8  d   QhRR/# )rw   r   z	abc.Eventrh   )rz   s   "rr   r{   r	  v	  s      Y rq   c                	    \        4       # r   rF   r  s   &rr   create_eventAsyncIOBackend.create_eventu	  s	    wrq   c                    V ^8  d   QhRRRR/# )rw   r  r  r   zabc.Lockrh   )rz   s   "rr   r{   r	  z	  s     / /$ /8 /rq   c               	    \        VR 7      # ))r  rH   r  s   &$rr   create_lockAsyncIOBackend.create_locky	  s    ..rq   r.  Nr  c               (    V ^8  d   QhRRRRRRRR/# )	rw   r0  r  r.  r  r  r  r   zabc.Semaphorerh   )rz   s   "rr   r{   r	  ~	  s8     X XX 	X
 X 
Xrq   c               	    \        WVR 7      # ))r.  r  rL   r3  s   &&$$rr   create_semaphoreAsyncIOBackend.create_semaphore}	  s     ,WWrq   c                    V ^8  d   QhRRRR/# )rw   rP  r-  r   zabc.CapacityLimiterrh   )rz   s   "rr   r{   r	  	  s     - -5 -=P -rq   c                	    \        V4      # r   rD   rS  s   &&rr   create_capacity_limiter&AsyncIOBackend.create_capacity_limiter	  s    |,,rq   c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )rw   r  &Callable[[Unpack[PosArgsT]], T_Retval]r   r  abandon_on_cancelr  limiterzabc.CapacityLimiter | Noner   r   rh   )rz   s   "rr   r{   r	  	  s<     :$ :$4:$ &:$  	:$
 ,:$ 
:$rq   c                	  "   V P                  4       G R j  xL
   \        P                  4       p\        P                  4       pT;'       g    V P                  4       ;_uu_4       GR j  xL
  \        V'       * R7      ;_uu_ 4       p\        P                  \        ,          ! 4       p\        4       p	V'       g_   \        WV4      p
V
P                  4        VP                  V
4       V	P!                  V
P"                  \$        P&                  ! 4       R7       MVP)                  4       p
V P+                  4       pV'       du   W^ ,          P,                  ,
          \        P.                  8  d   MGVP1                  4       pVP2                  P5                  VP"                  4       VP#                  4        K|  \7        4       pVP9                  \:        R 4       V'       g   VP<                  f   TpMVP<                  pV
P>                  PA                  WW(V34       VG R j  xL
 uuR R R 4       uuR R R 4      GR j  xL
  #  EL(  \         dC    \        4       p\        4       p\        P                  T4       \        P                  T4        ELIi ; i EL' Lv L]  + '       g   i     M; iR R R 4      GR j  xL 
  R #   + GR j  xL 
 '       g   i     R # ; i5i)Nr  )r   )!r2  r   r  r!  LookupErrorr   r  current_default_thread_limiterrO   r  r   r   r  r  r   rK  r  r  r   r   r  r  r  r  r  r  remove_done_callbackr   r   r9   r	  r  r  )r4  r  r   rM  rN  r  r  rv  r   r  workernowexpired_workerr   worker_scopes   &&&&&          rr   run_sync_in_worker_thread(AsyncIOBackend.run_sync_in_worker_thread	  s     nn	-3779L)--/G BBc@@BBBB(9$9::e 13*,	#))lKFLLNKK'//[-@-@-B 0  *--/F **,C&q/"<"<<*889 ")5)=)=)?&00EE*// '++-&.5t<$(;(;(C#(L#(#6#6L''l(ST#|K ;: CBB 	  	- 7LeG$((6##G,		- CL $M C:: CBBBBBs   KH>K(I KK*J+K.J>B8J	CJ	JJ	!
J>+K8J9KA	J
KJKJ	KJ(#J>+K6J97K>K	K
K	K		Kc                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r	  	  s     	( 	( 	(rq   c                	    \         P                  pVeM   VP                  '       d   \        R\	        V4      R 24      hVP
                  '       d   R # VP                  pKP  R # )NzCancelled by cancel scope r  )r:   r  rq  r   r  r*  r	  )r4  rv  s   & rr   check_cancelledAsyncIOBackend.check_cancelled	  sT    $0$E$E"""$'A"U)A%OPP|||''E  rq   c               (    V ^8  d   QhRRRRRRRR/# )	rw   r  r  r   r  tokenr1  r   r   rh   )rz   s   "rr   r{   r	  	  s2        ?  &  	 
 
 rq   c                	  aaa R  VVV3R llp\        RT;'       g    \        P                  P                  4      pVP	                  4       '       d   \
        h\        4       pVP                  \        R4       \        \        RR4      oVP                  \        P                  V! 4       VR7      pVP                  4       # )c                   V ^8  d   QhRR/# r  rh   )rz   s   "rr   r{   :AsyncIOBackend.run_async_from_thread.<locals>.__annotate__	  s     	/ 	/H 	/rq   c                   <"   R p SeQ   \        \        P                  \        4       4      p\	        RS4      \
        V&   SP                  P                  V4        S! S!  G Rj  xL
 Se   SP                  P                  X4       # #  L$  \         d/   p\        P                  P                  \        T4      4      RhRp?ii ; i  Se   SP                  P                  X4       i i ; i5ir  )r1   r  r  r   rN  r  rD  rK  rL  r   
concurrentfuturesr  )__tracebackhide__r   r!  r   r  rv  s      rr   task_wrapper:AsyncIOBackend.run_async_from_thread.<locals>.task_wrapper	  s      $ GLL,.9%.tU%;T"  &/!4[( $LL((. %	 )! L ((77CAtKL $LL((. %sH   AC,	B $B	%B (!C,	B C)B??CC "C))C,r   r  r  N)r   )r1   r:   r  native_tokenr  r?   r   r   r9   r   r  run_coroutine_threadsafer	  )	r4  r  r   r^  rf  r   r   r  rv  s	   &ff&    @rr   run_async_from_thread$AsyncIOBackend.run_async_from_thread	  s    	/ 	/ !Q!Q,*D*D*Q*Q
 >>"".-y9&<dC18,,ln4 2= 2
 xxzrq   c               (    V ^8  d   QhRRRRRRRR/# )	rw   r  rL  r   r  r^  r1  r   r   rh   )rz   s   "rr   r{   r	  	  s2      4 & 	
 
rq   c                	$  aaa \        S4      R  VVV3R ll4       p\        RT;'       g    \        P                  P                  4      pVP                  4       '       d   \        h\        4       oVP                  V4       SP                  4       # )c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   9AsyncIOBackend.run_sync_from_thread.<locals>.__annotate__	  s     	 	 	rq   c                    <  \        R 4       SP                  S! S!  4       R#   \         d4   p SP                  T 4       \	        T \
        4      '       g   h  Rp ? R# Rp ? ii ; i)r  N)r9   r   r  r   r$  r   )r!  r   r  r  s    rr   r  4AsyncIOBackend.run_sync_from_thread.<locals>.wrapper	  sQ    ))4T4[)  $!#y11 2s    % A#(AA#r   )
r   r1   r:   r  rh  r  r?   r   r   r	  )r4  r  r   r^  r  r   r  s   &ff&  @rr   run_sync_from_thread#AsyncIOBackend.run_sync_from_thread	  s{     
t	 	 
	 !Q!Q,*D*D*Q*Q
 >>""17!!'*xxzrq   c               0    V ^8  d   QhRRRRRRRRRRR	R
/# )rw   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]rt  zint | IO[Any] | Noner{  r  r  r.   r   rP  rh   )rz   s   "rr   r{   r	  
  sN     !L !L:!L $	!L
 %!L %!L !L 
!Lrq   c          	     	z  "   V P                  4       G R j  xL
  \        V\        4      '       d   \        P                  ! V4      p\        V\
        \        34      '       d'   \        P                  ! V3RVRVRV/VB G R j  xL
 pM$\        P                  ! VRVRVRV/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	\        WgW4      #  EL L L5i)Nrt  r{  r  )r2  r$  r$   osfspathr  r)  r  create_subprocess_shellcreate_subprocess_execrt  r9  r{  r$  r  rP  )
r4  ru  rt  r{  r  r  r  stdin_streamstdout_streamstderr_streams
   &&$$$,    rr   open_processAsyncIOBackend.open_process
  s.     nngx((ii(GgU|,,#;;  	
  G $::  	
  G >E]]]*7==9PT?F~~~+GNN;SW?F~~~+GNN;SWwmKK1 	
sF   D;D4A,D;D7$D;(D9)D;?(D;((D;$D;7D;9D;c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   r	  7
  s     
 
:J 
t 
rq   c                	    \        \        V4      R R7       \        4       P                  \	        \
        V4      4       R# )z AnyIO process pool shutdown taskr  N)r   r  r  r  r   r  )r4  r  s   &&rr   #setup_process_pool_exit_at_shutdown2AsyncIOBackend.setup_process_pool_exit_at_shutdown6
  s3    *733	
 	**;WE	
rq   c               (    V ^8  d   QhRRRRRRRR/# )	rw   hostr  portr  local_addressIPSockAddrType | Noner   r  rh   )rz   s   "rr   r{   r	  A
  s,     
1 
1
1!
12G
1	
1rq   c           
     	   "   \        \        \        P                  \        3,          \        4       P                  \        WVR 7      G Rj  xL
 4      w  rEVP                  4        \        WE4      #  L%5i))
local_addrN)	r1   r  r  r  r  r	   create_connectionr  r  )r4  r  r  r  r  r  s   &&&&  rr   connect_tcpAsyncIOBackend.connect_tcp@
  sg      #'##^34"$66} 7  
	 	!I00s   A	A3A1
&A3c                    V ^8  d   QhRRRR/# )rw   pathzstr | bytesr   zabc.UNIXSocketStreamrh   )rz   s   "rr   r{   r	  N
  s     4 4k 46J 4rq   c                	  aa"   V P                  4       G R j  xL
  \        4       o\        P                  ! \        P                  4      oSP	                  R4         SP                  V4       \        S4      #  La  \         dX    \        P                  ! 4       pSP                  STP                  R 4       TP                  TT3R l4       TG R j  xL 
   K  \         d    SP                  4        h i ; i5i)NFc                &   < SP                  S4      # r   r5  r  r   r  s   &rr   r   -AsyncIOBackend.connect_unix.<locals>.<lambda>Y
  s    d.@.@.Lrq   )r2  r	   r  AF_UNIXr  connectrB  rK  r  r   r7  r   r  r  r   )r4  r  r  r   r  s   && @@rr   connect_unixAsyncIOBackend.connect_unixM
  s     nn!]]6>>2
u%4""4( (
33! 	 # $+NN$4
ALL$?##$LM    "sG   C<A:AC<A< /C<<AC9CC9C<C9&C99C<c                    V ^8  d   QhRRRR/# rw   sockr  r   rR   rh   )rz   s   "rr   r{   r	  b
  s     ' '} ' 'rq   c                	    \        V4      # r   rq  r4  r  s   &&rr   create_tcp_listener"AsyncIOBackend.create_tcp_listenera
  s     &&rq   c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   r	  f
  s     ( ( (. (rq   c                	    \        V4      # r   )r  r  s   &&rr   create_unix_listener#AsyncIOBackend.create_unix_listenere
  s    !$''rq   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
rw   familyr'   r  r  remote_address
reuse_portr  r   zUDPSocket | ConnectedUDPSocketrh   )rz   s   "rr   r{   r	  j
  s<     ; ;; -; .	;
 ; 
(;rq   c                	   "   \        4       P                  \        VVVVR 7      G Rj  xL
 w  rVVP                  '       d   VP	                  4        VP                  hV'       g   \        WV4      # \        WV4      #  LR5i))r  remote_addrr  r  N)r	   create_datagram_endpointr  r   r   r  r  )r4  r  r  r  r  r  r  s   &&&&&  rr   create_udp_socket AsyncIOBackend.create_udp_socketi
  sy      %5$6$O$O$&! %P %
 
	 OO$$$Y11%i::
s   &A=A;;A=%A=c               $    V ^8  d   QhRRRRRR/# )rw   r  r  remote_pathzstr | bytes | Noner   z8abc.UNIXDatagramSocket | abc.ConnectedUNIXDatagramSocketrh   )rz   s   "rr   r{   r	  
  s$     2 2&25G2	A2rq   c                	  aa"   V P                  4       G R j  xL
  \        4       oV'       d     SP                  V4       \        S4      # \        S4      #  L?  \         dX    \
        P                  ! 4       pSP                  STP                  R 4       TP                  TT3R l4       TG R j  xL 
   K  \         d    SP                  4        h i ; i5i)Nc                &   < SP                  S4      # r   r  r  s   &rr   r   <AsyncIOBackend.create_unix_datagram_socket.<locals>.<lambda>
  s    $2D2DZ2Prq   )r2  r	   r  r  rK  r  r   r7  r   r  r  r   r  )r4  r  r  r  r   s   &f& @rr   create_unix_datagram_socket*AsyncIOBackend.create_unix_datagram_socket
  s      nn!C&&{3 7zBB%j11% 	 ' (/(8AOOJdC''(PQGG$ $$&sE   CACA CAC2B53C8C;CCCr  r  protorb  c               4    V ^8  d   QhRRRRRRRRR	R
RR
RR/# )rw   r  zbytes | str | Noner  zstr | int | Noner  zint | AddressFamilyr  zint | SocketKindr  r  rb  r   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]rh   )rz   s   "rr   r{   r	  
  sP     
 
 
 

 $
 
 
 


rq   c          	     	V   "   \        4       P                  WW4WVR 7      G Rj  xL
 #  L5i))r  r  r  rb  N)r	   getaddrinfo)r4  r  r  r  r  r  rb  s   &&&$$$$rr   r  AsyncIOBackend.getaddrinfo
  s3     & &'33v 4 
 
 	
 
s    )')c               $    V ^8  d   QhRRRRRR/# )rw   sockaddrrQ   rb  r  r   ztuple[str, str]rh   )rz   s   "rr   r{   r	  
  s)     E E%E.1E	Erq   c                	P   "   \        4       P                  W4      G R j  xL
 #  L5ir   )r	   getnameinfo)r4  r  rb  s   &&&rr   r  AsyncIOBackend.getnameinfo
  s!      &'33HDDDDr  c                    V ^8  d   QhRRRR/# rw   objrY   r   r   rh   )rz   s   "rr   r{   r	  
       2& 2&&8 2&T 2&rq   c                	  aaa	a
"    \         P                  4       o	\	        V\
        4      '       d   TMVP                  4       oS	P                  S4      '       d   \        R 4      h\        4       pVP                  4       oR VVV	V
3R llp VP                  SV4       VP                  o
SS	S&    SG Rj  xL
 p S	S S
! S4       T'       g   \         hR#   \         d    / o	\         P                  S	4        Li ; i  \         d/    ^ RIHp T! 4       pTP                  ST4       TP                  o
 Li ; i L  \         d     Li ; i   S	S S
! S4       i   \         d     i i ; i; i5i)r  c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   2AsyncIOBackend.wait_readable.<locals>.__annotate__
       	 	D 	rq   c                    <  SS  S! S 4        SP                  R 4       R#   \          d     L!i ; i  \        P                   d     R# i ; ir  rM  r   r  r  )rl  r  r  r(  s   rr   r  (AsyncIOBackend.wait_readable.<locals>.cb
  sW    "O b!t$   ,,    " 3 00AAget_selectorN)r  r  rP  r  r$  r  r>  r<   r	   r   r,  r(  r  $anyio._core._asyncio_selector_threadr  rM  r=   )r4  r  r   r  r  selectorsuccessrl  r  r  r(  s   &&     @@@@rr   wait_readableAsyncIOBackend.wait_readable
  sc    	*&**,K
 sC((Scjjl??2#N33!$($6$6$8	 			/OOB# !..MB	"iG"O b!%% ]  	*K[)	*4 # 	3I#~HB'$22M	3    "O b!     E0C >E01E0C? E01E 6D;7E <D= ?E0E0"C<9E0;C<<E0?6D85E07D88E0;E =EE0
EE0E-E	E-E*'E-)E**E--E0c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   r	  
  r  rq   c                	  aaa	a
"    \         P                  4       o
\	        V\
        4      '       d   TMVP                  4       oS
P                  S4      '       d   \        R 4      h\        4       pVP                  4       oR VVV	V
3R llp VP                  SV4       VP                  o	SS
S&    SG Rj  xL
 p S
S S	! S4       T'       g   \         hR#   \         d    / o
\         P                  S
4        Li ; i  \         d/    ^ RIHp T! 4       pTP                  ST4       TP                  o	 Li ; i L  \         d     Li ; i   S
S S	! S4       i   \         d     i i ; i; i5i)r  c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   2AsyncIOBackend.wait_writable.<locals>.__annotate__
  r  rq   c                    <  SS  S! S 4        SP                  R 4       R#   \          d     L!i ; i  \        P                   d     R# i ; ir  r  )rl  r  r5  r  s   rr   r  (AsyncIOBackend.wait_writable.<locals>.cb
  sX    " $ b!t$   ,, r  r  N)r  r  rP  r  r$  r  r>  r<   r	   r   r7  r5  r  r  r  rM  r=   )r4  r  r   r  r  r  r  rl  r  r5  r  s   &&     @@@@rr   wait_writableAsyncIOBackend.wait_writable
  sh    	,(,,.L
 sC((ScjjlB#L11!$($6$6$8	 			/OOB# !..MR	"iG" $ b!%% ]  	,Ll+	,4 # 	3I#~HB'$22M	3    " $ b!  r  c                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   r	  !  s     .5 .5!3 .5 .5rq   c                	D   \        V\        4      '       d   TMVP                  4       p\        4       p \        P                  4       p VP                  V4      p VP                  R 4        VP                  V4        \         P                  4       p TP                  T4      p TP                  R 4        TP#                  T4       R#   \        P                   d     Lvi ; i  \         d     ^ RIHp T! 4       P                  T4        Li ; i  \         d     Li ; i  \         d     Li ; i  \        P                   d     Li ; i  \         d!    ^ RIHp T! 4       P#                  T4        R# i ; i  \         d     R# i ; i  \         d     R# i ; i)Fr  N)r$  r  r>  r	   r  r  r  r   r  r  r5  r  r  r  rM  rP  r  r(  )r4  r  rl  r   r  r  r  r  s   &&      rr   notify_closingAsyncIOBackend.notify_closing   s   sC((Scjjl!	5(,,.L5"&&r*NN5)5&&r*	5&**,K5!oob)NN5)5&&r*5 00 
 + 5Q N0045    		@ 00 
 + 5Q N0045    		s   D$ 	D C -C& ?F E> &D5 8E C#"C#&'DDD! D!$D21D25EE'E;:E;>FFFFc                    V ^8  d   QhRRRR/# r  rh   )rz   s   "rr   r{   r	  R  s     ' 'm ' 'rq   c                	    "   \        V4      # 5ir   r  r  s   &&rr   wrap_listener_socket#AsyncIOBackend.wrap_listener_socketQ  s      &&   c                    V ^8  d   QhRRRR/# )rw   r  r  r   r  rh   )rz   s   "rr   r{   r	  V  s     1 1M 1l 1rq   c                	v   "   \        4       P                  \        VR 7      G Rj  xL
 w  r#\        W#4      #  L5i)r  N)r	   r  r  r  r4  r  r  r  s   &&  rr   wrap_stream_socket!AsyncIOBackend.wrap_stream_socketU  s=     $4$6$H$H %I %
 
	 I00
   #979c                    V ^8  d   QhRRRR/# )rw   r  r  r   rB  rh   )rz   s   "rr   r{   r	  ]  s     & & &CS &rq   c                	    "   \        V4      # 5ir   )rB  r  s   &&rr   wrap_unix_stream_socket&AsyncIOBackend.wrap_unix_stream_socket\  s     %%r  c                    V ^8  d   QhRRRR/# )rw   r  r  r   r  rh   )rz   s   "rr   r{   r	  a  s     . . .9 .rq   c                	v   "   \        4       P                  \        VR 7      G Rj  xL
 w  r#\        W#4      #  L5ir  )r	   r  r  r  r  s   &&  rr   wrap_udp_socketAsyncIOBackend.wrap_udp_socket`  s=     $4$6$O$O4 %P %
 
	 --
r  c                    V ^8  d   QhRRRR/# )rw   r  r  r   r  rh   )rz   s   "rr   r{   r	  h  s     7 7= 7EW 7rq   c                	v   "   \        4       P                  \        VR 7      G Rj  xL
 w  r#\        W#4      #  L5ir  )r	   r  r  r  r  s   &&  rr   wrap_connected_udp_socket(AsyncIOBackend.wrap_connected_udp_socketg  s=     $4$6$O$O4 %P %
 
	 ")66
r  c                    V ^8  d   QhRRRR/# )rw   r  r  r   r  rh   )rz   s   "rr   r{   r	  o  s     ( (= (EW (rq   c                	    "   \        V4      # 5ir   )r  r  s   &&rr   wrap_unix_datagram_socket(AsyncIOBackend.wrap_unix_datagram_socketn  s     !$''r  c                    V ^8  d   QhRRRR/# )rw   r  r  r   r  rh   )rz   s   "rr   r{   r	  s  s     1 1 1	$1rq   c                	    "   \        V4      # 5ir   )r  r  s   &&rr   #wrap_connected_unix_datagram_socket2AsyncIOBackend.wrap_connected_unix_datagram_socketr  s      +400r  c                   V ^8  d   QhRR/# )rw   r   rE   rh   )rz   s   "rr   r{   r	  y  s       rq   c                	     \         P                  4       #   \         d&    \        ^(4      p\         P	                  T4       Tu # i ; i)(   )r  r  rP  rE   r  )r4  rN  s   & rr   rQ  -AsyncIOBackend.current_default_thread_limiterx  sB    	*..00 	%b)G#''0N	s    -AAc                    V ^8  d   QhRRRR/# )rw   r  r&   r   z.AbstractContextManager[AsyncIterator[Signals]]rh   )rz   s   "rr   r{   r	    s     ( ((	7(rq   c                	    \        V4      # r   )r  )r4  r  s   &*rr   open_signal_receiver#AsyncIOBackend.open_signal_receiver  s     w''rq   c                   V ^8  d   QhRR/# )rw   r   r6   rh   )rz   s   "rr   r{   r	    s     / / /rq   c                	(    \        \        4       4      # r   )r*  r   r  s   &rr   get_current_taskAsyncIOBackend.get_current_task  s    |~..rq   c                   V ^8  d   QhRR/# )rw   r   zSequence[TaskInfo]rh   )rz   s   "rr   r{   r	    s     R R"4 Rrq   c                	    \        4        Uu. uF%  qP                  4       '       d   K  \        V4      NK'  	  up# u upi r   )r   r   r*  )r4  r   s   & rr   get_running_tasks AsyncIOBackend.get_running_tasks  s*    2;+Q+$YY[%%+QQQs   ;;c                   V ^8  d   QhRR/# r   rh   )rz   s   "rr   r{   r	    s      T rq   c                	  "   V P                  4       G R j  xL
  \        4       p \        4        FF  pW!J d   K
  VP                  pVe   VP	                  4       '       g   K2  \        R4      G R j  xL
   KS  	  R #  Le L5i)Ng?)r2  r   r   rp  r   r
   )r4  	this_taskr   ru  s   &   rr   wait_all_tasks_blocked%AsyncIOBackend.wait_all_tasks_blocked  sm     nn N	!$))>V[[]]*$$ $  	 %s(   B A<AB "B 0A>1B >B c                    V ^8  d   QhRRRR/# )rw   r  r  r   r  rh   )rz   s   "rr   r{   r	    s     % % %J %rq   c                	    \        R/ VB # )Nrh   )r  )r4  r  s   &&rr   create_test_runner!AsyncIOBackend.create_test_runner  s    $G$$rq   rh   r  r   )r   )5ri   rj   rk   rl   classmethodr   r  r  r  r2  rA  r  r
   rg  rh  r0  r5  r9  r=  rA  rE  rI  rW  r[  rj  rr  r~  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  rQ  r  r	  r  r  r  rp   rh   rq   rr   r  r  	  s   ) )B " " ) )     : :$     ="&((=;@= =
  ,     / / X !%	X
 #X X - - :$ :$x 	( 	(    D  4 !L !LF 
 
 
1 
1 4 4& ' ' ( ( ; ;. 2 2. 

 '(
 "#
 
 
 
, E E
 2& 2&h 2& 2&h .5 .5` ' ' 1 1 & & . . 7 7 ( ( 1 1
   ( (
 / / R R   % %rq   r  )r9  
   r8  r  )__conditional_annotations__
__future__r   rX  r  concurrent.futuresrc  r   rg  rw  r  rE  r   r  r   r   r   r   r   r	   r
   asyncio.base_eventsr   collectionsr   r   collections.abcr   r   r   r   r   r   r   r   r   
contextlibr   r   r   r   dataclassesr   r   	functoolsr   r   inspectr   r    r!   r"   ior#   r$   r  r%   r   r&   r'   r(   r)   typesr*   r+   typingr,   r-   r.   r/   r0   r1   r2   r  r3   r4   r5   r6   r7   _core._eventloopr8   r9   r:   _core._exceptionsr;   r<   r=   r>   r?   r@   rA   _core._socketsrB   _core._streamsrC   _core._synchronizationrE   BaseCapacityLimiterrG   	BaseEventrI   BaseLockrJ   rK   rM   BaseSemaphore_core._tasksrO   BaseCancelScoperP   rQ   rR   rS   rT   abc._eventlooprU   lowlevelrV   streams.memoryrW   rX   	_typeshedrY   r1  rF  rZ   typing_extensionsr[   r\   r]   enumr^   r_   r`   ra   exceptiongrouprb   Enumrd   r   r   r   r   r   r   r   r7  r  r  r  r  r'  rN  r  
TaskStatusr  eager_task_factoryr  r  r  r  r  _Retval_Queue_Typer  r   r!  ByteReceiveStreamr$  ByteSendStreamr9  rP  r  r  Protocolr  r  r  r  rB  rq  r  r  r  r  r  r  r  r  r  r*  r  r  backend_class)r  s   @rr   <module>rA     s   " "      	  
     7 *	 	 	 & 7 - ( $      ,  )  &  
   3 8 8 5 @ 9  ,  N,w +w++==16 
~& ~&@,, ::T2
#cN*0*>
' >>: @Q?R	< R
Y$&R7/ R7t
) 
) <M;N8 N7 7$ w070J0J0S0SoS#J Jb 8H-x/FFG K6 K\ 9?9 5  288M1N . N e*#// * * e*#,, * *< e6ckk 6 6r<2#4$W%% $Nw// >R$3## R$j+3 +3\q;(<(< q;h9!** 9!x"!++ "!J-. -.`/-// /-d!#*@*@ !H!/33R3R !H 9?}8M5 M9?9O6 O:I :.GL8 GLTN7 N7bu
) u
p 4::S3T 0 T&, &,\h BU' U'p\
%\ \
%~ rq   