a d dl Z d dlmZ d dlmZmZmZ ddlmZ ddl m
Z
m Z m Z m
Z
ddlmZ ddlmZmZ dd lmZmZmZ G d
d eeeeef ZdS ) N)suppress)AnyOptionalTuple ) BaseProtocol)
ClientOSErrorClientPayloadErrorServerDisconnectedErrorServerTimeoutError)BaseTimerContext)HttpResponseParserRawResponseMessage)
EMPTY_PAYLOAD DataQueue StreamReaderc b 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 ZdededdfdZddddddddee dededed ee d eddfd Zd$d Zd$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 S )N)r F )
r __init__r
_should_close_payload
_skip_payload_payload_parser_timer_tail _upgraded_parser
_read_timeout_read_timeout_handle)selfr s v/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib64/python3.11/site-packages/aiohttp/client_proto.pyr zResponseHandler.__init__ s| d....4&&& "04
" #
59 .2CG!!!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_close9 s !r c | j }|8| d | _ d | _ | d S d S r' ) transportcloser
_drop_timeout)r$ r4 s r% r5 zResponseHandler.close< sM N OO !DN DM ! r c H | j d uo| j S r' )r4
is_closingr( s r% is_connectedz ResponseHandler.is_connectedD s% ~T)M$.2K2K2M2M.MMr excc | | j Et t 5 | j d d d n # 1 swxY w Y d }| j Y | j }n># t $ r1 | j '| j t d Y nw xY w| sIt |t rt |j
}|t | }| | d| _ d | _ d | _ d | _ d| _ t# | d S )Nz!Response payload is not completedTF)r6 r r Exceptionfeed_eofr! r
set_exceptionr
r+
isinstanceOSErrorr argsr r _reading_pausedsuperconnection_lost)r$ r: uncompleted __class__s r% rD z ResponseHandler.connection_lostG s +)$$
0
0$--///
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0 < #
"l 3 3 5 5
=,M//*+NOO
{{}} $#w''
/#SX.{-k::
s # # # !
# $
$$$$$s# AA A,B 8C Cc . | d S r' )r6 r( s r% eof_receivedz ResponseHandler.eof_receivedi s r c p t | d S r' )rC
pause_readingr6 r$ rF s r% rJ z ResponseHandler.pause_readingm s1
r c p t | d S r' )rC resume_reading_reschedule_timeoutrK s r% rM z ResponseHandler.resume_readingq s1
"""""r c d| _ | t | d S r1 )r r6 rC r> )r$ r: rF s r% r> z ResponseHandler.set_exceptionu s; !
c"""""r parserpayloadc || _ || _ | | j r&| j dc}| _ | | d S d S )Nr )r r r6 r
data_received)r$ rP rQ datas r%
set_parserzResponseHandler.set_parserz sc
% : % #z3 D$* t $ $ $ $ $ % %r FTi )timer skip_payloadread_until_eofauto_decompress read_timeout read_bufsizerV rW rX rY rZ r[ c
|| _ || _ | t | | j ||t
| || | _ | j r&| j dc}| _ | | d S d S )N)rV payload_exceptionresponse_with_bodyrX rY r ) r r" rN r _loopr
r! r rS )r$ rV rW rX rY rZ r[ rT 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% r6 z ResponseHandler._drop_timeout s6 $ 0 % , , . . .(,D % % % 1 0r c | j }| j | j |r'| j || j | _ d S d | _ d S r' )r" r# rb r_
call_later_on_read_timeout)r$ timeouts r% rN z#ResponseHandler._reschedule_timeout sh $ $ 0 % , , . . . -(,
(=(=.) )D % % % )-D % % %r c t d }| | | j | j | d S d S )Nz#Timeout on reading data from socket)r r> r )r$ r: s r% re z ResponseHandler._on_read_timeout sP !FGG 3 = $ M ' ' , , , , , % $r rT 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 ]`\ }}|j rd| _
|| _ | j s |j dv r | |t fd H| ||fd a|8|t ur| | j n| |r"|r| | d S || _ d S d S )NT) i0 r )rN r feed_datar rS r r! r
BaseExceptionr4 r5 r> r/ r r coder on_eofr6 ) r$ rT eoftailmessagesr) r: rQ messages r% rS z ResponseHandler.data_received s+ """ F + ,66t< >$GW + 2-1*$+DM) >W\Z-G-G '?CCCC '91====&
m33 t'9:::: **,,, * * **400000%)
* *s B& &
C005C++C0)r N)!__name__
__module__ __qualname____doc__asyncioAbstractEventLoopr propertyr. r) r/ r2 r5 r9 r rk rD rH rJ rM r> r rU r
floatintr` r6 rN re bytesrS
__classcell__)rF s @r% r r s BBHW 6 H4 H H H H& $ X
d
X
" " " "! ! ! !Nd N N N N %8M#: %t % % % % % %D # # # # # ## #4 # # # # # #
%
%s
%t
%
%
%
%$ -1 " $ $(, ! % % % () % %
%
% uo % %
% % % %<- - - -
-
-
-
-- - - - =*% =*D =* =* =* =* =* =* =* =*r r )rv
contextlibr typingr r r
base_protocolr client_exceptionsr r
r r helpersr
httpr r streamsr r r r r r% r s& ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' & % % % % % 8 8 8 8 8 8 8 8 ; ; ; ; ; ; ; ; ; ;j* j* j* j* j*lIe4F 4T.U$V j* j* j* j* j*r