File: //usr/local/lib/python3.10/dist-packages/aiohappyeyeballs/__pycache__/impl.cpython-310.pyc
o
���g �
@ s
d Z ddlZddlZddlZddlZddlZddlmZmZm Z m
Z
ddl m Z ddl
mZ ddddd�de e d ee e d
ee d ee d eej d
ejf dd�Z dd ejdeee
eef ded ee e d
ejf
dd�Z dde e ded
ee fdd�ZdS )zBase implementation.� N)�List�Optional�Sequence�Union� )�
_staggered)� AddrInfoType)�local_addr_infos�happy_eyeballs_delay�
interleave�loop�
addr_infosr r
r r �returnc
� s� �| � s t �� � t| �dk}|dur|du rd}|r"|s"t| |�} d}g �|du s,|rJ| D ]}z
t� �|��I dH }W n ttfyH Y q.w nt�� ��fdd�| D �|�I dH \}}}|du r�dd� �D �} z\| d }
t| �dkrw|
�t |
��t
�fdd�| D ��r�|
�d � d
� d d� | D ���} t
|
t�r�|
j�t
�fd d�| D ��r�t�| ��t| ��t
|
t�r�t
d
d� | D ��r�t| ��t| ��d} d�w |S )aM
Connect to a TCP server.
Create a socket connection to a specified destination. The
destination is specified as a list of AddrInfoType tuples as
returned from getaddrinfo().
The arguments are, in order:
* ``family``: the address family, e.g. ``socket.AF_INET`` or
``socket.AF_INET6``.
* ``type``: the socket type, e.g. ``socket.SOCK_STREAM`` or
``socket.SOCK_DGRAM``.
* ``proto``: the protocol, e.g. ``socket.IPPROTO_TCP`` or
``socket.IPPROTO_UDP``.
* ``canonname``: the canonical name of the address, e.g.
``"www.python.org"``.
* ``sockaddr``: the socket address
This method is a coroutine which will try to establish the connection
in the background. When successful, the coroutine returns a
socket.
The expected use case is to use this method in conjunction with
loop.create_connection() to establish a connection to a server::
socket = await start_connection(addr_infos)
transport, protocol = await loop.create_connection(
MyProtocol, sock=socket, ...)
r Nc 3 s" � | ] }t �t� �|��V qd S �N)� functools�partial�
_connect_sock)�.0�addrinfo)� current_loop�
exceptionsr � �@/usr/local/lib/python3.10/dist-packages/aiohappyeyeballs/impl.py� <genexpr>O s � �
�
�z#start_connection.<locals>.<genexpr>c S s g | ] }|D ]}|�qqS r r )r �sub�excr r r �
<listcomp>Y s z$start_connection.<locals>.<listcomp>r c 3 s � | ] }t |�� kV qd S r ��str�r r )�modelr r r a s � zMultiple exceptions: {}z, c s s � | ]}t |�V qd S r r r r r r r f s � c 3 s$ � | ]
}t |t�o
|j� kV qd S r )�
isinstance�OSError�errnor )� first_errnor r r l s
� �
�c s s � | ]}t |t�V qd S r )r! � RuntimeErrorr r r r r q s �
�)�asyncio�get_running_loop�len�_interleave_addrinfosr r% r" r �staggered_racer �all�format�joinr! r# ) r
r r
r r �single_addr_info�sockr �_�all_exceptions�first_exception�msgr )r r r$ r r r �start_connection sl �&
�����
�
�
��r4 r � addr_infoc
� s� �g }|� |� |\}}}}} d}
z�zqtj|||d�}
|
�d� |durs|D ]>\} }}}} | |kr2q&z|
�| � W n8 tyd }
z d| �d|
jpJd�� � �}t|
j|�}
|� |
� W Y d}
~
q&d}
~
ww |rk|�� �td|�d���| � |
| �I dH |
W W d }}S t
tfy� }
z#|� |
� |
dur�z|
� � W � ty� } z|� |� � d}~ww � d}
~
w |
dur�z|
� � W � ty� } z|� |� � d}~ww � d }}w ) z$Create, bind and connect one socket.N)�family�type�protoFz*error while attempting to bind on address z: � z&no matching local address with family=z found) �append�socket� setblocking�bindr" �strerror�lowerr# �pop� sock_connectr% �close)r r r5 r �
my_exceptionsr6 �type_r8 r0 �addressr/ �lfamily�laddrr r3 �er r r r � sr �
� �� ��
�
�
���
�
��
r � addrinfos�first_address_family_countc C s� t �� }| D ]}|d }||vrg ||< || �|� qt|�� �}g }|dkr>|�|d d|d � � |d d|d �= |�dd� tj�tj |� �D �� |S )z-Interleave list of addrinfo tuples by family.r r Nc s s � | ] }|d ur|V qd S r r )r �ar r r r � s � ��z(_interleave_addrinfos.<locals>.<genexpr>)
� collections� OrderedDictr: �list�values�extend� itertools�chain�
from_iterable� zip_longest)rI rJ �addrinfos_by_family�addrr6 �addrinfos_lists� reorderedr r r r) � s �
�r) r )r )�__doc__r& rL r rQ r; �typingr r r r r9 r �typesr �float�int�AbstractEventLoopr4 r" r% r r) r r r r �<module> s\ ��
����
�v����
�
�;����