
    1hSu                       % S SK Jr  S SKrS SKrS SKrS SKJr  S SKJr  S SK	J
r
  S SKJr  S SKJr  S SKJr  S S	KJr  S S
KJr  S SKJrJrJrJrJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$J%r%  S SK&r&S SK'r(S SK)J*r*J+r+J,r,  S SK-J.r/  S SK0J1r1  SSK2J3r3J4r4J5r5J6r6  SSK7J8r8J9r9  SSK:J;r;  SSK<J=r=J>r>J?r?J@r@  SSK<JArB  SSKCJDrD  SSKEJFrG  SSKEJHrI  SSKEJJrJ  SSKKJLrM  SSK6JNrNJOrO  \(       a  S SKPJQrQ   S SK(JRrS  S SKTJUrUJVrV   \SR                  r[\$" S 5      r]\$" S!\^\N5      r_\(R                  r`\(R                  R                  rb\(R                  R                  rc\(R                  rd " S" S#\M5      rL\(R                  rf\(R                  R                  rg\(R                  R                  rh\(R                  R                  ri\(R                  rj\(R                  rk " S$ S%\B\(R                  5      rA " S& S'\6R                  5      rmS(SS).         S_S* jjrn      S`S+ jroSaS, jrp " S- S.\6R                  5      rq\
" S(S/9 " S0 S1\6R                  5      5       rs\
" S(S/9 " S2 S3\6R                  5      5       ru\
" S(S/9 " S4 S5\6R                  5      5       rvSSS(S6.                 SbS7 jjrZ " S8 S9\(Rl                  R                  5      rx\c" S:5      ryS;\zS:'   ScS< jr{ScS= jr| " S> S?\\_   5      r} " S@ SA\}\6R                  5      r~ " SB SC\~\6R                  5      r " SD SE\}\6GR                   5      r " SF SG\}\6GR                   5      r " SH SI\}\N   \6GR                  5      r " SJ SK\}\N   \6GR                  5      r Sd       SeSL jjrSfSM jr          SgSN jr\(R                  GR                  r\(R                  GR                  rShSO jrShSP jr " SQ SR\I5      rH " SS ST\G5      rF\c" SU5      rS;\zSU'   SiSV jr " SW SX\8SX   5      rSjSY jrSkSZ jrSlS[ jrSmS\ jr " S] S^\6GR&                  5      rg! \W a    S SK(JXrS  S SKYJUrUJVrV   GNRf = f! \\ a
    S SK(JZr[   GNXf = f)n    )annotationsN)Future)copy_context)	dataclass)partial)IOBase)PathLike)Signals)TracebackType)IOTYPE_CHECKINGAnyAsyncGeneratorAsyncIterator	AwaitableCallable
Collection	CoroutineGenericIterableMappingNoReturnSequenceTypeVarcast)ErrorOutcomeValue)
SocketType)run_sync   )CapacityLimiterStatisticsEventStatisticsTaskInfoabc)DeprecatedAsyncContextManagerDeprecatedAwaitableclaim_worker_thread)BrokenResourceErrorBusyResourceErrorClosedResourceErrorEndOfStream)ExceptionGroup)convert_ipv6_sockaddr)CapacityLimiter)Event)ResourceGuard)CancelScope)IPSockAddrTypeUDPPacketType)
TaskStatus)lowlevel)wait_readablewait_writable)hazmat)open_processT_Retval
T_SockAddrc                      \ rS rSr S     SS jjrSSS jjrSS jr        SS jrSS jr\	SS j5       r
\
R                  SS	 j5       r
\	SS
 j5       r\	SS j5       r\R                  SS j5       rSrg)r3   d   Nc                ,    [         R                  U 5      $ Nobject__new__)clsoriginalkwargss      M/var/www/auris/envauris/lib/python3.13/site-packages/anyio/_backends/_trio.pyrD   CancelScope.__new__e   s     ~~c""    c                L    U=(       d    [         R                  " S0 UD6U l        g )N )trior3   _CancelScope__original)selfrF   rG   s      rH   __init__CancelScope.__init__j   s    "@d&6&6&@&@rJ   c                :    U R                   R                  5         U $ rA   )rN   	__enter__rO   s    rH   rS   CancelScope.__enter__m   s    !!#rJ   c                :    U R                   R                  XU5      $ rA   )rN   __exit__rO   exc_typeexc_valexc_tbs       rH   rW   CancelScope.__exit__q   s      ''v
 	
rJ   c                `    U R                   R                  5         [        U R                  5      $ rA   )rN   cancelr'   rT   s    rH   r^   CancelScope.cancel|   s!     "4;;//rJ   c                .    U R                   R                  $ rA   rN   deadlinerT   s    rH   rb   CancelScope.deadline   s    '''rJ   c                $    XR                   l        g rA   ra   rO   values     rH   rb   rc      s    #( rJ   c                .    U R                   R                  $ rA   )rN   cancel_calledrT   s    rH   rh   CancelScope.cancel_called   s    ,,,rJ   c                .    U R                   R                  $ rA   rN   shieldrT   s    rH   rl   CancelScope.shield   s    %%%rJ   c                $    XR                   l        g rA   rk   re   s     rH   rl   rm      s    !&rJ   
__originalrA   )rF   trio.CancelScope | NonerG   rC   returnr3   )rF   rq   rG   r   rr   None)rr   r3   rY   type[BaseException] | NonerZ   BaseException | Noner[   TracebackType | Nonerr   zbool | Nonerr   r'   rr   floatrf   rz   rr   rs   rr   bool)rf   r}   rr   rs   )__name__
__module____qualname____firstlineno__rD   rP   rS   rW   r^   propertyrb   setterrh   rl   __static_attributes__rL   rJ   rH   r3   r3   d   s    15#.#AG#	#
A	
,	
 &	
 %		

 
	
0 ( ( __) ) - - & & ]]' 'rJ   r3   c                      \ rS rSrSrg)r.      rL   N)r~   r   r   r   r   rL   rJ   rH   r.   r.      s    rJ   r.   c                      \ rS rSrS
S jrSS jr        SS jrSS.       SS jjrSS.       SS jjrS	r	g)	TaskGroup   c                T    SU l         [        R                  " 5       U l        S U l        g NF)_activerM   open_nursery_nursery_managercancel_scoperT   s    rH   rP   TaskGroup.__init__   s"     $ 1 1 3 rJ   c                   #    SU l         U R                  R                  5       I S h  vN U l        [	        U R                  R
                  5      U l        U $  N/7fNT)r   r   
