
    hY'              	           S SK r S SKJr  S SKJrJrJr  SSKJr  SSK	J
r
JrJrJr  SSKJrJrJrJr  SSKJrJr  SS	KJr  SS
KJrJrJr   " S S\\\\\4      5      rg)    N)suppress)AnyOptionalTuple   )BaseProtocol)ClientOSErrorClientPayloadErrorServerDisconnectedErrorSocketTimeoutError)_EXC_SENTINELEMPTY_BODY_STATUS_CODESBaseTimerContextset_exception)HttpResponseParserRawResponseMessage)HttpProcessingError)EMPTY_PAYLOAD	DataQueueStreamReaderc                     ^  \ rS rSrSrS\R                  SS4S jr\S\	4S j5       r
\S\	4S j5       rS/S	 jrS/S
 jrS\	4S jrS\\   SS4U 4S jjrS/S jrS/U 4S jjrS/U 4S jjr\4S\S\SS4U 4S jjjrS\S\SS4S jrSSSSSSSSSS.	S\\   S\	S\	S\	S \\   S!\S"\S#\S$\SS4S% jjrS/S& jrS/S' jrS/S( jr\S\\   4S) j5       r \ RB                  S \\   SS4S* j5       r S/S+ jr"S,\#SS4S- jr$S.r%U =r&$ )0ResponseHandler   z8Helper class to adapt between Protocol and StreamReader.loopreturnNc                     [         R                  " XS9  [        R                  " X5        SU l        S U l        SU l        S U l        S U l        SU l        SU l	        S U l
        S U l        S U l        SU l        g )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     F/var/www/html/env/lib/python3.13/site-packages/aiohttp/client_proto.pyr   ResponseHandler.__init__   sq    d.4&"04"#
