+
     h4  c                  s   ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^RI	H
t
 ^RIHtHtHtHtHt ^RIHtHtHt ^RIHtHt ^RIHt ^RIHt ]P8                  ! R	4      t]P<                  ]P&                  ]P>                  ]P@                  3,          t! ! R
 R]PD                  4      t# ! R R]4      t$ ! R R4      t% ! R R]
4      t&R# )i    )annotationsN)NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError
WriteErrormap_exceptions)OriginRequestResponse)LockShieldCancellation)Trace)ConnectionInterfacezhttpcore.http11c                  s&    ] tR t^$t^ t^t^t^tRtR# )HTTPConnectionState N)	__name__
__module____qualname____firstlineno__NEWACTIVEIDLECLOSED__static_attributes__r       :/usr/lib/python3.14/site-packages/httpcore/_sync/http11.pyr   r   $   s    
CFDFr   r   c                  s   ] tR t^+tR)tR*tR+R R lltR R ltR R ltR R	 lt	R+R
 R llt
R R ltR R ltR+R R lltR R ltR R ltR R ltR R ltR R ltR R ltR R ltR  R! ltR" R# ltR$ R% ltR,R& R' lltR(tR# )-HTTP11ConnectionNc               (    V ^8  d   QhRRRRRRRR/# )	   originr   streamr   keepalive_expiryfloat | NonereturnNoner   Zformat   "r   __annotate__HTTP11Connection.__annotate__/   s2     
 

 
 '	

 

r   c                	s    Wn         W n        W0n        R V n        \        P
                  V n        \        4       V n        ^ V n	        \        P                  ! \        P                  V P                  R7      V n        R # )N)Zour_roleZmax_incomplete_event_size)_origin_network_stream_keepalive_expiry
_expire_atr   r   _stater
   _state_lock_request_counth11Z
