File: //usr/local/CyberCP/lib64/python3.10/site-packages/anyio/abc/__pycache__/_sockets.cpython-310.pyc
o
�h�3 � @ s, U d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm Z m
Z
d dl m Z d dl
mZ d dlmZmZ d dlmZ d d lmZmZmZ d
d lmZ d
d lmZmZm Z d
dl m Z m Z m Z d
dl!m"Z" ej#dkrsd dlm$Z$ nd dl%m$Z$ ee&eef Z'de(d< e)e&e*f Z+de(d< ee+e&f Z,de(d< e)e-e+f Z.de(d< e)e-e&f Z/de(d< ed�Z0ej1fddd�d:d&d'�Z2G d(d)� d)e�Z3G d*d+� d+e�Z4G d,d-� d-e e4�Z5G d.d/� d/e5�Z6G d0d1� d1e e5 e4�Z7G d2d3� d3e e. e4�Z8G d4d5� d5e e- e4�Z9G d6d7� d7e e/ e4�Z:G d8d9� d9e e- e4�Z;dS );� )� annotationsN)�abstractmethod)�Callable�
Collection�Mapping)�AsyncExitStack)�IOBase)� IPv4Address� IPv6Address)�
AddressFamily)�Any�TypeVar�Union� )�get_async_backend)�TypedAttributeProvider�TypedAttributeSet�typed_attribute� )�
ByteStream�Listener�UnreliableObjectStream)� TaskGroup)� �
)� TypeAliasr �
IPAddressType�IPSockAddrType� SockAddrType�
UDPPacketType�UNIXDatagramPacketType�T_RetvalF)�require_connected�
require_bound�
sock_or_fd�socket.socket | int� sock_type�socket.SocketKind� addr_family�socket.AddressFamilyr" �boolr# �return�
socket.socketc
C s� t | t�r4ztj| d�}W n: ty3 } z|jtjkr td�|�|r'td�|�|r.td�|�� d }~ww t | tj�r=| }n tdt| �j � d���zo|rcz|�
� W n tyb } ztd�|�d }~ww |r�z|j tj tj
fv rv|�� d }n|�� }W n ty� d }Y nw |s�td��|tjkr�|j |kr�td|j� d |j j� ���|j|kr�td
|j� d |jj� ���W n ty� t | t�r�|�� � w |�d � |S ) 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)r$ r& r( r" r# �sock�exc�
bound_addr� rE �E/usr/local/CyberCP/lib/python3.10/site-packages/anyio/abc/_sockets.py�_validate_socket$ sv
��
�� �
��� �
��
��
�
rG c @ sf e Zd ZU dZe� Zded< e� Zded< e� Zded< e� Z ded < e� Z
ded
< e� Z ded < d S )
�SocketAttributea�
.. 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 r9 r �
local_addressr/ �
local_portr, �
raw_socket�remote_address� remote_portN) �__name__�
__module__r7 �__doc__r r9 �__annotations__rI rJ rK rL rM rE rE rE rF rH i s
rH c @ s, e Zd Zed dd��Zeed
dd���ZdS ) �_SocketProviderr+ � Mapping[Any, Callable[[], Any]]c s� ddl m� tj�fdd�tj� �fdd�tj�fdd�i}z � �j�� ��W n ty2 d �Y nw �d ur@�fdd�|tj < �jjt
j t
j fv rd�fdd�|tj
< �d urd�d ��fd
d�|tj< |S ) Nr )�convert_ipv6_sockaddrc s � j jS �N)� _raw_socketr9 rE ��selfrE rF �<lambda>� s z2_SocketProvider.extra_attributes.<locals>.<lambda>c s � �j �� �S rU �rV r< rE )�convertrX rE rF rY � s �c s � j S rU )rV rE rW rE rF rY � � c � � S rU rE rE )�peernamerE rF rY � � c s � j �� d S )Nr rZ rE rW rE rF rY � s r c r] rU rE rE )rM rE rF rY � r_ )�_core._socketsrT rH r9 rI rK rV r8 r1 rL r r: r; rJ rM )rX �
attributesrE )r[ r^ rM rX rF �extra_attributes� s& � �
�z _SocketProvider.extra_attributesr, c C s d S rU rE rW rE rE rF rV � s z_SocketProvider._raw_socketN)r+ rS )r+ r, )rN rO r7 �propertyrb r rV rE rE rE rF rR � s rR c @ � e Zd ZdZeddd��ZdS ) � SocketStreamzu
Transports bytes over a socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
r$ r% r+ c � �$ �t |tjdd�}t� �|�I dH S )aH
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)rG r0 � SOCK_STREAMr �wrap_stream_socket��clsr$ rB rE rE rF � from_socket� � � zSocketStream.from_socketN)r$ r% r+ re �rN rO r7 rP � classmethodrl rE rE rE rF re � � re c @ s6 e Zd Zeddd��Zedd d ��Zeddd��ZdS )�UNIXSocketStreamr$ r% r+ c � �( �t |tjtjdd�}t� �|�I dH S )aR
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
Trg N)rG r0 rh �AF_UNIXr �wrap_unix_stream_socketrj rE rE rF rl � s
� �z UNIXSocketStream.from_socket�message�bytes�fds�Collection[int | IOBase]�Nonec � � �dS )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)
NrE )rX ru rw rE rE rF �send_fds� r\ zUNIXSocketStream.send_fds�msglenr/ �maxfds�tuple[bytes, list[int]]c � rz )a
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)
NrE )rX r| r} rE rE rF � receive_fds� r\ z UNIXSocketStream.receive_fdsN)r$ r% r+ rq )ru rv rw rx r+ ry )r| r/ r} r/ r+ r~ )rN rO r7 ro rl r r{ r rE rE rE rF rq � s rq c @ s: e Zd ZdZeddd��Zeddd ��Z
dddd�Zd
S )�SocketListenerz}
Listens to incoming socket connections.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
r$ r% r+ c � rf )a
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)rG r0 rh r �wrap_listener_socketrj rE rE rF rl � s �zSocketListener.from_socketre c � rz )z Accept an incoming connection.NrE rW rE rE rF �accept r\ zSocketListener.acceptN�handler� Callable[[SocketStream], Any]�
task_group�TaskGroup | Nonery c � sp �ddl m} t� 4 I d H � }|d u r |�|� �I d H } | �� I d H }|�||� q 1 I d H s1w Y d S )Nr )�create_task_group)� r� r �enter_async_contextr� �
start_soon)rX r� r� r� �stack�streamrE rE rF �serve s � ��zSocketListener.serve)r$ r% r+ r� )r+ re rU )r� r� r� r� r+ ry ) rN rO r7 rP ro rl r r� r� rE rE rE rF r� � s �r� c @ s( e Zd ZdZeddd��Zddd�ZdS )� UDPSocketz{
Represents an unconnected UDP socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
r$ r% r+ c � rf )aI
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)rG r0 �
SOCK_DGRAMr �wrap_udp_socketrj rE rE rF rl ) rm zUDPSocket.from_socket�datarv �host�str�portr/ ry c � s �| � |||ff�I dH S )z^
Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).
N��send)rX r� r� r� rE rE rF �sendto8 s �zUDPSocket.sendtoN)r$ r% r+ r� )r� rv r� r� r� r/ r+ ry �rN rO r7 rP ro rl r� rE rE rE rF r� " s
r� c @ rd ) �ConnectedUDPSocketzy
Represents an connected UDP socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
r$ r% r+ c � rf )aV
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
Trg N)rG r0 r� r �wrap_connected_udp_socketrj rE rE rF rl G s � �z ConnectedUDPSocket.from_socketN)r$ r% r+ r� rn rE rE rE rF r� @ rp r� c @ s( e Zd ZdZeddd��Zdd d
�ZdS )�UNIXDatagramSocketz�
Represents an unconnected Unix datagram socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
r$ r% r+ c � s$ �t |tjtj�}t� �|�I dH S )a'
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)rG r0 r� rs r �wrap_unix_datagram_socketrj rE rE rF rl d s �z UNIXDatagramSocket.from_socketr� rv �pathr� ry c � s �| � ||f�I dH S )zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr� )rX r� r� rE rE rF r� v s �zUNIXDatagramSocket.sendtoN)r$ r% r+ r� )r� rv r� r� r+ ry r� rE rE rE rF r� [ s
r� c @ rd ) �ConnectedUNIXDatagramSocketz�
Represents a connected Unix datagram socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
r$ r% r+ c � rr )ar
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
Trg N)rG r0 r� rs r �#wrap_connected_unix_datagram_socketrj rE rE rF rl � s
� �z'ConnectedUNIXDatagramSocket.from_socketN)r$ r% r+ r� rn rE rE rE rF r� { rp r� ) r$ r% r& r' r( r) r" r* r# r* r+ r, )<�
__future__r r2 r0 �sys�abcr �collections.abcr r r �
contextlibr �ior � ipaddressr r
r �typingr r
r �_core._eventloopr �_core._typedattrr r r �_streamsr r r �_tasksr � version_infor �typing_extensionsr� r rQ �tupler/ r r rv r r r! r= rG rH rR re rq r� r� r� r� r� rE rE rE rF �<module> sP
��E)&',
