bf$ddlZddlZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z ddl mZddlmZmZddlmZddlmZdd lmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%ddl&Z&d d l'm(Z(m)Z)d d l*m+Z+d d l,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6d dl7m8Z8d dl9m:Z:m;Z;mZ>m?Z?m@Z@mAZAd dlBmCZCd dlDmEZE ddlFZFeFjGZGn#eH$rdZFeIZGYnwxYwdZJerd dlKmLZLd dl9mMZMd dlNmOZOGddZPGddZQGddZRGddZSGdd ZTGd!d"eSZUGd#d$eSZVGd%d&eSZWdS)'N) defaultdictdeque)suppress) HTTPStatus) SimpleCookie)cycleislice) monotonic) TracebackType) TYPE_CHECKINGAny AwaitableCallable DefaultDictDictIteratorListLiteralOptionalSetTupleTypeUnioncast)hdrshelpers)AbstractResolver) ClientConnectionErrorClientConnectorCertificateErrorClientConnectorErrorClientConnectorSSLErrorClientHttpProxyErrorClientProxyConnectionErrorServerFingerprintMismatchUnixClientConnectorError cert_errors ssl_errors)ResponseHandler) ClientRequest Fingerprint_merge_ssl_params) ceil_timeoutget_running_loop is_ip_addressnoopsentinel)EventResultOrError)DefaultResolver) BaseConnector TCPConnector UnixConnectorNamedPipeConnector) ClientTimeout) ConnectionKey)TracecBeZdZdZdeeddfdZdefdZddZdS) _DeprecationWaiter _awaitable_awaited awaitablereturnNc"||_d|_dSNFr=)selfr@s K/var/www/html/Alfredo/env/lib/python3.11/site-packages/aiohttp/connector.py__init__z_DeprecationWaiter.__init__Ks# cBd|_|jSNT)r?r> __await__rDs rErJz_DeprecationWaiter.__await__Os ((***rGcL|jstjdtdSdS)NzDConnector.close() is a coroutine, please use await connector.close())r?warningswarnDeprecationWarningrKs rE__del__z_DeprecationWaiter.__del__Ss<}  M5"       rGrAN) __name__ __module__ __qualname__ __slots__rr rFrJrPrGrEr<r<Hsn*I)C.T+3++++rGr<c HeZdZdZdZdddddedejddf d Zde fd Z e fd e ddfd Z ded fdZedejfdZedeejfdZedeefdZdegdfddfdZddZddZddZedefdZdS) ConnectionN connectorr4keyr9protocollooprAc||_||_||_||_g|_|r-t jtj d|_ dSdS)Nr) _key _connector_loop _protocol _callbacks get_debug traceback extract_stacksys _getframe_source_traceback)rDrYrZr[r\s rErFzConnection.__init__asi # 4<46 >>   O%.%)r^rKs rE__repr__zConnection.__repr__qs)TY))))rG _warningsc2|jd|i}|jd|tfi||jrdS|j|j|jd|dd}|j |j|d<|j |dSdS)NsourcezUnclosed connection T should_closezUnclosed connection)client_connectionmessagesource_traceback) rarNResourceWarningr` is_closedr__releaser^rhcall_exception_handler)rDrlkwargscontexts rErPzConnection.__del__ts > %%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 & %rGTcdS)z9Force subclasses to not be falsy, to make checks simpler.TrVrKs rE__bool__zConnection.__bool__strGcHtjdtd|jS)Nz%connector.loop property is deprecated) stacklevel)rMrNrOr`rKs rEr\zConnection.loops. 35GTU    zrGc,|jdS|jjSN)ra transportrKs rErzConnection.transports > !4~''rGc|jSr)rarKs rEr[zConnection.protocols ~rGcallbackcB||j|dSdSr)rbappend)rDrs rE add_callbackzConnection.add_callbacks,   O " "8 , , , , , rGc|jddgc}|_|D]8}tt5|dddn #1swxYwY9dSr)rbr Exception)rD callbackscbs rE_notify_releasezConnection._notify_releases%)_QQQ%7" 4?  B)$$                   s AA A c||j0|j|j|jdd|_dSdS)NTro)rrar_rvr^rKs rEclosezConnection.closesP  > % O $ $TYT $ R R R!DNNN & %rGc||j:|j|j|j|jjd|_dSdS)Nro)rrar_rvr^rprKs rEreleasezConnection.releases`  > % O $ $ 4>8S %   "DNNN & %rGcH|jdup|j Sr)ra is_connectedrKs rEclosedzConnection.closeds%~%JT^-H-H-J-J)JJrGrQ)rRrSrTrh _transportr)asyncioAbstractEventLooprFstrrkrMr rPrr{propertyr\r Transportrr[rrrrrboolrrVrGrErXrX\sJO"OO" O ' O  OOOO *#****(0 7 7 7D 7 7 7 7'$-g/X (8G$56(((X( (?3X-Xb$h%7-D----""""""""KKKKXKKKrGrXceZdZdZddZdS)_TransportPlaceholderz.placeholder for BaseConnector.connect functionrANcdSrrVrKs rErz_TransportPlaceholder.closes rGrQ)rRrSrT__doc__rrVrGrErrs.88      rGrcfeZdZdZdZdZdZeddddddd d ee de fd e d e d e de de ejde ddfdZefdeddfdZd9dZdeddfdZd9dZ d:de eede ede eddfdZede fdZede fdZede fdZd;d Zd!d"d#e ddfd$Z!d;d%Z"de#dfd&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__..s777Qa777rGrnzUnclosed connector zUnclosed connector)rY connectionsrrrs) rrvalues_closerNrtrhr`rw)rDrlconnsrxrys rErPzBaseConnector.__del__ s <  F{  F77$+"4"4"6"6777 D! 5T55QQ&QQQ +    ! -*.*@G& ' ))'22222rGc:tjdt|S)NzH"with Connector():" is deprecated, use "async with Connector():" instead)rMrNrOrKs rE __enter__zBaseConnector.__enter__s%  4     rGexcc.|dSr)r)rDrs rE__exit__zBaseConnector.__exit__'s rGc K|SrrVrKs rE __aenter__zBaseConnector.__aenter__*s  rGexc_type exc_value exc_tracebackc>K|d{VdSr)r)rDrrrs rE __aexit__zBaseConnector.__aexit__-s. jjllrGc|jS)z1Ultimately close connection on releasing if True.)rrKs rErzBaseConnector.force_close5s   rGc|jS)zThe total number for simultaneous connections. If limit is 0 the connector has no limit. The default limit size is 100. )rrKs rErzBaseConnector.limit:s {rGc|jS)zThe limit for simultaneous connections to the same endpoint. Endpoints are the same if they are have equal (host, port, is_ssl) triple. )rrKs rErzBaseConnector.limit_per_hostCs ##rGc|jr |jd|_|j}|j}|jri}||z }|jD]\}}g}|D]\}} |re| |z dkrD|j} | |j r!|j s|j | f| || f~|j} | |j r!|j s|j | |r|||<||_|jr*tj|d||j|j|_dSdS)zCleanup unused transports.Nr_cleanupr)rcancelr`timerritemsrrris_sslrrrrweakref_handler) rDnowtimeoutrdeadlinerZraliveprotouse_timers rErzBaseConnector._cleanupLs   (  ' ' ) ) )$(D joo) ; &KW}H"k//11 - - U', N NOE8))++ N#h.22(-I!KKMMM"zR$2OR $ ? F Fy Q Q Q!LL%):;;;;$)O  :Nd.KN ;BB9MMM-',K$%DK ; #*#9 '+'C $$$D   rGrZr9valcr|j}||vrdS||}|||s |j|=dSdSr)rremove)rDrZracquired_per_hostrs rE_drop_acquired_per_hostz%BaseConnector._drop_acquired_per_hostys]!3 ' ' ' F!#& S -',,, - -rGc|jr|j|jD]}||g|_|js/t j|d|j|j|j |_dSdS)z~Double confirmation for transport close. Some broken ssl servers may leave socket open without proper close. Nrr) rrrabortrrr_cleanup_closed_periodr`r)rDrs rErzBaseConnector._cleanup_closeds  & 1  ' . . 0 0 08 " "I$!!!*,', *1*@!+ '+'C +++D ' ' '  rGc`|ttS)zClose all opened transports.)rr<r0rKs rErzBaseConnector.closes! !$&&)))rGc|jrdSd|_ |jru |j|j|jd|_|jd|_ dS|jr|j |j r|j |j D]}|D]\}}| |jD]}| |jD]}||  |j|j|jd|_|jd|_ dS#|j|j|jd|_|jd|_ wxYwrI)rr`rurclearrrrrrrrrr)rDdatart0rs rErzBaseConnector._closesP <  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 ' . . . .sG B6G A4H?c|jS)z;Is connector closed. A readonly property. )rrKs rErzBaseConnector.closeds |rGct|jrh|jt|jz }|jrD|dkr>||jvr5|j|}|J|jt|z }nH|jr?||jvr6|j|}|J|jt|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. rNr)rlenrrrget)rDrZ availableacquireds rE_available_connectionsz$BaseConnector._available_connectionss ;  c$.&9&99I$ AMM4222266s;;+++ 03x==@  ! cT-D&D&D.22377H''',s8}}>SDM11***,,C M#  % %c * * * ?#??E<<>>>>>>>>>> +    $-'' c*11#6666% $-'' c0B' c*$-'' c0B' c***** =#==E::<<<<<<<<<< # =0E0G0GHHK N  { + + +  #C ( , ,[ 9 9 9 ?#??E<<>>>>>>>>>> C"55c67KKKKKKKK<HKKMMM/0FGGGH|CN))+66600kBBB!   |+N))+66600kBBB((***   =#==E::<<<<<<<<<< ?"?4I4K4KLL "";///',00===#<>> 5!!! $((///$UDJ777s\ BD C C' CC CCCCCD D"AIAJ2c( |j|}n#t$rYdSwxYw|j}|r|\}}|r^||z |jkrD|j}||j r!|j s|j |nO|s|j|=|S|j}||j r!|j s|j |||j|=dSr) rKeyErrorr`rpoprrrrrrrr)rDrZrt1rrrs rErzBaseConnector._getAsA K$EE   44 Z__   F IE2!!## F7T444 %IKKMMMzJ$*GJ7>>yIII - K, L!O  :Fd&CF3::9EEE% F* K ts  cl|jsdSt|j}tj||D]m}||dkr|j|}|rB|}|s|ddS|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) rlistkeysrandomshufflerpopleftdone set_result)rDqueuesrZwaiterswaiters rErzBaseConnector._release_waiter`s}  Fdm((**++v  C**3//!33mC(G  **{{}}%%d+++FF    rGrc|jrdS |j|||||dS#t $rYdSwxYwr)rrrrrr)rDrZrs rE_release_acquiredzBaseConnector._release_acquiredzs <  F # N ! !% ( ( (  ( (e 4 4 4  " " " " "     DD s0A AAror[rpc|jrdS||||jrd}|s|jrI|j}||jr#|js|j |dSdSdS|j |}| gx}|j |<| ||j f|j/tj|d|j|j |j|_dSdS)NTrr)rrrrprrrrrrrrr`rrrrrr)rDrZr[rprrs rErvzBaseConnector._releasesD <  F sH---   L  80  *I NN   z B$"? B/66yAAAAA B B B BKOOC((E}+-- C( LL(DJOO$5$56 7 7 7#+'.'=+J+/+G ((($$$,+rGc"Ktr)NotImplementedError)rDrrrs rErz BaseConnector._create_connections"###rG)rAr4)NNNrQ)1rRrSrTrrrhrr1robjectrrintrrrrFrMr rPrrrrrr rrrrrrr)rrrrrrrr*rrXrrrrrvrrVrGrEr4r4s  G! 9A!&+48()555!u!455 5  5  5 $5w015!&5 5555n(0333D3333*ST 37-115 4 ./M* .   !T!!!X!sX$$$$X$++++Z -" -)8 -  - - - -.*y**** #/#/#/#/JX/cBQ8 Q8*.w-Q8BQQ8 Q8Q8Q8Q8fH_,E>4 #_ #_ #QU # # # #(# ### #"#  #  ####J$ $*.w-$BQ$ $$$$$$rGr4ceZdZddeeddfdZdedefdZde e e fde e e efddfd Zde e e fddfd Zdd Zde e e fde e e effd Zde e e fdefd ZdS)_DNSCacheTableNttlrAc0i|_i|_||_dSr) _addrs_rr _timestamps_ttl)rDr's rErFz_DNSCacheTable.__init__sVX9; rGhostc||jvSr)r))rDr,s rE __contains__z_DNSCacheTable.__contains__st~%%rGrZaddrsct|t|f|j|<|jt |j|<dSdSr)rrr)r+r r*)rDrZr/s rErz_DNSCacheTable.addsF$U||SZZ8s 9 $-KKD S ! ! ! ! rGc|j|d|j|j|ddSdSr)r)rr+r*rDrZs rErz_DNSCacheTable.removesI 3%%% 9   d + + + + + ! rGcj|j|jdSr)r)rr*rKs rErz_DNSCacheTable.clears1       rGc~|j|\}}tt||}t||Sr)r)rr next)rDrZr\lengthr/s rE next_addrsz_DNSCacheTable.next_addrss9~c* fVD&))** T  rGc^|jdS|j||jztkSrC)r+r*r r2s rEexpiredz_DNSCacheTable.expireds- 9 5$ty09;;>>rGrrQ)rRrSrTrrrFr#rr.rrr$rrr rrrr7r9rVrGrEr&r&s>HUOt &&D&&&&0uS#X0tDcN/C00000 ,%S/,d,,,, !!!!eCHo$tCH~2F?5c??t??????rGr&c!ReZdZdZdddddddddeddddddd d ed eed ed eededee de ee e fdee e efdeede deefdededededeejdef fdZdedffd ZedefdZedefdZ d>dee d eeddfd!Z d?de d ed"eed#deee effd$Zd%e e efde d ed"eed#deee eff d&Zd'ed"ed#d(d)de fd*Z!e"e#j$dd+ede fd,Z%d'edee fd-Z&d'eded.fd/Z'e(d0d1ed'ed(d)d2e)e*d3ede ej+e ff d4Z,d@d6Z-dAd7Z.defd8Z/d9ej+d'eddfd:Z0e(fd9ej+d'ed(d)d2e)e*de ej1e ff d;Z2e(d0d'ed"ed#d(d)d2e)e*de ej+e ff d<Z3d'ed"ed#d(d)de ej1e ffd=Z4xZ5S)Br5a/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 rFrr) verify_ssl fingerprint use_dns_cache ttl_dns_cachefamily ssl_contextssl local_addrresolverrrrrrr\rr<r=r>r?r@rArBrCrDrrrrrr\rc $t| | | | |||t|||||_| t |j} | |_||_t||_ i|_ ||_ ||_ dS)Nrr)r') superrFr,_sslr3r` _resolver_use_dns_cacher& _cached_hosts_throttle_dns_events_family _local_addr)rDr<r=r>r?r@rArBrCrDrrrrrr\r __class__s rErFzTCPConnector.__init__s( /#)"7#9    &c:{KPP  &DJ777H!++ >>>OQ! %rGrAc|jD]}|tS)zClose all ongoing DNS calls.)rKrrrFr)rDevrNs rErzTCPConnector.closesB+2244  B IIKKKKww}}rGc|jS)zSocket family like AF_INET.)rLrKs rEr@zTCPConnector.family$s |rGc|jS)z%True if local DNS caching is enabled.)rIrKs rEr>zTCPConnector.use_dns_cache)s ""rGr,portc| ||j||fdS||td|jdS)z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)rJrrr)rDr,rSs rEclear_dns_cachezTCPConnector.clear_dns_cache.se   0   % %tTl 3 3 3 3 3  !1WXX X   $ $ & & & & &rGrr:cKt|r||||jdddgS|jsn|r |D]}||d{V|j|||jd{V}|r |D]}||d{V|S||f}||jvrX|j|s>|j |}|r |D]}| |d{V|Stj | ||||} tj|d{VS#tj$rd d} || wxYw) z*Resolve host and return list of addresses.r)hostnamer,rSr@rflagsNr@r $asyncio.Future[List[Dict[str, Any]]]rActttj5|ddddS#1swxYwYdSr)rrrCancelledErrorresult)r s rEdrop_exceptionz2TCPConnector._resolve_host..drop_exceptionssi)?@@!!JJLLL!!!!!!!!!!!!!!!!!!sAA A)r rZrAN)r/rLrIsend_dns_resolvehost_startrHresolvesend_dns_resolvehost_endrJr9r7send_dns_cache_hitr create_task_resolve_host_with_throttleshieldr\add_done_callback) rDr,rSrr resrZr]resolved_host_taskr^s rE _resolve_hostzTCPConnector._resolve_host9s.    !%  "l   "  A#AAE::4@@@@@@@@@@..tT$,.OOOOOOOOC ?#??E88>>>>>>>>>>JTl $$ $ $T-?-G-G-L-L $'22377F 9#99E2248888888888M%0  , ,S$f E E    (:;;;;;;;; ;%    ! ! ! !  0 0 @ @ @  s &E*E*rZcK||jvrK|j|}|r |D]}||d{V|d{VnUt|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}~wwxYw |j|n#|j|wxYw|j |S)z(Resolve host with a dns events throttle.NrY)r)rKrbwaitr2r`send_dns_cache_missr_rHr`rLrarJrrrrr7) rDrZr,rSreventr r/r s rErdz(TCPConnector._resolve_host_with_throttlezsi $+ + +-c2E 9#99E2248888888888**,,        .@ -K-KD %c * :#::E33D9999999999 3E!'EE#>>tDDDDDDDDDD"n44T4 4UUUUUUUUC!'CC#<#t$r1}tj d|Yd}~nd}~wwxYw||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)rBcreate_default_context SSLContextPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONAttributeErrorrMrNformatset_default_verify_paths)rs sslcontextattr_errs rE_make_ssl_contextzTCPConnector._make_ssl_contexts  -// /(?@@J   #/ 1     #/ 1  (-J %%(]J " ""c&;;"""!    -.4VH-=-=    / / 1 1 1 sB C&'CCct|rttd|j}t|tjr|S|dur|dS|j}t|tjr|S|dur|dS|dSdS)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)rrB RuntimeError isinstancervrrG)rDrrs rE_get_ssl_contextzTCPConnector._get_ssl_contexts ::<< {"#:;;;J*cn55 "!!%%--e444J*cn55 "!!%%--e444))$// /4rGr+c~|j}t|tr|S|j}t|tr|SdSr)rBrr+rG)rDrrets rE_get_fingerprintzTCPConnector._get_fingerprintsCg c; ' ' Ji c; ' ' JtrG client_errorargsrrxcK t|j|j4d{V|jj|i|d{Vcdddd{VS#1d{VswxYwYdS#t $r}t |j||d}~wt$r}t|j||d}~wt$r9}|j t|tjr||j||d}~wwxYwNceil_threshold)r- sock_connectrr`create_connectionr'r rr(r"OSErrorerrnorr TimeoutError)rDrrrrrxrs rE_wrap_create_connectionz$TCPConnector._wrap_create_connections A#$W5K K K K K K K K K:TZ94J6JJJJJJJJ 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||}||}|jj}|J|dr|ddz}|j}|J ||||d{V} nJ#t$r=} | j t| tj rt|j| | d} ~ wwxYwd} | D]} | d}| d}|r"|jp| ddnd} ||j||||| d| d| d | |j|| d{V\}}n#t$r } | } Yd} ~ d} ~ wwxYw|rh|rf ||nO#t*$rB} ||js|j|| } Yd} ~ d} ~ wwxYw||fcS| J| ) Nz...)rr,rSrWr@rrX) rrBr@rrXrrCrr)rrrraw_hostendswithrstriprSrirrrrrr!rrrrrMrcheckr%rrrr)rDrrrrrr=r,rShostsrlast_exchinfortransprs rErqz&TCPConnector._create_direct_connections**3// ++C00 w ==   *;;s##c)Dx I,,T4,GGGGGGGGEE I I Iy ZW5I%J%J 's'93??S H  I)-, , E=D=D $9j(9AA#FFF   &*&B&BM#" ?..$3#/!-'C ' ' ! ! ! ! ! ! (    zz||   %%f----0LLNNN8G7>>vFFF"HHHHH 5= '''NsI6B C8CCAE$$ E:.E55E:F** G647G11G6cK|||}i}|j|j}|jtj|tj<|j}|Jttj|||j |j |j }| |g|td{V\}} | |jtjd} | =|s| |jtj<n| |jtj<|r|r|||tj|_|j|_t/j|jddd} t5|| | |j } || d{V} | j}|J|||j| | d{V}d| _d| _ |j!dkrJ|j"}|tG|j!j$}tK| j&|j'|j!||j|s<|(dd}|tSd |*}n##tV$r|,wxYw|s|,n#|s|,wwxYw|sU|-|}|.|j/||||j0| d{V | ,S|1||| d{V | ,S#tV$r*| ,| ,wxYw#| ,wxYw|| fS) N)headersauthr\rBr)ro proxy_authproxy_headers_hash)read_until_eofr)statusrrrsocket)rz)Transport does not expose socket instance)rrBsockrr)rr)2rr proxy_headersrrHOSTror*METH_GETrr`rBrqr$rr AUTHORIZATIONrPROXY_AUTHORIZATIONr METH_CONNECTmethodrattrevolverrXsendraset_response_paramsrstartrrreasonrphraser#rhistoryget_extra_inforduprrrrrr,r)rDrrrruntime_has_start_tlsrr proxy_reqrrrrZconn proxy_respr[resprrrawsockrs rErpz%TCPConnector._create_proxy_connections ""3''' $ = = ? ?"$   ('G [3 i! M     "&!?!? r71K"@" "        5  $$T%7>>  ::<< C8< D455>B !$":; ::<<Y #$ <++Is;;; $0I GIM+"$4TXCdC ;;D(~~d33333333JE #>+++ ,,#8+/+G-(--d33333333 "&"&*{c))"&+"?&0&=&=&DG2&3 L#';$+$(L 10"+":":8T":"R"R"?". K###*++--$OO%%% 1*!)))1*!))))*- !%!6!6s!;!;J!%!=!= '&$(+ ">"""  """""77# 8  """"s!     """  r  """"%sQANO#BJ76K17 KK1O1L  AO$O4O  OO$)NNr)rr*rANrQ)6rRrSrTrr1rrbytesr$rvrr+rrrrr#rrrFrrrr@r>rUrrr rirdr*r)r staticmethodr lru_cacherrrr!rrrrrrrr BaseTransportrrqrp __classcell__rNs@rEr5r5s6 '+"'),04804/38@!&+48()%'&'&'&'&e_ '&  '&  } '&'&j)'&4j0 1'&U38_-'&+,'&!uf!45'&'&'&'& $!'&"w01#'&$!&%'&'&'&'&'&'&RyX#t###X# AE ' 'SM '08  '  ' ' ' 'GK???"?,4T'],C? d38n ????B*2 38_*2*2 *2 g' *2 d38n  *2*2*2*2X   *.w- BQ      YDZ\*Mhz6JBMh}6M)= AAAAA! A 9o A  A w /1 2AAAA,))))$"$# %/# #   # # # # T)= >(>(%/>(>(! >( 9o >( w$o5 6 >(>(>(>(L)= NNN NW N! N 9o N w /1 2NNNN`B  B *.w-B BQB w$o5 6B B B B B B B B rGr5ceZdZdZdedddfdededeee dfd e d e d e e j d dffd Zed efdZdededddd efdZxZS)r6aUnix 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. FrrNpathrrrrr\rAcbt|||||||_dS)Nrrrrr\)rFrF_pathrDrrrrrr\rNs rErFzUnixConnector.__init__|sB #/)     rGc|jS)zPath to unix socket.rrKs rErzUnixConnector.path zrGrrr:rr8cK t|j|j4d{V|j|j|jd{V\}}dddd{Vn#1d{VswxYwYnP#t$rC}|jt|tj rt|j |j||d}~wwxYw|Sr)r-rrr`create_unix_connectionrrrrrrrr&rrrDrrrrrrrs rErz UnixConnector._create_connections X#$W5K        "&!B!BM4:""5                             X X Xy ZW5I%J%J *49c6H#NNTW W X  s:!A8/A&A8& A00A83A04A88 C>CCrRrSrTrr1rrrr#rr$rrrrFrrr*rr)rrrs@rEr6r6ps  "8@48!!45     w01 $cX *.w-BQ rGr6ceZdZdZdedddfdededeee dfd e d e d e e j d dffd Zed efdZdededddd efdZxZS)r7aNamed 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. FrrNrrrrrr\rAct|||||t|jtjst d||_dS)Nrz9Named Pipes only available in proactor loop under windows)rFrFrr`rProactorEventLooprrrs rErFzNamedPipeConnector.__init__sw #/)     J1   N  rGc|jS)zPath to the named pipe.rrKs rErzNamedPipeConnector.pathrrGrrr:rr8cK t|j|j4d{V|j|j|jd{V\}}tjdd{Vdddd{Vn#1d{VswxYwYnJ#t$r=}|j t|tj rt|j||d}~wwxYwtt |S)Nrr)r-rrr`create_pipe_connectionrrrsleeprrrrr!rrr)rs rErz%NamedPipeConnector._create_connections I#$W5K ' ' ' ' ' ' ' '"&!B!BM4:""5mA&&&&&&&&& ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' I I Iy ZW5I%J%J &s'93??S H I OU+++s;!BA B.B B  B B B C8CCrrs@rEr7r7s  ""8@48!!45     w01 0cX, ,*.w-,BQ, ,,,,,,,,rGr7)XrrrrfrdrM collectionsrr contextlibrhttpr http.cookiesr itertoolsrr rr typesr typingr r rrrrrrrrrrrrrrrrabcrclient_exceptionsrr r!r"r#r$r%r&r'r( client_protor) client_reqrepr*r+r,r-r.r/r0r1locksr2rDr3rBrv ImportErrorr#__all__clientr8r9tracingr:r<rXrr4r&r5r6r7rVrGrErs ********%%%%%%########$ !!!!!!                        *)))))HHHHHHHHHHRRRRRRRRRRRRRR%%%%%%%%%%%%JJJJJ CJJJ S%%%%%%,,,,,,(XKXKXKXKXKXKXKXKv        s$s$s$s$s$s$s$s$l$?$?$?$?$?$?$?$?NR  R  R  R  R  =R  R  R  j22222M222jB,B,B,B,B,B,B,B,B,B,s> C CC