/2] 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/m0Z0m1Z1m2Z2m3Z3 d d
l4m5Z5 d dl6m7Z7m8Z8m9Z9 d dl&m:Z:m;Z;mZ>m?Z? d dl@mAZA d dlBmCZC d dlDmEZE d dlFZFeFjG ZGn# eH$ r dZFeIZGY nw xY wdZJerd dlKmLZL d dl6mMZM d dlNmOZO G d d ZP G d d ZQ G d d ZR G d d ZS G d d ZT G d! d"eS ZU G d# d$eS ZV G d% d&eS ZWdS )' N) defaultdictdeque)suppress) SimpleCookie)cycleislice) monotonic)
TracebackType)
TYPE_CHECKINGAny AwaitableCallable DefaultDictDictIteratorListOptionalSetTupleTypeUnioncast )hdrshelpers)AbstractResolver)
ClientConnectionError ClientConnectorCertificateErrorClientConnectorErrorClientConnectorSSLErrorClientHttpProxyErrorClientProxyConnectionErrorServerFingerprintMismatchUnixClientConnectorError cert_errors
ssl_errors)ResponseHandler)
ClientRequest Fingerprint_merge_ssl_params)PY_36 ceil_timeoutget_running_loop
is_ip_addressnoopsentinel) RESPONSES)EventResultOrError)DefaultResolver)
BaseConnector TCPConnector
UnixConnectorNamedPipeConnector)
ClientTimeout)
ConnectionKey)Tracec B e Zd ZdZdee ddfdZdefdZddZdS ) _DeprecationWaiter
_awaitable_awaited awaitablereturnNc " || _ d| _ d S NFr= )selfr@ s s/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib64/python3.11/site-packages/aiohttp/connector.py__init__z_DeprecationWaiter.__init__Q s #
c B d| _ | j S NT)r? r> __await__rD s rE rJ z _DeprecationWaiter.__await__U s
((***rG c L | j s t j dt d S d S )NzDConnector.close() is a coroutine, please use await connector.close())r? warningswarnDeprecationWarningrK s rE __del__z_DeprecationWaiter.__del__Y s< } M5"
rG rA N) __name__
__module__ __qualname__ __slots__r
r rF rJ rP rG rE r< r< N sn *I )C. T +3 + + + + rG r< c
0 e Zd ZdZdZdddddedej ddf
d Zde fd
Z
e fd e ddfd Z
edej fd
Zedeej fd Zedee fd Zdeg df ddfdZddZddZddZedefd ZdS )
ConnectionN connectorr4 keyr9 protocollooprA c || _ || _ || _ || _ g | _ | r-t
j t j d | _
d S d S )Nr ) _key
_connector_loop _protocol
_callbacks get_debug traceback
extract_stacksys _getframe_source_traceback)rD rY rZ r[ r\ s rE rF zConnection.__init__g si #
4<46 >> O%.%)r^ rK s rE __repr__zConnection.__repr__w s )TY))))rG _warningsc F | j t rd| i}ni } |j d| t fi | | j rd S | j | j | j d | dd}| j
| j |d< | j
| d S d S )NsourcezUnclosed connection T should_closezUnclosed connection)client_connectionmessagesource_traceback) ra r+ rN ResourceWarningr` is_closedr_ _releaser^ rh call_exception_handler)rD rl kwargscontexts rE rP zConnection.__del__z s > %
"D) IN:$::O V Vv V V Vz##%%
O $ $TYT $ R R R,0=RSSG%1.2.D*+ J - -g 6 6 6 6 6 & %rG c H t j dt d | j S )Nz%connector.loop property is deprecated )
stacklevel)rM rN rO r` rK s rE r\ zConnection.loop s.
35GTU
zrG c , | j d S | j j S N)ra transportrK s rE r zConnection.transport s > !4~''rG c | j S r~ )ra rK s rE r[ zConnection.protocol s
~ rG callbackc B | | j | d S d S r~ )rb append)rD r s rE add_callbackzConnection.add_callback s, O " "8 , , , , , rG c | j d d g c}| _ |D ]8}t t 5 | d d d n # 1 swxY w Y 9d S r~ )rb r Exception)rD callbackscbs rE _notify_releasezConnection._notify_release s %)_QQQ%7" 4? B)$$
s AA A c | | j 0| j | j | j d d | _ d S d S )NTro )r ra r_ rv r^ rK s rE closezConnection.close sP > % O $ $TYT $ R R R !DNNN & %rG c | | j :| j | j | j | j j d | _ d S d S )Nro )r ra r_ rv r^ rp rK s rE releasezConnection.release s` > % O $ $ 4>8S
%
"DNNN & %rG c H | j d u p| j S r~ )ra is_connectedrK s rE closedzConnection.closed s% ~%JT^-H-H-J-J)JJrG rQ )rR rS rT rh
_transportr' asyncioAbstractEventLooprF strrk rM r rP propertyr\ r Transportr r[ r r r r r boolr rV rG rE rX rX b s JO"O O " O
' O
O O O O *# * * * * (0 7 7 7D 7 7 7 7" g/ X (8G$56 ( ( ( X(
(?3 X -Xb$h%7 -D - - - - " " " "" " " " K K K K XK K KrG rX c e Zd ZdZddZdS )_TransportPlaceholderz.placeholder for BaseConnector.connect functionrA Nc d S r~ rV rK s rE r z_TransportPlaceholder.close s rG rQ )rR rS rT __doc__r rV rG rE r r s. 88
rG r c ` e Zd ZdZdZdZdZeddddddd ee de
f d
e d e d e d
e de
ej ddfdZefdeddfdZd8dZdeddfdZd8dZ d9de
ee de
e de
e ddfdZede fd Z ede fd Z ede fd Z d:d Z d d d!e ddfd"Z!d:d#Z"de#d fd$Z$d:d%Z%ede fd& Z&d d de fd'Z'd(d)d*e(d+ d,d-de)fd.Z*d d de
e fd/Z+d:d0Z,d d d1e ddfd2Z-dd3d d d4e d5e ddfd6Z.d(d)d*e(d+ d,d-de fd7Z/dS );r4 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_closedr\ r r r r r r\ rA c |r||t urt d n |t u rd}t | }d| _ | r+t j t j d | _ i | _
|| _ || _ t | _ t t | _ t# t$ | | _ || _ t t* | _ || _ t1 j t4 | | _ t9 | _ d | _ d | _ | | _ g | _! | " d S )Nz6keepalive_timeout cannot be set if force_close is Trueg .@Fr r\ )#r0
ValueErrorr- _closedrc rd re rf rg rh _conns_limit_limit_per_hostset _acquiredr _acquired_per_hostr float_keepalive_timeout _force_closer _waitersr` functoolspartialr' _factoryr cookies_cleanup_handle_cleanup_closed_handle_cleanup_closed_disabled_cleanup_closed_transports_cleanup_closed)rD r r r r r r\ s rE rF zBaseConnector.__init__ sY ) ,1B(1R1R O !H,,$(! %% >> O%.%z)BaseConnector.__del__.. s 777Qa777rG rn zUnclosed connector zUnclosed connector)rY connectionsrr rs )
r r values_closer+ rN rt rh r` rw )rD rl connsrx ry s rE rP zBaseConnector.__del__ s < F{ F77$+"4"4"6"6777
%FFF 5T55QQ&QQQ +
! -*.*@G& '
))'22222rG c : t j dt | S )NzH"with Connector():" is deprecated, use "async with Connector():" instead)rM rN rO rK s rE __enter__zBaseConnector.__enter__# s%
4
rG excc . | d S r~ )r )rD r s rE __exit__zBaseConnector.__exit__+ s
rG c
K | S r~ rV rK s rE
__aenter__zBaseConnector.__aenter__. s rG exc_type exc_value
exc_tracebackc > K | d {V d S r~ )r )rD r r r s rE __aexit__zBaseConnector.__aexit__1 s. jjllrG c | j S )z1Ultimately close connection on releasing if True.)r rK s rE r zBaseConnector.force_close9 s
rG c | j S )zThe total number for simultaneous connections.
If limit is 0 the connector has no limit.
The default limit size is 100.
)r rK s rE r zBaseConnector.limit> s {rG c | j S )zThe limit for simultaneous connections to the same endpoint.
Endpoints are the same if they are have equal
(host, port, is_ssl) triple.
)r rK s rE r z BaseConnector.limit_per_hostG s
##rG c | j r | j d| _ | j }| j }| j ri }||z
}| j D ]\ }}g }|D ]\ }} | re| |z
dk rD|j }
| |j
r!| j s| j
|
f|
|| f ~|j }
| |j
r!| j s| j
|
|r|||< || _ | j r#t j | d|| j | _ dS dS )zCleanup unused transports.Nr _cleanup)r cancelr` timer r itemsr r r is_sslr r r r weakref_handle) rD nowtimeoutr deadlinerZ r aliveprotouse_timer s rE r zBaseConnector._cleanupP s ( ' ' ) ) ) $(D joo ) ; & KW}H "k / / 1 1
-
-
U',
N
NOE8 ))++ N#h.22(-I !KKMMM "z R$2O R $ ? F Fy Q Q Q !LL%): ; ; ; ;$)O
: Nd.K N ; B B9 M M M -',K$%DK ; #*#9j'4:$ $D rG rZ r9 valc r | j }||vrd S || }| | |s
| j |= d S d S r~ )r remove)rD rZ r acquired_per_hostr s rE _drop_acquired_per_hostz%BaseConnector._drop_acquired_per_hosty s] ! 3 ' ' ' F!#&
S -',,, - -rG c | j r| j | j D ]}|| g | _ | j s(t j | d| j | j | _ dS 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_periodr` )rD r s rE r z BaseConnector._cleanup_closed s
& 1 ' . . 0 0 0 8 " "I$!!!*,', *1*@')Ddj+ +D ' ' ' rG c ` | t t S )z Close all opened transports.)r r< r/ rK s rE r zBaseConnector.close s!
!$&&)))rG c | j rd S d| _ | j ru | j | j | j d | _ | j d | _ d S | j r| j
| j r| j
| j D ] }|D ]\ }}| | j D ]}| | j D ]}||
| j | j | j d | _ | j d | _ d S # | j | j | j d | _ | j d | _ w xY wrI )r r` ru r clearr r r r r r r r r )rD datar t0r s rE r zBaseConnector._close sP < F /z##%%
,
K N " " " M ! ! !#'D + 1 1 3 3 3*.D ' ' '1 #
.$++--- *
5+22444 **,,
"
"!% " "IE2KKMMMM"
! <
&
& ( OO%%%
&
K N " " " M ! ! !#'D + 1 1 3 3 3*.D ' ' '
K N " " " M ! ! !#'D + 1 1 3 3 3*.D ' . . . .s G B6G A4H?c | j S )z;Is connector closed.
A readonly property.
)r rK s rE r zBaseConnector.closed s |rG c t | j rh| j t | j z
}| j rD|dk r>|| j v r5| j | }|J | j t | z
}nH| j r?|| j v r6| j | }|J | j t | z
}nd}|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 Nr )r lenr r r get)rD rZ availableacquireds rE _available_connectionsz$BaseConnector._available_connections s ; c$.&9&99I $
A MM4222 266s;; +++ 03x== @
! cT-D&D&D.22377H''' ,s8}}>SDM 1 1***,,C
M# % %c * * *
? # ? ?E <<>>>>>>>>>>
+
$-''
c*11#6666%
$-''
c0B'
c* $-''
c0B'
c*****
= # = =E ::<<<<<<<<<< # = 0E0G0GHHK N { + + + #C ( , ,[ 9 9 9
? # ? ?E <<>>>>>>>>>>
C " 5 5c67 K KKKKKKK< HKKMMM/0FGGGH | CN))+66600kBBB !
| +N))+66600kBBB((***
= # = =E ::<<<<<<<<<<
? "?4I4K4K L L "";///',00=== # < >> 5!!! $((///$UDJ777s\
B D
C C' CC
CCCCC D D"AI AJ2c ( | j | }n# t $ r Y d S w xY w| j }|r| \ }}| r^||z
| j k rD|j }| |j r!| j
s| j | nO|s| j |= |S |j }| |j r!| j
s| j | || j |= d S r~ )
r KeyErrorr` r popr r r r r r r r )rD rZ r t1r r r s rE r zBaseConnector._get= sA K$EE 44 Z__
F IE2!!##
F7T 444 %IKKMMMz J$*G J 7>>yIII - K , L !O
: Fd&C F3::9EEE% F*
K ts
c l | j sdS t | j }t j | |D ]m}| | dk r | j | }|rB| }| s| d dS |BndS )z
Iterates over all waiters until one to be released is found.
The one to be released is not finsihed and
belongs to a host that has available connections.
Nr ) r listkeysrandomshuffler popleftdone
set_result)rD queuesrZ waiterswaiters rE r z BaseConnector._release_waiter\ s } F dm((**++v C**3//!33mC(G
** {{}} %%d+++FF
rG r c | j rd S | j | | || | d S # t
$ r Y d S w xY wr~ )r r r r r r
)rD rZ r s rE _release_acquiredz BaseConnector._release_acquiredv s < F # N ! !% ( ( ( ( (e 4 4 4
" " " " "
DD s 0A
A A ro r[ rp c | j rd S | || | j rd}|s|j rI|j }| |j r#| j s | j | d S d S d S | j
| }| g x}| j
|< | || j
f | j (t j | d| j | j | _ d S d S )NTr )r r r rp r r r r r r r r r` r r r r r )rD rZ r[ rp r r s rE rv zBaseConnector._release s6 < F sH--- L 80 *I NN z
B$"?
B/66yAAAAA
B
B
B
B KOOC((E}+-- C( LL(DJOO$5$56 7 7 7#+'.'=*d&=tz( ($$$ ,+rG c " K t r~ )NotImplementedError)rD r r r s rE r z BaseConnector._create_connection s "###rG )rA r4 )NNNrQ )0rR rS rT r r rh r r0 r objectr r intr r r rF rM r rP r r r r r r
r r r r r r r' r r r
r r r r r rX r r r r rv r rV rG rE r4 r4 s
G !
9A ! &+483 3 3 !u!453 3
3
3 $3 w013
3 3 3 3 j (0 3 3 3D 3 3 3 30 S T
37-115 4
./ M*
.
!T ! ! ! X! s X $ $ $ $ X$' ' ' 'R -" -)8 -
- - - - &*y * * * *
#/ #/ #/ #/J X / c BQ8"Q8,0MQ8DSQ8 Q8 Q8 Q8 Q8f H_,E > 4
#_
#_
#QU
#
#
#
#( #
"
B$"$,0M$DS$ $ $ $ $ $ $rG r4 c e Zd Zddee ddfdZdedefdZde e
e f de e
e
ef ddfd Zde e
e f ddfd
Zdd Zde e
e f de e
e
ef fd Zde e
e f defd
ZdS )_DNSCacheTableNttlrA c 0 i | _ i | _ || _ d S r~ ) _addrs_rr _timestamps_ttl)rD r! s rE rF z_DNSCacheTable.__init__ s VX9; rG hostc || j v S r~ )r# )rD r& s rE __contains__z_DNSCacheTable.__contains__ s t~%%rG rZ addrsc t | t | f| j |< | j rt | j |< d S d S r~ )r r r# r% r r$ )rD rZ r) s rE r z_DNSCacheTable.add sJ $U||SZZ 8s 9 0$-KKD S ! ! ! 0 0rG c | j |d | j r | j |d d S d S r~ )r# r r% r$ rD rZ s rE r z_DNSCacheTable.remove sM 3%%% 9 , d + + + + + , ,rG c j | j | j d S r~ )r# r r$ rK s rE r z_DNSCacheTable.clear s1 rG c ~ | j | \ }}t t || }t | |S r~ )r# r r next)rD rZ r\ lengthr) s rE
next_addrsz_DNSCacheTable.next_addrs s9 ~c* fVD&))** T
rG c ^ | j dS | j | | j z t k S rC )r% r$ r r, s rE expiredz_DNSCacheTable.expired s- 9 5 $ty09;;>>rG r~ rQ )rR rS rT r r rF r r r( r r r r r r r r r r1 r3 rV rG rE r r s> HUO t
& &D & & & &0uS#X 0tDcN/C 0 0 0 0 0 ,%S/ ,d , , , , ! ! ! !eCHo $tCH~2F ?5c? ?t ? ? ? ? ? ?rG r c e Zd ZdZdddddddddeddddddd ed
ee d ed ee d
edee de
dee e f dee e
ef dee de
deef dededededeej f fdZded f fd Zedefd Zedefd Z d:d ee
d ee ddfd Z d;d e
d ed eed! deee
e f fd"Z d#d$d ed! d%d&de fd'Z e e!j" d d(ede fd) Z#d#d$dee fd*Z$d#d$ded+ fd,Z%e&d-d.e d#d$d%d&d/e'e( d0e de ej) e f f d1Z*dr5 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 r\ r6 r7 r8 r9 r: r; r< r= r> r r r r r r\ c " t |
| | |
|| t |||| | _ | t | j } | | _ || _ t | | _ i | _
|| _ || _ d S )Nr r )r! )
superrF r* _sslr3 r` _resolver_use_dns_cacher
_cached_hosts_throttle_dns_events_family _local_addr)rD r6 r7 r8 r9 r: r; r< r= r> r r r r r r\ __class__s rE rF zTCPConnector.__init__ s & /#)"7
&c:{KPP &DJ777H! + +
> > >OQ! %rG rA c | j D ]}| t S )z Close all ongoing DNS calls.)rE r r r@ r )rD evrH s rE r zTCPConnector.close sB +2244 B IIKKKKww}} rG c | j S )zSocket family like AF_INET.)rF rK s rE r: zTCPConnector.family s |rG c | j S )z%True if local DNS caching is enabled.)rC rK s rE r8 zTCPConnector.use_dns_cache s
""rG r& portc | | | j ||f dS ||t d | j dS )z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)rD r r r )rD r& rM s rE clear_dns_cachez TCPConnector.clear_dns_cache$ se 0 % %tTl 3 3 3 3 3
!1 WXX X $ $ & & & & &rG r r: c | K t | r|||| j dddgS | j sn|r |D ] }| | d {V | j ||| j d {V }|r |D ] }| | d {V |S ||f}|| j v rX| j | s>| j | }|r |D ] }|
| d {V |S || j v rK| j | }|r |D ] }|
| d {V | d {V nUt | j | j |< |r |D ] }| | d {V |r |D ] }| | d {V | j ||| j d {V } |r |D ] }| | d {V | j || | j | n4# t$ $ r'}
| j | |
d }
~
ww xY w | j | n # | j | w xY w| j | S )Nr )hostnamer& rM r: r flags)r: )r )r. rF rC send_dns_resolvehost_startrB resolvesend_dns_resolvehost_endrD r3 r1 send_dns_cache_hitrE waitr2 r` send_dns_cache_missr r r r ) rD r& rM r r resrZ resulteventr) r s rE
_resolve_hostzTCPConnector._resolve_host/ s
!% "l
"
A # A AE ::4@@@@@@@@@@ ..tT$,.OOOOOOOOC
? # ? ?E 88>>>>>>>>>>JTl 4% % %0B0J0J30O0O %'22377F
9 # 9 9E 2248888888888M $+ + +-c2E
9 # 9 9E 2248888888888**,, .@
-K-KD %c *
: # : :E 33D9999999999
3 E!' E E # > >t D DDDDDDDDD "n 4 4T4 4 U UUUUUUU C!' C C # < # t $ r1}t j
d | Y d }~nd }~ww xY w| |S )NFz{!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< create_default_context
SSLContextPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONAttributeErrorrM rN formatset_default_verify_paths)rb
sslcontextattr_errs rE _make_ssl_contextz TCPConnector._make_ssl_context s -// / (?@@J #/ 1 #/ 1 (-J %%(]J "
""c&;;"""!
- .4VH-=-=
/ / 1 1 1 s B
C&'CCc l | rt t d |j }t |t j r|S || d S | j }t |t j r|S || d S | d S 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
isinstancere rs rA )rD r rq s rE _get_ssl_contextz TCPConnector._get_ssl_context s ::<< {"#:;;; J*cn55
"!!%--e444 J*cn55
"!!%--e444))$// /4rG r) c ~ |j }t |t r|S | j }t |t r|S d S r~ )r< rv r) rA )rD r rets rE _get_fingerprintz TCPConnector._get_fingerprint sC g c; ' ' Ji c; ' ' JtrG client_errorargsr| rx c K t |j 4 d {V | j j |i | d {V cd d d d {V S # 1 d {V swxY w Y d S # t $ r}t |j | |d }~wt $ r}t |j | |d }~wt $ r9}|j
t |t j
r ||j | |d }~ww xY wr~ )r, sock_connectr` create_connectionr% r r r& r OSErrorerrnorv r TimeoutError)rD r r r| r} rx r s rE _wrap_create_connectionz$TCPConnector._wrap_create_connection s
A#G$899
K
K
K
K
K
K
K
K 9TZ 94 J6 J JJJJJJJ
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K
K T T T1#2DcJJPS S L L L)#**>,!"(+.5m +? + + % % % % % %MM % )..000 "
F
% %
) T T T1#2DcJJPS S L L L)#*4E22
F;?7F66F;c K | | }| | }|j j }|J |j }|J t j | ||| | j } t j | d {V }
nr# t
j
$ r dd} | | t $ r=} | j
t | t
j r t! |j | | d } ~ ww xY wd }
|
D ]}|d }|d } | | j |||||d |d
|d |r|d nd | j ||
d {V \ }}n# t $ r } | }
Y d } ~ ud } ~ ww xY w| rg|re | | nN# t. $ rA} | | j s| j | | }
Y d } ~ d } ~ ww xY w||fc S |
J |
)N)r r r $asyncio.Future[List[Dict[str, Any]]]rA c t t t j 5 | d d d d S # 1 swxY w Y d S r~ )r r r CancelledErrorrZ )r s rE drop_exceptionz>TCPConnector._create_direct_connection..drop_exception s i)?@@ ! !JJLLL! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s AA Ar& rM r: r rR rQ ) r r< r: r rR r r= r r| )r r rA N) rw rz r raw_hostrM r
ensure_futurer\ r` shieldr add_done_callbackr r rv r r r r r rG r checkr# r r r r )rD r r r r| rq r7 r& rM
host_resolvedhostsr r last_exchinfotranspr s rE r` z&TCPConnector._create_direct_connectionj s **3//
++C00 w x - tT& 9 9
I ". 77777777EE%
!
!
!
!
+ +N ; ; ; I I Iy ZW5I%J%J 's'93??S H I )- $ $ E=D=D
&*&B&BM #" ? . .9C$ME*$5$5 # /!- 'C
'
'
!
!
!
!
!
!
(
zz||
%%f----0 LLNNN 8 G 7>>vFFF "H HHHH 5= '''NsI :B 2D8C??D AE//
F9F F F55
H ?7G;;H c K | | | }i }|j |j }|j t j |t j < |j }|J t t j |||j | j
|j }| |g |t d {V \ }} | |j t j d }
|
=| s|
|j t j < n|
|j t j < | r|r| || t j |_ |j |_ t/ j |j d d d } t5 | | | | j
} | | d {V }
| j }|J | | |
| d {V }d | _ d | _ |j dk rI|j! }|tD |j d }tG |
j$ |j% |j ||j |s<|& dd }|tO d
|( }n## tR $ r |* w xY w|s|* n # |s|* w w xY w|sU| + | }| , | j- ||||j. | d {V |
* S | / ||| d {V |
* S # tR $ r* |
* | * w xY w# |
* w xY w|| fS )
N)headersauthr\ r< r{ )r^
proxy_authproxy_headers_hash)read_until_eof r )statusrr r socket)r z)Transport does not expose socket instance)r r< sockr r )r r )0r r
proxy_headersr r HOSTr^ r( METH_GETr r` r< r` r" r r
AUTHORIZATIONr PROXY_AUTHORIZATIONr METH_CONNECTmethodr attrevolver rX sendra set_response_paramsstartr r reasonr1 r! r historyget_extra_inforu dupr r rw r r r& r )rD r r r runtime_has_start_tlsr r proxy_reqr r r rZ conn
proxy_respr[ resprr rawsockrq s rE r_ z%TCPConnector._create_proxy_connection s
""3''' $ = = ? ? "$ ('G [ 3 i! M
"&!?!? r71K "@ "
"
5 $$T%7>> ::<<
C8< D 455>B !$":; ::<< V #$
<++Is;;; $ 0I GIM+"$4TX C dC
;;D (~~d 3 3333333JB
# > +++
,, " " " """" " 7 7 # 8 """"s !
"""
r """"% sP 04/38@ ! &+48#%& %& %& %& e_ %&
%& }
%& %& j)%& 4{J6
7%& U38_-%& +,%& !uf!45%& %& %& %& $!%&" w01#%& %& %& %& %& %&N y X #t # # # X#
AE ' ' SM '08
'
' ' ' ' GKJ2 J2J2 "J2,4T'],CJ2
d38n J2 J2 J2 J2X " ,0M DS Y D Z \ * O 8L BO 8O )= A A AA A ! A
9o A
A
w /1 2A A A A() ) ) )& "$ #
% /#
#
#
#
#
#
T )= 9( 9( % /9( 9( ! 9(
9o 9(
w$o5 6
9( 9( 9( 9(B )=
L L L
L W
L ! L 9o
L
w /1 2L L L L\ " ,0M DS w$o5 6 rG r5 c e Zd ZdZdedddfdededeee df d e
d
e
d e e j
d df fd
Zed efd Zddded ddd efdZ xZS )r6 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 r\ rA c b t ||||| || _ d S )Nr r r r r\ )r@ rF _pathrD r r r r r r\ rH s rE rF zUnixConnector.__init__F sB # /)
rG c | j S )zPath to unix socket.r rK s rE r zUnixConnector.pathX zrG r r( r r: r r8 c K t |j 4 d {V | j | j | j d {V \ }}d d d d {V n# 1 d {V swxY w Y nP# t $ rC}|j t |t j
r t | j |j
| |d }~ww xY wt t | S r~ )r, r r` create_unix_connectionr r r r rv r r r$ r r r r' rD r r r ra r r s rE r z UnixConnector._create_connection] s} X#G$899
!%!B!BM4:" " 5
X X Xy ZW5I%J%J *49c6H#NNTW W X
OU+++s: A1 /A
A1
A))A1 ,A)-A1 1
B>;>B99B>rR rS rT r r0 r r r r r r r r r rF r r r r' r r r s @rE r6 r6 : s "8@ 48 !!45
w01
$ c X
,"
,,0M
,DS
,
,
,
,
,
,
,
,
,rG r6 c e Zd ZdZdedddfdededeee df d e
d
e
d e e j
d df fd
Zed efd Zddded ddd efdZ xZS )r7 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 Nr r r r r r\ rA c t ||||| t | j t j st
d || _ d S )Nr z9Named Pipes only available in proactor loop under windows)r@ rF rv r` r ProactorEventLoopru r r s rE rF zNamedPipeConnector.__init__| sw # /)
J1
N
rG c | j S )zPath to the named pipe.r rK s rE r zNamedPipeConnector.path r rG r r( r r: r r8 c K t |j 4 d {V | j | j | j d {V \ }}t
j d d {V d d d d {V n# 1 d {V swxY w Y nJ# t $ r=}|j t |t j r t |j
| |d }~ww xY wt t | S )Nr )r, r r` create_pipe_connectionr r r sleepr r rv r r r r r' r s rE r z%NamedPipeConnector._create_connection s I#G$899
'
'
'
'
'
'
'
'!%!B!BM4:" " 5 mA&&&&&&&&&
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
' I I Iy ZW5I%J%J &s'93??S H I
OU+++s; B A A9'B 9
BB BB
C8C
Cr r s @rE r7 r7 m s " "8@ 48 !!45
w01
0 c X,",,0M,DS, , , , , , , , ,rG r7 )Xr r r rf rd rM collectionsr r
contextlibr 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 client_exceptionsr r r r r! r" r# r$ r% r& client_protor'
client_reqrepr( r) r* r+ r, r- r. r/ r0 httpr1 locksr2 r> r3 r< re ImportErrorr __all__clientr8 r9 tracingr: r< rX r r4 r r5 r6 r7 rV rG rE r s
* * * * * * * * % % % % % % # # # # # # # # " ! ! ! ! ! ! * ) ) ) ) ) H H H H H H H H H H % % % % % % % % % % % %JJJ JJ
CJJJ
S %%%%%%,,,,,, (WK WK WK WK WK WK WK WKt
f$ f$ f$ f$ f$ f$ f$ f$R$? $? $? $? $? $? $? $?Nd d d d d = d d d N0, 0, 0, 0, 0,M 0, 0, 0,f@, @, @, @, @, @, @, @, @, @,s > C
CC