ConnectionZCLIENTMAX_INCOMPLETE_EVENT_SIZE
_h11_state)selfr   r   r       &&&&r   __init__ZHTTP11Connection.__init__/   s[     %/?(,)--6..ZZ&*&D&D
r   c                    V ^8  d   QhRRRR/# )r   requestr   r"   r	   r   r$   r%   r   r&   r'   A   s     G Gg G( Gr   c                	s   V P                  VP                  P                  4      '       g0   \        R VP                  P                   RV P                   24      hV P
                  ;_uu_ 4        V P                  \        P                  \        P                  39   d7   V ;P                  ^,          un
        \        P                  V n        RV n        M
\        4       h RRR4        RV/p \        R\        W4      ;_uu_ 4       pV P                   ! R/ VB  RRR4       \        R\        W4      ;_uu_ 4       pV P"                  ! R/ VB  RRR4       \        R\        Y4      ;_uu_ 4       pT P&                  ! R/ TB w  pppppTTTT3Tn        RRR4       T P*                  p	X^e8X  g$   TP,                  R8X  d   ^Tu;8:  d   R8  d   M M\/        T	X4      p	\1        TX\3        Y4      R	XR
XRT	/R7      #   + '       g   i     EL$; i  + '       g   i     L; i  + '       g   i     L; i  \$         d     Li ; i  + '       g   i     L; i  \4         d}   p
\7        4       ;_uu_ 4        \        R\        T4      ;_uu_ 4       pT P9                  4        RRR4       M  + '       g   i     M; iRRR4       T
h  + '       g   i     T
h; iRp
?
ii ; i)zAttempted to send request to z on connection to Nr6   Zsend_request_headersZsend_request_bodyZreceive_response_headerss   CONNECTi,  http_versionreason_phrasenetwork_stream)statusheadersZcontent
extensionsresponse_closedr   )can_handle_requesturlr   ZRuntimeErrorr(   r-   r,   r   r   r   r.   r   r+   r   r   logger_send_request_headers_send_request_bodyr   _receive_response_headersZreturn_valuer)   methodHTTP11UpgradeStreamr	   HTTP11ConnectionByteStreamBaseExceptionr   _response_closed)r2   r6   kwargsZtracer7   r:   r8   r;   trailing_datar9   excs   &&         r   handle_requestZHTTP11Connection.handle_requestA   s   &&w{{'9'9::/0B0B/C Dll^% 
 {{2668K8P8PQQ##q(#188"&,..  	 8	)F*FG ..88 .HHE++5f5 I *FG  22<V< !! !!	&"" "11N #:-C64GC4G!4^]!S24A"L#]$n		 	e   IH   F  	#%%,fg>>%))+ ?>>> & I &% I		s   /A0G;)I .H5 H!H5 ;H"H5 I /$IA'I ;H	H	H5 "H2	-H5 1I 2H5 5I I II I	I K $K6KJ*!	K*J:5K=
KK	KK c               r5   r   r6   r   r"   r#   r   r$   r%   r   r&   r'      s     
1 
1W 
1 
1r   c                	s   VP                   P                  R / 4      pVP                  RR4      p\        \        P                  \        /4      ;_uu_ 4        \        P
                  ! VP                  VP                  P                  VP                  R7      pRRR4       V P                  XVR7       R#   + '       g   i     L%; i)timeoutwriteN)rD   targetr;   rN   )r<   getr   r/   r   r   rD   r?   rP   r;   _send_eventr2   r6   timeoutsrN   event   &&   r   rA   Z&HTTP11Connection._send_request_headers   s    %%)))R8,,w-S335GHIIKK~~{{))E J 	0 JIs   AB55C	c               r5   rM   r   r$   r%   r   r&   r'      s     	> 	>' 	>d 	>r   c                	s&   VP                   P                  R / 4      pVP                  RR4      pVP                   F,  p\        P                  ! VR7      pV P                  WSR7       K.  	  V P                  \        P                  ! 4       VR7       R# )rN   rO   N)datarQ   )r<   rR   r   r/   DatarS   EndOfMessage)r2   r6   rU   rN   chunkrV   s   &&    r   rB   Z#HTTP11Connection._send_request_body   sw    %%)))R8,,w- ^^EHH%(EU4 $ 	))+W=r   c               $    V ^8  d   QhRRRRRR/# )r   rV   z	h11.EventrN   r!   r"   r#   r   r$   r%   r   r&   r'      s&     G G G\ GT Gr   c                	s    V P                   P                  V4      pVe   V P                  P                  W2R7       R # R # )NrQ   )r1   Zsendr)   rO   )r2   rV   rN   Zbytes_to_send   &&& r   rS   ZHTTP11Connection._send_event   s8    ,,U3$  &&}&F %r   c               r5   )r   r6   r   r"   z:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes]r   r$   r%   r   r&   r'      s      U UU	CUr   c                	s   VP                   P                  R / 4      pVP                  RR4      p V P                  VR7      p\        V\        P
                  4      '       d   M6\        V\        P                  4      '       g   KV  VP                  ^e8X  g   Ki   RVP                  ,           pVP                  P                  4       pV P                  P                  w  rxWTP                  VP                  Wg3# )rN   readNrQ   s   HTTP/)r<   rR   _receive_event
isinstancer/   r	   ZInformationalResponseZstatus_coder7   r;   Z	raw_itemsr1   rJ   Zreason)	r2   r6   rU   rN   rV   r7   r;   rJ   Z_s	   &&       r   rC   Z*HTTP11Connection._receive_response_headers   s     %%)))R8,,vt,'''8E%..5#";";<<%%,%"4"44 --))+??88..gTTr   c               r5   )r   r6   r   r"   typing.Iterator[bytes]r   r$   r%   r   r&   r'      s      	r   c              #  	sf  "   VP                   P                  R / 4      pVP                  RR4      p V P                  VR7      p\        V\        P
                  4      '       d   \        VP                  4      x  KL  \        V\        P                  \        P                  34      '       g   K~  R# 5i)rN   r^   NrQ   )
r<   rR   r_   r`   r/   rY   bytesrX   rZ   ZPAUSEDrT   rW   r   _receive_response_bodyZ'HTTP11Connection._receive_response_body   s      %%)))R8,,vt,'''8E%**EJJ''EC$4$4cjj#ABBs   B(B1/B1c               r5   )r   rN   r!   r"   zh11.Event | type[h11.PAUSED]r   r$   r%   r   r&   r'      s      #	%r   c                	s    \        \        P                  \        /4      ;_uu_ 4        V P                  P	                  4       pRRR4       X\        P
                  J d   V P                  P                  V P                  VR7      pVR8X  d7   V P                  P                  \        P                  8X  d   Rp\        V4      hV P                  P                  V4       K  V#   + '       g   i     L; i)TNrQ   r   z/Server disconnected without sending a response.)r   r/   r   r1   Z