__aenter___nurseryr3   r   rT   s    rH   r   TaskGroup.__aenter__   sG     "33>>@@'(B(BC As   %AA0Ac                   #     U R                   R                  XU5      I S h  vN SU l        $  N! [        R                   a  n[        UR                  5      S eS nAff = f! SU l        f = f7fr   )r   	__aexit__r   rM   
MultiErrorr.   
exceptions)rO   rY   rZ   r[   excs        rH   r   TaskGroup.__aexit__   s`     	!..88FSS !DL	 T 	; 0d:	; !DLs=   A/1 /1 A/1 A AA  A# #	A,,A/Nnamec               |    U R                   (       d  [        S5      eU R                  R                  " U/UQ7SU06  g Nz;This task group is not active; no new tasks can be started.r   )r   RuntimeErrorr   
start_soonrO   funcr   argss       rH   r   TaskGroup.start_soon   s9     ||M  	  8848rJ   c                  #    U R                   (       d  [        S5      eU R                  R                  " U/UQ7SU06I S h  vN $  N7fr   )r   r   r   startr   s       rH   r   TaskGroup.start   sE      ||M  ]]((@@4@@@@s   A A	AA	)r   r   r   r   rr   rs   )rr   r   rt   )r   Callable[..., Awaitable[Any]]r   rC   r   rC   rr   rs   )r   r   r   rC   r   rC   rr   rC   )
r~   r   r   r   rP   r   r   r   r   r   rL   rJ   rH   r   r      s    !
!,! &! %	!
 
! RV919:@9HN9	9 RVA1A:@AHNA	A ArJ   r   Fcancellablelimiterc                  ^ ^#    SUU 4S jjn[        5       nUR                  [        R                  R                  S 5        [        UR                  XAUS9I S h  vN $  N7f)Nc                 Z   > [        S5         T" T 6 sS S S 5        $ ! , (       d  f       g = f)NrM   r(   )r   r   s   rH   wrapper*run_sync_in_worker_thread.<locals>.wrapper   s     (; )((s   
*r   rr   r<   )r   runsniffiocurrent_async_library_cvarsetr    )r   r   r   r   r   contexts   `  `  rH   run_sync_in_worker_threadr      sU      
 nGKK2266=Ww   s   AA!AA!c                   ^ ^^ SUUU 4S jjn[        5       mTR                  [        R                  R                  S5        [
        R                  R                  U5      $ )Nc                    >^#    SUUU4S jjn [         R                  " 5        IS h  vN nTR                  UR                  U 5        S S S 5      IS h  vN   SnT$  N4 N
! , IS h  vN  (       d  f       SnT$ = f7f)Nc                 0   >#    Sn T" T6 I S h  vN mg  N7fr   rL   )__tracebackhide__r   fnretvals    rH   inner5run_async_from_thread.<locals>.wrapper.<locals>.inner   s      $t9_F_s   Tr   )rM   r   r   r   )r   nr   r   r   r   r   s      @rH   r   &run_async_from_thread.<locals>.wrapper   se     	% 	%
 $$&&!KKe, '& !	 '&&& !sD   $A>AA>A!	A>A	A>A>!A;'A*(A;4
A>rM   r   )r   r   r   r   r   rM   from_thread)r   r   r   r   s   `` @rH   run_async_from_threadr      sG      nGKK2266?((rJ   c                    [         R                  R                  " [        5       R                  U /UQ76 n[        [        U5      $ rA   )rM   r   r    r   r   r   r<   )r   r   r   s      rH   run_sync_from_threadr     s4    &&|~'9'92EEF&!!rJ   c                  X   ^  \ rS rSrSS jrSU 4S jjr            SS jrSrU =r$ )	BlockingPortali  c                ,    [         R                  U 5      $ rA   rB   rE   s    rH   rD   BlockingPortal.__new__	      ~~c""rJ   c                h   > [         TU ]  5         [        R                  R	                  5       U l        g rA   )superrP   rM   r7   current_trio_token_tokenrO   	__class__s    rH   rP   BlockingPortal.__init__  s"    mm668rJ   c                (   [        5       nUR                  [        R                  R                  S5        [
        R                  R                  UR                  [        U R                  R                  US9U R                  UUUUU R                  S9  g )NrM   r   )
trio_token)r   r   r   r   r   rM   r   r    r   _task_groupr   
_call_funcr   )rO   r   r   rG   r   futurer   s          rH   _spawn_task_from_thread&BlockingPortal._spawn_task_from_thread  su     .G66::FC!!KKD$$//d;OO{{ 	" 		
rJ   )r   )rr   r   r   )r   r   r   tuplerG   dict[str, Any]r   rC   r   r   rr   rs   )	r~   r   r   r   rD   rP   r   r   __classcell__r   s   @rH   r   r     sQ    #9

 
 	

 
 
 

 
rJ   r   )eqc                  8    \ rS rSr% S\S'   SS	S jjrS
S jrSrg)ReceiveStreamWrapperi+  ztrio.abc.ReceiveStream_streamNc                  #     U R                   R                  U5      I S h  vN nU(       a  U$ [        e N! [        R                   a  n[        UR                  eS nAf[        R
                   a  n[
        UR                  eS nAff = f7frA   )r   receive_somerM   r,   	__cause__r*   r-   rO   	max_bytesdatar   s       rH   receiveReceiveStreamWrapper.receive/  sr     	9229==D K >'' 	9%3==8'' 	9%3==8	9s=   B8 68 B8 B
AB
4BB

Bc                T   #    U R                   R                  5       I S h  vN   g  N7frA   r   acloserT   s    rH   r   ReceiveStreamWrapper.aclose<       ll!!###   (&(rL   rA   )r   
int | Nonerr   bytesr   )r~   r   r   r   __annotations__r   r   r   rL   rJ   rH   r   r   +  s    ##$rJ   r   c                  4    \ rS rSr% S\S'   SS jrS	S jrSrg)
SendStreamWrapperi@  ztrio.abc.SendStreamr   c                  #     U R                   R                  U5      I S h  vN   g  N! [        R                   a  n[        UR                  eS nAf[        R
                   a  n[
        UR                  eS nAff = f7frA   )r   send_allrM   r,   r   r*   rO   itemr   s      rH   sendSendStreamWrapper.sendD  s^     	9,,''---'' 	9%3==8'' 	9%3==8	9s<   A?* (* A?* A<AA<&A77A<<A?c                T   #    U R                   R                  5       I S h  vN   g  N7frA   r   rT   s    rH   r   SendStreamWrapper.acloseL  r   r   rL   Nr   r   rr   rs   r   )r~   r   r   r   r   r   r   r   rL   rJ   rH   r   r   @  s      9$rJ   r   c                      \ rS rSr% S\S'   S\S'   S\S'   S\S'   SS	 jrSS
 jrSS jrSS jrSS jr	\
SS j5       r\
SS j5       r\
SS j5       r\
SS j5       r\
SS j5       rSrg)ProcessiP  ztrio.Process_processabc.ByteSendStream | None_stdinabc.ByteReceiveStream | None_stdout_stderrc                ~  #    U R                   (       a"  U R                   R                  5       I S h  vN   U R                  (       a"  U R                  R                  5       I S h  vN   U R                  (       a"  U R                  R                  5       I S h  vN   U R	                  5       I S h  vN   g  N NR N! N7frA   )r  r   r  r  waitrT   s    rH   r   Process.acloseW  sy     ;;++$$&&&<<,,%%'''<<,,%%'''iik '''sE   /B=B52B=$B7%2B=B9B=/B;0B=7B=9B=;B=c                R   #    U R                   R                  5       I S h  vN $  N7frA   )r  r  rT   s    rH   r  Process.waita  s     ]]''))))   '%'c                8    U R                   R                  5         g rA   )r  	terminaterT   s    rH   r  Process.terminated  s    !rJ   c                8    U R                   R                  5         g rA   )r  killrT   s    rH   r  Process.killg  s    rJ   c                :    U R                   R                  U5        g rA   )r  send_signal)rO   signals     rH   r  Process.send_signalj  s    !!&)rJ   c                .    U R                   R                  $ rA   )r  pidrT   s    rH   r  Process.pidm  s    }}   rJ   c                .    U R                   R                  $ rA   )r  
returncoderT   s    rH   r  Process.returncodeq  s    }}'''rJ   c                    U R                   $ rA   )r  rT   s    rH   stdinProcess.stdinu  s    {{rJ   c                    U R                   $ rA   )r  rT   s    rH   stdoutProcess.stdouty      ||rJ   c                    U R                   $ rA   )r  rT   s    rH   stderrProcess.stderr}  r#  rJ   rL   Nr   rr   int)r  r
   rr   rs   )rr   r   )rr   r  )rr   r  )r~   r   r   r   r   r   r  r  r  r  r   r  r  r  r!  r%  r   rL   rJ   rH   r   r   P  s    %%))))*"* ! ! ( (      rJ   r   )cwdenvstart_new_sessionc               F  #    [        U UUUUUUUS9I S h  vN nUR                  (       a  [        UR                  5      OS n	UR                  (       a  [	        UR                  5      OS n
UR
                  (       a  [	        UR
                  5      OS n[        XX5      $  N7f)N)r  r!  r%  shellr)  r*  r+  )trio_open_processr  r   r!  r   r%  r   )commandr-  r  r!  r%  r)  r*  r+  processstdin_streamstdout_streamstderr_streams               rH   r;   r;     s      &+	 	G 8?}}$W]]3$L<CNN(8PTM<CNN(8PTM7-GG	s   B!BB	B!c                  ,   ^  \ rS rSrSU 4S jjrSrU =r$ )_ProcessPoolShutdownInstrumenti  c                "   > [         TU ]  5         g rA   )r   	after_runr   s    rH   r7  (_ProcessPoolShutdownInstrument.after_run  s    rJ   rL   r   )r~   r   r   r   r7  r   r   r   s   @rH   r5  r5    s     rJ   r5  &current_default_worker_process_limiterRunVarc                d  #     [        [        R                  5      I S h  vN   g  N! [        R                   aq    U  H"  nUR
                  b  M  UR                  5         M$     [        SS9   U  H  nUR                  5       I S h  vN    M     S S S 5         g ! , (       d  f        g = ff = f7f)NT)rl   )	sleepmathinfrM   	Cancelledr  r  r3   r   )workersr0  s     rH   _shutdown_process_poolrA    s     	'DHHo>> 'G!!)  %"nn&&& # &%%%'sa   B0( &( B0( $B-B--BB	
	BB-B0
B)	$B-'B0)B--B0c                L    [         R                  R                  [        U 5        g rA   )rM   r7   spawn_system_taskrA  )r@  s    rH   #setup_process_pool_exit_at_shutdownrD    s    MM##$:GDrJ   c                  P    \ rS rSrS	S jrS
S jr\SS j5       rS
S jrSS jr	Sr
g)_TrioSocketMixini  c                    Xl         SU l        g r   )_trio_socket_closed)rO   trio_sockets     rH   rP   _TrioSocketMixin.__init__  s    'rJ   c                z    U R                   (       a  [        eU R                  R                  5       S:  a  [        eg Nr   )rI  r,   rH  filenor*   rT   s    rH   _check_closed_TrioSocketMixin._check_closed  s1    <<%%##%)%% *rJ   c                .    U R                   R                  $ rA   )rH  _sockrT   s    rH   _raw_socket_TrioSocketMixin._raw_socket  s      &&&rJ   c                   #    U R                   R                  5       S:  a"  SU l        U R                   R                  5         g g 7f)Nr   T)rH  rN  rI  closerT   s    rH   r   _TrioSocketMixin.aclose  s:     ##%*DL##% +s   AAc                    [        U[        R                  5      (       a  [        UeU R                  R	                  5       S:  a  U R
                  (       a  [        S e[        U[        5      (       a  [        UeUerM  )
isinstancerM   r,   rH  rN  rI  OSErrorr*   rO   r   s     rH   _convert_socket_error&_TrioSocketMixin._convert_socket_error  s\    c43344%3.%%'!+%4/W%%%3.IrJ   )rI  rH  NrJ  TrioSocketTyperr   rs   r   )rr   socket.socket)r   BaseExceptionrr   r   )r~   r   r   r   rP   rO  r   rS  r   r\  r   rL   rJ   rH   rF  rF    s*    & ' '&
rJ   rF  c                  N   ^  \ rS rSrSU 4S jjrSS	S jjrS
S jrSS jrSrU =r	$ )SocketStreami  c                d   > [         TU ]  U5        [        S5      U l        [        S5      U l        g Nreading from
writing tor   rP   r2   _receive_guard_send_guardrO   rJ  r   s     rH   rP   SocketStream.__init__  *    %+N;(6rJ   c                  #    U R                       U R                  R                  U5      I S h  vN nW(       a  UsS S S 5        $ [
        e N! [         a  nU R	                  U5         S nAN:S nAff = f! , (       d  f       g = f7frA   )ri  rH  recvra  r\  r-   r   s       rH   r   SocketStream.receive  sr       0!..33I>>  !  "! ?  0**3//0 ! sY   BA6AAAA6
BA6A
A3A.)A6.A33A66
B Bc                4  #    U R                      [        U5      nU(       a2   U R                  R                  U5      I S h  vN nUWS  nU(       a  M2  S S S 5        g  N! [         a  nU R                  U5         S nAN9S nAff = f! , (       d  f       g = f7frA   )rj  
memoryviewrH  r   ra  r\  )rO   r   view
bytes_sentr   s        rH   r   SocketStream.send  s     d#D4'+'8'8'='=d'C!CJ JK( $  "D$ 4..s334 sW   BBAAAB	BA
B)A?:B?BB
BBc                ^   #    U R                   R                  [        R                  5        g 7frA   )rH  shutdownsocketSHUT_WRrT   s    rH   send_eofSocketStream.send_eof  s     ""6>>2s   +-ri  rj  r^  )   )r   r(  rr   r   r   r   )
r~   r   r   r   rP   r   r   rz  r   r   r   s   @rH   rc  rc    s    7

"	)3 3rJ   rc  c                  (    \ rS rSrSS jrSS jrSrg)UNIXSocketStreami  c           	     r  #    [        U[        5      (       a  US:  a  [        S5      e[        U[        5      (       a  US:  a  [        S5      e[        R                  " S5      n[	        5       I S h  vN   U R
                       U R                  R                  U[        R                  " X#R                  -  5      5      I S h  vN u  pEpgU(       d  U(       d  [        e S S S 5        W Hy  u  pnU	[        R                  :w  d  U
[        R                  :w  a  [!        SW< SU	 SU
 35      eUR#                  US [%        U5      [%        U5      UR                  -  -
   5        M{     W['        U5      4$  GN N! [         a  nU R                  U5         S nAOS nAff = fGM!  ! , (       d  f       N= f7f)	Nr   z%msglen must be a non-negative integer   z!maxfds must be a positive integeriz.Received unexpected ancillary data; message = z, cmsg_level = z, cmsg_type = )rY  r(  
ValueErrorarray
checkpointri  rH  recvmsgrx  CMSG_LENitemsizer-   ra  r\  
SOL_SOCKET
SCM_RIGHTSr   	frombyteslenlist)rO   msglenmaxfdsfdsmessageancdataflagsaddrr   
cmsg_level	cmsg_type	cmsg_datas               rH   receive_fdsUNIXSocketStream.receive_fds  s    &#&&&1*DEE&#&&&1*@AAkk#l  
:>:K:K:S:S0E F; 51Ge #7)) ! 18,J9V...)v?P?P2P"DWK P$$.<~i[J 
 MM)$Vc)nI8U&VWX 18 S	!!1 	5 % 4..s334  ! sg   A0F72E63F7F&?E;E9E;F&"BF79E;;
F FF&F  F&&
F40F7c                  #    U(       d  [        S5      eU(       d  [        S5      e/ nU Ha  n[        U[        5      (       a  UR                  U5        M+  [        U[        5      (       d  MB  UR                  UR                  5       5        Mc     [        R                  " SU5      n[        5       I S h  vN   U R                       U R                  R                  U/[        R                  [        R                  U4/5      I S h  vN    S S S 5        g  Nb N! [         a  nU R                  U5         S nAOS nAff = fM~  ! , (       d  f       g = f7f)Nzmessage must not be emptyzfds must not be emptyr  )r  rY  r(  appendr   rN  r  r  rj  rH  sendmsgrx  r  r  ra  r\  )rO   r  r  filenosfdfdarrayr   s          rH   send_fdsUNIXSocketStream.send_fds   s#    899455B"c""r"B''ryy{+	  ++c7+l4++33 	 !' 1 1 & 1 1 '	 	 	   		 % 4..s334  sn   A'E-AE4D5EEA DD	DE
ED
E %D;6E;E  E
EErL   N)r  r(  r  r(  rr   ztuple[bytes, list[int]])r  r   r  zCollection[int | IOBase]rr   rs   )r~   r   r   r   r  r  r   rL   rJ   rH   r  r    s    "B4rJ   r  c                  6   ^  \ rS rSrSU 4S jjrSS jrSrU =r$ )TCPSocketListeneriA  c                ~   > [         TU ]  [        R                  R	                  U5      5        [        S5      U l        g Nzaccepting connections fromr   rP   rM   rx  from_stdlib_socketr2   _accept_guardrO   
raw_socketr   s     rH   rP   TCPSocketListener.__init__B  -    77
CD*+GHrJ   c                h  #    U R                       U R                  R                  5       I S h  vN u  pS S S 5        WR                  [        R                  [        R                  S5        [        U5      $  NH! [         a  nU R	                  U5         S nANdS nAff = f! , (       d  f       Nr= f7f)Nr  )
r  rH  acceptra  r\  
setsockoptrx  IPPROTO_TCPTCP_NODELAYrc  rO   rJ  _addrr   s       rH   r  TCPSocketListener.acceptF  s     0+/+<+<+C+C+E%E"   	v1163E3EqIK(( &F  0**3//0  sO   B2B!A9A7A9AB27A99
BBB!BB!!
B/+B2r  r  r`  )rr   rc  r~   r   r   r   rP   r  r   r   r   s   @rH   r  r  A  s    I) )rJ   r  c                  6   ^  \ rS rSrSU 4S jjrSS jrSrU =r$ )UNIXSocketListeneriQ  c                ~   > [         TU ]  [        R                  R	                  U5      5        [        S5      U l        g r  r  r  s     rH   rP   UNIXSocketListener.__init__R  r  rJ   c                
  #    U R                       U R                  R                  5       I S h  vN u  pS S S 5        [        W5      $  N! [         a  nU R	                  U5         S nAN5S nAff = f! , (       d  f       NC= f7frA   )r  rH  r  ra  r\  r  r  s       rH   r  UNIXSocketListener.acceptV  sn     0+/+<+<+C+C+E%E"    ,,	 &F  0**3//0  sN   BA2A
AA
BA


A/A*%A2*A//A22
B <Br  r  )rr   r  r  r   s   @rH   r  r  Q  s    I- -rJ   r  c                  @   ^  \ rS rSrSU 4S jjrSS jrSS jrSrU =r$ )		UDPSocketi`  c                d   > [         TU ]  U5        [        S5      U l        [        S5      U l        g re  rh  rk  s     rH   rP   UDPSocket.__init__a  rm  rJ   c                &  #    U R                       U R                  R                  S5      I S h  vN u  pU[        U5      4sS S S 5        $  N! [         a  nU R                  U5         S nAOS nAff = f S S S 5        g ! , (       d  f       g = f7fNr}  )ri  rH  recvfromr/   ra  r\  )rO   r   r  r   s       rH   r   UDPSocket.receivef  sv       0#'#4#4#=#=e#DD
2488 ! D  0**3//0/ !  sU   BB AAA
BA
A3A.)B .A33B 7	B 
B
Bc                   #    U R                       U R                  R                  " U6 I S h  vN   S S S 5        g  N! [         a  nU R	                  U5         S nAN+S nAff = f! , (       d  f       g = f7frA   )rj  rH  sendtora  r\  r   s      rH   r   UDPSocket.sendn  sa     0''..555 5  0**3//0 sH   A6A%=;=	A6=
A"AA%A""A%%
A3/A6r|  r^  )rr   ztuple[bytes, IPSockAddrType])r   r5   rr   rs   	r~   r   r   r   rP   r   r   r   r   r   s   @rH   r  r  `  s    7
00 0rJ   r  c                  @   ^  \ rS rSrSU 4S jjrSS jrSS jrSrU =r$ )	ConnectedUDPSocketiv  c                d   > [         TU ]  U5        [        S5      U l        [        S5      U l        g re  rh  rk  s     rH   rP   ConnectedUDPSocket.__init__w  rm  rJ   c                  #    U R                       U R                  R                  S5      I S h  vN sS S S 5        $  N! [         a  nU R	                  U5         S nAOS nAff = f S S S 5        g ! , (       d  f       g = f7fr  )ri  rH  ro  ra  r\  r[  s     rH   r   ConnectedUDPSocket.receive|  sd       0!..33E:: ! :  0**3//0/	 !  sN   BA1?=?
B?
A$	AA1A$$A1(	B1
A?;Bc                   #    U R                       U R                  R                  U5      I S h  vN   S S S 5        g  N! [         a  nU R	                  U5         S nAN+S nAff = f! , (       d  f       g = f7frA   )rj  rH  r   ra  r\  r   s      rH   r   ConnectedUDPSocket.send  sa     0'',,T222 2  0**3//0 sH   A8A'?=?	A8?
A$	AA'A$$A''
A51A8r|  r^  )rr   r   r   r  r   s   @rH   r  r  v  s    7
00 0rJ   r  c                  #    SU ;   a  [         R                  O[         R                  n[        R                   R                  U5      nUR	                  [         R
                  [         R                  S5        U(       a  UR                  U5      I S h  vN    UR                  X45      I S h  vN   [        U5      $  N* N! [         a    UR                  5         e f = f7f)N:r  )rx  AF_INET6AF_INETrM   r  r  r  bindconnectra  rV  rc  )hostportlocal_addressfamilyrJ  s        rH   connect_tcpr    s      !$tV__F++$$V,K6--v/A/A1E}---!!4,///
 $$ 	. 	0 s<   BC B=C C -B?.C 2C ?C CC c                   #    [         R                  R                  [        R                  5      n UR                  U 5      I S h  vN   [        U5      $  N! [         a    UR                  5         e f = f7frA   )rM   rx  AF_UNIXr  ra  rV  r  )pathrJ  s     rH   connect_unixr    se     ++$$V^^4K!!$'''
 K(( 	( s.   .A6A AA 
A6A A33A6c                  #    [         R                  R                  U [        R                  S9nU(       a/  UR                  [        R                  [        R
                  S5        U(       a  UR                  U5      I S h  vN   U(       a$  UR                  U5      I S h  vN   [        U5      $ [        U5      $  N: N7f)N)r  typer  )
rM   rx  
SOCK_DGRAMr  r  SO_REUSEPORTr  r  r  r  )r  r  remote_address
reuse_portrJ  s        rH   create_udp_socketr    s      ++$$F9J9J$KKv00&2E2EqI}---!!.111!+..%% 	. 	2s$   A>B? B;B? B=!B?=B?c                   #     [        U 5      I S h  vN   g  N! [        R                   a)  n[        5       R                  UR                  5      S eS nAf[        R
                   a    [        S5      S ef = f7f)Nrf  )r8   rM   r,   with_traceback__traceback__r+   sockr   s     rH   wait_socket_readabler    se     :D!!!## P!#2233D3DE4O!! :/T9:0   A9  A9 A6$A$A66A9c                   #     [        U 5      I S h  vN   g  N! [        R                   a)  n[        5       R                  UR                  5      S eS nAf[        R
                   a    [        S5      S ef = f7f)Nrg  )r9   rM   r,   r  r  r+   r  s     rH   wait_socket_writabler    se     8D!!!## P!#2233D3DE4O!! 8-478r  c                  P    \ rS rSrS
S jrSS jrSS jrSS jrSS jrSS jr	Sr
g	)r1   i  c                ,    [         R                  U 5      $ rA   rB   r   s    rH   rD   Event.__new__  r   rJ   c                8    [         R                  " 5       U l        g rA   )rM   r1   _Event__originalrT   s    rH   rP   Event.__init__  s    **,rJ   c                6    U R                   R                  5       $ rA   )r  is_setrT   s    rH   r  Event.is_set  s    %%''rJ   c                R   #    U R                   R                  5       I S h  vN $  N7frA   )r  r  rT   s    rH   r  
Event.wait  s     __))++++r  c                \    U R                   R                  5       n[        UR                  S9$ )N)tasks_waiting)r  
statisticsr#   r  )rO   orig_statisticss     rH   r  Event.statistics  s%    //446_-J-JKKrJ   c                `    U R                   R                  5         [        U R                  5      $ rA   )r  r   r'   rT   s    rH   r   	Event.set  s!    "488,,rJ   ro   N)rr   r1   r   r|   )rr   r#   rx   )r~   r   r   r   rD   rP   r  r  r  r   r   rL   rJ   rH   r1   r1     s!    #'(,L-rJ   r1   c                     \ rS rSrSS jrSS.     SS jjrSS jr        SS jr\SS j5       r	\	R                  SS	 j5       r	\SS
 j5       r\SS j5       rSS jrSS jrSS jrSS jrSS jrSS jrSS jrSrg)r0   i  c                ,    [         R                  U 5      $ rA   rB   )rE   r   rG   s      rH   rD   CapacityLimiter.__new__  r   rJ   NrF   c               F    U=(       d    [         R                  " U6 U l        g rA   )rM   r0   _CapacityLimiter__original)rO   rF   r   s      rH   rP   CapacityLimiter.__init__  s     #Ad&:&:D&ArJ   c                R   #    U R                   R                  5       I S h  vN $  N7frA   )r  r   rT   s    rH   r   CapacityLimiter.__aenter__  s     __//1111r  c                X   #    U R                   R                  XU5      I S h  vN   g  N7frA   )r  r   rX   s       rH   r   CapacityLimiter.__aexit__  s!      oo''6BBBs    *(*c                .    U R                   R                  $ rA   r  total_tokensrT   s    rH   r  CapacityLimiter.total_tokens  s    +++rJ   c                $    XR                   l        g rA   r  re   s     rH   r  r    s    ',$rJ   c                .    U R                   R                  $ rA   )r  borrowed_tokensrT   s    rH   r  CapacityLimiter.borrowed_tokens
  s    ...rJ   c                .    U R                   R                  $ rA   )r  available_tokensrT   s    rH   r   CapacityLimiter.available_tokens  s    ///rJ   c                `    U R                   R                  5         [        U R                  5      $ rA   )r  acquire_nowaitr'   rT   s    rH   r  CapacityLimiter.acquire_nowait  s#    &&("4#6#677rJ   c                b    U R                   R                  U5        [        U R                  5      $ rA   )r  acquire_on_behalf_of_nowaitr'   rO   borrowers     rH   r  +CapacityLimiter.acquire_on_behalf_of_nowait  s%    33H="4#C#CDDrJ   c                T   #    U R                   R                  5       I S h  vN   g  N7frA   )r  acquirerT   s    rH   r"  CapacityLimiter.acquire  s     oo%%'''r   c                V   #    U R                   R                  U5      I S h  vN   g  N7frA   )r  acquire_on_behalf_ofr  s     rH   r%  $CapacityLimiter.acquire_on_behalf_of  s     oo228<<<s   )')c                6    U R                   R                  5       $ rA   )r  releaserT   s    rH   r(  CapacityLimiter.release   s    &&((rJ   c                8    U R                   R                  U5      $ rA   )r  release_on_behalf_ofr  s     rH   r+  $CapacityLimiter.release_on_behalf_of#  s    33H==rJ   c                    U R                   R                  5       n[        UR                  UR                  UR
                  UR                  S9$ )N)r  r  	borrowersr  )r  r  r"   r  r  r.  r  )rO   origs     rH   r  CapacityLimiter.statistics&  sC    ))+( 00**nn,,	
 	
