File: //usr/local/lib/python3.10/dist-packages/anyio/abc/__pycache__/_sockets.cpython-310.pyc
o
���gv � @ s� d dl mZ d dlZd dlmZ d dlmZmZmZ d dl m
Z
d dl m Z d dl
mZmZ d dlmZ d d lmZ d d
lmZmZmZ d d lmZmZmZ d
dlm Z m Z m Z d
dl m Z ee!eef Z"e#e!e$f Z%ee%e!f Z&e#e'e%f Z(e#e'e!f Z)ed�Z*G dd� d�Z+G dd� de�Z,G dd� de�Z-G dd� de e-�Z.G dd� de.�Z/G dd � d e e. e-�Z0G d d � d e e( e-�Z1G d d � d e e' e-�Z2G d!d"� d"e e) e-�Z3G d#d$� d$e e' e-�Z4dS )%� )� annotationsN)�abstractmethod)�Callable�
Collection�Mapping)�AsyncExitStack)�IOBase)� IPv4Address� IPv6Address)�
AddressFamily)�
TracebackType)�Any�TypeVar�Union� )�TypedAttributeProvider�TypedAttributeSet�typed_attribute� )�
ByteStream�Listener�UnreliableObjectStream)� TaskGroup�T_Retvalc @ s e Zd Zddd�Zdd d
�ZdS )�_NullAsyncContextManager�return�Nonec � � �d S �N� ��selfr r �=/usr/local/lib/python3.10/dist-packages/anyio/abc/_sockets.py�
__aenter__ s �z#_NullAsyncContextManager.__aenter__�exc_type�type[BaseException] | None�exc_val�BaseException | None�exc_tb�TracebackType | None� bool | Nonec � r r r )r! r$ r& r( r r r" � __aexit__! s �z"_NullAsyncContextManager.__aexit__N)r r )r$ r% r& r' r( r) r r* )�__name__�
__module__� __qualname__r# r+ r r r r" r s
r c @ sb e Zd ZU e� Zded< e� Zded< e� Zded< e� Zded< e� Z ded < e� Z
ded
< d S ) �SocketAttributer �family� SockAddrType�
local_address�int�
local_port�
socket.socket�
raw_socket�remote_address� remote_portN) r, r- r. r r0 �__annotations__r2 r4 r6 r7 r8 r r r r" r/ * s
r/ 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 r )� _raw_socketr0 r r r r" �<lambda>? s z2_SocketProvider.extra_attributes.<locals>.<lambda>c s � �j �� �S r �r= � getsocknamer )�convertr! r r" r> @ s �c s � j S r )r= r r r r" r> C � c � � S r r r )�peernamer r" r> L � c s � j �� d S )Nr r? r r r r" r> Q s r c rC r r r )r8 r r" r> U rE )�_core._socketsr< r/ r0 r2 r6 r= � getpeername�OSErrorr7 r �AF_INET�AF_INET6r4 r8 )r! �
attributesr )rA rD r8 r! r" �extra_attributes: s& � �
�z _SocketProvider.extra_attributesr5 c C s d S r r r r r r" r= Y s z_SocketProvider._raw_socketN)r r; )r r5 )r, r- r. �propertyrL r r= r r r r" r: 9 s r: c @ � e Zd ZdZdS )� SocketStreamzu
Transports bytes over a socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
N�r, r- r. �__doc__r r r r" rO _ � rO c @ s( e Zd Zeddd��Zedd
d��ZdS )�UNIXSocketStream�message�bytes�fds�Collection[int | IOBase]r r c � � �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)
Nr )r! rT rV r r r" �send_fdsh rB zUNIXSocketStream.send_fds�msglenr3 �maxfds�tuple[bytes, list[int]]c � rX )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)
Nr )r! rZ r[ r r r" � receive_fdsr rB z UNIXSocketStream.receive_fdsN)rT rU rV rW r r )rZ r3 r[ r3 r r\ )r, r- r. r rY r] r r r r" rS g s
rS c @ s, e Zd ZdZeddd��Z ddd d
�ZdS )�SocketListenerz}
Listens to incoming socket connections.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
r rO c � rX )z Accept an incoming connection.Nr r r r r" �accept� rB zSocketListener.acceptN�handler� Callable[[SocketStream], Any]�
task_group�TaskGroup | Noner 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)� rd r �enter_async_contextr_ �
start_soon)r! r` rb rd �stack�streamr r r" �serve� s � ��zSocketListener.serve)r rO r )r` ra rb rc r r )r, r- r. rQ r r_ rj r r r r" r^ } s �r^ c @ s e Zd ZdZd
d
d �Zd S )� UDPSocketz{
Represents an unconnected UDP socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
�datarU �host�str�portr3 r r c � s �| � |||ff�I dH S )z^
Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).
N��send)r! rl rm ro r r r" �sendto� s �zUDPSocket.sendtoN)rl rU rm rn ro r3 r r �r, r- r. rQ rr r r r r" rk � s rk c @ rN )�ConnectedUDPSocketzy
Represents an connected UDP socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
NrP r r r r" rt � rR rt c @ s e Zd ZdZd dd �Zd
S ) �UNIXDatagramSocketz�
Represents an unconnected Unix datagram socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
rl rU �pathrn r r c � s �| � ||f�I dH S )zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nrp )r! rl rv r r r" rr � s �zUNIXDatagramSocket.sendtoN)rl rU rv rn r r rs r r r r" ru � s ru c @ rN )�ConnectedUNIXDatagramSocketz�
Represents a connected Unix datagram socket.
Supports all relevant extra attributes from :class:`~SocketAttribute`.
NrP r r r r" rw � rR rw )5�
__future__r �socket�abcr �collections.abcr r r �
contextlibr �ior � ipaddressr r
r �typesr �typingr
r r �_core._typedattrr r r �_streamsr r r �_tasksr rn �
IPAddressType�tupler3 �IPSockAddrTyper1 rU �
UDPPacketType�UNIXDatagramPacketTyper r r/ r: rO rS r^ rk rt ru rw r r r r" �<module> s>
&