next_eventZ	NEED_DATAr)   r^   READ_NUM_BYTEStheir_stateZSEND_RESPONSEZreceive_data)r2   rN   rV   rX   ZmsgrW   r   r_   ZHTTP11Connection._receive_event   s     !8!8:M NOO224 P %++00'' 1  3;4??#>#>#BSBS#SKC-c22,,T2 / POs   C##C3	c                   V ^8  d   QhRR/# r   r"   r#   r   r$   r%   r   r&   r'      s      $ r   c                	s   V P                   ;_uu_ 4        V P                  P                  \        P                  J d   V P                  P
                  \        P                  J dk   \        P                  V n        V P                  P                  4        V P                  e-   \        P                  ! 4       pWP                  ,           V n        MV P                  4        R R R 4       R #   + '       g   i     R # ; iN)r-   r1   Z	our_stater/   ZDONEre   r   r   r,   Zstart_next_cycler*   time	monotonicr+   close)r2   now   & r   rH   Z!HTTP11Connection._response_closed   s    ))SXX5OO//388;166002))5..*C&),B,B&BDO

 s   CC**C;	c               rf   rg   r   r$   r%   r   r&   r'      s     % %t %r   c                	sd    \         P                  V n        V P                  P	                  4        R # rh   )r   r   r,   r)   rk   r2      &r   rk   ZHTTP11Connection.close   s#     *00""$r   c               r5   )r   r   r   r"   boolr   r$   r%   r   r&   r'     s     & & &D &r   c                	s    WP                   8H  # rh   )r(   r2   r      &&r   r>   Z#HTTP11Connection.can_handle_request  s    %%r   c               rf   r   r"   rp   r   r$   r%   r   r&   r'     s     7 7d 7r   c                	<    V P                   \        P                  8H  # rh   r,   r   r   rn   ro   r   is_availableZHTTP11Connection.is_available  s    
 {{16666r   c               rf   rs   r   r$   r%   r   r&   r'     s     8 8T 8r   c                	s   \         P                  ! 4       pV P                  R J;'       d    WP                  8  pV P                  \        P
                  8H  ;'       d    V P                  P                  R4      pT;'       g    T# )NZis_readable)ri   rj   r+   r,   r   r   r)   get_extra_info)r2   rl   Zkeepalive_expiredZserver_disconnected   &   r   has_expiredZHTTP11Connection.has_expired  sw    nn OO47QQC//<Q KK.333 C C$$33MB 	
 !77$77r   c               rf   rs   r   r$   r%   r   r&   r'      s     7 7 7r   c                	rt   rh   ru   rn   ro   r   is_idleZHTTP11Connection.is_idle   s    {{16666r   c               rf   rs   r   r$   r%   r   r&   r'   #  s     9 94 9r   c                	rt   rh   )r,   r   r   rn   ro   r   	is_closedZHTTP11Connection.is_closed#  s    {{18888r   c               rf   r   r"   strr   r$   r%   r   r&   r'   &  s     
 
c 
r   c                	s~    \        V P                  4      pV: R V P                  P                   RV P                   2# )z, HTTP/1.1, , Request Count: )r}   r(   r,   namer.   rq   rm   r   infoZHTTP11Connection.info&  sA    T\\"jT[[%5%5$6 7"1124	
r   c               rf   r|   r   r$   r%   r   r&   r'   -  s     
 
# 
r   c           	     	s    V P                   P                  p\        V P                  4      pR V RV: RV P                  P
                   RV P                   R2	# )Z<z [z, r~   z]>)Z	__class__r   r}   r(   r,   r   r.   )r2   Z
class_namer   s   &  r   __repr__ZHTTP11Connection.__repr__-  sZ    ^^,,
T\\"
|2fZr$++*:*:); <"112"6	
r   c               rf   )r   r"   r   r   r$   r%   r   r&   r'   8  s      + r   c                	s    V # rh   r   rn   ro   r   	__enter__ZHTTP11Connection.__enter__8  s    r   c               r   )	r   exc_typeztype[BaseException] | None	exc_valuezBaseException | None	tracebackztypes.TracebackType | Noner"   r#   r   r$   r%   r   r&   r'   ;  s2      , ( .	
 
r   c                	s&    V P                  4        R # rh   )rk   )r2   r   r   r   r3   r   __exit__ZHTTP11Connection.__exit__;  s     	

r   )r+   r1   r*   r)   r(   r.   r,   r-   i   i  rh   )NNN)r   r   r   r   rd   r0   r4   rL   rA   rB   rS   rC   rc   r_   rH   rk   r>   rv   ry   rz   r{   r   r   r   r   r   r   r   r   r   r   +   su    N *
$GV
1	>GU4: %&7879

 r   r   c                  s:    ] tR tRtR R ltR R ltR R ltRtR	# )
