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 dZIerd dlJmKZK d dl5mLZL d dlMmNZN G dd dZOG dd dZPG dd d ZQG d d d ZRG d d d ZSG d!d" d"eRZTG d#d$ d$eRZUG d%d& d&eRZVdS )' N) defaultdictdeque)suppress) SimpleCookie)cycleislice) monotonic)
TracebackType)
TYPE_CHECKINGAny AwaitableCallable DefaultDictDictIteratorListOptionalSetTupleTypeUnioncast )hdrshelpers)AbstractResolver) ClientConnectionError ClientConnectorCertificateErrorClientConnectorErrorClientConnectorSSLErrorClientHttpProxyErrorClientProxyConnectionErrorServerFingerprintMismatch cert_errors
ssl_errors)ResponseHandler)
ClientRequest Fingerprint_merge_ssl_params)PY_36 CeilTimeoutget_running_loop
is_ip_addressnoopsentinel) RESPONSES)EventResultOrError)DefaultResolver)
BaseConnector TCPConnector
UnixConnectorNamedPipeConnector)
ClientTimeout)
ConnectionKey)Tracec @ s@ e Zd ZdZee ddddZedddZddd d
ZdS ) _DeprecationWaiter
_awaitable_awaitedN) awaitablereturnc 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 stdt d S )NzDConnector.close() is a coroutine, please use await connector.close())r< warningswarnDeprecationWarningrG 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 ZdZdZddeejddddZe ddd Z
e fe dd
d d Z
eejdd
dZeeej dddZeee dddZeg df ddddZddddZddddZddddZeedd d ZdS )
ConnectionNr2 r7 ) connectorkeyprotocolloopr> c C s< || _ || _|| _|| _g | _| r8tt d| _
d S )Nr ) _key
_connector_loop _protocol
_callbacks get_debug traceback
extract_stacksys _getframe_source_traceback)r@ rQ rR rS rT rA rA rB rC _ s zConnection.__init__rD c C s d| j dS )Nz Connection<>)rU rG rA rA rB __repr__o s zConnection.__repr__ _warningsr> c C s | j d k rtrd| i}ni }|jd| tf| | j r@d S | jj| j| j dd | dd}| j d k rt| j |d< | j
| d S )NsourcezUnclosed connection T should_closezUnclosed connection)Zclient_connectionmessagesource_traceback) rX r) rI ResourceWarningrW is_closedrV _releaserU r_ call_exception_handler)r@ rc kwargscontextrA 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 callbackscbrA 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% asyncioAbstractEventLooprC 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 ZdZddddZdS )_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 ZdZdZdZdZeddddddee de
f e e e e e
ej dd d
d Zefedd d
dZd dddZeddddZd dddZdDe
ee e
e e
e ddddZee dddZ ee dd d Z ee dd d Z ddd d!Z d"e dd#d$d%Z!ddd&d'Z"e#d dd(d)Z$ddd*d+Z%ee dd,d-Z&d"e d.d/d0Z'd1e(d2 d3e)d4d5d6Z*d"e
e d.d7d8Z+ddd9d:Z,d"e dd;d<d=Z-dd>d"e e dd?d@dAZ.d1e(d2 d3e d4dBdCZ/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 @Fd r keepalive_timeout force_closelimitlimit_per_hostenable_cleanup_closedrT )r r r r r rT r> c C s |r |d k r*|t k r*tdn |t kr*d}t|}d| _| rRttd| _ 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_hostset _acquiredr _acquired_per_hostr float_keepalive_timeout _force_closer _waitersrW functoolspartialr% _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).0crA 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 )zThe 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 )zThe 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}| jri }|| }| 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|| _| jrt| d|| j| _ dS )zCleanup unused transports.Nr _cleanup)r cancelrW timer r itemsr{ rr ry is_sslr r rt r weakref_handle) r@ Znowtimeoutr ZdeadlinerR r ZaliveprotoZuse_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|
qW 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.closedrR 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 getAssertionError)r@ rR availableZacquiredrA rA rB _available_connections s" z$BaseConnector._available_connectionsr& r8 r6 reqtracesr r> c sb |j }| |}|dks$|| jkr| j }| j| | |rZ|D ]}| I dH qFznz|I dH W nZ tk
r } z<|| jkrz| 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| |} | dkrt t
t }
| j|
| j| |
|rb|D ]}| I dH qLz0| |||I dH } | jr| tdW n@ tk
r | js| j|
| ||
| Y n"X | js| j|
| ||
|r6|D ]}| I dH qn |r6|D ]}| I dH q | j| | j| | t| || | jS )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 futtraceer 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 listkeysrandomZshuffler popleftZdoneZ
set_result)r@ ZqueuesrR waitersZwaiterrA 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 krt| 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 ddddZeedddZe e
e f e e
e
ef ddd d
Ze e
e f dd d d
ZddddZe e
e f e e
e
ef d ddZe e
e f ed ddZdS )_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 ZdZdddddddddeddddddeee eee eee e
dee e f ee e
ef ee e
deef eeeeeej d fd d
Zed d fd d
Zeed ddZeed ddZd0ee
ee ddddZd1e
eeed eee
e f dddZ ded de dd d Z e e!"dee 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 dd.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_cachefamily ssl_contextssl
local_addrresolverr 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<tdn
| 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 |||| jdddgS | js~|rB|D ]}||I d H q,| jj||| jdI d H }|rz|D ]}||I d H qd|S ||f}|| jkr| j|s| j |}|r|D ]}|
|I d H q|S || j kr| j | }|r|D ]}|
|I d H q| I d H nt
| j| j |< |r@|D ]}||I d H q(zz~|rf|D ]}||I d H qN| jj||| jdI 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 resultZeventr 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_SSLv23ZoptionsZ OP_NO_SSLv2Z OP_NO_SSLv3ZOP_NO_COMPRESSIONAttributeErrorrH 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|tjr.|S |dk r@| dS | j}t|tjrV|S |dk rh| dS | dS 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|tr|S | j}t|tr(|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:ttj| j|||d| j d} zt
| I d H }
W n` tj k
r dd ddd} | | 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 qW 5 d } ~ X Y nX | r|rz|| W nL tk
r } z,| | js| j| | }
W Y qW 5 d } ~ X Y nX ||f S |
d k st|
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 Zcheckr" 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 s8tttj|||j| j |j
d}| j |g |t dI d H \}}|
|jtjd } | 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 nX d | _ d | _ zp|j!dkr|j"}|d krt#|j! d }t$|
j%|j&|j!||jd|j'dd d}|d krt(d |) }W 5 | X | j*| j+||
||j,|d
I d H \}}W 5 |
X ||fS ) N)headersauthrT 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_CONNECTmethodr! attrZevolver rP sendry rX Zset_response_paramsstartr r} r' reasonr/ r Z request_infohistoryZget_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
dedddZ 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 Npathr r r r rT r> c s t j|||||d || _d S )Nr r r r rT )r rC _pathr@ r5 r r r r rT r rA rB rC s zUnixConnector.__init__rD c C s | j S )zPath to unix socket.r7 rG rA rA rB r5 s zUnixConnector.pathr& r8 r6 r c
sr z6t |j" | j| j| jI 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 r7 r r r r r% r@ r r r r
r r rA rA rB r s z UnixConnector._create_connectionrL rM rN r r. r r r r r r r r~ r rC r r5 r r% r r3 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
dedddZ 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 Nr4 c s6 t j|||||d t| jtjs,td|| _d S )Nr6 z9Named Pipes only available in proactor loop under windows)r rC r rW r~ ZProactorEventLoopr r7 r8 r rA rB rC s zNamedPipeConnector.__init__rD c C s | j S )zPath to the named pipe.r9 rG rA rA rB r5 s zNamedPipeConnector.pathr& r8 r6 r c
s zFt |j2 | j| j| jI d H \}}tdI 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 r7 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/ Zlocksr0 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