Ë
|
¸^i¾ ã ó$ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m
|
Z
|
d dl m Z d dl mZ d dlmZmZmZ d dlmZ d dlmZ d dlmZmZmZmZm Z m Z m Z m 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-m.Z. d
|
d l/m0Z0m1Z1 d
|
d l2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z= d
|
dl>m?Z? d
|
dl@mAZAmBZBmCZC d
|
dl.mDZDmEZEmFZFmGZGmHZHmIZImJZJ d
|
dlKmLZL d
|
dlMmNZN ej dk\ rd dlPmQZQ n e'eReSddf ZQerd dlTZTeTjª ZUn d dlTZTeTjª ZU eXdh« ZY eXddh« ZZ eXddh« Z[eZeYz Z\e\e[z Z]d ej cxk xr d k nc xs ej d k Z^d Z_erd
|
d l`maZa d
|
d!l@mbZb d
|
d"lcmdZd G d# d$« Zed%e eeW d&dfd'Zf G d( d)« Zg G d* d+eg« Zh G d, d-« Zi G d. d/« Zj G d0 d1« Zkd2eld&eUfd3Zm emd4« Zn emd5« Zo G d6 d7ej« Zp G d8 d9ej« Zq G d: d;ej« Zry# eV$ r dZTeWZUY øw xY w)<é N)Ú OrderedDictÚ defaultdictÚdeque)Úsuppress)Ú
|
HTTPStatus)ÚchainÚcycleÚislice)Ú monotonic)Ú TracebackType)Ú TYPE_CHECKINGÚAnyÚ AwaitableÚCallableÚ DefaultDictÚDequeÚDictÚIteratorÚListÚLiteralÚOptionalÚSequenceÚSetÚTupleÚTypeÚUnionÚcast)Ú AddrInfoTypeÚSocketFactoryTypeé )ÚhdrsÚhelpers)ÚAbstractResolverÚ ResolveResult) ÚClientConnectionErrorÚ ClientConnectorCertificateErrorÚClientConnectorDNSErrorÚClientConnectorErrorÚClientConnectorSSLErrorÚClientHttpProxyErrorÚClientProxyConnectionErrorÚServerFingerprintMismatchÚUnixClientConnectorErrorÚ cert_errorsÚ
|
ssl_errors)ÚResponseHandler)Ú ClientRequestÚ FingerprintÚ_merge_ssl_params)Ú _SENTINELÚ ceil_timeoutÚ is_ip_addressÚnoopÚsentinelÚ set_exceptionÚ
|
set_result)Ú client_logger)ÚDefaultResolver©é é )ÚBufferzmemoryview[int]zmemoryview[bytes]Ú ÚhttpÚhttpsÚwsÚwss)r> é r )r> rF r )r> r? é )Ú BaseConnectorÚ TCPConnectorÚ UnixConnectorÚNamedPipeConnectorr r )Ú ClientTimeout)Ú ConnectionKey)ÚTracec ó: e Zd ZdZdee ddfdZdefdZddZy) Ú_DeprecationWaiter©Ú
|
_awaitableÚ_awaitedÚ awaitableÚreturnNc ó || _ d| _ y ©NFrQ )ÚselfrT s õd H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/connector.pyÚ__init__z_DeprecationWaiter.__init__w s Ø#Ø ó c óD d| _ | j j « S )NT)rS rR Ú __await__©rX s rY r] z _DeprecationWaiter.__await__{ s Ø Ø×(Ñ(Ó*Ð*r[ c óR | j st j dt « y y )NzDConnector.close() is a coroutine, please use await connector.close())rS ÚwarningsÚwarnÚDeprecationWarningr^ s rY Ú__del__z_DeprecationWaiter.__del__ s" Ø}}Ü MMð5ä"õ ð r[ ©rU N) Ú__name__Ú
|
__module__Ú __qualname__Ú __slots__r r rZ r] rc © r[ rY rP rP t s/ Ø*Ið )¨C¡.ð °Tó ð+3ó +ôr[ rP ÚwaitersrU c ó¦ K t j | ddi d{ }|D ]) }t |t « st j
|
d|« + y7 3w)z'Wait for all waiters to finish closing.Úreturn_exceptionsTNz!Error while closing connector: %r)ÚasyncioÚgatherÚ
|
isinstanceÚ Exceptionr; Údebug)rj ÚresultsÚress rY Ú_wait_for_closert sN è ø äNN GÐD¸tÑD×DGØò JÜ c9Õ %Ü × Ñ Ð CÀSÕ IñJð Eús AAA¶Ac
|
ó0 e Zd ZdZdddddedej ddf
|
d Zdefd
|
Z e
|
fd e ddfd Z de d fdZedej fd« Zedeej$ fd« Zedee fd« Zdeg df ddfdZddZddZddZedefd« Zy)Ú
|
ConnectionNÚ connectorrH ÚkeyrM ÚprotocolÚlooprU c óÆ || _ || _ || _ || _ g | _ |j « r.t j t j d« « | _
|
y y )Nr ) Ú_keyÚ
|
_connectorÚ_loopÚ _protocolÚ
|
_callbacksÚ get_debugÚ tracebackÚ extract_stackÚsysÚ _getframeÚ_source_traceback)rX rw rx ry rz s rY rZ zConnection.__init__ sR ð Ø#Ø
|
Ø4<Ø46à >>Ô Ü%.×%<Ñ%<¼S¿]¹]È1Ó=MÓ%NDÕ "ð r[ c ó" d| j dS )Nz Connection<ú>)r| r^ s rY Ú__repr__zConnection.__repr__¤ s Ø TYYK qÐ)Ð)r[ Ú _warningsc ól | j ¨d| i} |j d| t fi |¤ | j j « ry | j
|
j | j | j d¬« | dd}| j | j |d< | j j |« y y )NÚsourcezUnclosed connection T©Ú should_closezUnclosed connection)Úclient_connectionÚmessageÚsource_traceback)
|
r ra ÚResourceWarningr~ Ú is_closedr} Ú_releaser| r Úcall_exception_handler)rX r ÚkwargsÚcontexts rY rc zConnection.__del__§ s¦ Ø >>Ð %Ø Ð%FØ INNÐ 1°$°Ð:¼OÑ VÈvÒ VØzz×#Ñ#Ô%Øà OO× $Ñ $ T§Y¡Y°·±ÈTÐ $Ô Rà,0Ð=RÑSGØ×%Ñ%Ð1Ø.2×.DÑ.DÐ*Ñ+Ø JJ× -Ñ -¨gÕ 6ð &r[ Tc ó y)z9Force subclasses to not be falsy, to make checks simpler.Tri r^ s rY Ú__bool__zConnection.__bool__µ s àr[ c óR t j dt d¬« | j S )Nz%connector.loop property is deprecatedé ©Ú
|
stacklevel)r` ra rb r~ r^ s rY rz zConnection.loop¹ s# ä Ø 3Ô5GÐTUõ
|
ð zzÐr[ c óH | j y | j j S ©N)r Ú transportr^ s rY r zConnection.transportÀ s à >>Ð !ØØ~~×'Ñ'Ð'r[ c ó | j S r )r r^ s rY ry zConnection.protocolÆ s à~~Ð r[ Úcallbackc ó@ | | j j |« y y r )r Úappend)rX r¢ s rY Ú add_callbackzConnection.add_callbackÊ s Ø Ð Ø OO× "Ñ " 8Õ ,ð r[ c ó | j d d g c}| _ |D ]! }t t « 5 |« d d d « # y # 1 sw Y .xY wr )r r rp )rX Ú callbacksÚcbs rY Ú_notify_releasezConnection._notify_releaseÎ sO Ø%)§_¡_±QÐ%7¸Ð" 4?àò BÜ)Ó$ñ Ù÷ ð ñ ÷ ð ús ¬?¿A c ó° | j « | j :| j j | j | j d¬« d | _ y y )NTr ©r© r r} r r| r^ s rY ÚclosezConnection.closeÕ sE Ø × Ñ Ô à >>Ð %Ø OO× $Ñ $ T§Y¡Y°·±ÈTÐ $Ô RØ !DNð &r[ c ó¬ | j « | j 8| j j | j | j « d | _ y y r r« r^ s rY ÚreleasezConnection.releaseÜ s@ Ø × Ñ Ô à >>Ð %Ø OO× $Ñ $ T§Y¡Y°·±Ô ?Ø !DNð &r[ c óX | j d u xs | j j « S r )r Ú is_connectedr^ s rY ÚclosedzConnection.closedã s& à~~ Ð%ÒJ¨T¯^©^×-HÑ-HÓ-JÐ)JÐJr[ rd ) re rf rg r r0 rm ÚAbstractEventLooprZ Ústrr r` r rc r r Úpropertyrz r Ú Transportr ry r r¥ r© r¬ r® Úboolr± ri r[ rY rv rv s- à ÐðOà"ðOð ðOð "ð Oð
|
×'Ñ'ð Oð
|
ó Oð *#ó *ð (0ñ 7 ð 7°Dó 7ð ' $-ó ð ðg×/Ñ/ò ó ðð ð(8 G×$5Ñ$5Ñ6ò (ó ð(ð
|
ð ( ?Ñ3ò ó ð ð- X¨b°$¨hÑ%7ð -¸Dó -óó"ó"ð ðKò Kó ñKr[ rv c ó e Zd ZdZddZy)Ú_ConnectTunnelConnectiona¨ Special 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
|
Nc ó y)aa Do 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.
|
Nri r^ s rY r® z _ConnectTunnelConnection.releaseò ó r[ rd )re rf rg Ú__doc__r® ri r[ rY r¸ r¸ è s ñô r[ r¸ c óT e Zd ZdZdZdej ee ddfdZ d dZ
|
d dZ y)
|
Ú_TransportPlaceholderz.placeholder for BaseConnector.connect function©r± r Ú closed_futurerU Nc ó || _ d| _ y)z)Initialize a placeholder for a transport.Nr¾ )rX r¿ s rY rZ z _TransportPlaceholder.__init__ s à# Ø r[ c ó y)zClose the placeholder.Nri r^ s rY r¬ z_TransportPlaceholder.close rº r[ c ó y)z%Abort the placeholder (does nothing).Nri r^ s rY Úabortz_TransportPlaceholder.abort rº r[ rd ) re rf rg r» rh rm ÚFuturer rp rZ r¬ rà ri r[ rY r½ r½ ü s5 Ù8à'Ið g§n¡n°X¸iÑ5HÑ&Ið Èdó ó
|
%ô4r[ r½ c ób e Zd ZdZdZdZdZeZe ddddddd d
|
e
|
e de f d e d ed ede deej" de ddfdZefdeddfdZd;dZdeddfdZd;dZ d<deee dee dee ddfd Z e de fd « Z e defd « Z e defd « Z d=d Z!d=d!Z"dd"d#e de#d fd$Z$dd"d#e de%e#e fd%Z&e de fd&« Z'd'd(defd)Z(d*e)de)fd+Z*d*e)d,e%d- d.d/de+fd0Z,d'd(d,e%d- ddfd1Z-d'd(d,e%d- dee+ fd2Z.d=d3Z/d'd(d4e0ddfd5Z1dd6d'd(d7e0d8e ddfd9Z2d*e)d,e%d- d.d/de0fd:Z3y)>rH 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.
|
timeout_ceil_threshold - Trigger ceiling of timeout values when
|
it's above timeout_ceil_threshold.
|
loop - Optional event loop.
|
TNg @Féd r é ©Úkeepalive_timeoutÚ force_closeÚlimitÚlimit_per_hostÚenable_cleanup_closedrz Útimeout_ceil_thresholdrÉ rÊ rË rÌ rÍ rz rÎ rU c ól |r| |t urt d« |t u rd}|xs t j « }|| _ d| _ |j « r-t j t j d« « | _ t t « | _ || _ || _ t# « | _ t t" « | _ t) t* |« | _ || _ t t0 « | _ || _ t7 j8 t: |¬« | _ d | _ d | _ |r5tB s/tE jF dt jH tJ d¬« d}| | _& g | _' |jQ « | _) | jR jU d « | jW « y ) Nz6keepalive_timeout cannot be set if force_close is Trueg .@Fr ©rz zoenable_cleanup_closed ignored because https://github.com/python/cpython/pull/118960 is fixed in Python version r r ),r8 Ú
|
ValueErrorrm Úget_running_loopÚ_timeout_ceil_thresholdÚ_closedr r r r r
r r r Ú_connsÚ_limitÚ_limit_per_hostÚsetÚ _acquiredÚ_acquired_per_hostr ÚfloatÚ_keepalive_timeoutÚ _force_closer Ú_waitersr~ Ú functoolsÚpartialr0 Ú_factoryÚ_cleanup_handleÚ_cleanup_closed_handleÚNEEDS_CLEANUP_CLOSEDr` ra Ú version_inforb Ú_cleanup_closed_disabledÚ_cleanup_closed_transportsÚ create_futureÚ_placeholder_futurer: Ú_cleanup_closed)rX rÉ rÊ rË rÌ rÍ rz rÎ s rY rZ zBaseConnector.__init__$ s ñ Ø Ð,Ð1BÌ(Ñ1RÜ ØLóð ð !¤HÑ,Ø$(Ð!àÒ1w×/Ñ/Ó1Ø'=Ô$à Ø >>Ô Ü%.×%<Ñ%<¼S¿]¹]È1Ó=MÓ%NDÔ "ô Ó ð ð Ø -Ô Ü/2«uä Ó ð Ô ô #'¤uÐ.?Ó"@Ô Ø 'Ôô Ó $ð ð
|
Ü!×)Ñ)¬/ÀÔE ð ?CÔ ð FJÔ#á Õ)=Ü MMð%ä%(×%5Ñ%5Ð$6ð8ô #Ø õ ð %*Ð !à,AÐ(AÔ%ØMOÔ'à × Ñ Ó ð Ô ð × Ñ ×+Ñ+¨DÔ1Ø × Ñ Õ r[ r c óx | j ry | j sy | j j « D cg c] }t |« }}| j « d| i} |j
|
d| t fi |¤ | |dd}| j | j |d< | j j |« y c c}w )Nr zUnclosed connector zUnclosed connector)rw Ú connectionsr r )
|
rÔ rÕ ÚvaluesÚreprÚ_closera r r r~ r )rX r ÚcÚconnsr r s rY rc zBaseConnector.__del__q s° Ø <<Ø Ø{{Ø à"&§+¡+×"4Ñ"4Ó"6Ö7QaÐ7Ð7à àDÐ!Ø Ð,¨T¨HÐ5´ÑQÈ&ÒQà Ø Ø+ñ
|
ð
|
× !Ñ !Ð -Ø*.×*@Ñ*@GÐ&Ñ 'Ø
|
|
×)Ñ)¨'Õ2ùò 8s ·B7c ó: t j dt « | S )NzH"with Connector():" is deprecated, use "async with Connector():" instead)r` ra rb r^ s rY Ú __enter__zBaseConnector.__enter__ s Ü ð 4ä ô
|
ð
|
r[ Úexcc ó$ | j « y r )rï )rX rô s rY Ú__exit__zBaseConnector.__exit__ s Ø r[ c ó K | S wr ri r^ s rY Ú
|
__aenter__zBaseConnector.__aenter__ s è ø Ø ùs Úexc_typeÚ exc_valueÚ exc_tracebackc ó@ K | j « d { y 7 wr )r¬ )rX rù rú rû s rY Ú __aexit__zBaseConnector.__aexit__ s è ø ð jjl×Òús c ó | j S )z1Ultimately close connection on releasing if True.)rÝ r^ s rY rÊ zBaseConnector.force_close s ð × Ñ Ð r[ 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Ö r^ s rY rË zBaseConnector.limit¡ s ð {{Ðr[ c ó | j S )z¡The limit for simultaneous connections to the same endpoint.
|
|
Endpoints are the same if they are have equal
|
(host, port, is_ssl) triple.
|
)r× r^ s rY rÌ z BaseConnector.limit_per_hostª s ð ×#Ñ#Ð#r[ c óÎ | j r!| j j « d| _ t « }| j }| j rÖt t « }||z
|
}| j j « D ] \ }}t « }|D ] \ }} |j « r | |z
|
dk\ r|j || f« 2|j }
|
|j « | j r[|j sh| j j |
|
« |s|||< || _ | j r4t j | d|| j" | j$ ¬« | _ yy)zCleanup unused transports.Nr Ú_cleanup©rÎ )râ Úcancelr rÜ rÕ r r Úitemsr° r¤ r r¬ ræ Úis_sslrç r" Úweakref_handler~ rÓ ) rX ÚnowÚtimeoutrì Údeadlinerx rñ ÚaliveÚprotoÚuse_timer s rY r zBaseConnector._cleanup³ s@ à × Ò Ø × Ñ × 'Ñ 'Ô )ð $(DÔ äkØ×)Ñ)à ;;Ü%¤eÓ,KØW}HØ "kk× /Ñ /Ó 1ò -
|
UÜ>C»gØ',ò JOE8Ø ×)Ñ)Ô+°¸8Ñ0CÀqÒ0HØ e¨XÐ%6Ô7Ø Ø %§¡IØKKMØ ×8Ó8¸S¿Z»ZØ ×7Ñ7×>Ñ>¸yÕIðJò Ø',K Ò$ð -ð &DKà ;;Ü#*×#9Ñ#9ØØØØ
|
|
Ø'+×'CÑ'Cô $DÕ ð r[ c ó: | j r| j j « | j D ] }||j « g | _ | j s>t j | d| j | j | j ¬« | _ yy)z~Double confirmation for transport close.
|
|
Some broken ssl servers may leave socket open without proper close.
|
Nrê r )
|
rã r rç rà ræ r" r Ú_cleanup_closed_periodr~ rÓ )rX r s rY rê z BaseConnector._cleanup_closedÚ s ð
|
× &Ò &Ø × 'Ñ '× .Ñ .Ô 0à ×8Ñ8ò "IØÑ$ØÕ!ð "ð +-Ô'à×,Ò,Ü*1×*@Ñ*@ØØ!Ø×+Ñ+Ø
|
|
Ø'+×'CÑ'Cô +DÕ 'ð -r[ ©Ú abort_sslr c ó2 | j |¬« x}st t « « S t |« }t j
|
dk\ r-t j || j d¬« }t |« S | j j |« }t |« S )a Close 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.
|
r r= T©rz Ú eager_start)
|
rï rP r7 rt r rå rm ÚTaskr~ Ú create_task)rX r rj ÚcoroÚtasks rY r¬ zBaseConnector.closeñ s ð ;;°;Ó;Ð;Ð;ô &¤d£fÓ-Ð -Ü wÓ'Ü × Ñ wÒ &ô << ¨4¯:©:À4ÔHDô " $Ó'Ð'ð ::×)Ñ)¨$Ó/DÜ! $Ó'Ð'r[ c ó| g }| j r|S d| _ | j j « r®|| j j « | j
|
j « | j j « D ] }|D ] }|j « | j j « d | _ | j j « d | _ S | j r| j j « | j r| j j « | j j « D ]v }|D ]o \ }}|r8|j r,|j j d« |j « n|j « |j x}s_|j# |« q x | j
|
D ]l }|r8|j r,|j j d« |j « n|j « |j x}s\|j# |« n | j D ] } | | j « || j j « | j
|
j « | j j « D ] }|D ] }|j « | j j « d | _ | j j « d | _ S # | j j « | j
|
j « | j j « D ] }|D ] }|j « | j j « d | _ | j j « d | _ w xY w)NTÚ
|
sslcontext)rÔ r~ r rÕ ÚclearrÙ rÞ rí r râ rç rã r Úget_extra_inforà r¬ r± r¤ )
|
rX r rj Ú keyed_waitersÚ keyed_waiterÚdatar Ú_r± r s
|
rY rï zBaseConnector._close s Ø+-à <<ØNà ð4 /Øzz×#Ñ#Ô%Ø ðT KK× Ñ Ô Ø NN× Ñ Ô "Ø!%§ ¡ ×!5Ñ!5Ó!7ò * Ø$1ò *LØ ×'Ñ'Õ)ñ*ð *ð MM× Ñ Ô !Ø#'DÔ Ø × +Ñ +× 1Ñ 1Ô 3Ø*.DÕ 'ð_ ×#Ò#Ø×$Ñ$×+Ñ+Ô-ð ×*Ò*Ø×+Ñ+×2Ñ2Ô4à ×*Ñ*Ó,ò /Ø $ò
|
/HE1á!Ø !OOØ !OO× :Ñ :¸<Ó HÐ Tà à Ø!&§ ¡ Ð-vÑ-Ø vÕ.ñ
|
/ð /ð ò
|
+á Ø Ø ×6Ñ6°|ÓDÐPàKKMàKKMØ "\\Ð)6Ñ)ØNN 6Õ*ð
|
+ð "× <Ñ <ò & Ø Ñ(Ø OOÕ%ð &ð ð KK× Ñ Ô Ø NN× Ñ Ô "Ø!%§ ¡ ×!5Ñ!5Ó!7ò * Ø$1ò *LØ ×'Ñ'Õ)ñ*ð *ð MM× Ñ Ô !Ø#'DÔ Ø × +Ñ +× 1Ñ 1Ô 3Ø*.DÕ 'øð KK× Ñ Ô Ø NN× Ñ Ô "Ø!%§ ¡ ×!5Ñ!5Ó!7ò * Ø$1ò *LØ ×'Ñ'Õ)ñ*ð *ð MM× Ñ Ô !Ø#'DÔ Ø × +Ñ +× 1Ñ 1Ô 3Ø*.DÕ 'ús& L Ã!C L Æ+A<L È($L É L Ì B.N;c ó | j S )z;Is connector closed.
|
|
A readonly property.
|
)rÔ r^ s rY r± zBaseConnector.closedC s ð ||Ðr[ rx rM c óô d}| j r)| j t | j « z
|
x}dk r|S | j x}r2| j j |« x}r|t |« z }||kD r|S |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 r )rÖ ÚlenrÙ r× rÚ Úget)rX rx Ú total_remainÚ host_remainÚacquireds rY Ú_available_connectionsz$BaseConnector._available_connectionsK s ð à ;;¨D¯K©K¼#¸d¿n¹nÓ:MÑ,MÐ MLÐRSÒSØ Ð ð ×.Ñ.Ð .;Ð .Ø ×2Ñ2×6Ñ6°sÓ;Ð;xÐ;Øs 8}Ñ, ØkÒ)Ø"Ð"àÐr[ Úreqc ó |j }|J i }|j |j }|j t j |t j < t t j |||j | j |j ¬« }|j j t j d« }|L|j « s ||j t j < |S ||j t j < |S )znSet Proxy-Authorization header for non-SSL proxy requests and builds the proxy request for SSL proxy requests.N)ÚheadersÚauthrz Ússl)ÚproxyÚ proxy_headersr+ r! ÚHOSTr1 ÚMETH_GETÚ
|
proxy_authr~ r- ÚpopÚ AUTHORIZATIONr ÚPROXY_AUTHORIZATION)rX r) Úurlr+ Ú proxy_reqr, s rY Ú-_update_proxy_auth_header_and_build_proxy_reqz;BaseConnector._update_proxy_auth_header_and_build_proxy_reqd sä ð iiØÐ Ø"$Ø × Ñ Ð (Ø×'Ñ'GØ [[¬¯©Ñ 3 ÑÜ!Ü MMØ ØØ ØØô
|
ð × Ñ ×$Ñ$¤T×%7Ñ%7¸Ó>Ø Ð Ø::<Ø8< D× 4Ñ 4Ñ5ð Ðð ?C ×!Ñ!¤$×":Ñ":Ñ;ØÐr[ ÚtracesrN r rL c ó K |j }| j ||« d{ x} |j r| j |« |S t |j
|
|j « 4 d{ | j |« dk rf| j ||« d{ | j ||« d{ x}0|j r| j |« |cddd« d{ S t t t | j « « }| j j |« | j r | j | j |« |r |D ] }|j# « d{ | j% |||« d{ }|r |D ] }|j' « d{ | j( r|j+ « t- d« ddd« d{ | j j3 « | j j « | j r1| j | } | j3 |« | j |« t5 | ||| j6 « S 7 Q7
|
7 ß7 È7 7 7 ù7 Ü# t. $ r | j1 ||« w xY w7 Å# 1 d{ 7 sw Y ÕxY ww)z'Get from pool or create new connection.Nr zConnector is closed.) Úconnection_keyÚ_getr. r8 r5 ÚconnectÚceil_thresholdr( Ú _wait_for_available_connectionr r0 r½ ré rÙ Úaddr× rÚ Ú send_connection_create_startÚ_create_connectionÚsend_connection_create_endrÔ r¬ r% Ú BaseExceptionÚ_release_acquiredÚremoverv r~ )
|
rX r) r9 r rx ÚconnÚ placeholderÚtracer Úacquired_per_hosts
|
rY r= zBaseConnector.connect~ s è ø ð × Ñ Ø )) C¨Ó0×0Ð 0DÐ =ð yyØ×BÑBÀ3ÔGØKä §¡°×1GÑ1GÓH÷ Hñ HØ×*Ñ*¨3Ó/°1Ò4Ø×9Ñ9¸#¸vÓF×FÐFØ"&§)¡)¨C°Ó"8× 8Ð8DÐEØyyØ ×JÑJÈ3ÔOØ ÷ H÷ Hñ Hô Ü Ô!6°t×7OÑ7OÓ!PóKð NN× Ñ {Ô +Ø×#Ò#Ø×'Ñ'¨Ñ,×0Ñ0°Ô=ð Hñ Ø!'ò CØ #× @Ñ @Ó B×BÑBðCà "× 5Ñ 5°c¸6À7Ó K×KÙØ!'ò AØ #× >Ñ >Ó @×@Ñ@ðAð <<ØKKMÜ/Ð0FÓGÐG÷A H÷ HðN × Ñ kÔ*Ø ×Ñ5Ô!Ø × Ò Ø $× 7Ñ 7¸Ñ <Ð Ø × $Ñ $ [Ô 1Ø × !Ñ ! %Ô (Ü$ U¨D¯J©JÓ7Ð7ði 1ùð HùàFùØ 8ùð Hùð* CùØKøð AùÜ ò Ø×&Ñ& s¨KÔ8Øð úð5 Hø÷ H÷ Hñ Hüsê "K¤I5¥A KÁ.I8Á/KÁ2*J- I; J-Â6I>Â7$J-à KÃ'JÃ(KÃ-A(J-ÅJ Å0JÅ1 J Æ JÆ J Æ,J Æ-J Æ3'J-Ç KÇ%J+Ç&BKÉ8KÉ;J-É>J-ÊKÊJ ÊJ Ê J Ê J(Ê(J-Ê+KÊ-J?Ê3J6 Ê4J?Ê;Kc ól K d} | j j « }| j | }d||< |r|j |d¬« |r |D ] }|j « d{ | d{ |r |D ] }|j « d{ |j |d« | j j |d« s| j |= | j |« dkD ry|dz }ç7 7 ~7 a# |j |d« | j j |d« s| j |= w w xY ww)z&Wait for an available connection slot.r TNF©Úlastr ) r~ rè rÞ Ú move_to_endÚ send_connection_queued_startÚsend_connection_queued_endr3 r$ r( )rX rx r9 ÚattemptsÚfutr rI s rY r? z,BaseConnector._wait_for_available_connection¹ sK è ø ð ØØ(,¯
|
©
|
×(@Ñ(@Ó(BCØ MM¨#Ñ .MØ!%M#Ñ Ùð ×)Ñ)¨#°EÐ)Ô:ð +ñ Ø!'ò CØ #× @Ñ @Ó B×BÑBðCà ÙØ!'ò AØ #× >Ñ >Ó @×@Ñ@ðAð
|
×!Ñ! # tÔ,Ø}}×(Ñ(¨¨dÔ3Ø cÑ*à×*Ñ*¨3Ó/°!Ò3ØØ MHð; ð CøØøð Aùð ×!Ñ! # tÔ,Ø}}×(Ñ(¨¨dÔ3Ø cÑ*ð 4üsU AD4Á
|
C3 Á$C-Á% C3 Á0C/Á1 C3 ÂC1ÂC3 ÂAD4Ã-C3 Ã/C3 Ã1C3 Ã3>D1Ä1D4c óì K | j j |« x}yt « }|r|j « \ }}|j « r ||z
|
| j
|
k r|s | j |= | j j |« | j r | j | j |« |r |D ] } |j « d{ t | ||| j « S |j }|j! « | j" s'|j$ r| j& j) |« |r| j |= y7 # t $ r | j ||« w xY ww)znGet next reusable connection for the key or None.
|
|
The connection will be marked as acquired.
|
N)rÕ r$ r Úpopleftr° rÜ rÙ r@ r× rÚ Úsend_connection_reuseconnrD rE rv r~ r r¬ ræ r rç r¤ ) rX rx r9 rñ Út1r Út0rI r s rY r< zBaseConnector._getã sR è ø ð [[__ SÓ)Ð )EÐ 2Øä [ÚØ IE2ð ×!Ñ!Ô#¨¨R©°4×3JÑ3JÒ(JÙ à CÐ(Ø×"Ñ" 5Ô)Ø×'Ò'Ø×+Ñ+¨CÑ0×4Ñ4°UÔ;ÙØ!'ò "ð"Ø"'×"AÑ"AÓ"C× CÑ Cð"ô " $¨¨U°D·J±JÓ?Ð?ð IØ KKMà×0Ò0°S·Z²ZØ×/Ñ/×6Ñ6°yÔAó3 ð8 KKÐ Øð DùÜ ,ò "Ø × 2Ñ 2°3¸Ô >Ø !ð"üs7 B<E4Â?EÃEÃEÃA+E4ÅE4ÅEÅ E1Å1E4c óD | j syt | j « }t j |« |D ]d }| j |« dk r| j | }|s*|j d¬« \ }}|j « s|j d« y|r;f y)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 FrL )rÞ ÚlistÚrandomÚshuffler( ÚpopitemÚdoner: )rX Úqueuesrx rj Úwaiterr s rY Ú_release_waiterz BaseConnector._release_waiter s ð }}Ø ô dmmÓ$ÜvÔ àò CØ×*Ñ*¨3Ó/°!Ò3Øàmm CÑ(GÚØ #OO°OÓ 7 Ø {{}Ø×%Ñ% dÔ+Ùó ñ r[ r c ó | j ry| j j |« | j r=| j j |« x}r |j |« |s | j |= | j « y)z Release acquired connection.N)rÔ rÙ Údiscardr× rÚ r$ r` )rX rx r rñ s rY rE z BaseConnector._release_acquired' sk à <<à à × Ñ uÔ%Ø × Ò ¨d×.EÑ.E×.IÑ.IÈ#Ó.NÐ%N UÐ%NØ MM%Ô ÙØ×+Ñ+¨CÐ0Ø × Ñ Õ r[ r ry r c óú | j ry | j ||« | j s|s |j rP|j }|j « |j r'| j s| j j |« y | j | j |t « f« | j >t j | d| j | j | j" ¬« | _ y y )Nr r )rÔ rE rÝ r r r¬ r ræ rç r¤ rÕ r râ r" r rÜ r~ rÓ )rX rx ry r r s rY r zBaseConnector._release4 sÍ ð <<à à × Ñ s HÔ-à × Ò ¡ °×0EÒ0EØ ×*Ñ*IØ NNÔ àzz $×"?Ò"?Ø×/Ñ/×6Ñ6°yÔAØ à CÑ× Ñ ¬9«;Ð 7Ô8à × Ñ Ð 'Ü#*×#9Ñ#9ØØØ×'Ñ'Ø
|
|
Ø'+×'CÑ'Cô $DÕ ð (r[ c ó K t « wr )ÚNotImplementedError)rX r) r9 r s rY rB z BaseConnector._create_connectionT s è ø ô "Ó#Ð#ùs )rU rH )NNNrd )4re rf rg r» rÔ r r ÚHIGH_LEVEL_SCHEMA_SETÚallowed_protocol_schema_setr8 r ÚobjectrÛ r¶ Úintr rm r² rZ r` r rc ró rö rø r rD r rý r´ rÊ rË rÌ r rê r r¬ r rï r± r( r1 r8 rv r= r? r< r` r0 rE r rB ri r[ rY rH rH sú ñ ð GØ Ðð !Ðà"7Ð ð
|
9AØ !ØØ Ø&+Ø48Ø()òK ð ! ¨¨uÐ!4Ñ5ðK ð ð K ð
|
ð K ð ð K ð $ðK ð w×0Ñ0Ñ1ðK ð !&ðK ð
|
óK ðZ (0ñ 3 ð 3°Dó 3ó*ðSð Tó óð
|
37Ø-1Ø15ñ à4 Ñ.Ñ/ðð MÑ*ðð Ñ.ð ð
|
|
ó ð ð!Tò !ó ð!ð ðsò ó ðð ð$ ò $ó ð$ó%óNð. */ò ( $ð (°9¸T±?ó (ð( +0ò </ 4ð </°D¸À6Ñ9JÑ4Kó </ð| ð ò ó ð ð ¨/ð ¸có ð2Ø ðà óð498Ø ð98Ø*.¨w©-ð98ØBQð98à ó98ðv(Ø"ð(Ø,0°©Mð(à ó(ðT(Ø"ð(Ø,0°©Mð(à *Ñ ó(óTð4 _ð ¸_ð ÐQUó ð$ #ò à ð ð "ð ð
|
ð ð
|
ó ð@$Ø ð$Ø*.¨w©-ð$ØBQð$à ô$r[ rH c ó´ e Zd Zddee ddfdZdedefdZde e
|
e f de e ddfd Zde e
|
e f ddfd
|
Zdd Zde e
|
e f de e fd Zde e
|
e f defd Zy)Ú_DNSCacheTableNÚttlrU c ó. i | _ i | _ || _ y r )Ú _addrs_rrÚ _timestampsÚ_ttl)rX rl s rY rZ z_DNSCacheTable.__init__[ s ØUWØ9;ÔØ r[ Úhostc ó || j v S r )rn )rX rq s rY Ú __contains__z_DNSCacheTable.__contains__` s Øt~~Ð%Ð%r[ rx Úaddrsc ó t |« t |« f| j |< | j t « | j
|
|< y y r )r r# rn rp r ro )rX rx rt s rY r@ z_DNSCacheTable.addc s> Ü $ U|¬S°«ZÐ 8sÑà 99Ð Ü$-£KD× Ñ SÒ !ð !r[ c ó | j j |d « | j | j j |d « y y r )rn r3 rp ro ©rX rx s rY rF z_DNSCacheTable.removei s; Ø ×Ñ3 Ô%à 99Ð Ø × Ñ × Ñ dÕ +ð !r[ c ól | j j « | j j « y r )rn r ro r^ s rY r z_DNSCacheTable.clearo s$ Ø × Ñ Ô Ø ×Ñ× Ñ Õ r[ c ój | j | \ }}t t ||« « }t |« |S r )rn rY r
|
Únext)rX rx rz Úlengthrt s rY Ú
|
next_addrsz_DNSCacheTable.next_addrss s1 Ø~~ cÑ* fÜVD &Ó)Ó*ä T
|
Ø r[ c ój | j y| j | | j z t « k S rW )rp ro r rw s rY Úexpiredz_DNSCacheTable.expiredz s0 Ø 99Ð Øà× Ñ Ñ$ t§y¡yÑ0´9³;Ñ>Ð>r[ r rd )re rf rg r rÛ rZ rh r¶ rs r r³ ri r r$ r@ rF r r| r~ ri r[ rY rk rk Z s® ñH UOð °tó ð
|
& ð &¨Dó &ð0uS #Xð 0¨t°MÑ/Bð 0Àtó 0ð ,% S /ð ,¨dó ,ó !ðe C¨ Hoð °$°}Ñ2Eó ð?5 c ?ð ?¨tô ?r[ rk Úverifiedc óÔ t y| rt j « }n¸t j t j « }|xj t j
|
z c_ |xj t j z c_ d|_ t j |_ |xj t j z c_ |j « |j d« |S )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) r- Úcreate_default_contextÚ
|
SSLContextÚPROTOCOL_TLS_CLIENTÚoptionsÚ OP_NO_SSLv2Ú OP_NO_SSLv3Úcheck_hostnameÚ CERT_NONEÚ verify_modeÚOP_NO_COMPRESSIONÚset_default_verify_pathsÚset_alpn_protocols)r r s rY Ú_make_ssl_contextr s¦ ô {àÙÜ×/Ñ/Ó1
|
ä^^¤C×$;Ñ$;Ó<
|
Ø×ÒcooÑ-ÕØ×ÒcooÑ-ÕØ$)
|
Ô!Ü!$§ ¡
|
Ô Ø×Òc× 3Ñ 3Ñ3ÕØ×+Ñ+Ô-Ø×!Ñ! -Ô0Ø Ðr[ TFc , ó e Zd ZdZe edh« z Zddddej j dddde
|
dddddd d
|
dde
|
d d e d e e de de e dej de e dee eef de eeef de e dedeef de dedede de ej0 ded e e d e e d e e d eedef f( fd Zdd!d"e d#e e e f fd$Z dd!d"e d#df fd%Z e d#efd&« Z!e d#e fd'« Z" dJd(e e d)e e d#dfd*Z# dKd(ed)ed+e e$d, d#e e% fd-Z&d.eeef d(ed)ed/e'd0 d+e e$d, d#e e% f d1Z(d2e)d+e d, d3d4d#e*fd5Z+d2e)d#e e fd6Z,d2e)d#e d7 fd8Z-e.d9d:e/d;e e0 d2e)d3d4d<e1e2 d=e/d#eejf e*f fd>Z4e.d9d:e/d2e)d3d4d<e1e2 d=e/d#eejf e*f f d?Z5dLd@Z6dMdAZ7d#e fdBZ8dCejf d2e)d#dfdDZ9e.fdCejf d2e)d3d4d<e1e2 d#eejt e*f f
|
dEZ;dFe e% d#e e0 fdGZ<e.d9d2e)d+e d, d3d4d<e1e2 d#eejf e*f f
|
dHZ=d2e)d+e d, d3d4d#eejt e*f fdIZ> xZ?S )NrI uæ 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+.
|
ÚtcpTNé
|
FrÆ r rÇ g Ð?)Ú
|
verify_sslÚ fingerprintÚ use_dns_cacheÚ ttl_dns_cacheÚfamilyÚ ssl_contextr- Ú
|
local_addrÚresolverrÉ rÊ rË rÌ rÍ rz rÎ Úhappy_eyeballs_delayÚ
|
interleaveÚsocket_factoryÚssl_shutdown_timeoutr r r r r r r- r r rÉ rÊ rË rÌ rÍ rz rÎ r r r r c óh t | |
|
| | | |||¬« t ||||« | _ | | #t | j
|
¬« | _ d| _ n| | _ d| _ || _ t |¬« | _
|
i | _ || _ t j |« | _ || _ || _ t% « | _ || _ | |t* u rd| _ y t/ j0 dt2 d¬ « t4 j6 d
|
k r'|%|dk7 r t/ j0 d | d t8 d¬ « || _ y ) NrÈ rÐ TF)rl r zSThe ssl_shutdown_timeout parameter is deprecated and will be removed in aiohttp 4.0r r ©r> é zssl_shutdown_timeout=zd is ignored on Python < 3.11; only ssl_shutdown_timeout=0 is supported. The timeout will be ignored.) ÚsuperrZ r3 Ú_sslr< r~ Ú _resolverÚ_resolver_ownerÚ_use_dns_cacherk Ú _cached_hostsÚ_throttle_dns_futuresÚ_familyÚaiohappyeyeballsÚaddr_to_addr_infosÚ_local_addr_infosÚ_happy_eyeballs_delayÚ _interleaverØ Ú_resolve_host_tasksÚ_socket_factoryr8 Ú_ssl_shutdown_timeoutr` ra rb r rå ÚRuntimeWarning)rX r r r r r r r- r r rÉ rÊ rË rÌ rÍ rz rÎ r r r r Ú __class__s rY rZ zTCPConnector.__init__É sJ ø ô0 ÑØ /Ø#ØØ)Ø"7ØØ#9ð ô
|
ô & c¨:°{ÀKÓP á Ø Ð Ü ,°$·*±*Ô =DNØ#'DÕ à %DNØ#(DÔ à +ÔÜ +° Ô >Ôð ð Ô"ð Ü!1×!DÑ!DÀZÓ!PÔ Ø%9Ô"Ø%ÔÜMPËUÔ Ø -Ô Ù à ¤8Ñ +Ø)*DÕ &ô MMØeÜ"Ø õ ô × Ñ 7Ò*Ø(Ð4Ø(¨AÒ-ä Ø+Ð,@Ð+Að B]ð ]ä"Ø õ ð *>DÕ &r[ r r rU c ó t j | j j « « D ] }|j « t
|
| |¬« }| j D ]# }|j « |j |« % |S )z Close all ongoing DNS calls.r ) r Ú from_iterabler¦ rí r r rï r r¤ )rX r rR rj Útr± s rY rï zTCPConnector._close sx ø ä×&Ñ& t×'AÑ'A×'HÑ'HÓ'JÓKò CØ JJLð ô '.¨9.Ó5à×)Ñ)ò AØ HHJØ NN1Õ ð ð r[ c óÄ K | j r"| j j « d{ t | |xs | j dk( ¬« d{ y7 .7 w)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
|
Nr r )r£ r¢ r¬ r r¯ )rX r r± s rY r¬ zTCPConnector.close% sV øè ø ð × Ò Ø..×&Ñ&Ó(× (Ð (ägm iÒ&R°4×3MÑ3MÐQRÑ3RmÓS×SÑSð )øàSús! *A A ®(A ÁA ÁA Á A c ó | j S )zSocket family like AF_INET.)r§ r^ s rY r zTCPConnector.family4 s ð ||Ðr[ c ó | j S )z%True if local DNS caching is enabled.)r¤ r^ s rY r zTCPConnector.use_dns_cache9 s ð ×"Ñ"Ð"r[ rq Úportc ó | | | j j ||f« y|| t d« | j j « y)z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)r¥ rF rÑ r )rX rq r¸ s rY Úclear_dns_cachez TCPConnector.clear_dns_cache> sP ð Ð Ð 0Ø × Ñ × %Ñ % t¨T lÕ 3Ø Ð Ð!1Ü Ð TÓUÐ Uà × Ñ × $Ñ $Õ &r[ r9 rN c óî K t |« r|||| j dddgS | j sv|r |D ] }|j |« d{ | j j ||| j ¬« d{ }|r |D ] }|j |« d{ |S ||f}|| j v rZ| j j |« s?| j j |« }|r |D ] }|j |« d{ |S || j v r| j | }| j j « } |j | « |r |D ] }|j |« d{ | d{ |j | « | j j |« S t! « x| j |< }| j# |||||« }
|
t% j& « } t( j* dk\ rt% j, |
|
| d¬« } n| j/ |
|
« } | j1 « s@| j2 j | « | j5 | j2 j « t% j6 | « d{ S 7 U7 &7 7 7 77 -# |j | « w xY w7 ,# t$ j8 $ r d d} | j5 | « w xY ww)
|
z*Resolve host and return list of addresses.r )Úhostnamerq r¸ r r ÚflagsN©r r= Tr c ó t t t j « 5 | j « d d d « y # 1 sw Y y xY wr )r rp rm ÚCancelledErrorÚresult)rR s rY Údrop_exceptionz2TCPConnector._resolve_host.<locals>.drop_exception s0 Ü i¬×)?Ñ)?Ó@ñ !ØJJL÷!÷ !ñ !ús 9¹A)rR z#asyncio.Future[List[ResolveResult]]rU N) r6 r§ r¤ Úsend_dns_resolvehost_startr¢ ÚresolveÚsend_dns_resolvehost_endr¥ r~ r| Úsend_dns_cache_hitr¦ r~ rè r@ rb rØ Ú_resolve_host_with_throttlerm rÒ r rå r r r] r Úadd_done_callbackÚshieldrÀ )rX rq r¸ r9 rI rs rx rÁ ÚfuturesÚfuturer rz Úresolved_host_taskr s rY Ú _resolve_hostzTCPConnector._resolve_hostI sß è ø ô Ô ð !%Ø Ø Ø "llØ Ø ñ ð ð ð ×"Ò"áØ #ò AEØ ×:Ñ:¸4Ó@×@Ñ@ðAð ×.Ñ.¨t°TÀ$Ç,Á,Ð.ÓO×OCáØ #ò ?EØ ×8Ñ8¸Ó>×>Ñ>ð?ð JàTlØ $×$Ñ$Ñ $¨T×-?Ñ-?×-GÑ-GÈÔ-Là×'Ñ'×2Ñ2°3Ó7FáØ #ò 9EØ ×2Ñ2°4Ó8×8Ñ8ð9àMð $×,Ñ,Ñ ,à×0Ñ0°Ñ5GØ+/¯:©:×+CÑ+CÓ+EFØ KKÔ ÙØ #ò 9EØ ×2Ñ2°4Ó8×8Ñ8ð9ð (Ø à Ô'Ø×%Ñ%×0Ñ0°Ó5Ð 5ô 58³EÐ9×"Ñ" 3Ñ'¨'ð ×/Ñ/°°T¸4ÀÈ&ÓQÜ×'Ñ'Ó)Ü × Ñ wÒ &ä!(§ ¡ ¨d¸È4Ô!PÑ à!%×!1Ñ!1°$Ó!7Ð à!×&Ñ&Ô(Ø × $Ñ $× (Ñ (Ð);Ô <Ø × 0Ñ 0°×1IÑ1I×1QÑ1QÔ Rð Ü Ð(:Ó;×;Ð ;ð{ AùàOùð ?ùð 9ùð" 9ùà úà Õ'úð. <ùÜ×%Ñ%ò ó !ð × 0Ñ 0° Ô @Ø ð üs± AK5Á J Á
|
1K5Á;J!Á< K5ÂJ$ A+K5ÄJ'ÄA+K5Å3J*Å4K5Å;J0 Æ J-ÆJ0 ÆC;K5ÊK ÊKÊK Ê K5Ê!K5Ê$K5Ê'K5Ê*K5Ê-J0 Ê0KËK5ËK Ë*K2Ë2K5rx rÊ zasyncio.Future[None]c ó K |r@|D ] }|j |« d{ |D ] }|j |« d{ | j j ||| j ¬« d{ }|r |D ] }|j |« d{ | j j ||« |D ] }t |d« | j j |« | j j |« S 7 Þ7 À7 7 r# t $ r} |D ] }t || « d} ~ ww xY w# | j j |« w xY ww)z²Resolve 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.
|
Nr¾ )Úsend_dns_cache_missrà r¢ rÄ r§ rÅ r¥ r@ r: rD r9 r¦ r3 r| )
|
rX rx rq r¸ rÊ r9 rI rt rR Úes
|
rY rÇ z(TCPConnector._resolve_host_with_throttle¤ s\ è ø ð 0ÙØ #ò :EØ ×3Ñ3°DÓ9×9Ñ9ð:ð $ò AEØ ×:Ñ:¸4Ó@×@Ñ@ðAð ..×0Ñ0°°tÀDÇLÁLÐ0ÓQ×QEÙØ #ò ?EØ ×8Ñ8¸Ó>×>Ñ>ð?ð × Ñ × "Ñ " 3¨Ô .Ø ò &Ü3 Õ%ñ &ð × &Ñ &× *Ñ *¨3Ô /à×!Ñ!×,Ñ,¨SÓ1Ð1ð/ :øð AøàQøð ?ùô
|
ò ð ò &Ü c 1Õ%ð &à ûð ûð × &Ñ &× *Ñ *¨3Õ /üsy E D C> D ¿D Á 1D Á1DÁ2 D ÂDÂ5D Ã6E Ã>D Ä D ÄD ÄD Ä D(ÄD#Ä#D(Ä(D+ Ä+ EÅE r) r rL c óª K |j r | j |||« d{ \ }}|S | j |||« d{ \ }}|S 7 )7 w)zcCreate connection.
|
|
Has same keyword arguments as BaseEventLoop.create_connection.
|
N)r. Ú_create_proxy_connectionÚ_create_direct_connection)rX r) r9 r r r s rY rB z TCPConnector._create_connectionÍ s] è ø ð 99Ø !× :Ñ :¸3ÀÈÓ P×PHAuð ð "× ;Ñ ;¸CÀÈÓ Q×QHAuà ð QøàQús! #A¥A¦ AÁAÁ
|
AÁAc ó |j « syt t d« |j }t |t j « r|S |durt
|
S | j }t |t j « r|S |durt
|
S t S )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.T)r r- Ú RuntimeErrorro r Ú_SSL_CONTEXT_UNVERIFIEDr¡ Ú_SSL_CONTEXT_VERIFIED)rX r) r s rY Ú_get_ssl_contextz TCPConnector._get_ssl_contextÛ s} ð zz|Øä ;Ü Ð 6Ó7Ð 7ØWW
|
Ü j¤#§.¡.Ô 1Ø Ð Ø TÑ !ä*Ð *ØYY
|
Ü j¤#§.¡.Ô 1Ø Ð Ø TÑ !ä*Ð *Ü$Ð$r[ r2 c ó| |j }t |t « r|S | j }t |t « r|S y r )r- ro r2 r¡ )rX r) Úrets rY Ú_get_fingerprintz TCPConnector._get_fingerprintü s5 ØggÜ c;Ô 'ØJØiiÜ c;Ô 'ØJØr[ ©Ú client_errorÚargsÚ
|
addr_infosrÝ r c óX K t |j |j ¬« 4 d { t j || j
|
| j | j | j | j ¬« d { }|j d« r.| j r"t j dk\ r| j |d< | j j |i |¤d|i¤ d { cd d d « d { S 7 Ñ7 ~7 7 # 1 d { 7 sw Y y xY w# t $ r }t! |j" |« |d }~wt$ $ r }t' |j" |« |d }~wt( $ r@}|j* t- |t. j0 « r ||j" |« |d }~ww xY ww)N©r> )rß Úlocal_addr_infosr r rz r r- r r Úsock)r5 Ú sock_connectr> r¨ Ústart_connectionrª r« r¬ r~ r® r$ r¯ r rå Úcreate_connectionr. r& r; r/ r) ÚOSErrorÚerrnoro rm Ú TimeoutError) rX rß r) r rÝ rÞ r rã rô s rY Ú_wrap_create_connectionz$TCPConnector._wrap_create_connection s è ø ð AÜ#Ø×$Ñ$°W×5KÑ5Kô÷ Vñ Vô .× >Ñ >Ø )Ø%)×%;Ñ%;Ø)-×)CÑ)CØ #× /Ñ /Ø Ø#'×#7Ñ#7ô ÷ ð JJuÔ%Ø ×2Ò2Ü×(Ñ(¨GÒ3à59×5OÑ5OFÐ1Ñ2Ø 9TZZ× 9Ñ 9¸4Ð UÀ6Ñ UÐPTÒ U×U÷% V÷ Vò Vøðøð Vøð% Vø÷ V÷ Vñ Vûô& ò TÜ1°#×2DÑ2DÀcÓJÐPSÐ SûÜò LÜ)¨#×*<Ñ*<¸cÓBÈÐ KûÜò AØyyÐ ¤Z°´W×5IÑ5IÔ%JØÙ s× 1Ñ 1°3Ó7¸SÐ @ûð Aüs· F*%D ©C;ªD ADÁ>C=Á?A&DÃ%C?Ã&DÃ) D Ã5DÃ6D Ã:F*Ã;D Ã=DÃ?DÄD ÄDÄ D Ä
|
DÄD ÄF*ÄD Ä F'Ä!D8Ä8 F'ÅEÅ F'Å';F"Æ"F'Æ'F*c ó$ K t |j |j ¬« 4 d { | j j |i |¤ d { cd d d « d { S 7 97 7 # 1 d { 7 sw Y y xY w# t
|
$ r }t |j |« |d }~wt $ r }t |j |« |d }~wt $ r@}|j t |t j « r ||j |« |d }~ww xY ww©Nrá )r5 rä r> r~ ræ r. r& r; r/ r) rç rè ro rm ré )rX r) r rÝ rÞ r rô s rY Ú_wrap_existing_connectionz&TCPConnector._wrap_existing_connection+ s è ø ð AÜ#Ø×$Ñ$°W×5KÑ5Kô÷ Kñ Kð :TZZ× 9Ñ 9¸4Ð JÀ6Ñ J×J÷ K÷ Kò Køð Køð Kø÷ K÷ Kñ Kûô ò TÜ1°#×2DÑ2DÀcÓJÐPSÐ SûÜò LÜ)¨#×*<Ñ*<¸cÓBÈÐ KûÜò AØyyÐ ¤Z°´W×5IÑ5IÔ%JØÙ s× 1Ñ 1°3Ó7¸SÐ @ûð Aüs£ D%A> ©A#ªA> A)Á A%ÁA)Á A> Á A'Á A> Á"DÁ#A> Á%A)Á'A> Á)A;Á/A2 Á0A;Á7A> Á:DÁ;A> Á> D ÂB  D Â*Cà D à ;DÄD Ä Dc ó |j « sy|j }|J |j dk7 ry| j « y)zóRaise 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.
|
NrC )r r. ÚschemeÚ_check_loop_for_start_tls)rX r) Ú proxy_urls rY Ú_fail_on_no_start_tlsz"TCPConnector._fail_on_no_start_tlsA sB ð zz|Ø àII ØÐ$Ð$Ð$Ø × Ñ wÒ &Ø à ×&Ñ&Õ(r[ c ól | j j y # t $ r}t d« |d }~ww xY w)Na¶ An 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
|
)r~ Ú start_tlsÚAttributeErrorrÕ )rX Úattr_excs rY rð z&TCPConnector._check_loop_for_start_tlsS s< ð Ø JJ× Ó øÜ ò Ü ð Kó ð ð ûð ús 3¢ .®3c óD | j « y# t $ r Y yw xY w)NTF)rð rÕ r^ s rY Ú_loop_supports_start_tlsz%TCPConnector._loop_supports_start_tlsd s, ð Ø × *Ñ *Ô ,ð øô ò Ùð ús Úunderlying_transportc ó |j j j dk7 ryt |« j j d« ryt j dk\ xs t |dd« }|ryt j dt | d¬ « y)
|
z6Issue a warning if the requested URL has HTTPS scheme.rC NÚuvloopr Ú_start_tls_compatibleFa An 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
|
r> )r r ) Ú request_infor6 rï Útyperf Ú
|
startswithr rå Úgetattrr` ra r° )rX rù r) Úasyncio_supports_tls_in_tlss rY Ú_warn_about_tls_in_tlsz#TCPConnector._warn_about_tls_in_tlsl s ð × Ñ × Ñ × &Ñ &¨'Ò 1Ø ô Ð$Ó %× 0Ñ 0× ;Ñ ;¸HÔ EØ ô '*×&6Ñ&6¸'Ñ&Aò '
|
ÄWØ Ø #Ø óF
|
Ð#ñ 'Ø ä ð
|
Gô Øð ö!
|
r[ c óN K | j « }| j |« }t r|J t |j |j
|
¬« 4 d{ t j dk\ rb| j rV| j j ||||j xs |j |j | j ¬« d{ }nJ| j j ||||j xs |j |j ¬« d{ }t# |t$ j& « r%| j) |« }|r |j+ |« ddd« d{ d} ||j4 t7 | « « |j9 |« ||fS 7 I7 Ö7 # t $ r2 | j dk( r|j « |j! « w xY w# t, $ r9 |j! « | j. s| j0 j3 |« w xY w7 Ã# 1 d{ 7 sw Y ÓxY w# t: $ r }
|
t= |j4 |
|
« |
|
d}
|
~
|
wt> $ r }
|
tA |j4 |
|
« |
|
d}
|
~
|
wt6 $ r@}
|
|
|
jB t# |
|
t$ jD « r ||j4 |
|
« |
|
d}
|
~
|
wtF $ rN} tI d|j d |jJ d
|
d |jL d |jN xs d d| d « | d} ~ ww xY ww)z$Wrap the raw TCP transport with TLS.Nrá r )Úserver_hostnameÚssl_handshake_timeoutr )r r r z:Failed to start TLS (possibly caused by closing transport)z2Cannot initialize a TLS-in-TLS connection to host ú:Údz4 through an underlying connection to an HTTPS proxy z ssl:Údefaultz [ú])(rá rØ r r5 rä r> r rå r¯ r~ rô r rq ÚtotalrD rà r¬ ro rm rµ rÛ Úcheckr, ræ rç r¤ r; rç Úconnection_mader. r& r/ r) rè ré Ú TypeErrorr% r¸ r. r- ) rX rù r) r rÝ Ú tls_protor Ú tls_transportr Úmsgrô Útype_errs rY Ú_start_tls_connectionz"TCPConnector._start_tls_connection s è ø ð MMO Ø×*Ñ*¨3Ó/
|
Ý ð Ð)Ð )Ð)ðC Ü#Ø×$Ñ$°W×5KÑ5Kô÷ ( "ñ ( "ðä×'Ñ'¨7Ò2°t×7QÒ7QØ.2¯j©j×.BÑ.BØ 0Ø %Ø &Ø,/×,?Ñ,?Ò,KÀ3Ç8Á8Ø29·-±-Ø15×1KÑ1Kð /Có /÷ ) ð /3¯j©j×.BÑ.BØ 0Ø %Ø &Ø,/×,?Ñ,?Ò,KÀ3Ç8Á8Ø29·-±-ð /Có /÷ ) ô m¬W×->Ñ->Ô?Ø"&×"7Ñ"7¸Ó"<KÙ"ð"Ø '× -Ñ -¨mÔ <÷G( "÷ ( "ðz Ð$ØRÙ" 3×#5Ñ#5´w¸s³|ÓDÐDØ × %Ñ %Ø ô ð iÐ'Ð'ðI( "ùð )øð)ùô %ò ð ×1Ñ1°QÒ6Ø,×2Ñ2Ô4ð ð -×2Ñ2Ô4Øðûô 9ò "Ø )× /Ñ /Ô 1Ø#'×#@Ò#@Ø $× ?Ñ ?× FÑ FÀ}Ô UØ !ð "úðI( "ø÷ ( "÷ ( "ñ ( "ûôR ò TÜ1°#×2DÑ2DÀcÓJÐPSÐ SûÜò LÜ)¨#×*<Ñ*<¸cÓBÈÐ KûÜò AØyyÐ ¤Z°´W×5IÑ5IÔ%JØÙ s× 1Ñ 1°3Ó7¸SÐ @ûÜò
|
ô
|
(ØDØ88,a §¡¨|ð ,%Ø%(§Y¡Y M°°s·w±wÒ7KÀ)Ð6Lð MØ <qð"óð
|
ð ûð
|
üsæ ,L%¯%H> ÁF ÁH> ÁH)ÁA/F$Ã F Ã
|
A
|
F$ÄF"ÄF$Ä-H)ÅG"Å H> Å#H'Å$H> Å(5L%Æ H> Æ F$Æ"F$Æ$;G Ç H)Ç"AH$È$H)È'H> È)H;È/H2 È0H;È7H> È> L"ÉI É L"É*JÊ L"Ê ;KË L"ËA L Ì L"Ì"L%Úhostsc ó. g }|D ] }|d }d|v }|rt j nt j }| j r| j |k7 rJ|r ||d ddfn||d f}|j |t j
|
t j d|f« |S )zÈConverts the list of hosts to a list of addr_infos.
|
|
The list of hosts is the result of a DNS lookup. The list of
|
addr_infos is the result of a call to `socket.getaddrinfo()`.
|
rq r r¸ r rA )ÚsocketÚAF_INET6ÚAF_INETr§ r¤ Ú SOCK_STREAMÚ IPPROTO_TCP)rX r rß Úhinforq Úis_ipv6r Úaddrs rY Ú _convert_hosts_to_addr_infosz)TCPConnector._convert_hosts_to_addr_infosí s ð *,
|
Øò EØ=DØTkGÙ(/V__´V·^±^FØ|| § ¡ °Ò 6ØÙ29D% -¨¨AÑ.ÀÀeÈFÁmÐ?TDØ × Ñ Ø×+Ñ+¬V×-?Ñ-?ÀÀTÐJõ ð ð Ðr[ c ó K | j |« }| j |« }|j j }|J |j d« r|j d« dz }|j }|J | j |||¬« d { } d } | j | « } | r}|r |j xs |j d« nd } | j# | j$ ||| | ||¬« d { \ }}|j/ « r|r |j1 |« ||fS ||fS | J | 7 # t $ rC}
|
|
|
j t |
|
t j « r t |j |
|
« |
|
d }
|
~
|
ww xY w7 # t& t j f$ r-}
|
|
|
} t) j* | | j, « Y d }
|
~
|
d }
|
~
|
ww xY w# t2 $ r{}
|
|j5 « | j6 s| j8 j; |« |
|
} |j= d« }|j? « }t) j@ | |« Y d }
|
~
|
d }
|
~
|
ww xY ww)Nz..ú.)r9 )r r- rß r r) rÝ r )!rØ rÛ r6 Úraw_hostÚendswithÚrstripr¸ rÍ rç rè ro rm ré r' r; r r rê rá r( r¨ Úpop_addr_infos_interleaver¬ r r r, r¬ ræ rç r¤ r Ú getpeernameÚremove_addr_infos)rX r) r9 r rÝ r r rq r¸ r rô Úlast_excrß r Útranspr rã Úbad_peers rY rÓ z&TCPConnector._create_direct_connection sU è ø ð ×*Ñ*¨3Ó/
|
Ø×+Ñ+¨CÓ0 àww× Ñ ØÐ Ð Ð ð ==Ô Ø;;sÓ# cÑ)DØxxØÐ Ð Ð ð
|
Lð ×,Ñ,¨T°4ÀÐ,ÓG×GEð )-Ø×6Ñ6°uÓ=
|
Ùñ >H×$Ñ$Ò,¨×4Ñ4°SÔ9ÈTð ð Ø&*×&BÑ&BØMMØ #Ø"Ø )Ø$3ØØ!-ð 'Có '÷ ! ð zz|¡ ð Ø ×%Ñ% fÔ-ð 5=Ð 65=Ð àÐ'Ð 'Ð'ØNðc HùÜò LØyyÐ ¤Z°´W×5IÑ5IÔ%JØô *¨#×*<Ñ*<¸cÓBÈÐ Kûð Lúð"!ùô )¬'×*>Ñ*>Ð?ò Ø Ü ×:Ñ:¸:Àt×GWÑGWÔXÝûð ûô 1ò ØLLNØ ×8Ò8Ø ×7Ñ7×>Ñ>¸vÔFØ "Hà*0×*?Ñ*?ÀÓ*IDØ #× /Ñ /Ó 1HÜ$×6Ñ6°zÀ8ÔLÝ ûð üs£ A2I Á5D+  D) D+ Â8I Ã
|
%E< Ã/E:Ã0E< Ã7I Ä
|
G ÄI Ä)D+ Ä+ E7Ä4>E2Å2E7Å7I Å:E< Å<GÆ"F=Æ7I Æ=GÇI Ç I ÇA0IÈ>I ÉI É I c ó K | j |« | j « }| j |« }| j |g |t ¬« d { \ }}|j « r|r| j ||« t j |_ |j |_
|
|j j d d d ¬« }t | ||| j « } |j | « d { }
|
| j } | J | j# || j$ ¬« |
|
j' | « d { } d | _ | j( dk7 re| j* } | t- | j( « j. } t1 |
|
j2 | j4 | j( | | j6 ¬« |s0|j9 dd ¬« }| t; d« |j= « }|s|jA « |sT| jC |« }| jE | jF |||jH |¬ « d { |
|
jA « S | jK |||¬
|
« d { |
|
jA « S ||fS 7 07 7 R# t> $ r |jA « w xY w# |s|jA « w w xY w7 7 Y# t> $ r" |
|
jA « | jA « w xY w# |
|
jA « w xY ww) NrÜ )r. r2 Úproxy_headers_hash)Úread_until_eofrÎ éÈ )Ústatusr r+ r )r z)Transport does not expose socket instance)r r- rã r r) )r) r )&rò rø r8 rÓ r+ r r r! Ú METH_CONNECTÚmethodr6 r; Ú_replacer¸ r~ Úsendr Úset_response_paramsrÓ Ústartr- Úreasonr Úphraser* rý Úhistoryr+ r rÕ ÚduprD r¬ rØ rí rá rq r )rX r) r9 r Úruntime_has_start_tlsr7 r r rx rG Ú
|
proxy_respry Úrespr Úrawsockr s rY rÒ z%TCPConnector._create_proxy_connectionM s è ø ð ×"Ñ" 3Ô'Ø $× =Ñ =Ó ?Ð Ø×FÑFÀsÓK ð "&×!?Ñ!?Ø r7Ô1Kð "@ó "
|
÷
|
Ñ 5ð ::<Ù$Ø×+Ñ+¨I°sÔ;ô $× 0Ñ 0IÔ Ø GGIMØ×$Ñ$×-Ñ-Ø tÀð .ó Cô ,¨D°#°u¸d¿j¹jÓIDØ (~~¨dÓ 3×3JðD #Ø >>Ø Ð+Ð+Ð+ð
|
×,Ñ,Ø#8Ø+/×+GÑ+Gð -ô ð (× -Ñ -¨dÓ 3×3ð "&ð *Ø{{ cÒ)Ø"&§+¡+Ø"?Ü&0°·±Ó&=×&DÑ&DGÜ 2Ø &× 3Ñ 3Ø LLØ#'§;¡;Ø$+Ø$(§L¡Lô ð ñ 1Ø"+×":Ñ":¸8ÈTÐ":Ó"RØ"?Ü".Ø Kó# ð ð #*§+¡+£-ñ 1Ø!Õ)á,à!%×!6Ñ!6°sÓ!;JØ!%×!?Ñ!?Ø Ø 'Ø &Ø $Ø(+¯©Ø ð "@ó "÷ ð" × Ñ Õ"ð "× 7Ñ 7ð ØØ #ð 8ó ÷ ð × Ñ Õ"à%Ð Ð ð}
|
ùð. 4ùð 4úô6 %ò ð OOÔ%Øð ûñ 1Ø!Õ)ð 1úð øðùôa !ò Ø× Ñ Ô"Ø
|
|
Øð ûðp × Ñ Õ"üs² ALÁJÁB LÃ.JÃ/LÃ4AK Ä5JÄ6K Ä:K2 ÅB&J
|
Ç(AK2 È<K È=K2 É LÉK2 É(KÉ)K2 É,LÊLÊK Ê
|
J%Ê%J( Ê(J=Ê=K2 ËK2 Ë+K/Ë/K2 Ë2LÌL)NNr )r) r1 rU Nrd )@re rf rg r» rf Ú frozensetrg r Ú AddressFamilyÚ AF_UNSPECr8 r¶ r Úbytesri r r r2 r r³ r# rÛ rh rm r² r r4 rZ r r rï r¬ r´ r r rº r r$ rÍ r rÇ r1 r0 rB rØ rÛ r( r r r rp rµ rê rí rò rð rø r Ú BaseTransportr r rÓ rÒ Ú __classcell__©r± s @rY rI rI sb ø ñ$ðL #8¹)ÀUÀGÓ:LÑ"LÐ ð
|
Ø'+Ø "Ø')Ø'-×';Ñ';×'EÑ'EØ,0Ø48Ø04Ø/3Ø8@Ø !ØØ Ø&+Ø48Ø()Ø04Ø$(Ø6:Ø>Fò-M>ð ðM>ð e_ð M>ð
|
ð M>ð }ð M>ð ×$Ñ$ðM>ð jÑ)ðM>ð 4 jÐ0Ñ 1ðM>ð U 3¨ 8_Ñ-ðM>ð Ð+Ñ,ðM>ð ! u¨fÐ!4Ñ5ðM>ð ðM>ð ð M>ð ð M>ð $ð!M>ð" w×0Ñ0Ñ1ð#M>ð$ !&ð%M>ð& ' uoð'M>ð( SMð)M>ð* !Ð!2Ñ3ð+M>ð, $ I¨t°UÐ$:Ñ ;õ-M>ð^ +0ò 4ð °D¸À6Ñ9JÑ4Kõ ð 05ò T¨ð T¸õ Tð ð ò ó ð ð ð#tò #ó ð#ð
|
AEñ 'Ø SMð 'Ø08¸± ð 'à ó 'ð KOñYØðYØ "ðYØ,4°X¸gÑ5FÑ,GðYà mÑ óYðv'2à 38_ð'2ð ð'2ð ð '2ð
|
Ð+Ñ,ð '2ð 'Ñ*Ñ+ð '2ð
|
mÑ ó'2ðR Ø ð Ø*.¨w©-ð ØBQð à ó ð % Mð %°h¸zÑ6Jó %ðB Mð °h¸}Ñ6Mó ð )=ò $Aàð$Að Ñ&ð$Að ð $Að
|
!ð $Að 9oð $Að ð$Að
|
w× Ñ /Ð1Ñ 2ó$AðV )=ò AàðAð ðAð !ð Að
|
9oð Að ð Að
|
w× Ñ /Ð1Ñ 2óAó,)ó$ ð"¨$ó ð)
|
à %× /Ñ /ð)
|
ð ð)
|
ð
|
ó )
|
ð` )=ñ T(à %× /Ñ /ðT(ð ðT(ð !ð T(ð
|
9oð T(ð
|
w×$Ñ$ oÐ5Ñ 6ó T(ðlØ-Ñ(ðà lÑ óð6 )=ò Ià ðIð W ðIð !ð Ið 9oð Ið
|
w× Ñ /Ð1Ñ 2óIðVf Ø ðf Ø*.¨w©-ðf ØBQðf à w×$Ñ$ oÐ5Ñ 6÷f r[ rI c ó¾ e Zd ZdZe edh« z Zdedddfdede d e
|
e e df d
|
e d e d eej d df fd Zed efd« Zdeded ddd efdZ xZS )rJ 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.
|
ÚunixFrÆ r NÚpathrÊ rÉ rË rÌ rz rU c ó< t | |||||¬« || _ y )N©rÊ rÉ rË rÌ rz )r rZ Ú_path©rX rE rÊ rÉ rË rÌ rz r± s rY rZ zUnixConnector.__init__Ä s/ ø ô ÑØ#Ø /ØØ)Øð ô
|
ð
|
r[ c ó | j S )zPath to unix socket.©rH r^ s rY rE zUnixConnector.pathÖ ó ð zzÐr[ r) r9 rN r rL c óæ K t |j |j ¬« 4 d { | j j | j
|
| j « d { \ }}d d d « d { |S 7 Q7 7
|
# 1 d { 7 sw Y S xY w# t $ rN}|j t |t j « r t | j |j |« |d }~ww xY wwrì )r5 rä r> r~ Úcreate_unix_connectionrá rH rç rè ro rm ré r- rE r; ©rX r) r9 r r r rô s rY rB z UnixConnector._create_connectionÛ sß è ø ð
|
XÜ#Ø×$Ñ$°W×5KÑ5Kô÷ ñ ð "&§¡×!BÑ!BØMM 4§:¡:ó"÷ 5÷ ÷ ð ð øð øð ø÷ ÷ ð ð ûô ò XØyyÐ ¤Z°´W×5IÑ5IÔ%JØÜ*¨4¯9©9°c×6HÑ6HÈ#ÓNÐTWÐ Wûð Xüs C1%B ©A;ªB 4BÁ!A=Á"BÁ) B Á4A?Á5B Á9C1Á;B Á=BÁ?B ÂBÂB
|
ÂBÂB ÂC1ÂB  C. A C)Ã)C.Ã.C1©re rf rg r» rf r< rg r8 r³ r¶ r rh rÛ ri r rm r² rZ r´ rE r1 r r0 rB rA rB s @rY rJ rJ ¶ sÑ ø ñ ð #8¹)ÀVÀHÓ:MÑ"MÐ ð
|
"Ø8@ØØ Ø48ñàðð ðð ! ¨°Ð!4Ñ5ð ð
|
ð ð ð ð w×0Ñ0Ñ1ðð
|
õð$ ðcò ó ððØ ðØ*.¨w©-ðØBQðà ÷r[ rJ c ó¾ e Zd ZdZe edh« z Zdedddfdede d e
|
e e df d
|
e d e d eej d df fd Zed efd« Zdeded ddd efdZ xZS )rK 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.
|
ÚnpipeFrÆ r NrE rÊ rÉ rË rÌ rz rU c ó t | |||||¬« t | j t j
|
« s t d« || _ y )NrG z9Named Pipes only available in proactor loop under windows)r rZ ro r~ rm ÚProactorEventLooprÕ rH rI s rY rZ zNamedPipeConnector.__init__þ s[ ø ô ÑØ#Ø /ØØ)Øð ô
|
ô Ø JJÜ × %Ñ %ô
|
ô ØKóð ð
|
r[ c ó | j S )zPath to the named pipe.rK r^ s rY rE zNamedPipeConnector.path rL r[ r) r9 rN r rL c ó( K t |j |j ¬« 4 d { | j j | j
|
| j « d { \ }}t j d« d { d d d « d { t t « S 7 |7 F7 (7 # 1 d { 7 sw Y *xY w# t $ rC}|j t |t j « r t |j |« |d }~ww xY ww)Nrá r )r5 rä r> r~ Úcreate_pipe_connectionrá rH rm Úsleeprç rè ro ré r( r; r r0 rO s rY rB z%NamedPipeConnector._create_connection só è ø ð IÜ#Ø×$Ñ$°W×5KÑ5Kô÷
|
'ñ
|
'ð "&§¡×!BÑ!BØMM 4§:¡:ó"÷ 5ô mm AÓ&×&Ð&÷
|
'÷
|
'ô$ O UÓ+Ð+ð%
|
'øð øð 'øð
|
'ø÷
|
'÷
|
'ñ
|
'ûô ò IØyyÐ ¤Z°´W×5IÑ5IÔ%JØÜ& s×'9Ñ'9¸3Ó?ÀSÐ Hûð Iüs D%C ©B&ªC 4B.Á!B(Á" B.ÂB*ÂB. C ÂB,ÂC ÂDÂ&C Â(B.Â*B.Â,C Â.C Â4B7 Â5C Â<C à Dà >D
|
Ä
|
DÄDrP rB s @rY rK rK í sÑ ø ñ ð #8¹)ÀWÀIÓ:NÑ"NÐ ð
|
"Ø8@ØØ Ø48ñàðð ðð ! ¨°Ð!4Ñ5ð ð
|
ð ð ð ð w×0Ñ0Ñ1ðð
|
õð2 ðcò ó ðð,Ø ð,Ø*.¨w©-ð,ØBQð,à ÷,r[ rK )srm rß rZ r r r r` Ú collectionsr r r Ú
|
contextlibr rB r Ú itertoolsr r r
|
Útimer Útypesr Útypingr r r r r r r r r r r r r r r r r r¨ r r rA r! r" Úabcr# r$ Úclient_exceptionsr% r& r' r( r) r* r+ r, r- r. r/ Ú client_protor0 Ú client_reqrepr1 r2 r3 r4 r5 r6 r7 r8 r9 r: Úlogr; r r< rå Úcollections.abcr@ r? Ú bytearrayr- r Ú ImportErrorrh r< ÚEMPTY_SCHEMA_SETÚHTTP_SCHEMA_SETÚ WS_SCHEMA_SETÚHTTP_AND_EMPTY_SCHEMA_SETrf rä Ú__all__ÚclientrL rM ÚtracingrN rP rt rv r¸ r½ rH rk r¶ r r× rÖ rI rJ rK ri r[ rY ú<module>rn s8 ðÛ Û Û Û Û
|
Û Û ß 7Ñ 7Ý Ý ß *Ñ *Ý Ý ÷÷ ÷ ÷ õ ó( ß <ç ß 0÷ ÷ ÷ ñ õ *ß HÑ H÷÷ ñ õ Ý %à×ÑwÒ Þ&à 5)Ð%6Ð8KÐKÑ LFáÛà Jð Ûà^^
|
ñ
|
bT?Ð ÙV WÐ -Ó.Ù4 -Ó( à +Ð.>Ñ >Ð Ø1°MÑAÐ à! S×%5Ñ%5ö ð 9ô ò #ð ×Ñ
|
Ñ"ð ð ñ Ý%Ý,Ý ÷ñ ð(J 4¨ °&Ñ(9Ñ#:ð J¸tó J÷UKñ UKôp zô ÷(4ñ 4÷"J $ñ J $÷Z$?ñ $?ðN ð ¨ó ñ6 *¨$Ó/Ð Ù+¨EÓ2Ð ôS =ô S ôl4Mô 4ônE, õ E,øð{4 ò ØØ
|
ð ús ÄH È HÈH
|
