
    hl                        S SK Jr  S SKrS SKrS SKrSSKJrJrJrJ	r	J
r
JrJrJr  SSKJrJrJr   " S S\5      r " S	 S
\5      rg)    )annotationsN   )ConnectErrorConnectTimeoutExceptionMapping	ReadErrorReadTimeout
WriteErrorWriteTimeoutmap_exceptions   )SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStreamc                  x    \ rS rSrSS jrSSS jjrSSS jjrSS jr  S       SS jjrSS jr	SS	 jr
S
rg)
TrioStream   c                    Xl         g N_streamselfstreams     I/var/www/html/env/lib/python3.13/site-packages/httpcore/_backends/trio.py__init__TrioStream.__init__   s        Nc                  #    Uc  [        S5      OUn[        R                  [        [        R                  [
        [        R                  [
        0n[        U5         [        R                  " U5         U R                  R                  US9I S h  vN nUsS S S 5        sS S S 5        $  N! , (       d  f       O= f S S S 5        g ! , (       d  f       g = f7f)Ninf)	max_bytes)floattrioTooSlowErrorr	   BrokenResourceErrorr   ClosedResourceErrorr   
fail_afterr   receive_some)r   r!   timeouttimeout_or_infexc_mapdatas         r   readTrioStream.read   s     )0ug{$$i$$i%

 G$0$(LL$=$=	$=$RR 10 %$R 100 %$$sN   ACC3B+B)B+	C
C)B++
B9	5C=	C
CCc                  #    U(       d  g Uc  [        S5      OUn[        R                  [        [        R                  [
        [        R                  [
        0n[        U5         [        R                  " U5         U R                  R                  US9I S h  vN   S S S 5        S S S 5        g  N! , (       d  f       N= f! , (       d  f       g = f7f)Nr    )r,   )r"   r#   r$   r   r%   r
   r&   r   r'   r   send_all)r   bufferr)   r*   r+   s        r   writeTrioStream.write%   s     )0ug|$$j$$j%

 G$0ll+++888 1 %$8 10 %$sH   A"C$C;B0B.B0C%	C.B00
B>	:C
CCc                T   #    U R                   R                  5       I S h  vN   g  N7fr   )r   aclose)r   s    r   r5   TrioStream.aclose3   s     ll!!###s   (&(c                  #    Uc  [        S5      OUn[        R                  [        [        R                  [
        0n[        R                  " U R                  UUSSS9n[        U5          [        R                  " U5         UR                  5       I S h  vN   S S S 5        S S S 5        [        U5      $  N! , (       d  f       N#= f! [         a   nU R                  5       I S h  vN    UeS nAff = f! , (       d  f       NY= f7f)Nr    TF)ssl_contextserver_hostnamehttps_compatibleserver_side)r"   r#   r$   r   r%   r   	SSLStreamr   r   r'   do_handshake	Exceptionr5   r   )r   r8   r9   r)   r*   r+   
ssl_streamexcs           r   	start_tlsTrioStream.start_tls6   s      *1ug~$$l%
 ^^LL#+!

 G$__^4$11333 5 % *%%	 4 54 kkm##		 %$s~   A(D*C6,C	B8B6B8C	#D6B88
C	C	C6C		
C3C.&C)'C..C33C66
D Dc                   US:X  a?  [        U R                  [        R                  5      (       a  U R                  R                  $ US:X  a(  U R                  5       R                  R                  5       $ US:X  a(  U R                  5       R                  R                  5       $ US:X  a  U R                  n[        U[        R                  5      (       a-  UR                  n[        U[        R                  5      (       a  M-  [        U[        R                  5      (       d   eUR                  $ US:X  a!  U R                  S5      nUR                  5       $ g )N
ssl_objectclient_addrserver_addrsocketis_readable)
isinstancer   r#   r<   _ssl_object_get_socket_streamrG   getsocknamegetpeernametransport_streamSocketStreamget_extra_inforH   )r   infor   rG   s       r   rP   TrioStream.get_extra_infoQ   s	   <Jt||T^^$L$L <<+++= **,33??AA= **,33??AA8\\FVT^^4400 VT^^44fd&7&78888== = ((2F%%''r   c                    U R                   n[        U[        R                  5      (       a-  UR                  n[        U[        R                  5      (       a  M-  [        U[        R
                  5      (       d   eU$ r   )r   rI   r#   r<   rN   rO   r   s     r   rK   TrioStream._get_socket_streame   sX    00,,F 00&$"3"34444r   r   )r   ztrio.abc.StreamreturnNoner   )r!   intr)   float | NonerU   bytes)r1   rY   r)   rX   rU   rV   )rU   rV   NN)r8   zssl.SSLContextr9   
str | Noner)   rX   rU   r   )rQ   strrU   z
typing.Any)rU   ztrio.SocketStream)__name__
__module____qualname____firstlineno__r   r-   r2   r5   rA   rP   rK   __static_attributes__ r   r   r   r      sS    
9$ '+ $	&#& $& 	&
 
&6(r   r   c                  h    \ rS rSr   S           SS jjr  S	       S
S jjrSS jrSrg)TrioBackendm   Nc                  #    Uc  / nUc  [        S5      OUn[        R                  [        [        R                  [
        [        [
        0n[        U5         [        R                  " U5         [        R                  " XUS9I S h  vN nU H  n	UR                  " U	6   M     S S S 5        S S S 5        [        W5      $  N7! , (       d  f       N#= f! , (       d  f       N,= f7f)Nr    )hostportlocal_address)r"   r#   r$   r   r%   r   OSErrorr   r'   open_tcp_stream
setsockoptr   )
r   rg   rh   r)   ri   socket_optionsr*   r+   r   options
             r   connect_tcpTrioBackend.connect_tcpn   s      !N)0ug~$$l\%

 G$0040D0D1 + -F%%v. -	 1 % &!!+ 10 %$sH   AC#C.CB?C$C,C#?C
C	C
C C#c                  #    Uc  / nUc  [        S5      OUn[        R                  [        [        R                  [
        [        [
        0n[        U5         [        R                  " U5         [        R                  " U5      I S h  vN nU H  nUR                  " U6   M     S S S 5        S S S 5        [        W5      $  N7! , (       d  f       N#= f! , (       d  f       N,= f7f)Nr    )r"   r#   r$   r   r%   r   rj   r   r'   open_unix_socketrl   r   )r   pathr)   rm   r*   r+   r   rn   s           r   connect_unix_socketTrioBackend.connect_unix_socket   s      !N)0ug~$$l\%

 G$0040E0Ed0K*K,F%%v. - 1 %
 &!! +L 10 %$sH   AC$C.CC 	C%C-C$ C
C	C
C!C$c                L   #    [         R                  " U5      I S h  vN   g  N7fr   )r#   sleep)r   secondss     r   rw   TrioBackend.sleep   s     jj!!!s   $"$rb   )NNN)rg   r\   rh   rW   r)   rX   ri   r[   rm   %typing.Iterable[SOCKET_OPTION] | NonerU   r   rZ   )rs   r\   r)   rX   rm   rz   rU   r   )rx   r"   rU   rV   )r]   r^   r_   r`   ro   rt   rw   ra   rb   r   r   rd   rd   m   s    
 !%$(@D"" " 	"
 "" >" 
"< !%@D	"" " >	"
 
"*"r   rd   )
__future__r   ssltypingr#   _exceptionsr   r   r   r   r	   r
   r   r   baser   r   r   r   rd   rb   r   r   <module>r      sF    " 
  	 	 	 I HU# Up2"% 2"r   