n7۲ d dl Z d dlmZ d dlmZmZmZ ddlmZ ddl m
Z
m Z m Z m
Z
ddlmZmZ ddlmZmZ dd lmZmZmZ G d
d eeeeef ZdS ) N)suppress)AnyOptionalTuple ) BaseProtocol)
ClientOSErrorClientPayloadErrorServerDisconnectedErrorServerTimeoutError)BaseTimerContext status_code_must_be_empty_body)HttpResponseParserRawResponseMessage)
EMPTY_PAYLOAD DataQueue StreamReaderc | e Zd ZdZdej ddfdZedefd Z edefd Z
d*dZ d*d Z defd
Z
d ee ddf fd Zd*d
Zd* fd Zd* fd Zd eddf fd ZdededdfdZdddddddddd dee ded ed ed ee d ed ed!ed"eddfd#Zd*d$Zd*d%Z d*d&Z d*d'Z d(e ddfd)Z xZ!S )+ResponseHandlerz8Helper class to adapt between Protocol and StreamReader.loopreturnNc t j | | t j | | d| _ d | _ d| _ d | _ d | _ d| _ d| _ d | _
d | _ d | _ d| _
d S )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)selfr s h/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/client_proto.pyr zResponseHandler.__init__ s d....4&&& "04
" #
59 .2CG!89$$$r c | j S N)r" r' s r( upgradedzResponseHandler.upgraded) s
~ r c | j | j r| j rdS | j pL| j pE| d up/| j d up&t
| dk pt | j S NTr ) r is_eofr" r exceptionr lenboolr! r+ s r( should_closez ResponseHandler.should_close- s = $T]-A-A-C-C $t~ $4
~
~~ t+
#4/
4yy1}
DJ
r c d| _ d S NT)r r+ s r( force_closezResponseHandler.force_close; s !r c | j }|8| d | _ d | _ | d S d S r* ) transportcloser
_drop_timeout)r' r8 s r( r9 zResponseHandler.close> sM N OO !DN DM ! r c H | j d uo| j S r* )r8
is_closingr+ s r( is_connectedz ResponseHandler.is_connectedF s% ~T)M$.2K2K2M2M.MMr excc | | j Et t 5 | j d d d n # 1 swxY w Y d }| j i | j }nN# t $ rA}| j 0t d }||_ | j | Y d }~nd }~ww xY w|
sIt |t rt |j }|t | }| | d| _ d | _ d | _ d | _ d| _ t% | d S )Nz!Response payload is not completedTF)r: r r Exceptionfeed_eofr# r r
__cause__
set_exceptionr/
isinstanceOSErrorr argsr r _reading_pausedsuperconnection_lost)r' r> uncompletede __class__s r( rI z ResponseHandler.connection_lostI s +)$$
0
0$--///
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0 < #
5 "l 3 3 5 5
5
5
5=,,-PQQC$%CMM//444
5 {{}} $#w''
/#SX.{-k::
s # # # !
# $
$$$$$s) AA A,B
C7C Cc . | d S r* )r: r+ s r( eof_receivedz ResponseHandler.eof_receivedk s r c p t | d S r* )rH
pause_readingr: r' rL s r( rP z ResponseHandler.pause_readingo s1
r c p t | d S r* )rH resume_reading_reschedule_timeoutrQ s r( rS z ResponseHandler.resume_readings s1
"""""r c d| _ | t | d S r5 )r r: rH rC )r' r> rL s r( rC z ResponseHandler.set_exceptionw s; !
c"""""r parserpayloadc || _ || _ | | j r&| j dc}| _ | | d S d S )Nr )r r r: r!
data_received)r' rV rW datas r(
set_parserzResponseHandler.set_parser| sc
% : % #z3 D$* t $ $ $ $ $ % %r FTi r i ) timer skip_payloadread_until_eofauto_decompress read_timeout read_bufsizetimeout_ceil_threshold
max_line_sizemax_field_sizer\ r] r^ r_ r` ra rb rc rd c || _ || _ || _ t | | j ||t
| ||||
| _ | j r&| j dc}
| _ | |
d S d S )N)r\ payload_exceptionresponse_with_bodyr^ r_ rc rd r ) r r$ r& r _loopr
r# r! rY ) r' r\ r] r^ r_ r` ra rb rc rd rZ s r( set_response_paramsz#ResponseHandler.set_response_params s * )'=$) J 0#/ /) +')
: % #z3 D$* t $ $ $ $ $ % %r c X | j "| j d | _ d S d S r* )r% cancelr+ s r( r: z ResponseHandler._drop_timeout s6 $ 0 % , , . . .(,D % % % 1 0r c | j }| j | j |r'| j || j | _ d S d | _ d S r* )r$ r% rk rh
call_later_on_read_timeout)r' timeouts r( rT z#ResponseHandler._reschedule_timeout sh $ $ 0 % , , . . . -(,
(=(=.) )D % % % )-D % % %r c . | d S r* )rT r+ s r(
start_timeoutz ResponseHandler.start_timeout s """""r c t d }| | | j | j | d S d S )Nz#Timeout on reading data from socket)r rC r )r' r> s r( rn z ResponseHandler._on_read_timeout sP !FGG 3 = $ M ' ' , , , , , % $r rZ c | |sd S | j F| j | \ }}|r%d | _ d | _ |r| | d S | j s| j | xj |z
c_ d S | j | \ }}}nM# t $ r@}| j | j
| | Y d }~d S d }~ww xY w|| _ d }|D ]k\ }}|j rd| _
|| _ | j st |j r | |t" fd S| ||fd l|8|t" ur| | j n| |r"|r| | d S || _ d S d S r. )rT r feed_datar rY r" r# r!
BaseExceptionr8 r9 rC r3 r r r coder on_eofr: ) r' rZ eoftailmessagesr, r> rW messages r( rY z ResponseHandler.data_received s8 """ F + ,66t< >$GW + 2-1*$+DM) >-K . . > '?CCCC '91====&
m33 t'9:::: **,,, * * **400000%)
* *s B& &
C005C++C0)r N)"__name__
__module__ __qualname____doc__asyncioAbstractEventLoopr propertyr2 r, r3 r6 r9 r= r ru rI rN rP rS rC r r[ r
floatintri r: rT rq rn bytesrY
__classcell__)rL s @r( r r s BB:W 6 :4 : : : :* $ X
d
X
" " " "! ! ! !Nd N N N N %8M#: %t % % % % % %D # # # # # ## #4 # # # # # #
%
%s
%t
%
%
%
%$ -1 " $ $(, !() ! ""% "% "% ()"% "%
"%
"% uo"% "% !&"% "% "%
"% "% "% "%H- - - -
-
-
-
-# # # #- - - - ?*% ?*D ?* ?* ?* ?* ?* ?* ?* ?*r r )r
contextlibr typingr r r
base_protocolr client_exceptionsr r
r r helpersr
r httpr r streamsr r r r r r( r s- ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' F E E E E E E E 8 8 8 8 8 8 8 8 ; ; ; ; ; ; ; ; ; ;w* w* w* w* w*lIe4F 4T.U$V w* w* w* w* w*r