rJ   ro   )r   rC   rG   rC   rr   r0   )r   r   rF   trio.CapacityLimiter | Nonerr   rs   r   )rY   ru   rZ   rv   r[   rw   rr   rs   ry   r{   r'  rx   )r  rC   rr   r'   )r  rC   rr   rs   )rr   r"   )r~   r   r   r   rD   rP   r   r   r   r  r   r  r  r  r  r"  r%  r(  r+  r  r   rL   rJ   rH   r0   r0     s    # CGBB$?B	B
2C,C &C %	C
 
C , , - - / / 0 08E(=)>
rJ   r0   _capacity_limiter_wrapperc                      [         R                  5       $ ! [         a?    [        [        R
                  R                  5       S9n [         R                  U 5        U s $ f = f)Nr  )r2  getLookupErrorr0   rM   	to_threadcurrent_default_thread_limiterr   )r   s    rH   r7  r7  3  sT    (,,.. !^^BBD
 	"%%g.s    AAAc                  b    \ rS rSr% S\S'   SS jrSS jr        SS jrSS jrSS jr	S	r
g
)_SignalReceiveriC  zAsyncIterator[int]	_iteratorc                    Xl         g rA   )_signals)rO   signalss     rH   rP   _SignalReceiver.__init__F  s    rJ   c                    [         R                  " U R                  6 U l        U R                  R	                  5       U l        U $ rA   )rM   open_signal_receiverr<  _cmrS   r:  rT   s    rH   rS   _SignalReceiver.__enter__I  s1    ,,dmm<++-rJ   c                :    U R                   R                  XU5      $ rA   )rA  rW   rX   s       rH   rW   _SignalReceiver.__exit__N  s     xx  F;;rJ   c                    U $ rA   rL   rT   s    rH   	__aiter___SignalReceiver.__aiter__V  s    rJ   c                h   #    U R                   R                  5       I S h  vN n[        U5      $  N7frA   )r:  	__anext__r
   )rO   signums     rH   rI  _SignalReceiver.__anext__Y  s)     ~~//11v 2s   202)rA  r:  r<  N)r=  ztuple[Signals, ...])rr   r9  rt   )rr   r
   )r~   r   r   r   r   rP   rS   rW   rF  rI  r   rL   rJ   rH   r9  r9  C  sG    !! 
