File: //opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/connector.cpython-38.opt-1.pyc
U
'�7`ا � @ sN d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m
Z
d dl m Z d dl
mZmZ d dlmZ d dlmZ d dlmZmZmZmZmZmZmZm Z 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( d d l)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2 d d
l3m4Z4 d dl5m6Z6m7Z7m8Z8 d dl&m9Z9m:Z:m;Z;m<Z<m=Z=m>Z> d dl?m@Z@ d dlAmBZB d dlCmDZD zd dlEZEeEjFZFW n eGk
�r� dZEeHZFY nX dZIe�r�d dlJmKZK d dl5mLZL d dlMmNZN G dd� d�ZOG dd� d�ZPG dd � d �ZQG d d � d �ZRG d d � d �ZSG d!d"� d"eR�ZTG d#d$� d$eR�ZUG d%d&� d&eR�ZVdS )'� N)� defaultdict�deque)�suppress)� SimpleCookie)�cycle�islice)� monotonic)�
TracebackType)�
TYPE_CHECKING�Any� Awaitable�Callable� DefaultDict�Dict�Iterator�List�Optional�Set�Tuple�Type�Union�cast� )�hdrs�helpers)�AbstractResolver) �ClientConnectionError� ClientConnectorCertificateError�ClientConnectorError�ClientConnectorSSLError�ClientHttpProxyError�ClientProxyConnectionError�ServerFingerprintMismatch� cert_errors�
ssl_errors)�ResponseHandler)�
ClientRequest� Fingerprint�_merge_ssl_params)�PY_36� CeilTimeout�get_running_loop�
is_ip_address�noop�sentinel)� RESPONSES)�EventResultOrError)�DefaultResolver)�
BaseConnector� TCPConnector�
UnixConnector�NamedPipeConnector)�
ClientTimeout)�
ConnectionKey)�Tracec @ s@ e Zd ZdZee dd�dd�Zed�dd�Zdd�d d
�ZdS ) �_DeprecationWaiter��
_awaitable�_awaitedN)� awaitable�returnc C s || _ d| _d S �NFr: )�selfr= � rA �D/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/connector.py�__init__I s z_DeprecationWaiter.__init__�r> c C s d| _ | j�� S �NT)r< r; � __await__�r@ rA rA rB rF M s z _DeprecationWaiter.__await__c C s | j st�dt� d S )NzDConnector.close() is a coroutine, please use await connector.close())r< �warnings�warn�DeprecationWarningrG rA rA rB �__del__Q s
�z_DeprecationWaiter.__del__) �__name__�
__module__� __qualname__� __slots__r r rC rF rK rA rA rA rB r9 F s r9 c @ s� e Zd ZdZdZddeejdd�dd�Ze d�dd �Z
e fe dd
�d d �Z
eejd�d
d��Zeeej d�dd��Zeee d�dd��Zeg df dd�dd�Zdd�dd�Zdd�dd�Zdd�dd�Zeed�d d ��ZdS ) �
ConnectionNr2 r7 )� connector�key�protocol�loopr> c C s< || _ || _|| _|| _g | _|�� r8t�t� d��| _
d S )Nr ) �_key�
_connector�_loop� _protocol�
_callbacks� get_debug� traceback�
extract_stack�sys� _getframe�_source_traceback)r@ rQ rR rS rT rA rA rB rC _ s zConnection.__init__rD c C s d| j � d�S )Nz Connection<�>)rU rG rA rA rB �__repr__o s zConnection.__repr__�� _warningsr> c C s� | j d k r�trd| i}ni }|jd| ��tf|� | j�� r@d S | jj| j| j dd� | dd�}| j d k rt| j |d< | j�
|� d S )N�sourcezUnclosed connection T�� should_closezUnclosed connection)Zclient_connection�message�source_traceback) rX r) rI �ResourceWarningrW � is_closedrV �_releaserU r_ �call_exception_handler)r@ rc �kwargs�contextrA rA rB rK r s
zConnection.__del__c C s t jdtdd� | jS )Nz%connector.loop property is deprecated� )�
stacklevel)rH rI rJ rW rG rA rA rB rT � s �zConnection.loopc C s | j d krd S | j jS �N)rX � transportrG rA rA rB rr � s
zConnection.transportc C s | j S rq )rX rG rA rA rB rS � s zConnection.protocol)�callbackr> c C s |d k r| j �|� d S rq )rY �append)r@ rs rA rA rB � add_callback� s zConnection.add_callbackc
C s> | j d d � g }| _ |D ] }tt�� |� W 5 Q R X qd S rq )rY r � Exception)r@ Z callbacks�cbrA rA rB �_notify_release� s
zConnection._notify_releasec C s2 | � � | jd k r.| jj| j| jdd� d | _d S )NTre )rx rX rV rk rU rG rA rA rB �close� s
zConnection.closec C s6 | � � | jd k r2| jj| j| j| jjd� d | _d S )Nre )rx rX rV rk rU rf rG rA rA rB �release� s
�zConnection.releasec C s | j d kp| j �� S rq )rX � is_connectedrG rA rA rB �closed� s zConnection.closed)rL rM rN r_ �
_transportr% �asyncio�AbstractEventLooprC �strra rH r rK �propertyrT r � Transportrr rS r
ru rx ry rz �boolr| rA rA rA rB rP Z s, � rP c @ s e Zd ZdZdd�dd�ZdS )�_TransportPlaceholderz0 placeholder for BaseConnector.connect function NrD c C s d S rq rA rG rA rA rB ry � s z_TransportPlaceholder.close)rL rM rN �__doc__ry rA rA rA rB r� � s r� c @ s� e Zd ZdZdZdZdZedddddd�ee de
f e e e e e
ej dd �d
d �Zefedd �d
d�Zd d�dd�Zedd�dd�Zd d�dd�ZdDe
ee e
e e
e dd�dd�Zee d�dd��Z ee d�d d ��Z ee d�d d ��Z dd�d d!�Z d"e dd#�d$d%�Z!dd�d&d'�Z"e#d d�d(d)�Z$dd�d*d+�Z%ee d�d,d-��Z&d"e d.�d/d0�Z'd1e(d2 d3e)d4�d5d6�Z*d"e
e d.�d7d8�Z+dd�d9d:�Z,d"e dd;�d<d=�Z-dd>�d"e e dd?�d@dA�Z.d1e(d2 d3e d4�dBdC�Z/dS )Er2 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.
loop - Optional event loop.
TNg @F�d r ��keepalive_timeout� force_close�limit�limit_per_host�enable_cleanup_closedrT )r� r� r� r� r� rT r> c C s� |r |d k r*|t k r*td��n |t kr*d}t|�}d| _|�� rRt�t�d��| _ i | _
|| _ || _ t
� | _tt
�| _tt|�| _|| _tt�| _|| _tjt|d�| _t � | _ d | _ d | _ | | _ g | _!| �"� d S )Nz6keepalive_timeout cannot be set if force_close is Trueg .@Fr �rT )#r. �
ValueErrorr+ �_closedrZ r[ r\ r] r^ r_ �_conns�_limit�_limit_per_host�set� _acquiredr �_acquired_per_hostr �float�_keepalive_timeout� _force_closer �_waitersrW � functools�partialr% �_factoryr Zcookies�_cleanup_handle�_cleanup_closed_handle�_cleanup_closed_disabled�_cleanup_closed_transports�_cleanup_closed)r@ r� r� r� r� r� rT rA rA rB rC � s< ���
zBaseConnector.__init__rb c C s� | j r
d S | jsd S dd� | j�� D �}| �� tr>d| i}ni }|jd| ��tf|� | |dd�}| jd k rx| j|d< | j� |� d S )Nc S s g | ] }t |��qS rA )�repr)�.0�crA rA rB �
<listcomp> s z)BaseConnector.__del__.<locals>.<listcomp>rd zUnclosed connector zUnclosed connector)rQ � connectionsrg rh )
r� r� �values�_closer) rI ri r_ rW rl )r@ rc �connsrm rn rA rA rB rK s"
�
zBaseConnector.__del__rD c C s t �dt� | S )NzH"witn Connector():" is deprecated, use "async with Connector():" instead)rH rI rJ rG rA rA rB � __enter__ s
�zBaseConnector.__enter__)�excr> c G s | � � d S rq �ry )r@ r� rA rA rB �__exit__% s zBaseConnector.__exit__c � s | S rq rA rG rA rA rB �
__aenter__( s zBaseConnector.__aenter__)�exc_type� exc_value�
exc_tracebackr> c � s | � � I d H d S rq r� )r@ r� r� r� rA rA rB � __aexit__+ s zBaseConnector.__aexit__c C s | j S )z1Ultimately close connection on releasing if True.)r� rG rA rA rB r� 3 s zBaseConnector.force_closec C s | j S )z�The total number for simultaneous connections.
If limit is 0 the connector has no limit.
The default limit size is 100.
)r� rG rA rA rB r� 8 s zBaseConnector.limitc C s | j S )z�The limit_per_host for simultaneous connections
to the same endpoint.
Endpoints are the same if they are have equal
(host, port, is_ssl) triple.
)r� rG rA rA rB r� A s z BaseConnector.limit_per_hostc C s | j r| j �� d| _ | j�� }| j}| jr�i }|| }| j�� D ]�\}}g }|D ]z\}} |�� r�| | dk r�|j}
|� � |j
r�| j s�| j �
|
� q�|�
|| f� qR|j}
|� � |j
rR| j sR| j �
|
� qR|rB|||< qB|| _| jr�t�| d|| j�| _ dS )zCleanup unused transports.Nr �_cleanup)r� �cancelrW �timer� r� �itemsr{ rr ry �is_sslr� r� rt r �weakref_handle) r@ Znow�timeoutr� ZdeadlinerR r� Zalive�protoZuse_timerr rA rA rB r� L s@
�zBaseConnector._cleanupr7 )rR �valr> c C s4 | j }||krd S || }|�|� |s0| j |= d S rq )r� �remove)r@ rR r� Zacquired_per_hostr� rA rA rB �_drop_acquired_per_hostu s
z%BaseConnector._drop_acquired_per_hostc C sR | j r| j �� | jD ]}|dk r|�� qg | _| jsNt�| d| j| j�| _ dS )z}Double confirmation for transport close.
Some broken ssl servers may leave socket open without proper close.
Nr� ) r� r� r� �abortr� r r� �_cleanup_closed_periodrW )r@ rr rA rA rB r� � s
�z BaseConnector._cleanup_closedc C s | � � tt� �S )z Close all opened transports.)r� r9 r- rG rA rA rB ry � s zBaseConnector.closec C s� | j r
d S d| _ z�| j� � r$W �~d S | jr4| j�
� | jrD| j�
� | j� � D ]}|D ]\}}|� � qVqN| jD ] }|� � qp| jD ]}|d k r�|�
� q�W 5 | j�� | j�� | j�� d | _| j�� d | _X d S rE )r� r� �clearr� r� r� r� r� rW rj r� r� ry r� )r@ �datar� �t0rr rA rA rB r� � s0
zBaseConnector._closec C s | j S )z;Is connector closed.
A readonly property.
)r� rG rA rA rB r| � s zBaseConnector.closed�rR r> c C s� | j rV| j t| j� }| jr�|dkr�|| jkr�| j�|�}|dk sFt�| jt|� }n<| jr�|| jkr�| j�|�}|dk s~t�| jt|� }nd}|S )z�
Return number of available connections taking into account
the limit, limit_per_host and the connection key.
If it returns less than 1 means that there is no connections
availables.
r Nr )r� �lenr� r� r� �get�AssertionError)r@ rR � availableZacquiredrA rA rB �_available_connections� s" ��� z$BaseConnector._available_connectionsr& r8 r6 ��req�tracesr� r> c � sb |j }| �|�}|dks$|| jk�r| j�� }| j| �|� |rZ|D ]}|�� I dH qFznz|I dH W nZ tk
r� } z<|| jkr�z| j| �|� W n t k
r� Y nX |�W 5 d}~X Y nX W 5 || jkr�| j| s�| j|= X |�r|D ]}|�
� I dH q�| � |�} | dk�rt t
t� �}
| j�|
� | j| �|
� |�rb|D ]}|�� I dH �qLz0| �|||�I dH } | j�r�| �� td��W n@ tk
�r� | j�s�| j�|
� | �||
� | �� � Y n"X | j�s�| j�|
� | �||
� |�r6|D ]}|�� I dH �q�n |�r6|D ]}|�� I dH �q | j�| � | j| �| � t| || | j�S )z'Get from pool or create new connection.r NzConnector is closed.) �connection_keyr� r� rW Z
create_futurert Z send_connection_queued_start�
BaseExceptionr� r� Zsend_connection_queued_end�_getr r% r� r� �addr� Z send_connection_create_start�_create_connectionr� ry r r� �_release_waiterZsend_connection_create_endZsend_connection_reuseconnrP ) r@ r� r� r� rR r� �fut�trace�er� Z placeholderrA rA rB �connect� sj
zBaseConnector.connectc C s� z| j | }W n tk
r$ Y d S X | j�� }|r�|�� \}}|�� r�|| | jkr~|j}|�� |j r�| j
s�| j � |� q�|s�| j |= |S q0|j}|�� |j r0| j
s0| j � |� q0| j |= d S rq )
r� �KeyErrorrW r� �popr{ r� rr ry r� r� r� rt )r@ rR r� �t1r� r� rr rA rA rB r� 2 s,
zBaseConnector._getc C sp | j s
dS t| j �� �}t�|� |D ]D}| �|�dk r:q&| j | }|r&|�� }|�� sD|�d� dS qDq&dS )z�
Iterates over all waiters till found one that is not finsihed and
belongs to a host that has available connections.
Nr ) r� �list�keys�randomZshuffler� �popleftZdoneZ
set_result)r@ ZqueuesrR �waiters�waiterrA rA rB r� Q s
z BaseConnector._release_waiter)rR r� r> c C sH | j r
d S z | j�|� | �||� W n tk
r: Y n
X | �� d S rq )r� r� r� r� r� r� )r@ rR r� rA rA rB �_release_acquiredi s z BaseConnector._release_acquiredre )rR rS rf r> c C s� | j r
d S | �||� | jr d}|s*|jrR|j}|�� |jr�| js�| j� |� nV| j
� |�}|d krtg }| j
|< |� || j �
� f� | jd kr�t�| d| j| j �| _d S )NTr� )r� r� r� rf rr ry r� r� r� rt r� r� rW r� r� r r� r� )r@ rR rS rf rr r� rA rA rB rk x s*
�zBaseConnector._releasec � s
t � �d S rq )�NotImplementedError)r@ r� r� r� rA rA rB r� � s z BaseConnector._create_connection)NNN)0rL rM rN r� r� r_ r� r. r �objectr� r� �intr r~ r rC rH r rK r� r� r� r r� r r� r� r� r� r� r� r% r� r� r ry r� r| r� r rP r� r� r� r� rk r� rA rA rA rB r2 � s� � � 7 �
�
* � %" � M �� " �r2 c @ s� e Zd Zdee dd�dd�Zeed�dd�Ze e
e f e e
e
ef dd�d d
�Ze e
e f dd �d d
�Zdd�dd�Ze e
e f e e
e
ef d �dd�Ze e
e f ed �dd�ZdS )�_DNSCacheTableN)�ttlr> c C s i | _ i | _|| _d S rq )� _addrs_rr� _timestamps�_ttl)r@ r� rA rA rB rC � s �z_DNSCacheTable.__init__)�hostr> c C s
|| j kS rq )r� )r@ r� rA rA rB � __contains__� s z_DNSCacheTable.__contains__)rR �addrsr> c C s, t |�t|�f| j|< | jr(t� | j|< d S rq )r r� r� r� r r� )r@ rR r� rA rA rB r� � s z_DNSCacheTable.addr� c C s& | j �|d � | jr"| j�|d � d S rq )r� r� r� r� �r@ rR rA rA rB r� � s z_DNSCacheTable.removerD c C s | j �� | j�� d S rq )r� r� r� rG rA rA rB r� � s
z_DNSCacheTable.clearc C s( | j | \}}tt||��}t|� |S rq )r� r� r �next)r@ rR rT Zlengthr� rA rA rB �
next_addrs� s z_DNSCacheTable.next_addrsc C s$ | j d krdS | j| | j t� k S r? )r� r� r r� rA rA rB �expired� s
z_DNSCacheTable.expired)N)rL rM rN r r� rC r� r� r� r r� r� r r r r� r� r� r� r� rA rA rA rB r� � s &$r� c s� e Zd ZdZdddddddddedddddd�eee eee eee e
dee e f ee e
ef ee e
deef eeeeeej d�� fd d
�Zed d �� fd d
� Zeed �dd��Zeed �dd��Zd0ee
ee dd�dd�Zd1e
eeed eee
e f d�dd�Z ded de d�d d �Z e e!�"d�ee d �d d ���Z#dee d!�d"d#�Z$ded$ d!�d%d&�Z%e&d'�e dde'e( e e ej)e f d(�d)d*�Z*e&d'�ded de'e( e ej)e f d+�d,d-�Z+ded de ej)e f d�d.d/�Z,� Z-S )2r3 a/ 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/Transport_Layer_Security#Certificate_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.
loop - Optional event loop.
TN�
r Fr� )�
verify_ssl� fingerprint�
use_dns_cache�
ttl_dns_cache�family� ssl_context�ssl�
local_addr�resolverr� r� r� r� r� rT c sj t � j|
| | |
||d� t||||�| _| d kr<t| jd�} | | _|| _t|d�| _ i | _
|| _ || _ d S )Nr� r� )r� )
�superrC r( �_sslr1 rW � _resolver�_use_dns_cacher� �
_cached_hosts�_throttle_dns_events�_family� _local_addr)r@ r� r� r� r� r� r� r� r� r� r� r� r� r� r� rT �� __class__rA rB rC � s$ � �zTCPConnector.__init__rD c s" | j �� D ] }|�� q
t� �� S )z Close all ongoing DNS calls.)r� r� r� r� ry )r@ Zevr rA rB ry
s
zTCPConnector.closec C s | j S )zSocket family like AF_INET.)r� rG rA rA rB r� s zTCPConnector.familyc C s | j S )z%True if local DNS caching is enabled.)r� rG rA rA rB r� s zTCPConnector.use_dns_cache)r� �portr> c C sJ |dk r"|dk r"| j �||f� n$|dk s2|dk r<td��n
| j �� dS )z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)r� r� r� r� )r@ r� r rA rA rB �clear_dns_cache s
z TCPConnector.clear_dns_cacher8 )r� r r� r> c
� s t |�r |||| jddd�gS | js~|rB|D ]}|�|�I d H q,| jj||| jd�I d H }|rz|D ]}|�|�I d H qd|S ||f}|| jkr�| j�|�s�| j� |�}|r�|D ]}|�
|�I d H q�|S || j k�r| j | }|r�|D ]}|�
|�I d H q�|� � I d H n�t
| j�| j |< |�r@|D ]}|�|�I d H �q(z�z~|�rf|D ]}|�|�I d H �qN| jj||| jd�I d H } |�r�|D ]}|�|�I d H �q�| j�|| � | j | �� W n8 tk
�r� }
z| j | j|
d� � W 5 d }
~
X Y nX W 5 | j �|� X | j� |�S )Nr )�hostnamer� r r� r� �flags)r� )r� )r, r� r� Zsend_dns_resolvehost_startr� ZresolveZsend_dns_resolvehost_endr� r� r� Zsend_dns_cache_hitr� �waitr0 rW Zsend_dns_cache_missr� r� r� r� ) r@ r� r r� r� �resrR �result�eventr� r� rA rA rB �
_resolve_host& sd ��
zTCPConnector._resolve_hostr& r6 r� c � s< |j r | �|||�I dH \}}n| �|||�I dH \}}|S )zcCreate connection.
Has same keyword arguments as BaseEventLoop.create_connection.
N)�proxy�_create_proxy_connection�_create_direct_connection)r@ r� r� r� �_r� rA rA rB r� r s z TCPConnector._create_connection)�verifiedr> c
C s� | r t �� S t �t j�}| jt jO _| jt jO _z| jt jO _W n2 tk
r~ } zt �
d� |�� W 5 d }~X Y nX |� � |S d S )Nz�{!s}: The Python interpreter is compiled against OpenSSL < 1.0.0. Ref: https://docs.python.org/3/library/ssl.html#ssl.OP_NO_COMPRESSION)
r� Zcreate_default_context�
SSLContextZPROTOCOL_SSLv23�optionsZ OP_NO_SSLv2Z OP_NO_SSLv3ZOP_NO_COMPRESSION�AttributeErrorrH rI �formatZset_default_verify_paths)r �
sslcontextZattr_errrA rA rB �_make_ssl_context� s ��z TCPConnector._make_ssl_context)r� r> c C sz |� � rrtdkrtd��|j}t|tj�r.|S |dk r@| �d�S | j}t|tj�rV|S |dk rh| �d�S | �d�S dS dS )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.FT)r� r� � RuntimeError�
isinstancer r r� )r@ r� r rA rA rB �_get_ssl_context� s
z TCPConnector._get_ssl_contextr' c C s, |j }t|t�r|S | j}t|t�r(|S d S rq )r� r r' r� )r@ r� ZretrA rA rB �_get_fingerprint� s
z TCPConnector._get_fingerprint�� client_error)�argsr� r� r rm r> c
� s� z8t |j��$ | jj||�I d H W 5 Q R � W S Q R X W n� tk
rh } zt|j|�|�W 5 d }~X Y n^ tk
r� } zt|j|�|�W 5 d }~X Y n0 t k
r� } z||j|�|�W 5 d }~X Y nX d S rq )
r* � sock_connectrW Zcreate_connectionr# r r� r$ r �OSError)r@ r� r� r r rm r� rA rA rB �_wrap_create_connection� s , z$TCPConnector._wrap_create_connection)r� r� r� r r> c � s� | � |�}| �|�}|jj}|d k s(t�|j}|d k s:t�tj| j|||d�| j d�} zt�
| �I d H }
W n` tj k
r� dd d�dd�} | � | � � Y n0 t
k
r� } zt|j| �| �W 5 d } ~ X Y nX d }
|
D �]
}|d }|d }zN| j| j|||||d |d
|d |�r |d nd | j||d
� I d H \}}W n0 tk
�rh } z| }
W Y �q�W 5 d } ~ X Y nX |�� �r�|�r�z|�|� W nL tk
�r� } z,|�� | j�s�| j�|� | }
W Y �q�W 5 d } ~ X Y nX ||f S |
d k �s�t�|
�d S )N)r� r� z$asyncio.Future[List[Dict[str, Any]]])r� r> c S s$ t ttj�� | �� W 5 Q R X d S rq )r rv r~ �CancelledErrorr )r� rA rA rB �drop_exception� s z>TCPConnector._create_direct_connection.<locals>.drop_exceptionr� r r� r� r r ) r� r� r� r� r �server_hostnamer� r� r )r r �urlZraw_hostr� r r~ Z
ensure_futurer rW Zshieldr! Zadd_done_callbackr r r� r r� r r� �checkr" ry r� r� rt )r@ r� r� r� r r r� r� r Z
host_resolvedZhostsr" r� �last_excZhinfoZtranspr� rA rA rB r � sh
�
� z&TCPConnector._create_direct_connectionc � s* i }|j d k r|j }|jtj |tj< |j}|d k s8t�ttj|||j| j |j
d�}| j |g |t d�I d H \}}|�
� |j�tjd �} | d k r�|�� s�| |jtj< n | |jtj< |�� �r"| �|�}
tj|_|j|_tj|jd d d d�} t| | || j �} |�| �I d H }
�z
z0| j }|d k �s$t�|� � |
� | �I d H }W n( t k
�rf |
�� | �� � Y n�X d | _ d | _ zp|j!dk�r�|j"}|d k�r�t#|j! d }t$|
j%|j&|j!||jd��|j'dd d�}|d k�r�t(d ��|�)� }W 5 |�� X | j*| j+||
||j,|d
�I d H \}}W 5 |
�� X ||fS ) N)�headers�authrT r� r )r �
proxy_authZproxy_headers_hash�� r )�statusrg r' Zsocket)�defaultz)Transport does not expose socket instance)r� r� Zsockr# r� )-Z
proxy_headersr' r ZHOSTr r� r& ZMETH_GETr) rW r� r r! r� r� Z
AUTHORIZATIONr� ZPROXY_AUTHORIZATIONr Z METH_CONNECT�methodr$ �attrZevolver� rP �sendry rX Zset_response_params�startr� r} r+ �reasonr/ r Z request_info�historyZget_extra_infor �dupr r� r� )r@ r� r� r� r' r$ Z proxy_reqrr r� r( r rR ZconnZ
proxy_resprS Zresprg ZrawsockrA rA rB r
s�
�
�
�
�
�
z%TCPConnector._create_proxy_connection)NN)N).rL rM rN r� r. r� r �bytesr� r r r' r r� r r� r� r~ r rC r ry r� r� r� r r r r r r% r� � staticmethodr� � lru_cacher r r r r rv r� r r r
�
__classcell__rA rA r rB r3 � s� � �) � � �
� M � !� � � � M �r3 c sx e Zd ZdZdedddfeeeee df e
e
e e j
dd�� fdd�
Zeed �d
d ��Zd ed
ded�dd�Z� ZS )r4 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.
Fr� r N��pathr� r� r� r� rT r> c s t � j|||||d� || _d S )N�r� r� r� r� rT )r� rC �_path�r@ r9 r� r� r� r� rT r rA rB rC � s �zUnixConnector.__init__rD c C s | j S )zPath to unix socket.�r; rG rA rA rB r9 � s zUnixConnector.pathr& r8 r6 r� c
� sr z6t |j��" | j�| j| j�I d H \}}W 5 Q R X W n0 tk
rf } zt|j|�|�W 5 d }~X Y nX t t
|�S rq ) r* r rW Zcreate_unix_connectionr� r; r r r� r r% �r@ r� r� r� r r� r� rA rA rB r� � s � z UnixConnector._create_connection�rL rM rN r� r. r� r� r r� r� r� r r~ r rC r� r9 r r% r� r7 rA rA r rB r4 � s, � � �r4 c sx e Zd ZdZdedddfeeeee df e
e
e e j
dd�� fdd�
Zeed �d
d ��Zd ed
ded�dd�Z� ZS )r5 a Named pipe connector.
Only supported by the proactor event loop.
See also: https://docs.python.org/3.7/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.
Fr� r Nr8 c s6 t � j|||||d� t| jtj�s,td��|| _d S )Nr: z9Named Pipes only available in proactor loop under windows)r� rC r rW r~ ZProactorEventLoopr r; r< r rA rB rC � s ��zNamedPipeConnector.__init__rD c C s | j S )zPath to the named pipe.r= rG rA rA rB r9 � s zNamedPipeConnector.pathr& r8 r6 r� c
� s� zFt |j��2 | j�| j| j�I d H \}}t�d�I d H W 5 Q R X W n0 tk
rv } zt |j
|�|�W 5 d }~X Y nX t t |�S )Nr )
r* r rW Zcreate_pipe_connectionr� r; r~ �sleepr r r� r r% r> rA rA rB r� � s � z%NamedPipeConnector._create_connectionr? rA rA r rB r5 � s, � � �r5 )Wr~ r� r� r] r[ rH � collectionsr r �
contextlibr Z http.cookiesr � itertoolsr r r� r �typesr �typingr
r r r
r r r r r r r r r r r. � r r �abcr Zclient_exceptionsr r r r r r! r" r# r$ Z client_protor% Z
client_reqrepr& r' r( r) r* r+ r, r- r. Zhttpr/ �locksr0 r� r1 r� r � ImportErrorr� �__all__Zclientr6 r7 �tracingr8 r9 rP r� r2 r� r3 r4 r5 rA rA rA rB �<module> s^ @ ,
Z g) <1