File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/connector.cpython-310.pyc
o
;j� � @ sR d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m
Z
d dl m Z m
Z
mZmZ d dlmZ d dlmZ d dlmZmZmZ d dlmZ d dlmZ d d l m Z m Z m Z m Z m!Z!m"Z" d dl#Z#d d
l#m$Z$m%Z% d d l&m'Z'm(Z( d d
l)m*Z*m+Z+ d dl,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8 d dl9m:Z: d dl;m<Z<m=Z=m>Z> d dl(m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZF d dlGmHZH d dlImJZJ ejKdkr�d dl mLZL ne!eMeNddf ZLe r�d dlOZOeOjPZPnz d dlOZOeOjPZPW n eQ�y dZOeRZPY nw eSdh�ZTeSddh�ZUeSdd h�ZVeUeTB ZWeWeVB ZXd ejK k�o&d k n �p.ejKd k ZYd ZZe �rFd d!l[m\Z\ d d"l;m]Z] d d#l^m_Z_ G d$d%� d%�Z`d&eae eR d'dfd(d)�ZbG d*d+� d+�ZcG d,d-� d-ec�ZdG d.d/� d/�ZeG d0d1� d1�ZfG d2d3� d3�Zgd4ehd'ePfd5d6�Zieid7�Zjeid8�ZkG d9d:� d:ef�ZlG d;d<� d<ef�ZmG d=d>� d>ef�ZndS )?� N)� OrderedDict� defaultdict�deque)� Awaitable�Callable�Iterator�Sequence)�suppress)�
HTTPStatus)�chain�cycle�islice)� monotonic)�
TracebackType)�
TYPE_CHECKING�Any�Literal�Optional�Union�cast)� AddrInfoType�SocketFactoryType� )�hdrs�helpers)�AbstractResolver�
ResolveResult) �ClientConnectionError� ClientConnectorCertificateError�ClientConnectorDNSError�ClientConnectorError�ClientConnectorSSLError�ClientHttpProxyError�ClientProxyConnectionError�InvalidUrlClientError�ServerFingerprintMismatch�UnixClientConnectorError� cert_errors�
ssl_errors)�ResponseHandler)�
ClientRequest� Fingerprint�_merge_ssl_params)� _SENTINEL� ceil_timeout�is_canonical_ipv4_address�
is_ip_address�noop�sentinel�
set_exception�
set_result)�
client_logger)�DefaultResolver�� � )�Bufferzmemoryview[int]zmemoryview[bytes]� �http�https�ws�wss)r8 �
r )r8 r@ r )r8 r9 � )�
BaseConnector� TCPConnector�
UnixConnector�NamedPipeConnectorr r )�
ClientTimeout)�
ConnectionKey)�Tracec @ s> e Zd ZdZdee ddfdd�Zdefdd�Zd d d
�ZdS ) �_DeprecationWaiter��
_awaitable�_awaited� awaitable�returnNc C s || _ d| _d S �NFrJ )�selfrM � rQ �E/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/connector.py�__init__h �
z_DeprecationWaiter.__init__c C s d| _ | j�� S )NT)rL rK � __await__�rP rQ rQ rR rU l rT z _DeprecationWaiter.__await__c C s | j s t�dt� d S d S )NzDConnector.close() is a coroutine, please use await connector.close())rL �warnings�warn�DeprecationWarningrV rQ rQ rR �__del__p s ��z_DeprecationWaiter.__del__�rN N) �__name__�
__module__� __qualname__� __slots__r r rS rU rZ rQ rQ rQ rR rI e s
rI �waitersrN c � s< �t j| ddi�I dH }|D ]
}t|t�rt�d|� qdS )z'Wait for all waiters to finish closing.Zreturn_exceptionsTNz!Error while closing connector: %r)�asyncioZgather�
isinstance� Exceptionr5 �debug)r` �results�resrQ rQ rR �_wait_for_closey s �
��rg c
@ s� e Zd ZdZdddddedejddf
d d
�Zdefd d �Z e
fd
e ddfdd�Z de
d fdd�Zedejfdd��ZedejdB fdd��ZededB fdd��Zdeg df ddfdd�Zd$d d �Zd$d d �Zd$d d!�Zedefd"d#��ZdS )%�
ConnectionN� connectorrB �keyrG �protocol�looprN c C s@ || _ || _|| _|| _g | _|�� r t�t� d��| _
d S d S )Nr ) �_key�
_connector�_loop� _protocol�
_callbacks� get_debug� traceback�
extract_stack�sys� _getframe�_source_traceback)rP ri rj rk rl rQ rQ rR rS � s �zConnection.__init__c C s d| j � d�S )Nz Connection<�>)rm rV rQ rQ rR �__repr__� s zConnection.__repr__� _warningsc C s� | j d ur?d| i}|jd| ��tfi |�� | j�� r d S | jj| j| j dd� | dd�}| jd ur7| j|d< | j� |� d S d S )N�sourcezUnclosed connection T�� should_closezUnclosed connection)Zclient_connection�message�source_traceback)
rp rX �ResourceWarningro � is_closedrn �_releaserm rw �call_exception_handler)rP rz �kwargs�contextrQ rQ rR rZ � s
�zConnection.__del__Tc C � dS )z9Force subclasses to not be falsy, to make checks simpler.TrQ rV rQ rQ rR �__bool__� s zConnection.__bool__c C s t jdtdd� | jS )Nz%connector.loop property is deprecated� ��
stacklevel)rW rX rY ro rV rQ rQ rR rl � s �zConnection.loopc C s | j d u rd S | j jS �N)rp � transportrV rQ rQ rR r� � s
zConnection.transportc C � | j S r� )rp rV rQ rQ rR rk � s zConnection.protocol�callbackc C s |d ur | j �|� d S d S r� )rq �append)rP r� rQ rQ rR � add_callback� s �zConnection.add_callbackc C sR | j d d � g }| _ |D ]}tt�� |� W d � n1 s!w Y q
d S r� )rq r rc )rP Z callbacks�cbrQ rQ rR �_notify_release� s
���zConnection._notify_releasec C s6 | � � | jd ur| jj| j| jdd� d | _d S d S )NTr| �r� rp rn r� rm rV rQ rQ rR �close� s
�zConnection.closec C s2 | � � | jd ur| j�| j| j� d | _d S d S r� r� rV rQ rQ rR �release� s
�zConnection.releasec C s | j d u p
| j �� S r� )rp � is_connectedrV rQ rQ rR �closed� s zConnection.closedr[ )r\ r] r^ rw r) ra �AbstractEventLooprS �strry rW r rZ r r� �propertyrl � Transportr� rk r r� r� r� r� �boolr� rQ rQ rQ rR rh � s8 ����
�
rh c @ s e Zd ZdZddd�ZdS )�_ConnectTunnelConnectiona� Special connection wrapper for CONNECT tunnels that must never be pooled.
This connection wraps the proxy connection that will be upgraded with TLS.
It must never be released to the pool because:
1. Its 'closed' future will never complete, causing session.close() to hang
2. It represents an intermediate state, not a reusable connection
3. The real connection (with TLS) will be created separately
rN Nc C r� )aa Do nothing - don't pool or close the connection.
These connections are an intermediate state during the CONNECT tunnel
setup and will be cleaned up naturally after the TLS upgrade. If they
were to be pooled, they would never be properly closed, causing
session.close() to wait forever for their 'closed' future.
NrQ rV rQ rQ rR r� � � z _ConnectTunnelConnection.releaser[ )r\ r] r^ �__doc__r� rQ rQ rQ rR r� � s r� c @ sD e Zd ZdZdZdejedB ddfdd�Zd dd �Z d d
d �Z
dS )
�_TransportPlaceholderz.placeholder for BaseConnector.connect function�r� r� �
closed_futureNrN c C s || _ d| _dS )z)Initialize a placeholder for a transport.Nr� )rP r� rQ rQ rR rS � s
z _TransportPlaceholder.__init__c C r� )zClose the placeholder.NrQ rV rQ rQ rR r� � r� z_TransportPlaceholder.closec C r� )z%Abort the placeholder (does nothing).NrQ rV rQ rQ rR �abort� r� z_TransportPlaceholder.abortr[ ) r\ r] r^ r� r_ ra ZFuturerc rS r� r� rQ rQ rQ rR r� � s
r� c @ sH e Zd ZdZdZdZdZeZe ddddddd �d
e
dB e B d e d e
d
e
de dejdB de ddfdd�Zefdeddfdd�ZdRdd�Zdeddfdd�ZdRd d �Z dSd ee dB d edB d edB ddfd!d"�Zede fd#d$��Z ede
fd%d&��Z ede
fd'd(��Z dTd)d*�Z dTd+d,�Z dd-�d.e de!d fd/d0�Z"dd-�d.e de#e!e
fd1d2�Z$ede fd3d4��Z%d5d6de
fd7d8�Z&d9e'de'fd:d;�Z(d9e'd<e#d= d>d?de)fd@dA�Z*d5d6d<e#d= ddfdBdC�Z+d5d6d<e#d= de)dB fdDdE�Z,dTdFdG�Z-d5d6dHe.ddfdIdJ�Z/ddK�d5d6dLe.dMe ddfdNdO�Z0d9e'd<e#d= d>d?de.fdPdQ�Z1dS )UrB a\ Base connector class.
keepalive_timeout - (optional) Keep-alive timeout.
force_close - Set to True to force close and do reconnect
after each request (and between redirects).
limit - The total number of simultaneous connections.
limit_per_host - Number of simultaneous connections to one host.
enable_cleanup_closed - Enables clean-up closed ssl transports.
Disabled by default.
timeout_ceil_threshold - Trigger ceiling of timeout values when
it's above timeout_ceil_threshold.
loop - Optional event loop.
TNg @F�d r � ��keepalive_timeout� force_close�limit�limit_per_host�enable_cleanup_closedrl �timeout_ceil_thresholdr� r� r� r� r� rl r� rN c C s |r|d ur|t urtd��n|t u rd}|pt�� }|| _d| _|�� r.t�t �
d��| _ t t
�| _|| _|| _t� | _t t�| _tt|�| _|| _t t�| _|| _tj t |d�| _ d | _ d | _ |rst!sst"j#dt j$� �t%dd� d}| | _&g | _'|�(� | _)| j)�*d � | �+� d S ) Nz6keepalive_timeout cannot be set if force_close is Trueg .@Fr �rl zoenable_cleanup_closed ignored because https://github.com/python/cpython/pull/118960 is fixed in Python version r� r� ),r2 �
ValueErrorra �get_running_loop�_timeout_ceil_threshold�_closedrr rs rt ru rv rw r r �_conns�_limit�_limit_per_host�set� _acquired�_acquired_per_hostr �float�_keepalive_timeout� _force_closer �_waitersro � functools�partialr) �_factory�_cleanup_handle�_cleanup_closed_handle�NEEDS_CLEANUP_CLOSEDrW rX � version_inforY �_cleanup_closed_disabled�_cleanup_closed_transports�
create_future�_placeholder_futurer4 �_cleanup_closed)rP r� r� r� r� r� rl r� rQ rQ rR rS sV �� �� ���� zBaseConnector.__init__rz c C s� | j rd S | js
d S dd� | j�� D �}| �� d| i}|jd| ��tfi |�� | |dd�}| jd ur9| j|d< | j�|� d S )Nc S s g | ]}t |��qS rQ )�repr)�.0�crQ rQ rR �
<listcomp>h s z)BaseConnector.__del__.<locals>.<listcomp>r{ zUnclosed connector zUnclosed connector)ri � connectionsr~ r ) r� r� �values�_closerX r� rw ro r� )rP rz �connsr� r� rQ rQ rR rZ b s �
zBaseConnector.__del__c C s t �dt� | S )NzH"with Connector():" is deprecated, use "async with Connector():" instead)rW rX rY rV rQ rQ rR � __enter__w s
�zBaseConnector.__enter__�excc G s | � � d S r� )r� )rP r� rQ rQ rR �__exit__ s zBaseConnector.__exit__c � s �| S r� rQ rV rQ rQ rR �
__aenter__� s �zBaseConnector.__aenter__�exc_type� exc_value�
exc_tracebackc � s �| � � I d H d S r� )r� )rP r� r� r� rQ rQ rR � __aexit__� s �zBaseConnector.__aexit__c C r� )z1Ultimately close connection on releasing if True.)r� rV rQ rQ rR r� � � zBaseConnector.force_closec C r� )z�The total number for simultaneous connections.
If limit is 0 the connector has no limit.
The default limit size is 100.
)r� rV rQ rQ rR r� � � zBaseConnector.limitc C r� )z�The limit for simultaneous connections to the same endpoint.
Endpoints are the same if they are have equal
(host, port, is_ssl) triple.
)r� rV rQ rQ rR r� � r� z BaseConnector.limit_per_hostc C s� | j r | j �� d| _ t� }| j}| jr^tt�}|| }| j�� D ]9\}}t� }|D ])\}} |�� r@| | dkr@|� || f� q*|j
}
|� � | j sS|j
rS| j� |
� q*|rZ|||< q!|| _| jrptj| d|| j| jd�| _ dS dS )zCleanup unused transports.Nr �_cleanup�r� )r� �cancelr r� r� r r �itemsr� r� r� r� r� �is_sslr� r �weakref_handlero r� ) rP �now�timeoutr� Zdeadlinerj r� �alive�protoZuse_timer� rQ rQ rR r� � s@
�� ��zBaseConnector._cleanupc C s\ | j r| j �� | jD ]
}|dur|�� q g | _| js,tj| d| j| j| j d�| _ dS dS )z~Double confirmation for transport close.
Some broken ssl servers may leave socket open without proper close.
Nr� r� )
r� r� r� r� r� r r� �_cleanup_closed_periodro r� )rP r� rQ rQ rR r� � s
� ��z BaseConnector._cleanup_closed�� abort_sslr� c C sZ | j |d� }s
tt� �S t|�}tjdkr#tj|| jdd�}t|�S | j� |�}t|�S )a Close all opened transports.
:param abort_ssl: If True, SSL connections will be aborted immediately
without performing the shutdown handshake. This provides
faster cleanup at the cost of less graceful disconnection.
r� r7 T�rl Z eager_start)
r� rI r1 rg ru r� ra �Taskro � create_task)rP r� r` �coroZtaskrQ rQ rR r� � s
�zBaseConnector.closec
C s g }| j r|S d| _ z�| j�� r>|W | j�� | j�� | j�� D ] }|D ]}|�� q%q!| j�� d | _ | j
�� d | _ S | j rF| j �� | j rN| j �� | j�� D ])}|D ]$\}}|rm|j rm|j �
d�d urm|�� n|�� |j }r{|�|� qWqS| jD ]"}|r�|j r�|j �
d�d ur�|�� n|�� |j }r�|�|� q�| j
D ]
} | d ur�| �� q�|W | j�� | j�� | j�� D ] }|D ]}|�� q�q�| j�� d | _ | j
�� d | _ S | j�� | j�� | j�� D ] }|D ]}|�� q�q�| j�� d | _ | j
�� d | _ w )NT�
sslcontext)r� ro r� r� �clearr� r� r� r� r� r� r� r� �get_extra_infor� r� r� r� )
rP r� r` �
keyed_waitersZ keyed_waiter�datar� �_r� r� rQ rQ rR r� � s�
*
�
�
��
��
��
�
�
�
�
�
zBaseConnector._closec C r� )z;Is connector closed.
A readonly property.
)r� rV rQ rQ rR r� 4 s zBaseConnector.closedrj rG c C s\ d}| j r| j t| j� }dkr|S | j }r,| j�|� }r&|t|�8 }||kr,|S |S )z�
Return number of available connections.
The limit, limit_per_host and the connection key are taken into account.
If it returns less than 1 means that there are no connections
available.
r r )r� �lenr� r� r� �get)rP rj Z total_remainZ host_remainZacquiredrQ rQ rR �_available_connections< s
z$BaseConnector._available_connections�reqc C s� |j }|dus J �i }|jdur|j}|jtj |tj< ttj|||j| j|j d�}|j�
tj d�}|durH|� � sB||jtj
< |S ||jtj
< |S )znSet Proxy-Authorization header for non-SSL proxy requests and builds the proxy request for SSL proxy requests.N)�headers�authrl �ssl)�proxyZ
proxy_headersr� r ZHOSTr* ZMETH_GET�
proxy_authro r� �popZ
AUTHORIZATIONr� ZPROXY_AUTHORIZATION)rP r� �urlr� � proxy_reqr� rQ rQ rR �-_update_proxy_auth_header_and_build_proxy_reqU s*
� �z;BaseConnector._update_proxy_auth_header_and_build_proxy_req�tracesrH r� rF c
� s� �|j }| �||�I dH }dur|jr| �|� |S t|j|j�4 I dH �� | �|�dkrX| �||�I dH | �||�I dH }durX|jrL| �|� |W d �I dH S t t
t | j ��}| j
�|� | jrq| j| �|� z(|r�|D ] }|�� I dH qv| �|||�I dH }|r�|D ] }|�� I dH q�W n ty� | �||� � w | jr�|�� td��W d �I dH n 1 I dH s�w Y | j
�|� | j
�|� | jr�| j| } | �|� | �|� t| ||| j�S )z'Get from pool or create new connection.Nr zConnector is closed.) �connection_key�_getr� r� r. �connect�ceil_thresholdr� � _wait_for_available_connectionr r) r� r� r� �addr� r� Z send_connection_create_start�_create_connectionZsend_connection_create_end�
BaseException�_release_acquiredr� r� r �removerh ro )
rP r� r� r� rj �conn� placeholder�tracer� Zacquired_per_hostrQ rQ rR r o sX �
�
� � �
(� '
zBaseConnector.connectc
� s� �d} | j �� }| j| }d||< |r|j|dd� z4|r*|D ] }|�� I dH q |I dH |r=|D ] }|�� I dH q3W |�|d� | j�|d�sO| j|= n|�|d� | j�|d�sa| j|= w | �|�dkrkdS |d7 }q)z&Wait for an available connection slot.r TNF��lastr ) ro r� r� � move_to_endZ send_connection_queued_startZsend_connection_queued_endr� r� r� )rP rj r� �attempts�futr� r rQ rQ rR r � s8 �
� � �
�z,BaseConnector._wait_for_available_connectionc � s� �| j �|� }du r
dS t� }|ru|�� \}}|�� r`|| | jkr`|s)| j |= | j�|� | jr:| j | �|� |rX|D ]}z |�
� I dH W q> t yW | � ||� � w t
| ||| j�S |j}|�� | jss|jrs| j�|� |s| j |= dS )znGet next reusable connection for the key or None.
The connection will be marked as acquired.
N)r� r� r �popleftr� r� r� r r� r� Zsend_connection_reuseconnr r rh ro r� r� r� r� r� r� ) rP rj r� r� �t1r� �t0r r� rQ rQ rR r � s8 � � � zBaseConnector._getc C sv | j sdS t| j �}t�|� |D ]'}| �|�dk rq| j | }|r8|jdd�\}}|�� s6|�d� dS |s"qdS )z�
Iterates over all waiters until one to be released is found.
The one to be released is not finished and
belongs to a host that has available connections.
Nr Fr )r� �list�random�shuffler� �popitem�doner4 )rP Zqueuesrj r` �waiterr� rQ rQ rR �_release_waiter� s
���z BaseConnector._release_waiterr� c C sN | j rdS | j�|� | jr!| j�|� }r!|�|� |s!| j|= | �� dS )z Release acquired connection.N)r� r� �discardr� r� r� r )rP rj r� r� rQ rQ rR r s
z BaseConnector._release_acquiredr| rk r} c C s� | j rd S | �||� | js|s|jr(|j}|�� |jr&| js&| j� |� d S | j
| � |t � f� | j d u rHt
j| d| j| j| jd�| _ d S d S )Nr� r� )r� r r� r} r� r� r� r� r� r� r� r r� r r� r� ro r� )rP rj rk r} r� rQ rQ rR r� % s&
��zBaseConnector._releasec � s �t � �r� )�NotImplementedError)rP r� r� r� rQ rQ rR r E s �z BaseConnector._create_connection)rN rB )NNNr[ )2r\ r] r^ r� r� rw r� �HIGH_LEVEL_SCHEMA_SET�allowed_protocol_schema_setr2 �objectr� r� �intra r� rS rW r rZ r� r� r� �typer r r� r� r� r� r� r� r� r r� r r� r� r� r* r� rh r r r r r) r r� r rQ rQ rQ rR rB � s� �
������ �
�M
�
���
�
' >�
����
�;��
�*��
�
*����
� ����rB c @ s� e Zd ZddedB deddfdd�Zdedefd d
�Zd e e
ef d e e ddfd
d�Z
d e e
ef ddfdd�Zddd�Zd e e
ef de e fdd�Zd e e
ef defdd�ZdS )�_DNSCacheTableN�� �ttl�max_sizerN c C s t � | _i | _|| _|| _d S r� )r � _addrs_rr� _timestamps�_ttl� _max_size)rP r$ r% rQ rQ rR rS L s
�
z_DNSCacheTable.__init__�hostc C s
|| j v S r� )r& )rP r* rQ rQ rR � __contains__T s
z_DNSCacheTable.__contains__rj �addrsc C sz || j v r | j �|� t|�t|�f| j |< | jd ur!t� | j|< t| j �| jkr;| j jdd�\}}| j� |d � d S d S )NFr )
r& r r r� r( r r' r) r r� )rP rj r, Z
oldest_keyr� rQ rQ rR r W s
�z_DNSCacheTable.addc C s | j �|d � | j�|d � d S r� )r& r� r' �rP rj rQ rQ rR r d s z_DNSCacheTable.removec C s | j �� | j�� d S r� )r& r� r' rV rQ rQ rR r� h s
z_DNSCacheTable.clearc C s4 | j | \}}tt||��}t|� | j �|� |S r� )r& r r
�nextr )rP rj rl �lengthr, rQ rQ rR �
next_addrsl s
z_DNSCacheTable.next_addrsc C s$ | j d u rdS | j| | j t� k S rO )r( r' r r- rQ rQ rR �expiredt s
z_DNSCacheTable.expired)Nr# r[ )r\ r] r^ r� r rS r r� r+ �tupler� r r r r r� r0 r1 rQ rQ rQ rR r" K s "
r" �verifiedc C sz t du rdS | r
t �� }n)t �t j�}| jt jO _| jt jO _d|_t j|_ | jt j
O _|� � |� d� |S )z�Create SSL context.
This method is not async-friendly and should be called from a thread
because it will load certificates from disk and do other blocking I/O.
NF)zhttp/1.1)
r� �create_default_context�
SSLContext�PROTOCOL_TLS_CLIENT�options� OP_NO_SSLv2� OP_NO_SSLv3�check_hostname� CERT_NONE� verify_mode�OP_NO_COMPRESSION�set_default_verify_paths�set_alpn_protocols)r3 r� rQ rQ rR �_make_ssl_context{ s
r@ TFc , s� e Zd ZdZeedh�B Zdddddejj dddde
ddd ddd
d dde
d �d
e de dB de de
dB de
dejdedB de eB eB deee
f dB dedB ddeB eB de de
de
de d ejdB d ed edB d e
dB d edB d!edB eB f*� fd"d#�Zdd$�d%e d&eee f� fd'd(�Z dd$�d%e d&df� fd)d*�Z e d&e
fd+d,��Z e d&e fd-d.��Z dbd/edB d0e
dB d&dfd1d2�Z! dcd/ed0e
d3e"d4 dB d&ee# fd5d6�Z$d7eee
f d/ed0e
d8e%d9 d3e"d4 dB d&ee# f d:d;�Z&d<e'd3ed4 d=d>d&e(fd?d@�Z)d<e'd&edB fdAdB�Z*d<e'd&e+dC fdDdE�Z,e-dF�dGe.dHee/ d<e'd=d>dIe0e1 dJe.d&eej2e(f fdKdL�Z3e-dF�dGe.d<e'd=d>dIe0e1 dJe.d&eej2e(f f dMdN�Z4dddPdQ�Z5dedRdS�Z6d&e fdTdU�Z7dVej2d<e'd&dfdWdX�Z8e-fdVej2d<e'd=d>dIe0e1 d&eej9e(f f
dYdZ�Z:d[ee# d&ee/ fd\d]�Z;e-dF�d<e'd3ed4 d=d>dIe0e1 d&eej2e(f f
d^d_�Z<d<e'd3ed4 d=d>d&eej9e(f fd`da�Z=� Z>S )frC u� TCP connector.
verify_ssl - Set to True to check ssl certifications.
fingerprint - Pass the binary sha256
digest of the expected certificate in DER format to verify
that the certificate the server presents matches. See also
https://en.wikipedia.org/wiki/HTTP_Public_Key_Pinning
resolver - Enable DNS lookups and use this
resolver
use_dns_cache - Use memory cache for DNS lookups.
ttl_dns_cache - Max seconds having cached a DNS entry, None forever.
family - socket address family
local_addr - local tuple of (host, port) to bind socket to
keepalive_timeout - (optional) Keep-alive timeout.
force_close - Set to True to force close and do reconnect
after each request (and between redirects).
limit - The total number of simultaneous connections.
limit_per_host - Number of simultaneous connections to one host.
enable_cleanup_closed - Enables clean-up closed ssl transports.
Disabled by default.
happy_eyeballs_delay - This is the “Connection Attempt Delay”
as defined in RFC 8305. To disable
the happy eyeballs algorithm, set to None.
interleave - “First Address Family Count” as defined in RFC 8305
loop - Optional event loop.
socket_factory - A SocketFactoryType function that, if supplied,
will be used to create sockets given an
AddrInfoType.
ssl_shutdown_timeout - DEPRECATED. Will be removed in aiohttp 4.0.
Grace period for SSL shutdown handshake on TLS
connections. Default is 0 seconds (immediate abort).
This parameter allowed for a clean SSL shutdown by
notifying the remote peer of connection closure,
while avoiding excessive delays during connector cleanup.
Note: Only takes effect on Python 3.11+.
ZtcpTN�
r# Fr� r r� g �?)�
verify_ssl� fingerprint�
use_dns_cache�
ttl_dns_cache�dns_cache_max_size�family� ssl_contextr� �
local_addr�resolverr� r� r� r� r� rl r� �happy_eyeballs_delay�
interleave�socket_factory�ssl_shutdown_timeoutrB rC rD rE rF rG rH r� rI rJ r� r� r� r� r� rl r� rK rL rM rN c s t � j| | |
||||d� t||||�| _| |
d u r&t| jd�| _d| _n|
| _d| _|| _t ||d�| _
i | _ || _ t
�| �| _|| _|| _t� | _|| _| |tu rZd| _d S tjdtdd � tjd
k r{|d ur{|dkr{tjd |� d �t dd � || _d S )
Nr� r� TF)r$ r% r zSThe ssl_shutdown_timeout parameter is deprecated and will be removed in aiohttp 4.0r� r� �r8 � zssl_shutdown_timeout=zd is ignored on Python < 3.11; only ssl_shutdown_timeout=0 is supported. The timeout will be ignored.) �superrS r, �_sslr6 ro � _resolver�_resolver_owner�_use_dns_cacher" �
_cached_hosts�_throttle_dns_futures�_family�aiohappyeyeballsZaddr_to_addr_infos�_local_addr_infos�_happy_eyeballs_delay� _interleaver� �_resolve_host_tasks�_socket_factoryr2 �_ssl_shutdown_timeoutrW rX rY ru r� �RuntimeWarning)rP rB rC rD rE rF rG rH r� rI rJ r� r� r� r� r� rl r� rK rL rM rN �� __class__rQ rR rS � sZ �
��
�
�
zTCPConnector.__init__r� r� rN c sN t �| j�� �D ]}|�� qt� j|d�}| jD ] }|�� |�|� q|S )z Close all ongoing DNS calls.r� ) r �
from_iterablerW r� r� rQ r� r] r� )rP r� r r` �tra rQ rR r� s
zTCPConnector._closec � s> �t � j|p
| jdkd�I dH | jr | j�� I dH dS dS )a�
Close all opened transports.
:param abort_ssl: If True, SSL connections will be aborted immediately
without performing the shutdown handshake. If False (default),
the behavior is determined by ssl_shutdown_timeout:
- If ssl_shutdown_timeout=0: connections are aborted
- If ssl_shutdown_timeout>0: graceful shutdown is performed
r r� N)rQ r� r_ rT rS )rP r� ra rQ rR r� " s
� �zTCPConnector.closec C r� )zSocket family like AF_INET.)rX rV rQ rQ rR rG 1 r� zTCPConnector.familyc C r� )z%True if local DNS caching is enabled.)rU rV rQ rQ rR rD 6 r� zTCPConnector.use_dns_cacher* �portc C sJ |dur|dur| j �||f� dS |dus|dur td��| j �� dS )z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)rV r r� r� )rP r* re rQ rQ rR �clear_dns_cache; s
z TCPConnector.clear_dns_cacher� rH c � s �t |�r d|vrt|�st|d��|||| jddd�gS | jsT|r/|D ]
}|�|�I dH q$| jr6td��| jj ||| jd�I dH }|rR|D ]
}|�
|�I dH qG|S ||f}|| j v rz| j � |�sz| j �
|�}|rx|D ]
}|�|�I dH qm|S || jv r�| j| }| j�� } |�| � |r�|D ]
}|�|�I dH q�z | I dH W |�| � n|�| � w | j �
|�S t� | j|< }| �|||||�}
t�� } tjdkr�tj|
| d d
�} n| �|
�} | � � s�| j �| � | � | j j� z t� | �I dH W S tj �y ddd�}
| � |
� � w )z*Resolve host and return list of addresses.�:z is not a canonical IPv4 addressr )�hostnamer* re rG r� �flagsNzConnector is closed�rG r7 Tr� r �#asyncio.Future[list[ResolveResult]]rN c S s: t ttj��
| �� W d � d S 1 sw Y d S r� )r rc ra �CancelledError�result)r rQ rQ rR �drop_exception� s
"�z2TCPConnector._resolve_host.<locals>.drop_exception)r rk rN N)!r0 r/ r$ rX rU �send_dns_resolvehost_startr� r rS �resolve�send_dns_resolvehost_endrV r1 r0 Zsend_dns_cache_hitrW ro r� r r r� �_resolve_host_with_throttlera r� ru r� r� r� r r] Zadd_done_callbackZshieldrl )rP r* re r� r rf rj rm �futuresZfuturer� rl Zresolved_host_taskrn rQ rQ rR �
_resolve_hostD sr �
��
�zTCPConnector._resolve_hostrj rs zasyncio.Future[None]c
� s� �zkzK|r |D ]
}|� |�I dH q|D ]
}|�|�I dH q| jj||| jd�I dH }|r;|D ]
}|�|�I dH q0| j�||� |D ]}t|d� qDW n t yd } z |D ]}t
|| � qW� d} ~ ww W | j � |� n| j � |� w | j�
|�S )z�Resolve host and set result for all waiters.
This method must be run in a task and shielded from cancellation
to avoid cancelling the underlying lookup.
Nrj )Zsend_dns_cache_missro rS rp rX rq rV r r4 r r3 rW r� r0 )
rP rj r* re rs r� r r, r �erQ rQ rR rr � s0 �
� ���
z(TCPConnector._resolve_host_with_throttler� r� rF c � s@ �|j r| �|||�I dH \}}|S | �|||�I dH \}}|S )zcCreate connection.
Has same keyword arguments as BaseEventLoop.create_connection.
N)r� �_create_proxy_connection�_create_direct_connection)rP r� r� r� r� r� rQ rQ rR r � s ��z TCPConnector._create_connectionc C sd |� � sdS tdu rtd��|j}t|tj�r|S |dur tS | j}t|tj�r*|S |dur0tS tS )a* Logic to get the correct SSL context
0. if req.ssl is false, return None
1. if ssl_context is specified in req, use it
2. if _ssl_context is specified in self, use it
3. otherwise:
1. if verify_ssl is not specified in req, use self.ssl_context
(will generate a default context according to self.verify_ssl)
2. if verify_ssl is True in req, generate a default SSL context
3. if verify_ssl is False in req, generate a SSL context that
won't verify
NzSSL is not supported.T)r� r� � RuntimeErrorrb r5 �_SSL_CONTEXT_UNVERIFIEDrR �_SSL_CONTEXT_VERIFIED)rP r� r� rQ rQ rR �_get_ssl_context� s z TCPConnector._get_ssl_contextr+ c C s, |j }t|t�r
|S | j}t|t�r|S d S r� )r� rb r+ rR )rP r� �retrQ rQ rR �_get_fingerprint� s
z TCPConnector._get_fingerprint�� client_error�args�
addr_infosr r� c
� s@ �z[t |j|jd�4 I d H �A tj|| j| j| j| j| j d�I d H }|�
d�r4| j r4t j
dkr4| j |d< | jj|i |�d|i��I d H W d �I d H W S 1 I d H sUw Y W d S tyo } zt|j|�|�d }~w ty� } zt|j|�|�d }~w ty� } z|jd u r�t|tj�r�� ||j|�|�d }~ww )N�r )r� Zlocal_addr_infosrK rL rl rM r� rO rN �sock)r. � sock_connectr rY Zstart_connectionrZ r[ r\ ro r^ r� r_ ru r� �create_connectionr' r r� r( r! �OSError�errnorb ra � TimeoutError) rP r� r� r� r r� r� r� r� rQ rQ rR �_wrap_create_connection sB � � �
��
4�����z$TCPConnector._wrap_create_connectionc
� s� �z2t |j|jd�4 I d H � | jj|i |��I d H W d �I d H W S 1 I d H s,w Y W d S tyF } zt|j|�|�d }~w tyX } zt |j|�|�d }~w t
yv } z|j d u rkt |t
j�rk� ||j|�|�d }~ww �Nr� )r. r� r ro r� r' r r� r( r! r� r� rb ra r� )rP r� r� r r� r� r� rQ rQ rR �_wrap_existing_connection. s& ��4�����z&TCPConnector._wrap_existing_connectionr* c C s8 |� � sdS |j}|dusJ �|jdkrdS | �� dS )z�Raise a :py:exc:`RuntimeError` on missing ``start_tls()``.
It is necessary for TLS-in-TLS so that it is possible to
send HTTPS queries through HTTPS proxies.
This doesn't affect regular HTTP requests, though.
Nr= )r� r� �scheme�_check_loop_for_start_tls)rP r� Z proxy_urlrQ rQ rR �_fail_on_no_start_tlsD s
z"TCPConnector._fail_on_no_start_tlsc
C s2 z| j j W d S ty } ztd�|�d }~ww )Na� An HTTPS request is being sent through an HTTPS proxy. This needs support for TLS in TLS but it is not implemented in your runtime for the stdlib asyncio.
Please upgrade to Python 3.11 or higher. For more details, please see:
* https://bugs.python.org/issue37179
* https://github.com/python/cpython/pull/28073
* https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support
* https://github.com/aio-libs/aiohttp/discussions/6044
)ro � start_tls�AttributeErrorrx )rP Zattr_excrQ rQ rR r� V s � ���z&TCPConnector._check_loop_for_start_tlsc C s$ z| � � W dS ty Y dS w )NFT)r� rx rV rQ rQ rR �_loop_supports_start_tlsg s
��z%TCPConnector._loop_supports_start_tls�underlying_transportc C st |j jjdkr dS |jdu s|jjdkrdS t|�j�d�r dS tjdkp*t |dd�}|r/dS t
j dt | dd � dS )
z6Issue a warning if the requested URL has HTTPS scheme.r= NZuvlooprO Z_start_tls_compatibleFa An HTTPS request is being sent through an HTTPS proxy. This support for TLS in TLS is known to be disabled in the stdlib asyncio (Python <3.11). This is why you'll probably see an error in the log below.
It is possible to enable it via monkeypatching. For more details, see:
* https://bugs.python.org/issue37179
* https://github.com/python/cpython/pull/28073
You can temporarily patch this as follows:
* https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support
* https://github.com/aio-libs/aiohttp/discussions/6044
r8 )r{ r� )
� request_infor� r� r� r! r] �
startswithru r� �getattrrW rX r` )rP r� r� Zasyncio_supports_tls_in_tlsrQ rQ rR �_warn_about_tls_in_tlso s& �
�z#TCPConnector._warn_about_tls_in_tlsc � sf �| � � }| �|�}tr|dusJ �z�t|j|jd�4 I dH �� z7tjdkrA| jrA| j j
||||j p4|j |j
p8d| jd�I dH }n| j j
||||j pL|j |j
pPdd�I dH }W n tym | jdkrh|�� � |�� � w t|tj�r�| �|�}|r�z|�|� W n ty� |�� | js�| j�|� � w W d �I dH n 1 I dH s�w Y W nl ty� } zt|j | �| �d} ~ w t y� } zt |j | �| �d} ~ w t y� } z| j du r�t| tj!�r� ||j | �| �d} ~ w t"�y }
z t#d|j �d|j$d �d
|j%�d |j&�p
d � d
|
�d� �|
�d}
~
ww |du �r*d} ||j t | ���|�'|� ||fS )z$Wrap the raw TCP transport with TLS.Nr� rO )�server_hostname�ssl_handshake_timeoutrN )r� r� r z2Cannot initialize a TLS-in-TLS connection to host rg �dz4 through an underlying connection to an HTTPS proxy z ssl:�defaultz [�]z:Failed to start TLS (possibly caused by closing transport))(r� r{ r r. r� r ru r� r_ ro r� r� r* �totalr r� r� rb ra r� r} �checkr% r� r� r� r' r r� r( r! r� r� r� � TypeErrorr re r� r� Zconnection_made) rP r� r� r� r Z tls_protor� Z
tls_transportrC r� Ztype_err�msgrQ rQ rR �_start_tls_connection� s� �
�
�
��
��
��(��)������
������
�z"TCPConnector._start_tls_connection�hostsc C s| g }|D ]7}|d }d|v }|rt jnt j}| jr | j|kr q|r)||d ddfn||d f}|�|t jt jd|f� q|S )z�Converts the list of hosts to a list of addr_infos.
The list of hosts is the result of a DNS lookup. The list of
addr_infos is the result of a call to `socket.getaddrinfo()`.
r* rg re r r; )�socket�AF_INET6�AF_INETrX r� � SOCK_STREAM� IPPROTO_TCP)rP r� r� Zhinfor* Zis_ipv6rG �addrrQ rQ rR � _convert_hosts_to_addr_infos� s �z)TCPConnector._convert_hosts_to_addr_infosc
� s� �| � |�}| �|�}|jj}|d usJ �|�d�r!|�d�d }|j}|d us*J �z
| j|||d�I d H } W n tyV }
z|
j d u rKt
|
t j �rK� t
|j|
�|
�d }
~
ww d } | �| �} | r�|rj|jpf|�d�nd }
z| j| j||| |
||d�I d H \}}W n tt j fy� }
z|
} t�| | j� W Y d }
~
q^d }
~
ww |�� r�|r�z
|�|� W ||fS ty� }
z$|�� | js�| j � |� |
} |� d�}|� � }t� | |� W Y d }
~
q^d }
~
ww ||fS | d us�J �| �)Nz..�.)r� )r� r� r� r� r� r r� )!r{ r} r� Zraw_host�endswith�rstripre rt r� r� rb ra r� r r� r� r� r� r� r rY Zpop_addr_infos_interleaver\ r� r� r% r� r� r� r� r� � getpeernameZremove_addr_infos)rP r� r� r� r r� rC r* re r� r� �last_excr� r� Ztranspr� r� Zbad_peerrQ rQ rR rw sp �
��
�� �� �
�� z&TCPConnector._create_direct_connectionc � s �| � |� | �� }| �|�}| j|g |td�I d H \}}|�� r�|r)| �||� tj|_ |j
|_
|j j d d d d�}t
| ||| j�} |�| �I d H }
z�z| j} | d usUJ �| j|| jd� |
�| �I d H } W n tyv |
�� | �� � w d | _zKz6| jdkr�| j}
|
d u r�t| j�j}
t|
j| j | j|
| j d��|s�|j dd d�}|d u r�t d��|� � }W n ty� |�� � w W |s�|�� n|s�|�� w w |s�| �!|�}| j"| j#||||j$|d �I d H W |
�� S | j%|||d
�I d H W |
�� S |
�� w ||fS ) Nr~ )r� r� Zproxy_headers_hash)Zread_until_eofr� �� )�statusr~ r� r� )r� z)Transport does not expose socket instance)r� r� r� r� r� )r� r� )&r� r� r� rw r# r� r� r Z METH_CONNECT�methodr� r� �_replacer� ro �sendrp Zset_response_paramsr� �startr r� r� �reasonr
�phraser" r� �historyr� r� rx �dupr{ r� r� r* r� )rP r� r� r� Zruntime_has_start_tlsr� r� r� rj r Z
proxy_resprk Zrespr~ Zrawsockr� rQ rQ rR rv V s� �
� � � �
��� ����
�
�
� �z%TCPConnector._create_proxy_connection)NNr� )r� r* rN Nr[ )?r\ r] r^ r� r � frozensetr r� �
AddressFamily� AF_UNSPECr2 r� �bytesr r5 r+ r2 r� r r� r ra r� r r- rS r r r� r� r� rG rD rf r r rt r� rr r* r) r r{ r r} r r r r! rc r� r� r� r� r� r� r� Z
BaseTransportr� r� rw rv �
__classcell__rQ rQ ra rR rC � st &������� �
� � �
����������
�$R
���
�
�c
����
�
�)���
�!�������
�+������
�
��
�6�����
�V�
������
�K��� �rC c � e Zd ZdZeedh�B Zdedddfdede d e
e B dB d
e d e d e
jdB d
df� fdd�
Zed
efdd��Zdeded ddd
efdd�Z� ZS )rD a� Unix socket connector.
path - Unix socket path.
keepalive_timeout - (optional) Keep-alive timeout.
force_close - Set to True to force close and do reconnect
after each request (and between redirects).
limit - The total number of simultaneous connections.
limit_per_host - Number of simultaneous connections to one host.
loop - Optional event loop.
ZunixFr� r N�pathr� r� r� r� rl rN c s t � j|||||d� || _d S )N�r� r� r� r� rl )rQ rS �_path�rP r� r� r� r� r� rl ra rQ rR rS � s �
zUnixConnector.__init__c C r� )zPath to unix socket.�r� rV rQ rQ rR r� � r� zUnixConnector.pathr� r� rH r� rF c
� s� �z5t |j|jd�4 I d H � | j�| j| j�I d H \}}W d �I d H W |S 1 I d H s/w Y W |S tyW } z|jd u rJt |t
j �rJ� t | j
|j|�|�d }~ww r� )r. r� r ro Zcreate_unix_connectionr� r� r� r� rb ra r� r& r� r� �rP r� r� r� r� r� r� rQ rQ rR r � s$ ���� � ���z UnixConnector._create_connection�r\ r] r^ r� r r� r r2 r� r� r r� r ra r� rS r� r� r* r r) r r� rQ rQ ra rR rD � sD ���
���������rD c r� )rE a� Named pipe connector.
Only supported by the proactor event loop.
See also: https://docs.python.org/3/library/asyncio-eventloop.html
path - Windows named pipe path.
keepalive_timeout - (optional) Keep-alive timeout.
force_close - Set to True to force close and do reconnect
after each request (and between redirects).
limit - The total number of simultaneous connections.
limit_per_host - Number of simultaneous connections to one host.
loop - Optional event loop.
ZnpipeFr� r Nr� r� r� r� r� rl rN c s6 t � j|||||d� t| jtj�std��|| _d S )Nr� z9Named Pipes only available in proactor loop under windows)rQ rS rb ro ra ZProactorEventLooprx r� r� ra rQ rR rS s ���
zNamedPipeConnector.__init__c C r� )zPath to the named pipe.r� rV rQ rQ rR r� r� zNamedPipeConnector.pathr� r� rH r� rF c
� s� �z:t |j|jd�4 I d H �! | j�| j| j�I d H \}}t�d�I d H W d �I d H n 1 I d H s5w Y W n t yZ } z|j
d u rOt |tj �rO� t
|j|�|�d }~ww tt|�S )Nr� r )r. r� r ro Zcreate_pipe_connectionr� r� ra �sleepr� r� rb r� r r� r r) r� rQ rQ rR r % s$ ���(��
��
z%NamedPipeConnector._create_connectionr� rQ rQ ra rR rE � sD ���
���������rE )ora r� r r� ru rs rW � collectionsr r r �collections.abcr r r r �
contextlibr r< r
� itertoolsr r r
�timer �typesr �typingr r r r r r rY r r r; r r �abcr r Zclient_exceptionsr r r r r! r" r# r$ r% r& r' r( Z client_protor) Z
client_reqrepr* r+ r, r- r. r/ r0 r1 r2 r3 r4 �logr5 rJ r6 r� r: r� � bytearrayr� r5 � ImportErrorr r� ZEMPTY_SCHEMA_SETZHTTP_SCHEMA_SETZ
WS_SCHEMA_SETZHTTP_AND_EMPTY_SCHEMA_SETr r� �__all__�clientrF rG �tracingrH rI r rg rh r� r� rB r" r� r@ rz ry rC rD rE rQ rQ rQ rR �<module> s� 8 (
�
�
X Q0 +7