<,< &< %	<
 
<rJ   r9  c                     [        U 5      $ rA   )r9  )r=  s    rH   r@  r@  ^  s    7##rJ   c                    [         R                  " 5       n S nU R                  (       a:  U R                  R                  (       a  [	        U R                  R                  5      n[        [	        U 5      XR                  U R                  5      $ rA   )trio_lowlevelcurrent_taskparent_nurseryparent_taskidr$   r   coro)task	parent_ids     rH   get_current_taskrV  g  s]    %%'DIt22>>t**667	BtHiDII>>rJ   c            
        [         R                  " 5       n [        [        U 5      S U R                  U R
                  5      /nU R                  nU(       a  / nU H~  nUR                   Hk  nUR                  [        [        U5      [        UR                  5      UR                  UR
                  5      5        UR                  UR                  5        Mm     M     UnU(       a  M  U$ rA   )rN  current_root_taskr$   rR  r   rS  child_nurserieschild_tasksr  rQ  extend)	root_task
task_infos	nurseriesnew_nurseriesnurseryrT  s         rH   get_running_tasksra  q  s    //1I2i=$		OPJ))I
,. G++!!RXr'*=*='>		499U $$T%9%9:	 , ! "	 ) rJ   c                 >    SS K n U R                  R                  5       $ rM  )trio.testingtestingwait_all_tasks_blocked)rM   s    rH   re  re    s    <<..00rJ   c                      \ rS rSrSS jrSS jr        SS jrSS jrSS jr        SS jr	SS jr
      SS	 jr      SS
 jr      SS jrSrg)
TestRunneri  c                t    SSK Jn  SSKJn  U" 5       U l        U" 5       U l        S U l        S U l        Xl        g )Nr   )deque)Queue)	collectionsri  queuerj  _call_queue_result_queue_stop_eventr   _options)rO   optionsri  rj  s       rH   rP   TestRunner.__init__  s0    %9>-2W.2-1rJ   c                *  #    [         R                  " 5       U l        [         R                  " 5        IS h  vN U l        U R                  R                  5       I S h  vN   S S S 5      IS h  vN   g  N< N N	! , IS h  vN  (       d  f       g = f7frA   )rM   r1   ro  r   r   r  rT   s    rH   
_trio_mainTestRunner._trio_main  sZ     ::<$$&&$-""''))) '&&) '&&&sV   4BA3B#A9A5A9"B-A7.B5A97B9B?B BBc                   #     U" U0 UD6I S h  vN nU R                   R                  [        U5      5        g  N)! [         a.  nU R                   R                  [	        U5      5         S nAg S nAff = f7frA   )rn  r  r   ra  r   )rO   r   r   rG   r   r   s         rH   r   TestRunner._call_func  se     	5000F %%eFm4	 1 	2%%eCj11	2s7   A6; 9; %A6; 
A3$A.)A6.A33A6c                    S U l         g rA   )r   )rO   outcomes     rH   _main_task_finishedTestRunner._main_task_finished  s	    rJ   c                V   U R                   c  [        R                  R                  " U R                  4U R
                  R                  U R                  S.U R                  D6  U R                   c.  U R
                  R                  5       " 5         U R                   c  M.  U R                   $ )N)run_sync_soon_threadsafedone_callback)
r   rM   r7   start_guest_runrt  rm  putrz  rp  r4  rT   s    rH   _get_nurseryTestRunner._get_nursery  s    == MM)))-)9)9)=)="66 --	 --'  $$&( --' }}rJ   c                2   U R                  5       R                  U R                  XU5        U R                  (       d2  U R                  R                  5       " 5         U R                  (       d  M2  U R                  R                  5       nUR                  5       $ rA   )r  r   r   rn  rm  r4  popunwrap)rO   r   r   rG   ry  s        rH   _callTestRunner._call  sr     	&&tFK$$  "$ $$$ $$((*~~rJ   c                    U R                   (       aW  U R                   R                  5         U R                  b/  U R                  R	                  5       " 5         U R                  b  M.  g g g rA   )ro  r   r   rm  r4  rT   s    rH   rV  TestRunner.close  sM      "--+  $$&( --+ rJ   c              #     ^ ^^^^#    SUUU4S jjm[         R                  " 5       mT R                  UU 4S j5      nUv   TR                  5         g 7f)Nc                J  >#    T" S0 TD6nUR                  S 5      I S h  vN nU R                  U5        TR                  5       I S h  vN    UR                  S 5      I S h  vN   UR                  5       I S h  vN   [	        S5      e Nj NC N+ N! [
         a     g f = f7f)Nz$Async generator fixture did not stoprL   )asendstartedr  r   r   StopAsyncIteration)task_statusagenr   fixture_funcrG   teardown_events      rH   fixture_runner7TestRunner.run_asyncgen_fixture.<locals>.fixture_runner  s     )&)D::d++F' %%'''Kjj&&& kkm##"#IJJ ,'& $ & si   B#B(B#	B
