Ë
|
¸^iµ0 ã óÌ d dl Z d dlmZ d dlmZmZmZmZ ddlm Z ddl
|
m Z m Z m Z mZmZ ddlmZmZmZmZmZ ddlmZmZ dd lmZ dd
|
lm Z m Z m Z G d d e e eee f « Z y) é N)Úsuppress)ÚAnyÚOptionalÚTupleÚUnioné )Ú BaseProtocol)ÚClientConnectionErrorÚ ClientOSErrorÚClientPayloadErrorÚServerDisconnectedErrorÚSocketTimeoutError)Ú _EXC_SENTINELÚEMPTY_BODY_STATUS_CODESÚBaseTimerContextÚ set_exceptionÚ
|
set_result)ÚHttpResponseParserÚRawResponseMessage)ÚHttpProcessingError)Ú EMPTY_PAYLOADÚ DataQueueÚ StreamReaderc ó e Zd ZdZdej
|
ddfdZededej d f fd« Z
|
ede fd« Z ede fd« Z d/d Zd/d
|
Zd/d Zde fd Zd ee ddf fd Zd/dZd/ fd Zd/ fd Zefd ededdf fd ZdededdfdZdddddddddd d ee d e d e d e d!ee d"e d#e d$e d%e ddfd&Z d/d'Z d/d(Z!d/d)Z"edee fd*« Z#e#jH d!ee ddfd+« Z#d/d,Z%d-e&ddfd.Z' xZ(S )0ÚResponseHandlerz8Helper class to adapt between Protocol and StreamReader.ÚloopÚreturnNc ó t j | |¬« t j | |« d| _ d | _ d| _ d | _ d | _ d| _ d| _ d | _
|
d | _ d | _ d| _ d | _ d| _ y )N)r Fó é )r Ú__init__r Ú _should_closeÚ_payloadÚ _skip_payloadÚ_payload_parserÚ_timerÚ_tailÚ _upgradedÚ_parserÚ _read_timeoutÚ_read_timeout_handleÚ_timeout_ceil_thresholdÚ_closedÚ_connection_lost_called)Úselfr s õg H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/client_proto.pyr! zResponseHandler.__init__ s Ü× Ñ d¨Õ.Ü×Ñ4 Ô&à "Ôà04 Ø "ÔØ #Ô à à
|
Ø Ø59 à.2ÔØCGÔ!à89Ô$à:> Ø',Õ$r c ó | j +| j s | j j « | _ | j S )a6 Future that is set when the connection is closed.
|
|
This property returns a Future that will be completed when the connection
|
is closed. The Future is created lazily on first access to avoid creating
|
futures that will never be awaited.
|
|
Returns:
|
- A Future[None] if the connection is still open or was closed after
|
this property was accessed
|
- None if connection_lost() was already called before this property
|
was ever accessed (indicating no one is waiting for the closure)
|
)r- r. Ú_loopÚ create_future©r/ s r0 ÚclosedzResponseHandler.closed4 s4 ð <<Ð ¨×(DÒ(DØ ::×3Ñ3Ó5DLØ||Ðr c ó | j S ©N)r( r4 s r0 ÚupgradedzResponseHandler.upgradedF s à~~Ð r c ó t | j xsu | j d uxr | j j « xsH | j xs: | j
|
d uxs* | j d uxs | j xs | j « S r7 ) Úboolr" r# Úis_eofr( Ú
|
_exceptionr% Ú_bufferr' r4 s r0 Ú should_closez ResponseHandler.should_closeJ s äØ × Ñ ò Ø TÐ)ÒH°$·-±-×2FÑ2FÓ2HÐ.Hò à~~ò ð dÐ*ò ð ×#Ñ#¨4Ð/ò ð
|
||ò ð zzó
|
ð
|
r c ó d| _ y ©NT)r" r4 s r0 Ú force_closezResponseHandler.force_closeV s
|
Ø !Õr c ó d | _ | j }|/|j « d | _ d | _ | j « y y r7 )r< Ú transportÚcloser# Ú _drop_timeout©r/ rC s r0 rD zResponseHandler.closeY óA Ø ØNN Ø Ð Ø OOÔ Ø !DNØ DMØ × Ñ Õ ð !r c ó d | _ | j }|/|j « d | _ d | _ | j « y y r7 )r< rC Úabortr# rE rF s r0 rI zResponseHandler.abortb rG r c óX | j d uxr | j j « S r7 )rC Ú
|
is_closingr4 s r0 Ú is_connectedz ResponseHandler.is_connectedk s& Ø~~ TÐ)ÒM°$·.±.×2KÑ2KÓ2MÐ.MÐMr Úexcc ó d| _ | j « |}|}|d u }| j @|rt | j d « n'|J t | j t d|« |« | j 2t t « 5 | j j « d d d « d }| j | j j « }| j « sSt |t « rt! |j" }|r t% |« }|rt& n|}|J |J | j ||« d| _ d | _
|
d | _ d | _ d| _ t, | ] |« y # 1 sw Y ÈxY w# t $ rD}| j .d|}|s|d|}t | j t |« |« Y d }~êd }~ww xY w)NTzConnection lost: z#Response payload is not completed: z. F)r. rE r- r r r
|
r% r Ú ExceptionÚfeed_eofr) r# r r; Ú
|
isinstanceÚOSErrorr Úargsr r r" Ú_reading_pausedÚsuperÚconnection_lost)
|
r/ rM Úoriginal_connection_errorÚ reraised_excÚconnection_closed_cleanlyÚ uncompletedÚunderlying_excÚclient_payload_exc_msgÚunderlying_non_eof_excÚ __class__s
|
r0 rV z ResponseHandler.connection_lostn sî ø Ø'+Ô$Ø ×ÑÔ à$'Ð!Ø0 à$=ÀÐ$EÐ!à <<Ð #ñ )Ü4<<¨Õ.à0Ð<Ð<Ð<Ü ØLLÜ)Ø+Ð,EÐ+IÐJóð .ô ð × Ñ Ð +Ü)Ó$ñ 0Ø×$Ñ$×-Ñ-Ô/÷ 0ð Ø <<Ð #ð Ø "ll× 3Ñ 3Ó 5 ð" {{}ÜÐ3´WÔ=Ü ,Ð.G×.LÑ.LÐ M Ù(Ü 6°{Ó C ñ
|
-õ à.ð #ð
|
*Ð5Ð 5Ð5Ø Ð+Ð +Ð+Ø × Ñ |Ð-CÔ Dà !ÔØ Ø Ø #Ô Ø $Ô ä Ñ Õ-÷[ 0ð 0ûô ò Ø==Ð,à=¸nÐ=PÐQð +ñ 5à 5Ð 9¸Ø 8Ð <ð >ð /ô "Ø Ü*Ð+AÓBØ&ôÿøð ús$ ÂE*Â:E6 Å*E3Å6 GÅ?:F>Æ>Gc ó$ | j « y r7 )rE r4 s r0 Ú eof_receivedz ResponseHandler.eof_received¹ s à ×ÑÕ r c óB t | « | j « y r7 )rU Ú pause_readingrE ©r/ r^ s r0 rb z ResponseHandler.pause_reading½ s ø Ü Ñ Ô Ø ×ÑÕ r c óB t | « | j « y r7 )rU Úresume_readingÚ_reschedule_timeoutrc s r0 re z ResponseHandler.resume_readingÁ s ø Ü Ñ Ô Ø × Ñ Õ"r Ú exc_causec óT d| _ | j « t | ||« y r@ )r" rE rU r )r/ rM rg r^ s r0 r z ResponseHandler.set_exceptionÅ s( ø ð
|
"ÔØ ×ÑÔ Ü Ñ c 9Õ-r ÚparserÚpayloadc ó¤ || _ || _ | j « | j r&| j dc}| _ | j |« y y )Nr )r# r% rE r' Ú data_received)r/ ri rj Údatas r0 Ú
|
set_parserzResponseHandler.set_parserÎ sK ð Ø %Ô à ×ÑÔ à ::Ø #zz¨3Ð D$*Ø × Ñ tÕ $ð r FTi r iþ ) ÚtimerÚ skip_payloadÚread_until_eofÚauto_decompressÚ read_timeoutÚ read_bufsizeÚtimeout_ceil_thresholdÚ max_line_sizeÚmax_field_sizero rp rq rr rs rt ru rv rw c óä || _ || _ || _ t | | j ||t
|
| |||| ¬«
|
| _ | j r&| j dc}
|
| _ | j |
|
« y y )N)ro Úpayload_exceptionÚresponse_with_bodyrq rr rv rw r ) r$ r* r, r r2 r r) r' rl ) r/ ro rp rq rr rs rt ru rv rw rm s r0 Úset_response_paramsz#ResponseHandler.set_response_paramsÝ s{ ð *Ôà )Ôà'=Ô$ä)Ø Ø JJØ ØÜ 0Ø#/Ð /Ø)Ø +Ø'Ø)ô
|
ð ::Ø #zz¨3Ð D$*Ø × Ñ tÕ $ð r c ó` | j "| j j « d | _ y y r7 )r+ Úcancelr4 s r0 rE z ResponseHandler._drop_timeout s- Ø × $Ñ $Ð 0Ø × %Ñ %× ,Ñ ,Ô .Ø(,DÕ %ð 1r c óÒ | j }| j | j j « |r,| j j || j
|
« | _ y d | _ y r7 )r* r+ r} r2 Ú
|
call_laterÚ_on_read_timeout)r/ Útimeouts r0 rf z#ResponseHandler._reschedule_timeout sZ Ø×$Ñ$Ø × $Ñ $Ð 0Ø × %Ñ %× ,Ñ ,Ô .á Ø(,¯
|
©
|
×(=Ñ(=Ø×.Ñ.ó)DÕ %ð )-DÕ %r c ó$ | j « y r7 )rf r4 s r0 Ú start_timeoutz ResponseHandler.start_timeout s Ø × Ñ Õ"r c ó | j S r7 ©r* r4 s r0 rs z ResponseHandler.read_timeout s à×!Ñ!Ð!r c ó || _ y r7 r
)r/ rs s r0 rs z ResponseHandler.read_timeout s
|
à )Õr c ó t d« }| j |« | j t | j |« y y )Nz#Timeout on reading data from socket)r r r# )r/ rM s r0 r z ResponseHandler._on_read_timeout s8 Ü Ð!FÓGØ ×Ñ3Ô Ø ==Ð $Ü $--¨Õ -ð %r rm c ó | j « |sy | j B| j j |« \ }}|r!d | _ d | _ |r| j |« y | j
|
s | j | xj |z c_ y | j j |« \ }}}|| _ d }|D ]j \ } }| j" rd| _ || _ | j& s| j t( v r| j | t* fd« W| j | |fd« l |4|t* ur |j- | j. « n| j/ « |r|r| j |« y y y # t $ r}| j | j j « t |t « r-t |j |j |j ¬« }n
|
t « }| j! ||« Y d }~y d }~ww xY w)N)ÚcodeÚmessageÚheadersTr )rf r% Ú feed_datar# rl r( r) r' Ú BaseExceptionrC rD rQ r r r r r r> r" r$ r r Úon_eofrE )
|
r/ rm ÚeofÚtailÚmessagesr8 r[ rM rj r s
|
r0 rl z ResponseHandler.data_received# sÞ Ø × Ñ Ô"áØ ð × Ñ Ð +Ø ×,Ñ,×6Ñ6°tÓ<ICÙØ $ Ø'+Ô$áØ×&Ñ& tÔ,Ø à >>T\\Ð 1à JJ$Ñ JØ ð Ø'+§|¡|×'=Ñ'=¸dÓ'CÑ $Hh ð& "à*.Ø (ò 6Ñ GWØ×#Ò#Ø%)Ô"à #DMà×!Ò! W§\¡\Ô5LÑ%LØ ¬ Ð 7¸Õ;à ¨Ð 1°1Õ5ð 6ð Ð ð
|
mÑ+Øt× 1Ñ 1Õ2à×"Ñ"Ô$á Ø × Ñ tÕ $ð 8øôU ò Ø~~Ð)ð ×$Ñ$Ô&ä.Ô*=Ô>Ü)Ø'×,Ñ,Ø *× 2Ñ 2Ø *× 2Ñ 2ôô *Ó+Ø × Ñ s NÔ 3Ü ûð! ús  E6 Å6 HÅ?A?HÈH)r N))Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__ÚasyncioÚAbstractEventLoopr! Úpropertyr ÚFuturer5 r: r8 r> rA rD rI rL r r rV r` rb re r r r rn r ÚfloatÚintr{ rE rf r rs Úsetterr Úbytesrl Ú __classcell__)r^ s @r0 r r s ø ÙBð-W× 6Ñ 6ð -¸4ó -ð0 ð d G§N¡N°4Ñ$8Ð 8Ñ9ò ó ð ð" ð $ò ó ð ð ð
|
dò
|
ó ð
|
ó"ó!ó!ðNdó NðI. 8¨MÑ#:ð I.¸tõ I.óV õ õ#ð $1ñ.à ð.ð !ð.ð
|
õ .ð % ð %¨sð %°tó %ð$ -1Ø "Ø $Ø $Ø(,Ø !Ø()Ø !Ø "ò"%ð Ð(Ñ)ð"%ð ð "%ð
|
ð "%ð ð "%ð uoð"%ð ð"%ð !&ð"%ð ð"%ð ð"%ð
|
ó"%óH-ó
|
|
-ó#ð ð"h uoò "ó ð"ð ×Ñð*¨°%© ð *¸Tò *ó ð*ó.ð D% %ð D%¨D÷ D%r r ) r Ú
|
contextlibr Útypingr r r r Ú base_protocolr Úclient_exceptionsr
|
r r r r Úhelpersr r r r r Úhttpr r Úhttp_exceptionsr Ústreamsr r r r © r r0 ú<module>r¨ sV ðÛ Ý ß .Ó .å '÷õ ÷õ ÷ 9Ý 0ß ;Ñ ;ôN%l I¨eÐ4FÈ Ð4TÑ.UÑ$Võ N%r
|
