| Server IP : 198.38.94.13 / Your IP : 216.73.217.33 Web Server : Apache System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : revivere ( 1140) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /opt/saltstack/salt/lib/python3.10/site-packages/aiohappyeyeballs/__pycache__/ |
Upload File : |
o
;j�% � @ s> d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z ddl
mZ ddlmZmZ dddddd�de
e d e e
e d
e e d e e d e ej d
e e dejfdd�Z dd ejdeee eef ded e e
e de e ej d
e e dejfdd�Z dde
e dedee fdd�ZdS ) zBase implementation.� N)�List�Optional�Sequence�Set�Union� )�
_staggered)� AddrInfoType�SocketFactoryType)�local_addr_infos�happy_eyeballs_delay�
interleave�loop�socket_factory�
addr_infosr r r
r r �returnc � sL �| � s t �� � t| �dk}|dur|du rd}|r"|s"t| |�} d}g �|du s,|rL| D ] }zt� �|�d��I dH }W n ttfyJ Y q.w nft� �z=t� � ����fdd�| D �|�I dH \}} } W �D ] }
|
|ur�t
� t�� |
� � W d � n1 s�w Y qjd�n%�D ] }
|
|ur�t
� t�� |
� � W d � n1 s�w Y q�d�w |du �r$dd� �D �} z`| d } t| �dkr�| �t
| ��t�fdd�| D ��r�| �d �d
�d d� | D ���}
t| t��r| j�t�fd d�| D ���rt�|
��t|
��t| t��rtd
d� | D ���rt|
��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 � open_socketsr � �I/opt/saltstack/salt/lib/python3.10/site-packages/aiohappyeyeballs/impl.py� <genexpr>X s �
��
�z#start_connection.<locals>.<genexpr>c S s g | ] }|D ]}|�qqS r r )r �sub�excr r r �
<listcomp>v s z$start_connection.<locals>.<listcomp>r c 3 s � | ] }t |�� kV qd S r ��str�r r )�modelr r r ~ s � zMultiple exceptions: {}z, c s s � | ]}t |�V qd S r r! r# r r r r � s � c 3 s$ � | ]
}t |t�o
|j� kV qd S r )�
isinstance�OSError�errnor# )� first_errnor r r � s
� �
�c s s � | ]}t |t�V qd S r )r% � RuntimeErrorr# r r r r � s �
�)�asyncioZget_running_loop�len�_interleave_addrinfosr r) r& �setr Zstaggered_race�
contextlib�suppress�closer" �all�format�joinr% r' )r r r r
r r Zsingle_addr_info�sockr �_�sZall_exceptionsZfirst_exception�msgr )r r r( r r$ r r r �start_connection s� �'
���
� �
���
��
�
�
�
�r8 r � addr_infor c
� s� �g }|� |� |\}}} }
} d} z�z�|dur ||�} ntj||| d�} |dur-|�| � | �d� |dur�|D ]>\}
}
}
}
}|
|krDq8z| �|� W n8 tyv } z d|�d|jp\d�� � �}t|j|�}|� |� W Y d}~q8d}~ww |r}|� � �td|�d���| �
| | �I dH | W W d }}S t tfy� } z,|� |� | dur�|dur�|� | � z| �
� W � ty� } z|� |� � d}~ww � d}~w | dur�|dur�|� | � z| �
� W � ty� } z|� |� � d}~ww � d }}w ) aq
Create, bind and connect one socket.
If open_sockets is passed, add the socket to the set of open sockets.
Any failure caught here will remove the socket from the set and close it.
Callers can use this set to close any sockets that are not the winner
of all staggered tasks in the result there are runner up sockets aka
multiple winners.
N)�family�type�protoFz*error while attempting to bind on address z: � z&no matching local address with family=z found)�append�socket�add� setblocking�bindr& �strerror�lowerr' �popZ sock_connectr) �remover0 )r r r9 r r r Z
my_exceptionsr: �type_r< r5 �addressr4 Zlfamily�laddrr r7 �er r r r � s� �
� �� ��
�
�
���
�
��
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)rK rL Zaddrinfos_by_family�addrr: Zaddrinfos_listsZ reorderedr r r r, � s �
�r, )NNN)r )�__doc__r* rN r. r rS r? �typingr r r r r r= r �typesr r
�float�intZAbstractEventLoopr8 r& r) r r, r r r r �<module> sr ��
�����
� ����
� ��
�O����