59.2CG!89$r   c                     U R                   $ N)r&   r+   s    r,   upgradedResponseHandler.upgraded/   s    ~~r   c                 h   [        U R                  =(       d    U R                  S L=(       a    U R                  R                  5       (       + =(       d\    U R                  =(       dI    U R
                  S L=(       d4    U R                  S L=(       d    U R                  =(       d    U R                  5      $ r/   )	boolr    r!   is_eofr&   
_exceptionr#   _bufferr%   r0   s    r,   should_closeResponseHandler.should_close3   s     T)H$--2F2F2H.H~~ d* ##4/	
 || zz
 	
r   c                     SU l         g NT)r    r0   s    r,   force_closeResponseHandler.force_close?   s
    !r   c                     S U l         U R                  nUb/  UR                  5         S U l        S U l        U R	                  5         g g r/   )r6   	transportcloser!   _drop_timeout)r+   r?   s     r,   r@   ResponseHandler.closeB   sA    NN	 OO!DN DM 	 !r   c                 j    U R                   S L=(       a    U R                   R                  5       (       + $ r/   )r?   
is_closingr0   s    r,   is_connectedResponseHandler.is_connectedK   s&    ~~T)M$..2K2K2M.MMr   excc                 4  > U R                  5         UnUnUS L nU R                  b2  [        [        5         U R                  R	                  5         S S S 5        S nU R
                  b   U R
                  R	                  5       nU R                  5       (       dc  [        U[        5      (       a  [        UR                  6 nU(       a  [        U5      nU(       a  [        OUnUc   eUc   eU R                  X85        SU l        S U l        S U l        S U l        SU l        [$        T	U ]M  U5        g ! , (       d  f       N= f! [         aN  nU R                  b6  SU< 3nU(       d	  U< SU< 3n[        U R                  [        U5      U5         S nAGNS nAff = f)Nz#Response payload is not completed: z. TF)rA   r#   r   	Exceptionfeed_eofr'   r!   r   r
   r5   
isinstanceOSErrorr	   argsr   r   r    _reading_pausedsuperconnection_lost)
r+   rG   original_connection_errorreraised_excconnection_closed_cleanlyuncompletedunderlying_excclient_payload_exc_msgunderlying_non_eof_exc	__class__s
            r,   rP   ResponseHandler.connection_lostN   s   $'!0$=$E!+)$$$--/ % <<#"ll335" {{}}3W==,.G.L.LM(6{C
 - . #
 *555+++|D!#$-[ %$  ==,=n=PQ + 5598<> / "*+AB&s$   D.)D? .
D<?
F	AFFc                 $    U R                  5         g r/   )rA   r0   s    r,   eof_receivedResponseHandler.eof_received   s    r   c                 B   > [         TU ]  5         U R                  5         g r/   )rO   pause_readingrA   r+   rX   s    r,   r^   ResponseHandler.pause_reading   s    r   c                 B   > [         TU ]  5         U R                  5         g r/   )rO   resume_reading_reschedule_timeoutr_   s    r,   rb   ResponseHandler.resume_reading   s       "r   	exc_causec                 R   > SU l         U R                  5         [        TU ]  X5        g r;   )r    rA   rO   r   )r+   rG   re   rX   s      r,   r   ResponseHandler.set_exception   s&    
 "c-r   parserpayloadc                     X l         Xl        U R                  5         U R                  (       a%  U R                  Sso0l        U R	                  U5        g g )Nr   )r!   r#   rA   r%   data_received)r+   rh   ri   datas       r,   
set_parserResponseHandler.set_parser   sE      %::#zz3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       	             X l         XPl        Xpl        [        U U R                  UU[
        U(       + UUUU	S9
U l        U R                  (       a%  U R                  Ssol        U R                  U
5        g g )N)ro   payload_exceptionresponse_with_bodyrq   rr   rv   rw   r   )	r"   r(   r*   r   _loopr
   r'   r%   rk   )r+   ro   rp   rq   rr   rs   rt   ru   rv   rw   rl   s              r,   set_response_params#ResponseHandler.set_response_params   ss     *)'=$)JJ0#//)+')
 ::#zz3D*t$ r   c                 b    U R                   b"  U R                   R                  5         S U l         g g r/   )r)   cancelr0   s    r,   rA   ResponseHandler._drop_timeout   s-    $$0%%,,.(,D% 1r   c                     U R                   nU R                  b  U R                  R                  5         U(       a+  U R                  R	                  XR
                  5      U l        g S U l        g r/   )r(   r)   r   r{   
call_later_on_read_timeout)r+   timeouts     r,   rc   #ResponseHandler._reschedule_timeout   sX    $$$$0%%,,.(,

(=(=..)D% )-D%r   c                 $    U R                  5         g r/   )rc   r0   s    r,   start_timeoutResponseHandler.start_timeout   s      "r   c                     U R                   $ r/   r(   r0   s    r,   rs   ResponseHandler.read_timeout   s    !!!r   c                     Xl         g r/   r   )r+   rs   s     r,   rs   r      s    )r   c                     [        S5      nU R                  U5        U R                  b  [        U R                  U5        g g )Nz#Timeout on reading data from socket)r   r   r!   )r+   rG   s     r,   r    ResponseHandler._on_read_timeout   s8     !FG3==$$--- %r   rl   c                 r   U R                  5         U(       d  g U R                  bK  U R                  R                  U5      u  p#U(       a&  S U l        S U l        U(       a  U R	                  U5        g U R
                  (       d  U R                  c  U =R                  U-  sl        g  U R                  R                  U5      u  pEnXPl        S nU Hu  u  pU	R"                  (       a  SU l        Xl        U R&                  (       d  U	R                  [(        ;   a  U R                  U	[*        4S5        Mb  U R                  X4S5        Mw     Ub5  U[*        La  UR-                  U R.                  5        OU R/                  5         U(       a  U(       a  U R	                  U5        g g g ! [         a  nU R                  b  U R                  R                  5         [        U[        5      (       a*  [        UR                  UR                  UR                  S9nO
[        5       nU R!                  Xv5         S nAg S nAff = f)N)codemessageheadersTr   )rc   r#   	feed_datar!   rk   r&   r'   r%   BaseExceptionr?   r@   rK   r   r   r   r   r   r8   r    r"   r   r   on_eofrA   )
r+   rl   eoftailmessagesr1   rU   rG   ri   r   s
             r,   rk   ResponseHandler.data_received   s     " +,,66t<IC $'+$&&t,>>T\\1JJ$J	'+||'='=d'C$H& "*. (G##%)"#M!!W\\5L%L7;115 !) 
 m+t112""$t$ 8U  	~~) $$&.*=>>)',,*22*22 *+s3!	s   &F! !
H6+BH11H6)r6   r'   r!   r#   r(   r)   rN   r    r"   r%   r*   r$   r&   r?   )r   N)'__name__
__module____qualname____firstlineno____doc__asyncioAbstractEventLoopr   propertyr4   r1   r8   r<   r@   rE   r   r   rP   r[   r^   rb   r   r   r   rm   r   floatintr|   rA   rc   r   rs   setterr   bytesrk   __static_attributes____classcell__)rX   s   @r,   r   r      s   B:W66 :4 :* $   	
d 	
 	
"!Nd N6.8M#: 6.t 6.p# $1.. !. 
	. .% %s %t %$ -1"$ $(,!()!""% ()"% 	"%
 "% "% uo"% "% !&"% "% "% 
"%H-

-# "huo " " *% *T * *.D%% D%D D% D%r   r   )r   
contextlibr   typingr   r   r   base_protocolr   client_exceptionsr	   r
   r   r   helpersr   r   r   r   httpr   r   http_exceptionsr   streamsr   r   r   r    r   r,   <module>r      sV      ' ' '   9 0 ; ;]%lIe4F4T.U$V ]%r   