
    zbjj3                       % S SK Jr  S SKrS SKrS SKJr  S SKJrJrJ	r	  S SK
Jr  S SKJr  S SKJrJr  S SKJr  S S	KJrJrJrJr  S
SKJr  S
SKJrJrJr  SSKJrJrJ r   \(       a  SSK!J"r"  \#\-  \-  r$S\%S'   \&\#\'4   r(S\%S'   \(\#-  r)S\%S'   \&\*\(4   r+S\%S'   \&\*\#4   r,S\%S'   \" S5      r-\R\                  4SSS.           S,S jjjr/ " S S\5      r0 " S S\5      r1 " S S\\15      r2 " S  S!\25      r3 " S" S#\\2   \15      r4 " S$ S%\ \+   \15      r5 " S& S'\ \*   \15      r6 " S( S)\ \,   \15      r7 " S* S+\ \*   \15      r8g)-    )annotationsN)abstractmethod)Callable
CollectionMapping)AsyncExitStack)IOBase)IPv4AddressIPv6Address)AddressFamily)TYPE_CHECKINGAny	TypeAliasTypeVar   )get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute   )
ByteStreamListenerUnreliableObjectStream)	TaskGroupr   IPAddressTypeIPSockAddrTypeSockAddrTypeUDPPacketTypeUNIXDatagramPacketTypeT_RetvalF)require_connectedrequire_boundc                  [        U [        5      (       a   [        R                  " U S9nOD[        U [        R                  5      (       a  U nO"[        S[        U 5      R                   S35      e U(       a   UR                  5         U(       af   UR                  [        R                  [        R                  4;   a  UR                  5       S   nOUR                  5       n U(       d  [        S5      eU[        R                  :w  a?  UR                  U:w  a/  [        SUR                    S	UR                  R                    35      eUR                  U:w  a/  [        S
UR                    S	UR                  R                    35      e UR'                  S5        U$ ! [         aV  nUR                  [        R
                  :X  a  [        S5      UeU(       a  [        S5      UeU(       a  [        S5      Uee S nAff = f! [         a  n[        S5      UeS nAff = f! [         a    S n GNHf = f! ["         a'    [        U [        5      (       a  UR%                  5         e f = f)N)filenoz.the file descriptor does not refer to a socketzthe socket must be connectedz+the socket must be bound to a local addresszexpected an int or socket, got z insteadr   z"address family mismatch: expected z, got zsocket type mismatch: expected F)
isinstanceintsocketOSErrorerrnoENOTSOCK
ValueError	TypeErrortype__qualname__getpeernamefamilyAF_INETAF_INET6getsockname	AF_UNSPECnameBaseExceptiondetachsetblocking)
sock_or_fd	sock_typeaddr_familyr!   r"   sockexc
bound_addrs           ڎ/tmp/claude-0/-home-danvics-docker-quiz/c1e0577a-e42c-4a3d-b1ea-3edd61103a4e/scratchpad/stt/lib/python3.13/site-packages/anyio/abc/_sockets.py_validate_socketr@       s+    *c""	==
3D 
J	.	.-d:.>.K.K-LHU
 	
"J  " ";;6>>6??"CC!%!1!1!3A!6J!%!1!1!3J  !NOO&***t{{k/I4[5E5E4Ff;;##$& 
 99	!1)..1A		GWX  " 	UKo  
	yyENN* D # !?@cI !NOUXX
	,  J !?@cIJ  "!
"   j#&&KKMsz   F 1H0 9G? 	H0 AH H0 H #B%H0 
G<&AG77G<?
H	HHH0 H-)H0 ,H--H0 01I!c                      \ rS rSr% Sr\" 5       rS\S'   \" 5       rS\S'   \" 5       r	S\S'   \" 5       r
S	\S
'   \" 5       rS\S'   \" 5       rS\S'   Srg)SocketAttributee   a  
.. attribute:: family
    :type: socket.AddressFamily

    the address family of the underlying socket

.. attribute:: local_address
    :type: tuple[str, int] | str

    the local address the underlying socket is connected to

.. attribute:: local_port
    :type: int

    for IP based sockets, the local port the underlying socket is bound to

.. attribute:: raw_socket
    :type: socket.socket

    the underlying stdlib socket object

.. attribute:: remote_address
    :type: tuple[str, int] | str

    the remote address the underlying socket is connected to

.. attribute:: remote_port
    :type: int

    for IP based sockets, the remote port the underlying socket is connected to
r   r0   r   local_addressr&   
local_portsocket.socket
raw_socketremote_addressremote_port N)__name__
__module__r.   __firstlineno____doc__r   r0   __annotations__rD   rE   rG   rH   rI   __static_attributes__rJ       r?   rB   rB   e   sX    @ ,-FM-"1"3M<3%'J' / 1J1#2#4NL4&(K(rQ   rB   c                  F    \ rS rSr\SS j5       r\\SS j5       5       rSrg)_SocketProvider   c                  ^ ^^^ SSK Jm  [        R                  U 4S j[        R                  UU 4S j[        R
                  U 4S j0n T" T R                  R                  5       5      mTb  U4S jU[        R                  '   T R                  R                  [        R                  [        R                  4;   a6  U 4S jU[        R                  '   Tb  TS   mU4S	 jU[        R                  '   U$ ! [         a    S m Nf = f)
Nr   )convert_ipv6_sockaddrc                 0   > T R                   R                  $ N)_raw_socketr0   selfs   r?   <lambda>2_SocketProvider.extra_attributes.<locals>.<lambda>   s    D,<,<,C,CrQ   c                 D   > T " TR                   R                  5       5      $ rX   rY   r3   )convertr[   s   r?   r\   r]      s    7  ,,.4rQ   c                    > T R                   $ rX   )rY   rZ   s   r?   r\   r]      s    0@0@rQ   c                    > T $ rX   rJ   )peernames   r?   r\   r]      s    rQ   c                 >   > T R                   R                  5       S   $ )Nr   r_   rZ   s   r?   r\   r]      s      ,,.q1rQ   r   c                    > T $ rX   rJ   )rI   s   r?   r\   r]      s    +rQ   )_core._socketsrV   rB   r0   rD   rG   rY   r/   r(   rH   r   r1   r2   rE   rI   )r[   
attributesr`   rc   rI   s   ` @@@r?   extra_attributes _SocketProvider.extra_attributes   s    E ""$C)) , &&(@4

	/6t7G7G7S7S7U/VH
 9IJ556 ""}'<'<m>T>T&UU6J112 #&qk:M
?667!  	H	s    C5 5DDc                    g rX   rJ   rZ   s    r?   rY   _SocketProvider._raw_socket   s     	rQ   rJ   N)returnzMapping[Any, Callable[[], Any]])rl   rF   )	rK   rL   r.   rM   propertyrh   r   rY   rP   rJ   rQ   r?   rS   rS      s0     <   rQ   rS   c                  ,    \ rS rSrSr\SS j5       rSrg)SocketStream   zi
Transports bytes over a socket.

Supports all relevant extra attributes from :class:`~SocketAttribute`.
c                   #    [        U[        R                  SS9n[        5       R	                  U5      I Sh  vN $  N7f)a  
Wrap an existing socket object or file descriptor as a socket stream.

The newly created socket wrapper takes ownership of the socket being passed in.
The existing socket must already be connected.

:param sock_or_fd: a socket object or file descriptor
:return: a socket stream

Tr!   N)r@   r'   SOCK_STREAMr   wrap_stream_socketclsr9   r<   s      r?   from_socketSocketStream.from_socket   s6       
F,>,>RVW&(;;DAAAA   6?=?rJ   N)r9   socket.socket | intrl   ro   rK   rL   r.   rM   rN   classmethodrw   rP   rJ   rQ   r?   ro   ro      s     B BrQ   ro   c                  P    \ rS rSr\SS j5       r\SS j5       r\S	S j5       rSr	g)
UNIXSocketStream   c                   #    [        U[        R                  [        R                  SS9n[	        5       R                  U5      I Sh  vN $  N7f)a"  
Wrap an existing socket object or file descriptor as a UNIX socket stream.

The newly created socket wrapper takes ownership of the socket being passed in.
The existing socket must already be connected.

:param sock_or_fd: a socket object or file descriptor
:return: a UNIX socket stream

Trr   N)r@   r'   rs   AF_UNIXr   wrap_unix_stream_socketru   s      r?   rw   UNIXSocketStream.from_socket   s@       **FNNd
 '(@@FFFF   AAAAc                   #    g7f)z
Send file descriptors along with a message to the peer.

:param message: a non-empty bytestring
:param fds: a collection of files (either numeric file descriptors or open file
    or socket objects)
NrJ   )r[   messagefdss      r?   send_fdsUNIXSocketStream.send_fds           c                   #    g7f)z
Receive file descriptors along with a message from the peer.

:param msglen: length of the message to expect from the peer
:param maxfds: maximum number of file descriptors to expect from the peer
:return: a tuple of (message, file descriptors)
NrJ   )r[   msglenmaxfdss      r?   receive_fdsUNIXSocketStream.receive_fds   r   r   rJ   N)r9   rz   rl   r~   )r   bytesr   zCollection[int | IOBase]rl   None)r   r&   r   r&   rl   ztuple[bytes, list[int]])
rK   rL   r.   rM   r|   rw   r   r   r   rP   rJ   rQ   r?   r~   r~      s>    G G     rQ   r~   c                  b    \ rS rSrSr\    SS j5       r\S	S j5       r S
     SS jjr	Sr
g)SocketListener   zq
Listens to incoming socket connections.

Supports all relevant extra attributes from :class:`~SocketAttribute`.
c                   #    [        U[        R                  SS9n[        5       R	                  U5      I Sh  vN $  N7f)z
Wrap an existing socket object or file descriptor as a socket listener.

The newly created listener takes ownership of the socket being passed in.

:param sock_or_fd: a socket object or file descriptor
:return: a socket listener

Tr"   N)r@   r'   rs   r   wrap_listener_socketru   s      r?   rw   SocketListener.from_socket   s5       
F,>,>dS&(==dCCCCry   c                   #    g7f)zAccept an incoming connection.NrJ   rZ   s    r?   acceptSocketListener.accept
  r   r   Nc                  #    SSK Jn  [        5        IS h  vN nUc  UR                  U" 5       5      I S h  vN n U R	                  5       I S h  vN nUR                  X5        M+   NQ N2 N! , IS h  vN  (       d  f       g = f7f)Nr   )create_task_group) r   r   enter_async_contextr   
start_soon)r[   handler
task_groupr   stackstreams         r?   serveSocketListener.serve  sn     
 	)!##u!#(#<#<=N=P#QQ
#{{},%%g6 	 $Q - $##sT   B	A)B	A/A+A/A-A/)B	+A/-A//B5A86BB	rJ   )r9   rz   rl   r   )rl   ro   rX   )r   zCallable[[SocketStream], Any]r   zTaskGroup | Nonerl   r   )rK   rL   r.   rM   rN   r|   rw   r   r   r   rP   rJ   rQ   r?   r   r      sp     D'D 
D D  - - (,7.7 %7 
	7 7rQ   r   c                  6    \ rS rSrSr\SS j5       rSS jrSrg)		UDPSocketi  zo
Represents an unconnected UDP socket.

Supports all relevant extra attributes from :class:`~SocketAttribute`.
c                   #    [        U[        R                  SS9n[        5       R	                  U5      I Sh  vN $  N7f)a  
Wrap an existing socket object or file descriptor as a UDP socket.

The newly created socket wrapper takes ownership of the socket being passed in.
The existing socket must be bound to a local address.

:param sock_or_fd: a socket object or file descriptor
:return: a UDP socket

Tr   N)r@   r'   
SOCK_DGRAMr   wrap_udp_socketru   s      r?   rw   UDPSocket.from_socket%  s5       
F,=,=TR&(88>>>>ry   c                F   #    U R                  XU445      I Sh  vN $  N7f)zN
Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).

Nsend)r[   datahostports       r?   sendtoUDPSocket.sendto4  s#     
 YYTl34444s   !!rJ   N)r9   rz   rl   r   )r   r   r   strr   r&   rl   r   	rK   rL   r.   rM   rN   r|   rw   r   rP   rJ   rQ   r?   r   r     s      ? ?5rQ   r   c                  ,    \ rS rSrSr\SS j5       rSrg)ConnectedUDPSocketi<  zm
Represents an connected UDP socket.

Supports all relevant extra attributes from :class:`~SocketAttribute`.
c                   #    [        U[        R                  SS9n[        5       R	                  U5      I Sh  vN $  N7f)a&  
Wrap an existing socket object or file descriptor as a connected UDP socket.

The newly created socket wrapper takes ownership of the socket being passed in.
The existing socket must already be connected.

:param sock_or_fd: a socket object or file descriptor
:return: a connected UDP socket

Trr   N)r@   r'   r   r   wrap_connected_udp_socketru   s      r?   rw   ConnectedUDPSocket.from_socketC  s<       "

 '(BB4HHHHry   rJ   N)r9   rz   rl   r   r{   rJ   rQ   r?   r   r   <  s     I IrQ   r   c                  >    \ rS rSrSr\    SS j5       rSS jrSrg)	UNIXDatagramSocketiW  zy
Represents an unconnected Unix datagram socket.

Supports all relevant extra attributes from :class:`~SocketAttribute`.
c                   #    [        U[        R                  [        R                  5      n[	        5       R                  U5      I Sh  vN $  N7f)z
Wrap an existing socket object or file descriptor as a UNIX datagram
socket.

The newly created socket wrapper takes ownership of the socket being passed in.

:param sock_or_fd: a socket object or file descriptor
:return: a UNIX datagram socket

N)r@   r'   r   r   r   wrap_unix_datagram_socketru   s      r?   rw   UNIXDatagramSocket.from_socket`  s9       
F,=,=v~~N&(BB4HHHHs   AAA	Ac                B   #    U R                  X45      I Sh  vN $  N7f)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr   )r[   r   paths      r?   r   UNIXDatagramSocket.sendtor  s     YY|,,,,s   rJ   N)r9   rz   rl   r   )r   r   r   r   rl   r   r   rJ   rQ   r?   r   r   W  s6     I'I 
I I"-rQ   r   c                  4    \ rS rSrSr\    SS j5       rSrg)ConnectedUNIXDatagramSocketiw  zv
Represents a connected Unix datagram socket.

Supports all relevant extra attributes from :class:`~SocketAttribute`.
c                   #    [        U[        R                  [        R                  SS9n[	        5       R                  U5      I Sh  vN $  N7f)a:  
Wrap an existing socket object or file descriptor as a connected UNIX datagram
socket.

The newly created socket wrapper takes ownership of the socket being passed in.
The existing socket must already be connected.

:param sock_or_fd: a socket object or file descriptor
:return: a connected UNIX datagram socket

Trr   N)r@   r'   r   r   r   #wrap_connected_unix_datagram_socketru   s      r?   rw   'ConnectedUNIXDatagramSocket.from_socket~  s@        ))6>>T
 '(LLTRRRRr   rJ   N)r9   rz   rl   r   r{   rJ   rQ   r?   r   r   w  s1     S'S 
%S SrQ   r   )r9   rz   r:   zsocket.SocketKindr;   zsocket.AddressFamilyr!   boolr"   r   rl   rF   )9
__future__r   r)   r'   abcr   collections.abcr   r   r   
contextlibr   ior	   	ipaddressr
   r   r   typingr   r   r   r   _core._eventloopr   _core._typedattrr   r   r   _streamsr   r   r   _tasksr   r   r   rO   tupler&   r   r   r   r   r   r    r4   r@   rB   rS   ro   r~   r   r   r   r   r   rJ   rQ   r?   <module>r      s   "    9 9 %  .   9 9 0 
 C B!,{:y :!#s(O	 +(3.i . !67y 7$)%*$5 	 5: )/(8(8B
 $B#B B &B
 B B BJ&)' &)R#, #LB: B.$| $N)7Xl+_ )7X5&}5 5<I/6 I6-12O-@S"8"? SrQ   