rF   iD  c               r\   )r   
connectionr   r6   r   r"   r#   r   r$   r%   r   r&   'HTTP11ConnectionByteStream.__annotate__E  s"      #3 g $ r   c                	s,    Wn         W n        R V n        R# )FN)_connection_request_closed)r2   r   r6      &&&r   r4   Z#HTTP11ConnectionByteStream.__init__E  s    %r   c               rf   )r   r"   ra   r   r$   r%   r   r&   r   J  s      0 r   c              #  	s  "   R V P                   /p \        R\        V P                   V4      ;_uu_ 4        V P                  P                  ! R/ VB  F  pVx  K	  	  RRR4       R#   + '       g   i     R# ; i  \
         dG   p\        4       ;_uu_ 4        T P                  4        RRR4       Th  + '       g   i     Th; iRp?ii ; i5i)r6   Zreceive_response_bodyNr   )r   r   r@   r   rc   rG   r   rk   )r2   rI   r[   rK   rx   r   __iter__Z#HTTP11ConnectionByteStream.__iter__J  s     T]]+
	.vNN!--DDNvNEK O ONNN  	 $%%

 &I &%I	sc   C$A< (A(A< &C(A9	3A< 7C9A< <CCB4*
C4C?	CCCc               rf   rg   r   r$   r%   r   r&   r   X  s     4 4t 4r   c                	s    V P                   '       gP   R V n         \        R\        V P                  4      ;_uu_ 4        V P                  P                  4        RRR4       R# R#   + '       g   i     R# ; i)Tr=   N)r   r   r@   r   r   rH   rn   ro   r   rk   Z HTTP11ConnectionByteStream.closeX  sP    |||DL(&$--@@  113 A@ @@@s   A$$A5	)r   r   r   N)r   r   r   r   r4   r   rk   r   r   r   r   rF   rF   D  s    
4 4r   rF   c                  sj    ] tR tRtR R ltRR R lltRR R lltR	 R
 ltRR R lltR R lt	Rt
R# )rE   i_  c               r\   )r   r   r   leading_datarb   r"   r#   r   r$   r%   r   r&    HTTP11UpgradeStream.__annotate__`  s!     * *} *E *d *r   c                	s    Wn         W n        R # rh   )_stream_leading_data)r2   r   r   r   r   r4   ZHTTP11UpgradeStream.__init__`  s    )r   Nc               r\   )r   	max_bytesZintrN   r!   r"   rb   r   r$   r%   r   r&   r   d  s!     9 9c 9L 9E 9r   c                	s    V P                   '       d&   V P                   R V pV P                   VR  V n         V# V P                  P                  W4      # rh   )r   r   r^   )r2   r   rN   bufferr]   r   r^   ZHTTP11UpgradeStream.readd  sO    ''
3F!%!3!3IJ!?DM<<$$Y88r   c               r\   )r   r   rb   rN   r!   r"   r#   r   r$   r%   r   r&   r   l  s!     , ,E ,L ,D ,r   c                	s<    V P                   P                  W4       R # rh   )r   rO   )r2   r   rN   r   r   rO   ZHTTP11UpgradeStream.writel  s    6+r   c               rf   rg   r   r$   r%   r   r&   r   o  s      t r   c                	s:    V P                   P                  4        R # rh   )r   rk   rn   ro   r   rk   ZHTTP11UpgradeStream.closeo  s    r   c               r   )	r   ssl_contextzssl.SSLContextserver_hostnamez
str | NonerN   r!   r"   r   r   r$   r%   r   r&   r   r  s8     M M#M $M 	M
 
Mr   c                	s:    V P                   P                  WV4      # rh   )r   	start_tls)r2   r   r   rN   r3   r   r   ZHTTP11UpgradeStream.start_tlsr  s     ||%%kGLLr   c               r5   )r   r   r}   r"   z
typing.Anyr   r$   r%   r   r&   r   z  s     1 13 1: 1r   c                	s8    V P                   P                  V4      # rh   )r   rw   )r2   r   rr   r   rw   Z"HTTP11UpgradeStream.get_extra_infoz  s    ||**400r   )r   r   rh   )NN)r   r   r   r   r4   r^   rO   rk   r   rw   r   r   r   r   rE   rE   _  s&    *9,M1 1r   rE   )'Z
__future__r    ZenumZloggingZsslri   ZtypesZtypingr/   Z_backends.baser   Z_exceptionsr   r   r   r   r   Z_modelsr   r   r	   Z_synchronizationr
   r   Z_tracer   Z
interfacesr   Z	getLoggerr@   ZUnionrY   rZ   ZH11SendEventZIntEnumr   r   rF   rE   r   r   r   <module>r      s    "   
    
 *  0 / 7  +			,	- ||KKHH$,, V* Vr4 461- 1r   