B#B #B$B (B#;B<B#B#B B#
B B#B  B#c                 B   > TR                  5       R                  T 5      $ rA   )r  r   )r  rO   s   rH   <lambda>1TestRunner.run_asyncgen_fixture.<locals>.<lambda>  s    4+<+<+>+D+D^+TrJ   )r  zTaskStatus[T_Retval]rr   rs   )rM   r1   r  r   )rO   r  rG   fixture_valuer  r  s   ``` @@rH   run_asyncgen_fixtureTestRunner.run_asyncgen_fixture  s@     
	K 	K 

#TUs   AAc                (    U R                   " U40 UD6$ rA   r  )rO   r  rG   s      rH   run_fixtureTestRunner.run_fixture  s    
 zz,1&11rJ   c                *    U R                   " U40 UD6  g rA   r  )rO   	test_funcrG   s      rH   run_testTestRunner.run_test  s     	

9''rJ   )rm  r   rp  rn  ro  N)rq  r   rr   rs   r   )r   z Callable[..., Awaitable[object]]r   r   rG   dictrr   rs   )ry  rC   rr   rs   )rr   ztrio.Nursery)r   "Callable[..., Awaitable[T_Retval]]r   rC   rG   rC   rr   r<   )r  z,Callable[..., AsyncGenerator[T_Retval, Any]]rG   r   rr   zIterable[T_Retval])r  z,Callable[..., Coroutine[Any, Any, T_Retval]]rG   r   rr   r<   )r  z'Callable[..., Coroutine[Any, Any, Any]]rG   r   rr   rs   )r~   r   r   r   rP   rt  r   rz  r  r  rV  r  r  r  r   rL   rJ   rH   rg  rg    s     *
545<A5KO5	5 6 ?E QW 	 )B  
	.2B2 2 
	2(@(JX(	(rJ   rg  )
r   Callable[..., T_Retval]r   rC   r   r}   r   r1  rr   r<   )r   r  r   r   rr   r<   )r   r  r   r   rr   r<   )r/  z#str | bytes | Sequence[str | bytes]r-  r}   r  int | IO[Any] | Noner!  r  r%  r  r)  zstr | bytes | PathLike | Noner*  zMapping[str, str] | Noner+  r}   rr   r   )r@  zset[Process]rr   rs   rA   )r  strr  r(  r  IPSockAddrType | Nonerr   rc  )r  r  rr   r  )
r  zsocket.AddressFamilyr  r  r  r  r  r}   rr   zUDPSocket | ConnectedUDPSocket)r  r`  rr   rs   )rr   r0   )r=  r
   rr   r9  )rr   r$   )rr   zlist[TaskInfo])rr   zAwaitable[None])
__future__r   r  r=  rx  concurrent.futuresr   contextvarsr   dataclassesr   	functoolsr   ior   osr	   r  r
   typesr   typingr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   trio.from_threadrM   ry  r   r   r   trio.socketr   r_  trio.to_threadr     r"   r#   r$   r%   _core._compatr&   r'   _core._eventloopr)   _core._exceptionsr*   r+   r,   r-   r.   BaseExceptionGroup_core._socketsr/   _core._synchronizationr0   BaseCapacityLimiterr1   	BaseEventr2   _core._tasksr3   BaseCancelScoper4   r5   trio_typingr6   r7   rN  trio.lowlevelr8   r9   ImportErrorr:   trio.hazmatr;   r.  AttributeErrorr<   r  r=   r   r   current_tokenr:  r<  r?  CancelledErrorr  checkpoint_if_cancelledcancel_shielded_checkpointcurrent_effective_deadlinecurrent_timer   r   r   r   r   r   ByteReceiveStreamr   ByteSendStreamr   r   
Instrumentr5  r9  r   rA  rD  rF  rc  r  SocketListenerr  r  r  r  r  r  r  getaddrinfogetnameinfor  r  r2  r7  r9  r@  rV  ra  re  rg  rL   rJ   rH   <module>r     s   "    % $ !         &   ) ) 4 # H H N 2  E 2 K 7 2 9 /&;.
 ;%22 :\37
 hh00			 	

.'/ .'b ]]%%
--?? !]]EE !<<   	' 	+A +Al +/	
!  )	
 &)*)36)),"
S'' 
F e$300 $ $( e$** $ $ e.ckk . .p *.$(#H0H H  	H
 !H !H 
'H 
"H H H6TXX%8%8 
 28,2 & 
'Ewz* >3#S%5%5 3B@4|S%9%9 @4F)(#*<*< ) -)3+=+= -0 0#-- 0,0).93;Q;Q 0, BF%
%%)>%%$)& &(& *& 	&
 $&* kk%%kk%%:8-I -,?
) ?
D %++F$G 6 G 34EF 6$?$1[( [(Y  9,889   s$   &P/ 5Q
 /QQ
QQ