ó
    	[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     Úc/home/gothic/public_html/Fooocus/fooocus_env/lib64/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°$·-±-×2FÑ2FÓ2HÔ.H÷à�~‰~÷ð �‰ dÐ*÷ð ×#Ñ#¨4Ð/÷	ð
 �|‰|÷ð �z‰zó
ð 	
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   € ØˆŒØ—N‘Nˆ	ØÑ Ø�O‰OÔØ!ˆDŒNØ ˆDŒMØ×ÑÕ ð	 !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°$·.±.×2KÑ2KÓ2MÔ.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Ð!à×ÑÑ+Üœ)Õ$Ø×$Ñ$×-Ñ-Ô/÷ %ð ˆØ�<‰<Ñ#ðØ"Ÿl™l×3Ñ3Ó5�ð" �{‰{�}‰}ÜÐ3´W×=Ñ=Ü,Ð.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   € ð  ŒØ%Ôà×ÑÔà�:�:Ø#Ÿz™z¨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       	         óè   • 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o l        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   € ð *Ôà)Ôà'=Ô$ä)ØØ�J‰JØØÜ0Ø#/Ô/Ø)Ø+Ø'Ø)ñ
ˆŒð �:�:Ø#Ÿz™z¨3Ðˆ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  p˜U	R"                  (       a  SU l        X€l        U R&                  (       d  U	R                  [(        ;   a  U R                  U	[*        4S5        Mb  U R                  X˜4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Ñ6°tÓ<‰IˆCÞØ $�”Ø'+�Ô$æØ×&Ñ& tÔ,Øà�>�>˜TŸ\™\Ñ1à�JŠJ˜$Ñ�JØð	Ø'+§|¡|×'=Ñ'=¸dÓ'CÑ$ˆH ð& "Œà*.ˆÛ (ÑˆGØ×#×#Ø%)�Ô"à#ŒMà×!×! W§\¡\Ô5LÓ%LØ—‘ ¬Ð7¸Ö;à—‘ Ð1°1Ö5ñ !)ð Ñð
 œmÒ+Ø—‘˜t×1Ñ1Õ2à×"Ñ"Ô$æžØ×Ñ˜tÕ$ð ˆ8øôU ó 	Ø�~‰~Ñ)ð —‘×$Ñ$Ô&ä˜.Ô*=×>Ñ>Ü)Ø'×,Ñ,Ø*×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. 8¨MÑ#:ð 6.¸t÷ 6.ôp÷÷#ð $1ñ.àð.ð !ð.ð 
÷	.ð .ð% ð %¨sð %°tô %ð$ -1Ø"Ø$Ø $Ø(,Ø!Ø()Ø!Ø"ò"%ð Ð(Ñ)ð"%ð ð	"%ð
 ð"%ð ð"%ð ˜u‘oð"%ð ð"%ð !&ð"%ð ð"%ð ð"%ð 
õ"%ôH-ô

-ô#ð ð"˜h u™oó "ó ð"ð ×Ñð*¨°%©ð *¸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ß ;Ñ ;ô]%�l I¨eÐ4FÈÐ4TÑ.UÑ$Võ ]%r   