/opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/__pycache__
Edit: /opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/__pycache__/connector.cpython-311.pyc (65865B)
*Q#v d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m
Z
d dl m Z d dl
mZ d dlmZmZ d dlmZ d dlmZ d d lmZmZmZmZmZm Z m Z m Z m 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/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6 d
dl7m8Z8 d
dl9m:Z:m;Z;m
Z>m?Z?m@Z@mAZA d
dlBmCZC d
dlDmEZE d dlFZFeFjG ZGn# eH$ r dZFeIZGY nw xY wdZJerd
dlKmLZL d
dl9mMZM 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)
HTTPStatus) SimpleCookie)cycleislice) monotonic)
TracebackType)
TYPE_CHECKINGAny AwaitableCallable DefaultDictDictIteratorListLiteralOptionalSetTupleTypeUnioncast )hdrshelpers)AbstractResolver)
ClientConnectionError ClientConnectorCertificateErrorClientConnectorErrorClientConnectorSSLErrorClientHttpProxyErrorClientProxyConnectionErrorServerFingerprintMismatchUnixClientConnectorError cert_errors
ssl_errors)ResponseHandler)
ClientRequest Fingerprint_merge_ssl_params) ceil_timeoutget_running_loop
is_ip_addressnoopsentinel)EventResultOrError)DefaultResolver)
BaseConnector TCPConnector
UnixConnectorNamedPipeConnector)
ClientTimeout)
ConnectionKey)Tracec B e Zd ZdZdee ddfdZdefdZddZdS ) _DeprecationWaiter
_awaitable_awaited awaitablereturnNc " || _ d| _ d S NFr= )selfr@ s e/builddir/build/BUILD/cloudlinux-venv-1.0.12/venv/lib64/python3.11/site-packages/aiohttp/connector.py__init__z_DeprecationWaiter.__init__K s #
c B d| _ | j S NT)r? r> __await__rD s rE rJ z _DeprecationWaiter.__await__O 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__S s< } M5"
rG rA N) __name__
__module__ __qualname__ __slots__r r
rF rJ rP rG rE r< r< H sn *I )C. T +3 + + + + rG r< c
H e Zd ZdZdZdddddedej ddf
d Zde fd
Z
e fd e ddfd Z
ded
fdZedej fd Zedeej fd Zedee fd Zdeg df ddfdZddZddZddZedefd Z dS )
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__a si #
4<46 >> O%.%)r^ rK s rE __repr__zConnection.__repr__q s )TY))))rG _warningsc 2 | j d| i} |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 rN ResourceWarningr` is_closedr_ _releaser^ rh call_exception_handler)rD rl kwargscontexts rE rP zConnection.__del__t s > % %F 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 Tc dS )z9Force subclasses to not be falsy, to make checks simpler.TrV rK s rE __bool__zConnection.__bool__ s trG 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 r r{ propertyr\ r Transportr r[ r r r r r boolr rV rG rE rX rX \ 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 f e Zd ZdZdZdZdZeddddddd d
ee de
f d e d e d
e de de
ej de
ddfdZefdeddfdZd9dZdeddfdZd9dZ d:de
ee de
e de
e ddfd Zede 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*e(d+e)d, d-d.de*fd/Z+d!d"de
e fd0Z,d;d1Z-d!d"d2e ddfd3Z.dd4d!d"d5e d6e ddfd7Z/d*e(d+e)d, d-d.de fd8Z0dS )> O%.%z)BaseConnector.__del__.. s 777Qa777rG rn zUnclosed connector zUnclosed connector)rY connectionsrr rs ) r r values_closerN rt rh r` rw )rD rl connsrx ry s rE rP zBaseConnector.__del__
s < F{ F77$+"4"4"6"6777
D! 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__- s. jjllrG c | j S )z1Ultimately close connection on releasing if True.)r rK s rE r zBaseConnector.force_close5 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_hostC 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 | j | _ dS dS )zCleanup unused transports.Nr _cleanupr )r cancelr` timer r itemsr r r is_sslr r r r weakref_handler ) rD nowtimeoutr deadlinerZ r aliveprotouse_timer s rE r zBaseConnector._cleanupL 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 ; #*#9
'+'C $ $ $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 | j | _ dS dS )z~Double confirmation for transport close.
Some broken ssl servers may leave socket open without proper close.
Nr r )
r r r abortr r r _cleanup_closed_periodr` r )rD r s rE r z BaseConnector._cleanup_closed s
& 1 ' . . 0 0 0 8 " "I$!!!*,', *1*@!+
'+'C + + +D ' ' ' rG c ` | t t S )z Close all opened transports.)r r< r0 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._getA 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 finished 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_acquiredz 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 | j | _ d S d S )NTr r )r r r rp r 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 sD < F sH--- L 80 *I NN z
B$"?
B/66yAAAAA
B
B
B
B KOOC((E}+-- C( LL(DJOO$5$56 7 7 7#+'.'= +J+/+G ( ( ($$$ ,+rG c " K t r )NotImplementedError)rD r r r s rE r z BaseConnector._create_connection s "###rG )rA r4 )NNNrQ )1rR rS rT r r rh r r1 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* r rX r r r r rv r rV rG rE r4 r4 s G !
9A ! &+48()5 5 5 !u!455 5
5
5 $5 w015 !&5
5 5 5 5 n (0 3 3 3D 3 3 3 3* S T
37-115 4
./ M*
.
!T ! ! ! X! s X $ $ $ $ X$+ + + +Z -" -)8 -
- - - - .*y * * * *
#/ #/ #/ #/J X / c BQ8 Q8*.w-Q8BQQ8 Q8 Q8 Q8 Q8f H_,E > 4
#_
#_
#QU
#
#
#
#( # # # #
# "#
#
# # # #J$ $*.w-$BQ$ $ $ $ $ $ $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 t | j |< d S d S r )r r r) r+ r
r* )rD rZ r/ s rE r z_DNSCacheTable.add sF $U||SZZ 8s 9 $-KKD S ! ! ! ! rG c | j |d | j | j |d d S d S r )r) r r+ r* rD rZ s rE r z_DNSCacheTable.remove sI 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
r2 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 r7 r9 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 d
ed ee d ed
ee dedee de
ee e f dee e
ef dee de
deef dededededeej def fdZded f fd Zedefd Zedefd Z dd4Z,d?d5Z-defd6Z.d7ej* d%e ddfd8Z/e'fd7ej* d%e d&d'd0e(e) de ej0 e f f
d9Z1e'd.d%e d"ed# d&d'd0e(e) de ej* e f f
d:Z2d%e d"ed# d&d'de ej0 e f fd;Z3 xZ4S )@r5 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 r )
verify_ssl fingerprint
use_dns_cache
ttl_dns_cachefamily ssl_contextssl
local_addrresolverr r r r r r\ r r< r= r> r? r@ rA rB rC rD 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 r< r= r> r? r@ rA rB rC rD r r r r r r\ r __class__s rE rF zTCPConnector.__init__ s ( /#)"7#9
&c:{KPP &DJ777H! + +
> > >OQ! %rG rA c | j D ]}| t S )z Close all ongoing DNS calls.)rK r r rF r )rD evrN s rE r zTCPConnector.close sB +2244 B IIKKKKww}} rG c | j S )zSocket family like AF_INET.)rL rK s rE r@ zTCPConnector.family$ s |rG c | j S )z%True if local DNS caching is enabled.)rI rK s rE r> 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)rJ r r r )rD r, rS 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, rS r@ r flags)r@ )r )r/ rL rI send_dns_resolvehost_startrH resolvesend_dns_resolvehost_endrJ r9 r7 send_dns_cache_hitrK waitr2 r` send_dns_cache_missr r r r ) rD r, rS r r resrZ resulteventr/ r s rE
_resolve_hostzTCPConnector._resolve_host9 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)rB create_default_context
SSLContextPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONAttributeErrorrM rN formatset_default_verify_paths)rh
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 t | rt t d |j }t |t j r|S |dur| d S | j }t |t j r|S |dur| 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.TF)r rB RuntimeError
isinstancerk ry rG )rD r rw 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 )rB r| r+ rG )rD r rets rE _get_fingerprintz TCPConnector._get_fingerprint sC g c; ' ' Ji c; ' ' JtrG client_errorargsr rx c K t |j |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 wNceil_threshold)r- sock_connectr r` create_connectionr' r r r( r" OSErrorerrnor| r TimeoutError)rD r r r r rx r s rE _wrap_create_connectionz$TCPConnector._wrap_create_connection s A#$W5K
K
K
K
K
K
K
K
K :TZ 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)#**>,!"(+(;(Gsx.5m +? + + % % % % % %MM % )..000 "
J $R"l3#5ws||DDD % %
/ T T T1#2DcJJPS S L L L)#*>
G+ E!!
G+.4F""
G+/7G&&G+c K | | }| | }|j j }|J | d r| d dz }|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
}|r"|j p|d d nd } | | j |||||d |d
|d || j || d {V \ }}n# t$ $ r } | }
Y d } ~ d } ~ ww xY w| rh|rf | | nO# t4 $ rB} | | j s| j | | }
Y d } ~ d } ~ ww xY w||fc S |
J |
)Nz...)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 CancelledErrorr` )r
s rE drop_exceptionz>TCPConnector._create_direct_connection..drop_exception s i)?@@ ! !JJLLL! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s AA Ar, rS rW r@ r rX ) r rB r@ r rX r rC r r )r
r rA N) r} r r raw_hostendswithrstriprS r
ensure_futurerb r` shieldr add_done_callbackr r r| r r! r r r r rM r checkr% r r r r )rD r r r r rw r= r, rS
host_resolvedhostsr r last_exchinfor transpr s rE rf z&TCPConnector._create_direct_connectionz s5 **3//
++C00 w == *;;s##c)Dx - tT& 9 9
I ". 77777777EE%
!
!
!
!
+ +N ; ; ; I I Iy ZW5I%J%J 's'93??S H I )- , , E=D=D $9j(9AA#FFF
&*&B&BM #" ? . .$3 # /!- 'C
'
'
!
!
!
!
!
!
(
zz||
%%f----0 LLNNN 8 G 7>>vFFF "H HHHH 5= '''NsI 'C 2D148D,,D12AF99
GG
G)G??
I 7II 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 | || j |
| d {V }d | _ d | _ |j! dk rJ|j" }|tG |j! j$ }tK |
j& |j' |j! ||j |s<|( dd }|tS d |* }n## tV $ r |, w xY w|s|, n # |s|, w w xY w|sU| - | }| . | j/ ||||j0 |
d {V |
, S | 1 ||| d {V |
, S # tV $ r* |
, | , w xY w# |
, w xY w|| fS ) N)headersauthr\ rB r )rd
proxy_authproxy_headers_hash)read_until_eofr )statusrr r socket)r z)Transport does not expose socket instance)r rB sockr r )r r )2r r
proxy_headersr r HOSTrd r* METH_GETr r` rB rf r$ r r
AUTHORIZATIONr PROXY_AUTHORIZATIONr METH_CONNECTmethodr attrevolver rX sendra set_response_paramsr startr r reasonr phraser# r historyget_extra_infor{ dupr r r} r r r, r )rD r r r runtime_has_start_tlsr r proxy_reqr r r rZ conn
proxy_respr[ resprr rawsockrw s rE re z%TCPConnector._create_proxy_connection s
""3''' $ = = ? ? "$ ('G [ 3 i! M
"&!?!? r71K "@ "
"
5 $$T%7>> ::<<
C8< D 455>B !$":; ::<< Y #$
<++Is;;; $ 0I GIM+"$4TX C dC
;;D (~~d 3 3333333JE
# > +++
,,#8+/+G - ( - -d 3 3333333 "&"& *{c))"&+"?&0&=&=&DG 2 & 3 L#';$+$(L 1 0"+":":8T":"R"R"?". K# # #*++--$ OO%%% 1 *!))) 1 *!))))* -
!%!6!6s!;!;J!%!=!=
' & $(+
"> " " " """" " 7 7 # 8 """"s !
"""
r """"% sQ AN O #BJ7 6K1 7 KK1 O 1L
AO $ O 4O O O$)NNr )r r* rA NrQ )5rR rS rT r r1 r r bytesr$ rk r r+ r r r r r# r r rF r r r r@ r> rU r r r
rb r* r) r staticmethodr lru_cachery r} r r! r r r r r r r r
BaseTransportr rf re
__classcell__rN s @rE r5 r5 sa 6 '+ "'),04804/38@ ! &+48()%'& '& '& '& e_ '&
'& }
'& '& j)'& 4j0
1'& U38_-'& +,'& !uf!45'& '& '& '& $!'&" w01#'&$ !&%'& '& '& '& '& '&R y X #t # # # X#
AE ' ' SM '08
'
' ' ' ' GKJ2 J2J2 "J2,4T'],CJ2
d38n J2 J2 J2 J2X *.w- BQ Y D Z \ * M hz6J BM h}6M )= A A AA A ! A
9o A
A
w /1 2A A A A,) ) ) )$ "$ #
% /#
#
#
#
#
#
T )= >( >( % />( >( ! >(
9o >(
w$o5 6
>( >( >( >(L )=
Y Y Y
Y W
Y ! Y 9o
Y
w /1 2Y Y Y YvB B *.w-B BQB w$o5 6B B B B B B B B rG r5 c e Zd ZdZdedddfdededeee df d e
d
e
d e e j
d df fd
Zed efd Zdeded 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\ )rF rF _pathrD r r r r r r\ rN 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 r8 c K t |j |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 w|S r )r- r r r` create_unix_connectionr r r r r| r r r& r r rD r r r rg r r s rE r z UnixConnector._create_connection} s
X#$W5K
"&!B!BM4:" " 5
X X Xy ZW5I%J%J *49c6H#NNTW W X
s: !A8 /A&A8 &
A00A8 3A04A8 8
C>C CrR rS rT r r1 r r r r# r r$ r r r rF r r r* r r) r r r s @rE r6 r6 Z s "8@ 48 !!45
w01
$ c X *.w-BQ rG r6 c e Zd ZdZdedddfdededeee df d e
d
e
d e e j
d df fd
Zed efd Zdeded ddd efdZ xZS )r7 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.
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)rF rF r| r` r ProactorEventLoopr{ 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 r8 c K t |j |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 r r` create_pipe_connectionr r r sleepr r r| r r! r r r) r s rE r z%NamedPipeConnector._create_connection s I#$W5K
'
'
'
'
'
'
'
' "&!B!BM4:" " 5 mA&&&&&&&&&
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
' I I Iy ZW5I%J%J &s'93??S H I
OU+++s; !B A B .B
B
B
B
B
C 8CCr r s @rE r7 r7 s " "8@ 48 !!45
w01
0 c X, ,*.w-,BQ, , , , , , , , ,rG r7 )Xr r r rf rd rM collectionsr r
contextlibr httpr http.cookiesr itertoolsr r r r
typesr typingr r
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/ r0 r1 locksr2 rD r3 rB rk 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 R R R R R R R R R R R R R R % % % % % % % % % % % %JJJ JJ
CJJJ
S %%%%%%,,,,,, (XK XK XK XK XK XK XK XKv
s$ s$ s$ s$ s$ s$ s$ s$l$? $? $? $? $? $? $? $?N| | | | | = | | | ~2 2 2 2 2M 2 2 2jB, B, B, B, B, B, B, B, B, B,s > C
CC