File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/__pycache__/tcpclient.cpython-310.pyc
Back
o ;j" � @ s� d Z ddlmZmZmZ ddlZddlZddlmZ ddl m Z ddl m Z ddl mZ ddlmZ dd lmZ d ZG d d � d e�ZG d d� de�ZdS )z'A non-blocking TCP connection factory. � )�absolute_import�division�print_functionN)�Future)�IOLoop)�IOStream)�gen)�Resolver)�set_close_execg333333�?c @ sX e Zd ZdZdd� Zedd� �Zefdd�Zdd � Z d d � Z d d � Z dd� Z dd� Z dS )� _Connectora� A stateless implementation of the "Happy Eyeballs" algorithm. "Happy Eyeballs" is documented in RFC6555 as the recommended practice for when both IPv4 and IPv6 addresses are available. In this implementation, we partition the addresses by family, and make the first connection attempt to whichever address was returned first by ``getaddrinfo``. If that connection fails or times out, we begin a connection in parallel to the first address of the other family. If there are additional failures we retry with other addresses, keeping one connection attempt per family in flight at a time. http://tools.ietf.org/html/rfc6555 c C s@ || _ || _t� | _d | _d | _t|�| _| �|�\| _ | _ d S �N) �io_loop�connectr �future�timeout� last_error�len� remaining�split� primary_addrs�secondary_addrs)�self�addrinfor r � r �N/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/tcpclient.py�__init__4 s z_Connector.__init__c C sP g }g }| d d }| D ]\}}||kr |� ||f� q |� ||f� q ||fS )a� Partition the ``addrinfo`` list by address family. Returns two lists. The first list contains the first entry from ``addrinfo`` and all others with the same family, and the second list contains all other addresses (normally one list will be AF_INET and the other AF_INET6, although non-standard resolvers may return additional families). r )�append)r ZprimaryZ secondaryZ primary_af�af�addrr r r r > s z_Connector.splitc C s | � t| j�� | �|� | jS r )� try_connect�iterr � set_timoutr �r r r r r �startR s z_Connector.startc C sx zt |�\}}W n ty' | jdkr$| j�� s$| j�| jp"td�� Y d S w | �||�}|� t � | j |||�� d S )Nr zconnection failed) �next� StopIterationr r �done� set_exceptionr �IOErrorr Zadd_done_callback� functools�partial�on_connect_done)r �addrsr r r r r r r W s �� �z_Connector.try_connectc C s� | j d8 _ z|�� }W n7 tyD } z+| j�� r!W Y d }~d S || _| �|� | jd ur9| j� | j� | � � W Y d }~d S d }~ww | � � | j�� rT|� � d S | j� |||f� d S )N� )r �result� Exceptionr r& r r r r �remove_timeout� on_timeout� clear_timeout�closeZ set_result)r r, r r r �stream�er r r r+ f s$ �� z_Connector.on_connect_donec C s | j �| j �� | | j�| _d S r )r Z add_timeout�timer1 r r" r r r r! ~ s �z_Connector.set_timoutc C s d | _ | �t| j�� d S r )r r r r �r r r r r1 � s z_Connector.on_timeoutc C s | j d ur| j�| j � d S d S r )r r r0 r7 r r r r2 � s �z_Connector.clear_timeoutN)�__name__� __module__� __qualname__�__doc__r � staticmethodr �_INITIAL_CONNECT_TIMEOUTr# r r+ r! r1 r2 r r r r r # s r c @ sL e Zd ZdZd dd�Zdd� Zejej ddddfdd��Z d d d �Z dS ) � TCPClientzwA non-blocking TCP connection factory. .. versionchanged:: 4.1 The ``io_loop`` argument is deprecated. Nc C s< |pt �� | _|d ur|| _d| _d S t|d�| _d| _d S )NF)r T)r �currentr �resolver� _own_resolverr )r r@ r r r r r � s zTCPClient.__init__c C s | j r | j�� d S d S r )rA r@ r3 r7 r r r r3 � s �zTCPClient.closec c sf � | j �|||�V }t|| jtj| j|||d��} | �� V \}} } |dur.| jd||d�V } t � | ��)a� Connect to the given host and port. Asynchronously returns an `.IOStream` (or `.SSLIOStream` if ``ssl_options`` is not None). Using the ``source_ip`` kwarg, one can specify the source IP address to use when establishing the connection. In case the user needs to resolve and use a specific interface, it has to be handled outside of Tornado as this depends very much on the platform. Similarly, when the user requires a certain source port, it can be specified using the ``source_port`` arg. .. versionchanged:: 4.5 Added the ``source_ip`` and ``source_port`` arguments. )� source_ip� source_portNF)� ssl_options�server_hostname) r@ �resolver r r) r* �_create_streamr# Z start_tlsr ZReturn) r �host�portr rD �max_buffer_sizerB rC r Z connectorr r4 r r r r � s � ��� zTCPClient.connectc C s� t |t�r|nd}|}|r|s|tjkrdnd}t�|�}t|�� � |s'|r>z |�||f� W n tjy= |�� � w z t || j |d�} W n tjye } zt � } | � | � | W Y d } ~ S d } ~ ww | � |�S )Nr z::1z 127.0.0.1)r rJ )� isinstance�int�socket�AF_INET6r �fileno�bind�errorr3 r r r r' r ) r rJ r r rB rC Zsource_port_bindZsource_ip_bindZ socket_objr4 r5 Zfur r r rG � s2 � � �� zTCPClient._create_stream)NN) r8 r9 r: r; r r3 r � coroutinerM � AF_UNSPECr rG r r r r r> � s �"�r> )r; � __future__r r r r) rM Zsalt.ext.tornado.concurrentr Zsalt.ext.tornado.ioloopr Zsalt.ext.tornado.iostreamr Zsalt.ext.tornador Zsalt.ext.tornado.netutilr Z salt.ext.tornado.platform.autor r= �objectr r> r r r r �<module> s h
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings