+ PV-jX^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIHtH t H t ^RI H t H t HtHt^RIHt^RIHt^RIHtHtHt^RIHt^RIHt^R IHtHtHtH t H!t!H"t"^RI#t#^R I#H$t$H%t%^R I&H't'H(t(^R I)H*t*H+t+^R I,H-t-H.t.H/t/H0t0H1t1H2t2H3t3H4t4H5t5H6t6H7t7H8t8^RI9H:t:^RI;Ht>^RI(H?t?H@t@HAtAHBtBHCtCHDtDHEtEHFtF^RIGHHtH^RIIHJtJ]PR68d^RI HLtLM ]!]M]NRR3,tL]'d^RIOtO]OPtPM^RIOtO]OPtP]S!R04tT]S!RR04tU]S!RR04tV]U]T,tW]W]V,tXR7]Pu;8*;'dR88Mu;'g]PR98tYR:tZ]'d^RI[H\t\^R I;H]t]^R!I^H_t_!R"R#4t`R$R%lta!R&R'4tb!R(R)]b4tc!R*R+4td!R,R4te!R-R.4tfR/R0ltg]g!R14th]g!R24ti!R3R]e4tj!R4R]e4tk!R5R]e4tlR# ]Qd RtO]RtPEL i;i);N) OrderedDict defaultdictdeque) AwaitableCallableIteratorSequence)suppress) HTTPStatus)chaincycleislice) monotonic) TracebackType) TYPE_CHECKINGAnyLiteralOptionalUnioncast) AddrInfoTypeSocketFactoryType)hdrshelpers)AbstractResolver ResolveResult) ClientConnectionErrorClientConnectorCertificateErrorClientConnectorDNSErrorClientConnectorErrorClientConnectorSSLErrorClientHttpProxyErrorClientProxyConnectionErrorInvalidUrlClientErrorServerFingerprintMismatchUnixClientConnectorError cert_errors ssl_errorsResponseHandler) ClientRequest Fingerprint_merge_ssl_params) _SENTINEL ceil_timeoutis_canonical_ipv4_address is_ip_addressnoopsentinel set_exception set_result) client_logger)DefaultResolver)Bufferzmemoryview[int]zmemoryview[bytes]httphttpswswss BaseConnector TCPConnector UnixConnectorNamedPipeConnector) ClientTimeout) ConnectionKey)TracecZa]tRt^etoRtV3RlRltV3RlRltV3RlRltRtVt R#) _DeprecationWaiterc4<V^8dQhRS[S[,RR/#) awaitablereturnN)rr)format __classdict__s"b/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/aiohttp/connector.py __annotate___DeprecationWaiter.__annotate__hs)C.Tc WnRVnR#)FN _awaitable_awaited)selfrIs&&rM__init___DeprecationWaiter.__init__hs# rPc <V^8dQhRS[/#rHrJr)rKrLs"rMrNrOls++3+rPcDRVnVPP4#)T)rTrS __await__rUs&rMr\_DeprecationWaiter.__await__ls ((**rPc<V^8dQhRR/#rHrJN)rKrLs"rMrNrOpsrPcdVP'g\P!R\4R#R#)zDConnector.close() is a coroutine, please use await connector.close()N)rTwarningswarnDeprecationWarningr]s&rM__del___DeprecationWaiter.__del__ps$}}} MM5" rPrRN) __name__ __module__ __qualname____firstlineno__ __slots__rVr\rf__static_attributes____classdictcell__rLs@rMrFrFes(*I++rPrFcTV^8dQhR\\\,,RR/#)rHwaitersrJN)listrobject)rKs"rMrNrNys(JJ4 &(9#:JtJrPc"\P!VRR/GRjxL pVF2p\V\4'gK\P !RV4K4 R#L>5i)z'Wait for all waiters to finish closing.return_exceptionsTNz!Error while closing connector: %r)asynciogather isinstance Exceptionr6debug)rqresultsress& rM_wait_for_closer}ysINNGDtDDG c9 % %    CS IEsAAAAc*a]tRt^toRtV3RlRltV3RlRlt]3V3RlRlltV3RlR lt ] V3R lR l4t ] V3R lR l4t ] V3RlRl4t V3RlRltV3RlRltV3RlRltV3RlRlt] V3RlRl4tRtVtR#) ConnectionNc F<V^8dQhRRRRRS[RS[PRR/#) rH connectorr>keyrCprotocollooprJN)r*rvAbstractEventLoop)rKrLs"rMrNConnection.__annotate__sJOO"OO" O '' O  OrPcW nWnW@nW0n.VnVP 4'd2\ P!\P!^44Vn R#R#)N) _key _connector_loop _protocol _callbacks get_debug traceback extract_stacksys _getframe_source_traceback)rUrrrrs&&&&&rMrVConnection.__init__sM # 1946 >>  %.%<%)rr]s&rM__repr__Connection.__repr__sTYYKq))rPc$<V^8dQhRS[RR/#rH _warningsrJNrZ)rKrLs"rMrNrs 7 7 7D 7rPcVPeRV/pVP!RV: 2\3/VBVPP 4'dR#VP P VPVPRR7RVRR/pVPeVPVR&VPPV4R#R#) NsourcezUnclosed connection T should_closeclient_connectionmessagezUnclosed connectionsource_traceback) rrdResourceWarningr is_closedr_releaserrcall_exception_handler)rUrkwargscontexts&& rMrfConnection.__del__s >> %%F NN1$:O Vv Vzz##%% OO $ $TYYT $ R*D)=RSG%%1.2.D.D*+ JJ - -g 6 &rPc.<V^8dQhRS[R,/#)rHrJT)r)rKrLs"rMrNrs'$-rPc R#)z9Force subclasses to not be falsy, to make checks simpler.Trar]s&rM__bool__Connection.__bool__srPc4<V^8dQhRS[P/#rY)rvr)rKrLs"rMrNrsg//rPcT\P!R\^R7VP#)z%connector.loop property is deprecated stacklevel)rcrdrerr]s&rMrConnection.loops# 35GTU zzrPcB<V^8dQhRS[PR,/#r`)rv Transport)rKrLs"rMrNrs((7,,t3(rPcNVPfR#VPP#N)r transportr]s&rMrConnection.transports >> !~~'''rPc.<V^8dQhRS[R,/#r`r))rKrLs"rMrNrs/D0rPcVP#r)rr]s&rMrConnection.protocols ~~rPc6<V^8dQhRS[.R3,RR/#)rHcallbackNrJ)r)rKrLs"rMrNrs$--Xb$h%7-D-rPcHVeVPPV4R#R#r)rappend)rUrs&&rM add_callbackConnection.add_callbacks   OO " "8 , rPc<V^8dQhRR/#r`ra)rKrLs"rMrNrsrPcVPR,.uqnVF*p\\4;_uu_4V!4RRR4K, R# +'giKA;i):NNNN)rr ry)rU callbackscbs& rM_notify_releaseConnection._notify_releasesC%)__Q%7" ?B)$$%$$$$s A  A c<V^8dQhRR/#r`ra)rKrLs"rMrNrs""t"rPcVP4VPe<VPPVPVPRR7RVnR#R#)NTrrrrrrr]s&rMcloseConnection.closesE  >> % OO $ $TYYT $ R!DN &rPc<V^8dQhRR/#r`ra)rKrLs"rMrNrs"""rPcVP4VPe:VPPVPVP4RVnR#R#rrr]s&rMreleaseConnection.releases@  >> % OO $ $TYY ?!DN &rPc <V^8dQhRS[/#rYbool)rKrLs"rMrNrsKKKrPclVPRJ;'g VPP4'*#r)r is_connectedr]s&rMclosedConnection.closeds)~~%JJT^^-H-H-J)JJrP)rrrrrr)rhrirjrkrrVrrcrfrpropertyrrrrrrrrrmrnros@rMrrsOO **(0 7 7 (( --""""KKrPrc6a]tRt^toRtV3RlRltRtVtR#)_ConnectTunnelConnectionaSpecial connection wrapper for CONNECT tunnels that must never be pooled. This connection wraps the proxy connection that will be upgraded with TLS. It must never be released to the pool because: 1. Its 'closed' future will never complete, causing session.close() to hang 2. It represents an intermediate state, not a reusable connection 3. The real connection (with TLS) will be created separately c<V^8dQhRR/#r`ra)rKrLs"rMrN%_ConnectTunnelConnection.__annotate__s   rPc R#)a9Do nothing - don't pool or close the connection. These connections are an intermediate state during the CONNECT tunnel setup and will be cleaned up naturally after the TLS upgrade. If they were to be pooled, they would never be properly closed, causing session.close() to wait forever for their 'closed' future. Nrar]s&rMr _ConnectTunnelConnection.releaserPraN)rhrirjrk__doc__rrmrnros@rMrrs  rPrc^a]tRt^toRtRtV3RlRltV3RlRltV3RlRltRt Vt R #) _TransportPlaceholderz.placeholder for BaseConnector.connect functioncV<V^8dQhRS[PS[R,,RR/#)rH closed_futureNrJ)rvFuturery)rKrLs"rMrN"_TransportPlaceholder.__annotate__s)gnnY5E&F4rPc WnRVnR#)z)Initialize a placeholder for a transport.Nrr)rUrs&&rMrV_TransportPlaceholder.__init__s# rPc<V^8dQhRR/#r`ra)rKrLs"rMrNrs%%t%rPc R#)zClose the placeholder.Nrar]s&rMr_TransportPlaceholder.closerrPc<V^8dQhRR/#r`ra)rKrLs"rMrNrs44t4rPc R#)z%Abort the placeholder (does nothing).Nrar]s&rMabort_TransportPlaceholder.abortrrPrN) rhrirjrkrrlrVrrrmrnros@rMrrs+8'I %%44rPrc<a]tRt^toRtRtRtRt]t R] RRR^dR ^R RR RR ^/V3R lRllt ] 3V3RlRllt V3RlRltV3RlRltV3RlRltR>V3RlRllt]V3RlRl4t]V3RlRl4t]V3RlRl4tV3RlR ltV3R!lR"ltR#R/V3R$lR%lltR#R/V3R&lR'llt]V3R(lR)l4tV3R*lR+ltV3R,lR-ltV3R.lR/ltV3R0lR1ltV3R2lR3ltV3R4lR5lt V3R6lR7lt!R8R/V3R9lR:llt"V3R;lR<lt#R=t$Vt%R#)?r>a0Base 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. timeout_ceil_threshold - Trigger ceiling of timeout values when it's above timeout_ceil_threshold. loop - Optional event loop. TNg@keepalive_timeout force_closeFlimitlimit_per_hostenable_cleanup_closedrtimeout_ceil_thresholdc<V^8dQhRS[R,S[,RS[RS[RS[RS[RS[P R,RS[R R/#) rHrNrrrrrrrJ)rsfloatrintrvr)rKrLs"rMrNBaseConnector.__annotate__s{KK"D=50K K  K  K $K''$.K!&K KrPcV'dVeV\Jd \R4hM V\JdRpT;'g\P!4pWpnRVnVP 4'd0\P!\P!^44Vn \\4VnW0nW@n\#4Vn\\"4Vn\)\*V4VnW n\\04VnW`n\6P8!\:VR7VnRVnRVn V'd=\B'g1\DPF!R\PH 2\J^R7RpV'*Vn&.Vn'VPQ4Vn)VPRPUR4VPW4R#)Nz6keepalive_timeout cannot be set if force_close is Trueg.@Frzoenable_cleanup_closed ignored because https://github.com/python/cpython/pull/118960 is fixed in Python version r),r3 ValueErrorrvget_running_loop_timeout_ceil_threshold_closedrrrrrrrr_conns_limit_limit_per_hostset _acquired_acquired_per_hostrr_keepalive_timeout _force_closer_waitersr functoolspartialr*_factory_cleanup_handle_cleanup_closed_handleNEEDS_CLEANUP_CLOSEDrcrd version_infore_cleanup_closed_disabled_cleanup_closed_transports create_future_placeholder_futurer5_cleanup_closed)rUrrrrrrrs&$$$$$$$rMrVBaseConnector.__init__s  ,1B(1R L!H,$(!11w//1'=$ >>  %.%<%ra)rKrLs"rMrNrws?rPc<\P!R\4V#)zH"with Connector():" is deprecated, use "async with Connector():" instead)rcrdrer]s&rM __enter__BaseConnector.__enter__ws  4   rPc$<V^8dQhRS[RR/#)rHexcrJNrZ)rKrLs"rMrNrsSTrPc&VP4R#r)r )rUr*s&*rM__exit__BaseConnector.__exit__s  rPc<V^8dQhRR/#r%ra)rKrLs"rMrNrs/rPc"V#5irrar]s&rM __aenter__BaseConnector.__aenter__s  scj<V^8dQhRS[S[,R,RS[R,RS[R,RR/#)rHexc_typeN exc_value exc_tracebackrJ)type BaseExceptionr)rKrLs"rMrNrsG}%,!4'%t+   rPcB"VP4GRjxL R#L5ir)r)rUr3r4r5s&&&&rM __aexit__BaseConnector.__aexit__s jjls c <V^8dQhRS[/#rYr)rKrLs"rMrNrs!!T!rPc VP#)z1Ultimately close connection on releasing if True.)r r]s&rMrBaseConnector.force_closes   rPc <V^8dQhRS[/#rYr)rKrLs"rMrNrssrPc VP#)zyThe total number for simultaneous connections. If limit is 0 the connector has no limit. The default limit size is 100. )rr]s&rMrBaseConnector.limits{{rPc <V^8dQhRS[/#rYr?)rKrLs"rMrNrs$$$rPc VP#)zThe limit for simultaneous connections to the same endpoint. Endpoints are the same if they are have equal (host, port, is_ssl) triple. )rr]s&rMrBaseConnector.limit_per_hosts###rPc<V^8dQhRR/#r`ra)rKrLs"rMrNrs%%$%rPc >VP'd"VPP4RVn\4pVPpVP'd\ \ 4pW, pVPP4FwrV\ 4pVFwrVP4'd"W, ^8dVPW34K<VPp VP4VP'dKlVP'gKVPPV 4K V'gKWsV&K W0nVP'd7\P !VRVVP"VP$R7VnR#R#)zCleanup unused transports.N_cleanupr)rcancelrr rrritemsrrrrris_sslrrweakref_handlerr) rUnowtimeoutrdeadlinerr"aliveprotouse_timers & rMrGBaseConnector._cleanups7      ' ' )$(D k)) ;;;%e,K}H"kk//1 >Cg',OE))++0Cq0H e%67 %IKKM888SZZZ77>>yI(-5',$2&K ;;;#*#9#9 '+'C'C $D  rPc<V^8dQhRR/#r`ra)rKrLs"rMrNrsrPc bVP'dVPP4VPFpVfK VP4K .VnVP'gA\ P !VRVPVPVPR7VnR#R#)znDouble confirmation for transport close. Some broken ssl servers may leave socket open without proper close. NrrH) rrIrrrrrL_cleanup_closed_periodrr)rUrs& rMrBaseConnector._cleanup_closeds  & & &  ' ' . . 088I$!9+-',,,*1*@*@!++ '+'C'C +D '-rP abort_sslc4<V^8dQhRS[RS[R,/#rHrXrJN)rr)rKrLs"rMrNrs(($(9T?(rPc .VPVR7;p'g\\44#\V4p\P R8d$\ P!W0PRR7pMVPPV4p\V4#)zClose all opened transports. :param abort_ssl: If True, SSL connections will be aborted immediately without performing the shutdown handshake. This provides faster cleanup at the cost of less graceful disconnection. rXTr eager_start ) r rFr2r}rrrvTaskr create_task)rUrXrqcorotasks&$ rMrBaseConnector.closesv ;;;;;;&df- -w'   w &<<::4HD::))$/D!$''rPcF<V^8dQhRS[RS[S[S[,,/#rHrXrJrrrrrs)rKrLs"rMrNrs%</</4</D69J4K</rPc,.pVP'dV#RVnVPP4'dTVPP 4VP P 4VP P4FpVFpVP4K K VP P 4RVn VPP 4RVn #VP'dVPP4VP'dVPP4VPP4FpVFwrgV'dAVP'd/VPPR4eVP4MVP4VP ;p'gKsVP#V4K K VP FpV'dAVP'd/VPPR4eVP4MVP4VP ;p'gKqVP#V4K VPFp V fK V P4K TVPP 4VP P 4VP P4FpVFpVP4K K VP P 4RVn VPP 4RVn # TPP 4TP P 4TP P4FpTFpTP4K K TP P 4RTn TPP 4RTn i;i)TN sslcontext)rrrrclearr r rrIrrrrget_extra_inforrrr) rUrXrq keyed_waiters keyed_waiterdatarQ_rrs &$ rMr BaseConnector._closes+- <<<N 4 /zz##%%T KK    NN "!%!5!5!7 $1L '')%2"8 MM   !#'D  + + 1 1 3*.D '_###$$++-***++224 **, $HE!!OOO!OO::<HT  !&-v--v.!%-66|DPKKMKKM"\\)6))NN6*("<< (OO%= KK    NN "!%!5!5!7 $1L '')%2"8 MM   !#'D  + + 1 1 3*.D ' KK    NN "!%!5!5!7 $1L '')%2"8 MM   !#'D  + + 1 1 3*.D 'sEM!M!1M!+M!/AM!AM!AM!AM!1%M!M!!B2Pc <V^8dQhRS[/#rYr)rKrLs"rMrNr5srPc VP#)z+Is connector closed. A readonly property. )rr]s&rMrBaseConnector.closed4s ||rPc$<V^8dQhRRRS[/#)rHrrCrJr?)rKrLs"rMrNr<s/crPc .^pVP'd0VP\VP4, ;p^8:dV#VP;p'd>VPP V4;p'dV\V4,pW#8dV#V#)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. )rlenr rr get)rUr total_remain host_remainacquireds&& rM_available_connections$BaseConnector._available_connections<s ;;;DKK#dnn:M,MMLRSS .. .; .2266s;;x;s8}, )""rPc&<V^8dQhRS[RS[/#)rHreqrJ)r+)rKrLs"rMrNrUs  rPc  <VPpVfQh/pVPe VPpVP\P,V\P&\ \P VVVPVPVPR7pVPP\PR4pVeQVP4'gWQP\P&V#WTP\P&V#)znSet Proxy-Authorization header for non-SSL proxy requests and builds the proxy request for SSL proxy requests.N)headersauthrssl)proxy proxy_headersrrHOSTr+METH_GET proxy_authrrpop AUTHORIZATIONrKPROXY_AUTHORIZATION)rUrurlr proxy_reqrs&& rM-_update_proxy_auth_header_and_build_proxy_req;BaseConnector._update_proxy_auth_header_and_build_proxy_reqUsii"$    (''G [[3 ! MM     $$T%7%7>  ::<<8< D445?C!!$":":;rPc><V^8dQhRS[RS[R,RRRS[/#rHrtracesrDrNrBrJ)r+rrr)rKrLs"rMrNros19898 98*.w-98BQ98 98rPc "VPpVPWB4GRjxL ;pe&VP'dVPV4V#\ VP VP 4;_uu_4GRjxL VPV4^8:dnVPWB4GRjxL VPWB4GRjxL ;pe8VP'dVPV4TuuRRR4GRjxL #\\\VP44pVPPV4VP'd#VP V,PV4V'd"VFpVP#4GRjxL K VP%WV4GRjxL pV'd"VFpVP'4GRjxL K VP('dVP+4\-R4hRRR4GRjxL TPP3X4TPPX4TP'd6TP T,p T P3T4T PT4\5YYP64#ELEL;ELELELEL,ELL \.dTP1YF4hi;iL +GRjxL 'giL;i5i)z'Get from pool or create new connection.NzConnector is closed.)connection_key_getrrr/connectceil_thresholdr}_wait_for_available_connectionrr*rrr addrr send_connection_create_start_create_connectionsend_connection_create_endrrrr7_release_acquiredremoverr) rUrrrNrconn placeholdertracerQacquired_per_hosts &&&& rMrBaseConnector.connectosk  ))C00 0D =yyyBB3GK1G1GHHH**3/1499#FFF"&))C"888DEyyyJJ3O IHH!6t7O7O!PK NN  { +###'',00= H!'#@@BBB"("55c7KK!'#>>@@@"( <<<KKM/0FGG =IHN k* 5!     $ 7 7 <   $ $[ 1  ! !% ($UJJ77i1IF8I*CKA  &&s8 5IHHHs !L J5L ?L =J8>L +K/,J;-K/J>K/ K/2 L ?KL A2K/8K K K K 6K7 K K K K $.K/ L K-A L *A L 8L ;K/>K/L K K  K  K**K/-L /L 5K86 L L L c6<V^8dQhRRRS[R,RR/#rHrrCrrDrJN)rr)rKrLs"rMrNrs)(("(,0M( (rPc "^pVPP4pVPV,pRWT&V'dVPVRR7V'd"VFpVP 4GRjxL K VGRjxL V'd"VFpVP 4GRjxL K VP VR4VPPVR4'gVPVTPT4^8dR#T^, pEKLLLq TP TR4TPPTR4'gTPTii;i5i)z&Wait for an available connection slot.TNFlast) rrr  move_to_endsend_connection_queued_startsend_connection_queued_endrryr})rUrrattemptsfutrnrs&&& rMr,BaseConnector._wait_for_available_connections9(, (@(@(BC MM#.M!%M ))#E): +!'#@@BBB"( !'#>>@@@"( !!#t,}}((d33 c***3/!3 MHCA!!#t,}}((d33 c*4sbAE!DD3D4 DD DD&D'D/A%E!DDDAEE!cF<V^8dQhRRRS[R,RS[R,/#r)rrr)rKrLs"rMrNrs.(("(,0M( d (rPc d"VPPV4;pfR#\4pV'EdHVP4wrVVP 4'dWF, VP 8:dV'gVPVVP PV4VP'd#VPV,PV4V'd#VFpVP4GRjxL K \WWPP4#VPpVP!4VP"'dEKVP$'gEK2VP&P)V4EKPVPVR#L \dTPY4hi;i5i)z^Get next reusable connection for the key or None. The connection will be marked as acquired. N)rryrpopleftrr r rrr send_connection_reuseconnr7rrrrrrrKrr) rUrrr"t1rQt0rrs &&& rMrBaseConnector._getsJ[[__S) )E 2 [e IE!!##43J3J(J C(""5)'''++C044U;!'""'"A"A"CCC"( "$UJJ??I KKM000SZZZ//66yA KK D," 223>!"sT4F0AF0>9F08)F0"F0(F;F <FAF0 F0 -F0 FF--F0c<V^8dQhRR/#r`ra)rKrLs"rMrNrsrPc |VP'gR#\VP4p\P!V4VFvpVP V4^8dKVPV,pV'gK8VP RR7wrEVP 4'dK6VPR4R# R#)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. NFr)r rrrandomshuffler}popitemdoner5)rUqueuesrrqwaiterrqs& rM_release_waiterBaseConnector._release_waiters}}} dmm$vC**3/!3mmC(G'#OOO7 {{}}%%d+rPc(<V^8dQhRRRS[RR/#)rHrrCrQrJNr))rKrLs"rMrNrs#  _ _ QU rPc :VP'dR#VPPV4VP'dJVPP V4;p'd'VPV4V'gVPVVP 4R#)zRelease acquired connection.N)rr discardrr ryr)rUrrQr"s&&& rMrBaseConnector._release_acquiredsp <<<  u%    d.E.E.I.I#.N%NU%N MM% ++C0 rPrc.<V^8dQhRRRS[RS[RR/#)rHrrCrrrJN)r*r)rKrLs"rMrNr%s3 "    rPcVVP'dR#VPW4VP'gV'gVP'd^VPpVP 4VP 'd.VP'gVPPV4R#VPV,PV\434VPfA\P!VRVPVP VP"R7Vn R#R#)NrGrH)rrr rrrrKrrrrrrrrLr rr)rUrrrrs&&&$ rMrBaseConnector._release%s <<<  s-     0E0E0E **I NN zzz$"?"?"?//66yA  C9; 78    '#*#9#9'' '+'C'C $D  (rPc><V^8dQhRS[RS[R,RRRS[/#rr+rrr*)rKrLs"rMrNrEs1$$ $*.w-$BQ$ $rPc"\4h5ir)NotImplementedError)rUrrrNs&&&&rMr BaseConnector._create_connectionEs"##s )r r rrrrrrrr r rrrrrrr )NNN)&rhrirjrkrrrrVHIGH_LEVEL_SCHEMA_SETallowed_protocol_schema_setr3rVrcrfr'r,r0r9rrrrrGrrr rr}rrrrrrrrrmrnros@rMr>r>s G!"7K4<K" K  K  K',K26K)*KKZ(033*!!$$%%N.((((</%</</|249898v((T((T4   # @$$rPca]tRtRtoRV3RlRlltV3RlRltV3RlRltV3R lR ltV3R lR ltV3R lRlt V3RlRlt Rt Vt R#)_DNSCacheTableiKNc8<V^8dQhRS[R,RS[RR/#)rHttlNmax_sizerJ)rr)rKrLs"rMrN_DNSCacheTable.__annotate__Ls&""EDL"3"$"rPcJ\4Vn/VnWnW nR#r)r _addrs_rr _timestamps_ttl _max_size)rUrrs&&&rMrV_DNSCacheTable.__init__Ls$ M :< !rPc&<V^8dQhRS[RS[/#)rHhostrJ)rsr)rKrLs"rMrNrTs&&&D&rPcWP9#r)r)rUrs&&rM __contains___DNSCacheTable.__contains__Ts~~%%rPcP<V^8dQhRS[S[S[3,RS[S[,RR/#)rHraddrsrJNtuplerrrrr)rKrLs"rMrNrWs/ 3 3uS#X 3tM/B 3t 3rPcWP9dVPPV4\V4\V43VPV&VPe\ 4VP V&\VP4VP8d=VPPRR7wr4VP PVR4R#R#)NFr) rrr rxrrrrrr)rUrr oldest_keyrqs&&& rMr_DNSCacheTable.addWs .. NN & &s +$U|SZ8s 99 $-KD  S ! t~~  / NN222>MJ    T 2 0rPc:<V^8dQhRS[S[S[3,RR/#)rHrrJN)rrr)rKrLs"rMrNrds#((%S/(d(rPcvVPPVR4VPPVR4R#r)rrrrUrs&&rMr_DNSCacheTable.removeds, 3% S$'rPc<V^8dQhRR/#r`ra)rKrLs"rMrNrhs!!t!rPcnVPP4VPP4R#r)rrlrr]s&rMrl_DNSCacheTable.clearhs$   rPcL<V^8dQhRS[S[S[3,RS[S[,/#rHrrJr)rKrLs"rMrNrls(eCHo$}2ErPcVPV,wr#\\W#44p\V4VPP V4V#r)rrrrnextr)rUrrlengthrs&& rM next_addrs_DNSCacheTable.next_addrsls?~~c* VD)* T  ""3' rPc<<V^8dQhRS[S[S[3,RS[/#r)rrrr)rKrLs"rMrNrts#??5c??t?rPcVPfR#VPV,VP,\48#)NF)rrrrs&&rMexpired_DNSCacheTable.expiredts0 99 $tyy09;>>rP)rrrr)N) rhrirjrkrVrrrrlrrrmrnros@rMrrKsK""&& 3 3((!!??rPrc0V^8dQhR\R\/#)rHverifiedrJ)r SSLContext)rKs"rMrNrN{srPc\fR#V'd\P!4pM\P!\P4pV;P\P ,unV;P\P ,unRVn\PVn V;P\P,unVP4VPR4V#)zCreate SSL context. This method is not async-friendly and should be called from a thread because it will load certificates from disk and do other blocking I/O. NF)zhttp/1.1) rcreate_default_contextrPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONset_default_verify_pathsset_alpn_protocols)rrks& rM_make_ssl_contextr {s  {//1 ^^C$;$;< coo-coo-$) !!$ c333++-!!-0 rPTFc*aa]tRtRtoRt]]!R04,tRRRRRRR ^ R R R ]PPR RRRRRRRR] RRR^dR^RRRRR^RRRRRRR] /V3RlV3Rlllt R R/V3R!lV3R"lllt R R/V3R#lV3R$lllt]V3R%lR&l4t]V3R'lR(l4tRKV3R)lR*lltRLV3R+lR,lltV3R-lR.ltV3R/lR0ltV3R1lR2ltV3R3lR4ltR5]/V3R6lR7lltR5]/V3R8lR9lltV3R:lR;ltV3R<lR=ltV3R>lR?ltV3R@lRAlt]3V3RBlRClltV3RDlRElt R5]/V3RFlRGllt!V3RHlRIlt"RJt#Vt$V;t%#)Mr?iu^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/HTTP_Public_Key_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. happy_eyeballs_delay - This is the “Connection Attempt Delay” as defined in RFC 8305. To disable the happy eyeballs algorithm, set to None. interleave - “First Address Family Count” as defined in RFC 8305 loop - Optional event loop. socket_factory - A SocketFactoryType function that, if supplied, will be used to create sockets given an AddrInfoType. ssl_shutdown_timeout - DEPRECATED. Will be removed in aiohttp 4.0. Grace period for SSL shutdown handshake on TLS connections. Default is 0 seconds (immediate abort). This parameter allowed for a clean SSL shutdown by notifying the remote peer of connection closure, while avoiding excessive delays during connector cleanup. Note: Only takes effect on Python 3.11+. tcp verify_sslT fingerprintN use_dns_cache ttl_dns_cachedns_cache_max_sizerfamily ssl_contextr local_addrresolverrrFrrrrrhappy_eyeballs_delayg? interleavesocket_factoryssl_shutdown_timeoutc+<V^8dQhRS[RS[R,RS[RS[R,RS[RS[PRS[R,R S[S[,S[,R S[S[S[3,R,R S[ R,R RS[ ,S[ ,R S[RS[RS[RS[RS[ PR,RS[ RS[ R,RS[R,RS[R,RS[R,S[ ,/#)rHr r Nrrrrrrrrrrrrrrrrrrr)rbytesrsocket AddressFamilyrr,rrrrrsrvrrr.)rKrLs"rMrNTCPConnector.__annotate__sPP>P>P>T\ P>  P> Tz P> P>$$P> $&P>K * ,P>#s(Od*P>#T)P> %<&0P>P>P> !P>" $#P>$''$.%P>&!&'P>($dl)P>*$J+P>,*D0-P>.($.6/P>rPc |<\SV`V V V VVVVR7\WWr4VnVV f$\ VP R7VnRVnM WnRVnW0n\WER7Vn /Vn W`n \P!V 4VnVVnVVn\%4VnVVnVV\*Jd ^VnR#\.P0!R\2^R7\4P6R 8d-Ve)V^8wd"\.P0!RV R 2\8^R7VVnR#) )rrrrrrrNrTF)rrzSThe ssl_shutdown_timeout parameter is deprecated and will be removed in aiohttp 4.0rzssl_shutdown_timeout=zd is ignored on Python < 3.11; only ssl_shutdown_timeout=0 is supported. The timeout will be ignored.r` )superrVr-_sslr7r _resolver_resolver_owner_use_dns_cacher _cached_hosts_throttle_dns_futures_familyaiohappyeyeballsaddr_to_addr_infos_local_addr_infos_happy_eyeballs_delay _interleaver_resolve_host_tasks_socket_factoryr3_ssl_shutdown_timeoutrcrdrerrRuntimeWarning)rUr r rrrrrrrrrrrrrrrrrrr __class__s&$$$$$$$$$$$$$$$$$$$$$rMrVTCPConnector.__init__sC2 /#)"7#9  &c{P   ,$**=DN#'D %N#(D ++   " !1!D!DZ!P%9"%KN5 - 8 +)*D & MMe"    7*(4(A- +,@+AB]]"  *>D &rPrXcF<V^8dQhRS[RS[S[S[,,/#rhri)rKrLs"rMrNrs%  4 D69J4K rPc <\P!VPP44FpVP 4K \ SV`VR7pVPF$pVP 4VPV4K& V#)zClose all ongoing DNS calls.r\) r from_iterabler'rrIr!r r.r)rUrXrrqtr2s&$ rMr TCPConnector._closeso&&t'A'A'H'H'JKC JJLL'.9.5))A HHJ NN1 *rPc$<V^8dQhRS[RR/#rZr)rKrLs"rMrNr"s ) ) ) )rPc <"\ST`T;'gVP^8HR7GRjxL VP'd%VPP4GRjxL R#R#L<L 5i)a Close all opened transports. :param abort_ssl: If True, SSL connections will be aborted immediately without performing the shutdown handshake. If False (default), the behavior is determined by ssl_shutdown_timeout: - If ssl_shutdown_timeout=0: connections are aborted - If ssl_shutdown_timeout>0: graceful shutdown is performed r\N)r!rr0r$r#)rUrXr2s&$rMrTCPConnector.close"s`gmi&R&R43M3MQR3RmSSS    ..&&( ( (  T (s'+A/A+A/A/"A-# A/-A/c <V^8dQhRS[/#rYr?)rKrLs"rMrNr2srPc VP#)zSocket family like AF_INET.)r(r]s&rMrTCPConnector.family1s||rPc <V^8dQhRS[/#rYr)rKrLs"rMrNr7s##t#rPc VP#)z%True if local DNS caching is enabled.)r%r]s&rMrTCPConnector.use_dns_cache6s"""rPcF<V^8dQhRS[R,RS[R,RR/#)rHrNportrJ)rr)rKrLs"rMrNr;s+''C$J'S4Z'SW'rPc Ve#VeVPPW34R#VfVe \R4hVPP4R#)z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)r&rrrl)rUrrCs&&&rMclear_dns_cacheTCPConnector.clear_dns_cache;sL   0    % %tl 3  !1TU U    $ $ &rPc ^<V^8dQhRS[RS[RS[R,R,RS[S[,/#)rHrrCrrDNrJ)rrr rrr)rKrLs"rMrNrDsBaaa"a,4W,=,Da m arPc "\V4'd>RV9d\V4'g \VR4hRVRVRVRVPR^R^/.#VP'gV'd#VFpVP V4GR jxL K VP 'd \R 4hVPPWVPR 7GR jxL pV'd#VFpVPV4GR jxL K V#W3pW`P9diVPPV4'gHVPPV4pV'd#VFpVPV4GR jxL K V#W`P9dVPV,pVP P#4p VP%V 4V'd#VFpVPV4GR jxL K V GR jxL VP'V 4VPPV4#\)4;VPV&pVP+WaW(V4p \,P.!4p \0P2R8d\,P4!WR R 7p MV P7V 4p V P94'gAVP:P%V 4V P=VP:P&4\,P>!V 4GR jxL #ELELSEL0ELELAEL5 TP'T 4i;iL, \,P@dRRlp T P=T 4hi;i5i)z*Resolve host and return list of addresses.:zis not a canonical IPv4 addresshostnamerrCrrQflagsNzConnector is closedrTr]c V^8dQhRRRR/#)rHrz#asyncio.Future[list[ResolveResult]]rJNra)rKs"rMrN0TCPConnector._resolve_host..__annotate__s ! !$I !d !rPc\\\P4;_uu_4VP 4RRR4R# +'giR#;ir)r ryrvCancelledErrorresult)rs&rMdrop_exception2TCPConnector._resolve_host..drop_exceptions.i)?)?@@JJLA@@@s A A r_)!r1r0r$r(r%send_dns_resolvehost_startrrr#resolvesend_dns_resolvehost_endr&rrsend_dns_cache_hitr'rrrrr_resolve_host_with_throttlervrrrrbrcrr.add_done_callbackshieldrP)rUrrCrrr|rrQfuturesfuturerdrresolved_host_taskrRs&&&& rM _resolve_hostTCPConnector._resolve_hostDs   $'@'F'F+D2STTDDdllQQ   """#E::4@@@$|||+,ABB..t$,,.OOC#E88>>>$Jl $$ $T-?-?-G-G-L-L''2237F#E224888$M ,, ,005G+/::+C+C+EF KK #E224888$ ( '%%005 558E9""3'' //4&Q'')   w &!(d4!P !%!1!1$!7 !&&((  $ $ ( (); <  0 01I1I1Q1Q R  (:;; ;AA P?9"9'.<%%  !  0 0 @  sA M?#M?+M?L$M?5M?L' M?!M?:L*;=M?9"M?M?5L-6AM?M?/L00M?9L6>L3?L6CM?AM?MM  M#M?'M?*M?-M?0M?3L66M  M? M.M<<M?c <V^8dQhRS[S[S[3,RS[RS[RS[R,RS[R,R,R S[S[,/#) rHrrrCr[zasyncio.Future[None]rrDNrJ)rrrrr rrr)rKrLs"rMrNrsd'2'2 38_'2'2 '2 +, '2 !D( '2 m '2rPc "V'dEVFpVPV4GRjxL K VFpVPV4GRjxL K VPPW#VPR7GRjxL pV'd#VFpVP V4GRjxL K VP PW4VFp\VR4K TPPT4TP PT4#LLLLu \dp TFp\Y4K hRp ? ii;i TPPT4i;i5i)zResolve host and set result for all waiters. This method must be run in a task and shielded from cancellation to avoid cancelling the underlying lookup. NrL)send_dns_cache_missrTr#rUr(rVr&rr5r7r4r'rr) rUrrrCr[rrrres &&&&&& rMrX(TCPConnector._resolve_host_with_throttles7 0#E33D999$$E::4@@@$..00DLL0QQE#E88>>>$    " "3 .3%  & & * *3 /!!,,S11/:AQ?  c%     & & * *3 /sE !DD!DD2D:D; DD D!8D6E DDDD D=#D88D==EEE c><V^8dQhRS[RS[R,RRRS[/#rr)rKrLs"rMrNrs1    *.w- BQ   rPc "VP'dVPWV4GRjxL wrEV#VPWV4GRjxL wrEV#L&L 5i)zSCreate connection. Has same keyword arguments as BaseEventLoop.create_connection. N)r_create_proxy_connection_create_direct_connection)rUrrrNrqrQs&&&& rMrTCPConnector._create_connectionsU 999!::3PPHA ";;CQQHA QQs!(AAAA AAc4<V^8dQhRS[RS[R,/#)rHrrJN)r+r)rKrLs"rMrNrs %%M%j46G%rPc LVP4'gR#\f \R4hVPp\V\P4'dV#VRJd\ #VP p\V\P4'dV#VRJd\ #\#)aLogic 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.T)rKr RuntimeErrorrxr_SSL_CONTEXT_UNVERIFIEDr"_SSL_CONTEXT_VERIFIED)rUrrks&& rM_get_ssl_contextTCPConnector._get_ssl_contextszz|| ;67 7WW j#.. 1 1  T !* *YY j#.. 1 1  T !* *$$rPc4<V^8dQhRS[RS[R,/#)rHrrJr,)r+r)rKrLs"rMrNrs Mh}6MrPcVPp\V\4'dV#VPp\V\4'dV#R#r)rrxr,r")rUrrets&& rM_get_fingerprintTCPConnector._get_fingerprints;gg c; ' 'Jii c; ' 'JrP client_errorc<V^8dQhRS[RS[S[,RS[RRRS[S[,RS[RS[S[PS[ 3,/#) rHargs addr_infosrrNrBrvrrJ) rrrrr+r6ryrrvrr*)rKrLs"rMrNrss$A$A$A&$A $A ! $A 9o $A$A w  /1 2$ArPc "\VPVPR7;_uu_4GRjxL \P!VVP VP VPVPVPR7GRjxL pVPR4'd7VP'd%\PR8dVPVR&VPP!V/VBRV/BGRjxL uuRRR4GRjxL #LLLL +GRjxL 'giR#;i \dp\!TP"T4ThRp?i\$dp\'TP"T4ThRp?i\(dIpTP*f"\-T\.P04'dhT!TP"T4ThRp?ii;i5i)rN)rylocal_addr_infosrrrrrrsockr)r/ sock_connectrr)start_connectionr+r,r-rr/ryr0rrcreate_connectionr'rrr(r!OSErrorerrnorxrv TimeoutError) rUryrrNrvrxrr}r*s &$$$$*, rM_wrap_create_connection$TCPConnector._wrap_create_connections A#$$W5K5K.>>)%)%;%;)-)C)C#//#'#7#7 JJu%%222((G3595O5OF12!ZZ994U6UPTUU%V%& T1#2D2DcJPS S L)#*<*D,?C D,#D,$AD''D,,D/c"<V^8dQhRRRR/#)rHrr+rJNra)rKrLs"rMrNrDs)))T)rPc VP4'gR#VPpVfQhVPR8wdR#VP4R#)zRaise a :py:exc:`RuntimeError` on missing ``start_tls()``. It is necessary for TLS-in-TLS so that it is possible to send HTTPS queries through HTTPS proxies. This doesn't affect regular HTTP requests, though. Nr;)rKrscheme_check_loop_for_start_tls)rUr proxy_urls&& rM_fail_on_no_start_tls"TCPConnector._fail_on_no_start_tlsDsDzz|| II $$$   w &  &&(rPc<V^8dQhRR/#r`ra)rKrLs"rMrNrVs4rPcrVPPR# \dp\R4ThRp?ii;i)aAn HTTPS request is being sent through an HTTPS proxy. This needs support for TLS in TLS but it is not implemented in your runtime for the stdlib asyncio. Please upgrade to Python 3.11 or higher. For more details, please see: * https://bugs.python.org/issue37179 * https://github.com/python/cpython/pull/28073 * https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support * https://github.com/aio-libs/aiohttp/discussions/6044 N)r start_tlsAttributeErrorrl)rUattr_excs& rMr&TCPConnector._check_loop_for_start_tlsVs<  JJ   K   s 6 16c <V^8dQhRS[/#rYr)rKrLs"rMrNrgs$rPcLVP4R# \dR#i;i)TF)rrlr]s&rM_loop_supports_start_tls%TCPConnector._loop_supports_start_tlsgs,   * * ,  s  ##c><V^8dQhRS[PRS[RR/#)rHunderlying_transportrrJN)rvrr+)rKrLs"rMrNros// / %/// /   / rPc VPPPR8wdR#VPeVPPR8wdR#\ V4P P R4'dR#\PR8;'g\VRR4pV'dR#\P!R\V^R7R#) z6Issue a warning if the requested URL has HTTPS scheme.r;Nuvloop_start_tls_compatibleFaAn HTTPS request is being sent through an HTTPS proxy. This support for TLS in TLS is known to be disabled in the stdlib asyncio (Python <3.11). This is why you'll probably see an error in the log below. It is possible to enable it via monkeypatching. For more details, see: * https://bugs.python.org/issue37179 * https://github.com/python/cpython/pull/28073 You can temporarily patch this as follows: * https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support * https://github.com/aio-libs/aiohttp/discussions/6044 )rrr) request_inforrrr6ri startswithrrgetattrrcrdr1)rUrrasyncio_supports_tls_in_tlss&&& rM_warn_about_tls_in_tls#TCPConnector._warn_about_tls_in_tlsos      & &' 1  99  0 0G ;  $ % 0 0 ; ;H E E '*&6&6'&A' ' W # F # '   G ! rPc <V^8dQhRS[PRS[RRRS[S[,RS[S[P S[3,/#)rHrrrNrBrvrJ)rvrr+r6ryr BaseTransportr*)rKrLs"rMrNrs^T(T(%//T(T(! T( 9o T( w$$o5 6 T(rPc 2"VP4pVPV4p\'dVfQh\VPVP R7;_uu_4GRjxL \ PR8dyVP'dgVPPTTTVP;'g VPVP;'gRVPR7GRjxL pM[VPPTTTVP;'g VPVP;'gRR7GRjxL p\#V\$P&4'd,VP)V4pV'dVP+V4RRR4GRjxL XfRp V!VP4\7V 44hVP9V4Wu3#ELLL \d5TP^8XdTP4hTP!4hi;i \,d@TP!4TP.'gTP0P3T4hi;iL +GRjxL 'giL;i \:dp \=TP4T 4T hRp ? i\>dp \ATP4T 4T hRp ? i\6dIp T PBf"\#T \$PD4'dhT!TP4T 4T hRp ? i\FdXp \IRTP: RTPJR R TPL: R TPN;'gR R T : R 2 4T hRp ? ii;i5i)z$Wrap the raw TCP transport with TLS.Nr{)server_hostnamessl_handshake_timeoutr)rrz:Failed to start TLS (possibly caused by closing transport)z2Cannot initialize a TLS-in-TLS connection to host rIdz4 through an underlying connection to an HTTPS proxy z ssl:defaultz []r)(rrorr/r~rrrr0rrrrtotalr7rrrxrvrrtcheckr%rrrrrconnection_mader'rr(r!rr TypeErrorrrCrr) rUrrrNrv tls_protork tls_transportr msgr*type_errs &&&&& rM_start_tls_connection"TCPConnector._start_tls_connections;MMO **3/ =) ))C #$$W5K5K''72t7Q7Q7Q.2jj.B.B0%&,/,?,?,K,K38829--2G2G4151K1K /C/) /3jj.B.B0%&,/,?,?,K,K38829--2G2G4 /C/) mW->->??"&"7"7"H$$,,44S9T  &*&B&BMM#")$3!-'C'! zz||  %%f-= 6= ' ''NcH Lyy ZW5I5I%J%J*#*<**>?  :::GWGWX 1 LLN88877>>vF"H*0*?*?*ID#//1H$66z8L sAJ *J EEEJ 9J J J )%F0F.F0J +J 4G<J E F+ AF&&F++J .F00G9 "G4-J 4G99J < J A7J>J J  J c h<V^8dQhRS[RS[R,RRRS[S[PS[3,/#r)r+rrrrvrr*)rKrLs"rMrNrVsGf f  f *.w-f BQf w$$o5 6f rPc f"VPV4VP4pVPV4pVPV.V\R7GRjxL wrgVP 4'Ed0V'dVP Wa4\PVn VPVn VPPRRRR7p\WWpP4p VPV 4GRjxL p V P p V fQhV P#VVP$R7V P'V 4GRjxL p RV nV P(^8wdhV P*p V f \-V P(4P.p \1V P2V P4V P(V V P6R7hV'g3VP9RRR7pVf \;R4hVP=4pT'gTPA4T'gUTPCT4pTPETPFTTXTPHTR7GRjxL T PA4#TPKTTTR 7GRjxL T PA4#Wg3#ELPELELh \>dTPA4hi;i T'gTPA4ii;iLL` \>d#T PA4T PA4hi;i T PA4i;i5i) )rvN)rrproxy_headers_hash)read_until_eofr)statusrrr)rz)Transport does not expose socket instance)rNrr}rr)rrN)&rrrrhr#rKrr METH_CONNECTmethodrr_replacerrsendrset_response_paramsrstartrreasonr phraser"rhistoryrrmrldupr7rrorrrr)rUrrrNruntime_has_start_tlsrrrQrr proxy_resprresprrawsockrks&&&& rMrg%TCPConnector._create_proxy_connectionVs ""3' $ = = ?FFsK "&!?!? r71K"@"    ::<<$++I; $00I GGIM$$--t.C,DujjID(~~d33JD #>>+++ ,,#8+/+G+G-(--d33 "&*{{c)"&++"?&0&=&D&DG2&33 LL#';;$+$(LL 1"+":":8T":"R"?". K##*++-1!),!%!6!6s!;J!%!?!? '&$(+ "@""  ""77# 8  "} .446%OO% 1!)1 a!   "  p  "sAL1J!$L17A?L16J$7L1L?LK(L!L12L K* L L1$L1'K,*KK K%%L*L,-LLL..L1) r&r(r,r-r+r.r#r$r/r"r0r'r%)NNr)&rhrirjrkrr frozensetrrr AF_UNSPECr3rVr rrrrrEr^rXrrortr rrrrrrrrrhrgrmrn __classcell__r2rLs@@rMr?r?sI$L#8)UG:L"LP> P>%) P> # P> %' P>#'P>(.';';'E'EP>*.P>04P>.2P>-1P>4<P>"P>P>  !P>"',#P>$26%P>&)*'P>(.2)P>*"&+P>,48-P>.:B/P>P>d %   )u ) )##''aaF'2'2R  %%B$A )= $A$ALA )= AA,))$"/ / l)= T(T(l*I )= IIVf f f rPcaa]tRtRtoRt]]!R04,tR]^d^R3V3RlV3Rlllt ] V3RlR l4t V3R lR lt R t VtV;t#) r@iaaUnix 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. unixFNc<V^8dQhRS[RS[RS[S[,R,RS[RS[RS[P R,RR/# rHpathrrNrrrrJrrrsrrrvr)rKrLs"rMrNUnixConnector.__annotate__se"E>D0     ''$. rPc<<\SV`VVVVVR7WnR#)rrrrrN)r!rV_pathrUrrrrrrr2s&&&&&&&rMrVUnixConnector.__init__s- #/)   rPc <V^8dQhRS[/#rYr)rKrLs"rMrNrcrPc VP#)zPath to unix socket.rr]s&rMrUnixConnector.pathzzrPc><V^8dQhRS[RS[R,RRRS[/#rr)rKrLs"rMrNrs1 *.w-BQ rPc"\VPVPR7;_uu_4GRjxL VPP VP VP 4GRjxL wrERRR4GRjxL V#LPLL +GRjxL 'giX#;i \dWpTPf"\T\P4'dh\TPTPT4ThRp?ii;i5ir)r/r~rrcreate_unix_connectionrrrrrxrvrr&rrrUrrrNrqrQr*s&&&& rMr UnixConnector._create_connections X#$$W5K5K"&!B!BMM4::"   Xyy ZW5I5I%J%J*499c6H6H#NTW W XsD -B%BB%4B)B*B0 B%;B<B%D B%BB%B" B B" B" B% D "B%% D0ADDD rrhrirjrkrrrrr3rVrrrrmrnrrs@@rMr@r@s\ #8)VH:M"M "3;15$rPcaa]tRtRtoRt]]!R04,tR]^d^R3V3RlV3Rlllt ] V3RlR l4t V3R lR lt R t VtV;t#) rAiaNamed 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. npipeFNc<V^8dQhRS[RS[RS[S[,R,RS[RS[RS[P R,RR/#rr)rKrLs"rMrNNamedPipeConnector.__annotate__se"E>D0     ''$. rPc<\SV`VVVVVR7\VP\P 4'g \ R4hWnR#)rz9Named Pipes only available in proactor loop under windowsN)r!rVrxrrvProactorEventLooprlrrs&&&&&&&rMrVNamedPipeConnector.__init__s^ #/)   JJ  % %  K  rPc <V^8dQhRS[/#rYr)rKrLs"rMrNr!rrPc VP#)zPath to the named pipe.rr]s&rMrNamedPipeConnector.path rrPc><V^8dQhRS[RS[R,RRRS[/#rr)rKrLs"rMrNr%s1,, ,*.w-,BQ, ,rPcZ"\VPVPR7;_uu_4GRjxL VPP VP VP 4GRjxL wrE\P!^4GRjxL RRR4GRjxL \\ X4#L|LFL(L +GRjxL 'giL1;i \dLpTPf"\T\P4'dh\TPT4ThRp?ii;i5ir)r/r~rrcreate_pipe_connectionrrrvsleeprrrxrr rrr*rs&&&& rMr%NamedPipeConnector._create_connection%s I#$$W5K5K"&!B!BMM4::"mmA&&&$OU++%' Iyy ZW5I5I%J%J&s'9'93?S H IsD+-CB.C4B6)B0*B6 B2 B6 CB4CD+.C0B62B64C6C <B?= C C CD+C D(AD##D((D+rrrs@@rMrArAs\ #8)WI:N"N "3;152,,,rPr_)r` r)r`rr)r`ra)r>r?r@rArr)mrvrrrrrrc collectionsrrrcollections.abcrrrr contextlibr r:r itertoolsr r rtimertypesrtypingrrrrrrr)rrr9rrabcrrclient_exceptionsrrrr r!r"r#r$r%r&r'r( client_protor* client_reqrepr+r,r-r.r/r0r1r2r3r4r5logr6rr7rr8r bytearrayrr ImportErrorrsrEMPTY_SCHEMA_SETHTTP_SCHEMA_SET WS_SCHEMA_SETHTTP_AND_EMPTY_SCHEMA_SETrr__all__clientrBrCtracingrDrFr}rrrr>rr rnrmr?r@rArarPrMr(s  77CC**EE<0    *HH   %w& 5)%68KK LFJ^^ bT?VW-.4-( +.>>1MA!S%5%59##  "  %,(JUKUKp z (44"J $J $Z-?-?`6*$/+E2b  =b  J4M4nE,E,k5  s H H)(H)