+
     BiAo                        Rt ^ RIt^ RIt^ RIt^ RIt^ RIt]! ]R4      '       d
   ] R,          t ^RIHt ^RIH	t	 ^RIH
t
 ^RIHt ^R	IHt ^R
IHt ^RIHt RtRR]/R lltRR]/R llt]! ]R4      '       d   RR]/R lltRR]/R llt ! R R]P,                  4      t ! R R]]P,                  4      t ! R R4      t ! R R 4      tR# )StreamReaderStreamWriterStreamReaderProtocolNAF_UNIX)
coroutines)events)
exceptions)format_helpers)	protocols)logger)sleeplimitc                   a	"   \         P                  ! 4       p\        W$R 7      p\        WTR7      o	VP                  ! V	3R lW3/ VB G Rj  xL
 w  rg\        VS	WT4      pWX3#  L5i)r   loopr   c                     < S # N protocols   &/usr/lib/python3.14/asyncio/streams.py<lambda>!open_connection.<locals>.<lambda>1   s        N)r   get_running_loopr   r   create_connectionr   )
hostportr   kwdsr   reader	transport_writerr   s
   &&$,     @r   open_connectionr$      si     & ""$D1F#F6H//$.(,. .LI)Xv<F>.   A	A%A#A%c                   a aa"   \         P                  ! 4       oV VV3R  lpSP                  ! WQV3/ VB G Rj  xL
 #  L5i)c                  >   < \        SSR 7      p \        V SSR7      pV# r   r   r   r   r    r   client_connected_cbr   r   s     r   factorystart_server.<locals>.factoryN   s&    E5'0C-13r   N)r   r   create_server)r+   r   r   r   r   r,   r   s   f&&d, @r   start_serverr/   6   s;     , ""$D ##G4@4@@@@s   5A?Ac                   a"   \         P                  ! 4       p\        WR 7      p\        WCR7      oVP                  ! V3R lV 3/ VB G Rj  xL
 w  rV\        VSWC4      pWG3#  L5i)r   r   c                     < S # r   r   r   s   r   r   &open_unix_connection.<locals>.<lambda>b   s    Hr   N)r   r   r   r   create_unix_connectionr   )	pathr   r   r   r    r!   r"   r#   r   s	   &$,     @r   open_unix_connectionr5   Z   si      &&(E5':!88d,&*, ,	i6@~,r%   c                   a aa"   \         P                  ! 4       oV VV3R  lpSP                  ! WA3/ VB G Rj  xL
 #  L5i)c                  >   < \        SSR 7      p \        V SSR7      pV# r(   r)   r*   s     r   r,   "start_unix_server.<locals>.factoryk   s&    !D9F+F4G157HOr   N)r   r   create_unix_server)r+   r4   r   r   r,   r   s   f&d, @r   start_unix_serverr:   f   s9      &&(	 ,,WCdCCCCs   4A >A c                   H   a  ] tR t^tt o R	R ltR tR tR tR tR t	Rt
V tR# )
FlowControlMixinNc                    Vf   \         P                  ! 4       V n        MWn        RV n        \        P
                  ! 4       V n        RV n        R # )NF)r   get_event_loop_loop_pausedcollectionsdeque_drain_waiters_connection_lost)selfr   s   &&r   __init__FlowControlMixin.__init__~   s<    <..0DJJ)//1 %r   c                    R V n         V P                  P                  4       '       d   \        P                  ! RV 4       R# R# )Tz%r pauses writingN)r@   r?   	get_debugr   debugrE   s   &r   pause_writingFlowControlMixin.pause_writing   s0    ::!!LL,d3 "r   c                    R V n         V P                  P                  4       '       d   \        P                  ! RV 4       V P
                   F,  pVP                  4       '       d   K  VP                  R4       K.  	  R# )Fz%r resumes writingN)r@   r?   rI   r   rJ   rC   done
set_resultrE   waiters   & r   resume_writingFlowControlMixin.resume_writing   sT    ::!!LL-t4))F;;==!!$' *r   c                    R V n         V P                  '       g   R# V P                   FC  pVP                  4       '       d   K  Vf   VP	                  R4       K2  VP                  V4       KE  	  R# TN)rD   r@   rC   rO   rP   set_exceptionrE   excrR   s   && r   connection_lost FlowControlMixin.connection_lost   sR     $|||))F;;==;%%d+((- *r   c                j  "   V P                   '       d   \        R 4      hV P                  '       g   R# V P                  P	                  4       pV P
                  P                  V4        VG Rj  xL
  V P
                  P                  V4       R#  L!  T P
                  P                  T4       i ; i5i)zConnection lostN)rD   ConnectionResetErrorr@   r?   create_futurerC   appendremoverQ   s   & r   _drain_helperFlowControlMixin._drain_helper   s        &'899|||))+""6*	/LL&&v. &&v.s4   /B37B3*B /B0B 4B3B B00B3c                    \         hr   )NotImplementedErrorrE   streams   &&r   _get_close_waiter"FlowControlMixin._get_close_waiter   s    !!r   )rD   rC   r?   r@   r   )__name__
__module____qualname____firstlineno__rF   rL   rS   rZ   ra   rg   __static_attributes____classdictcell____classdict__s   @r   r<   r<   t   s(     &4(.
/" "r   r<   c                   z   a a ] tR t^t oRtRV 3R llt]R 4       tR tR t	V 3R lt
R tR tR	 tR
 tRtVtV ;t# )r   Nc                .  < \         SV `  VR 7       Ve.   \        P                  ! V4      V n        VP
                  V n        MRV n        Ve   Wn        RV n        RV n        RV n	        W n
        RV n        V P                  P                  4       V n        R# )r   NF)superrF   weakrefref_stream_reader_wr_source_traceback_strong_reader_reject_connection_task
_transport_client_connected_cb	_over_sslr?   r^   _closed)rE   stream_readerr+   r   	__class__s   &&&&r   rF   StreamReaderProtocol.__init__   s    d#$%,[[%?D"%2%D%DD"%)D"* #0"'
$7!zz//1r   c                B    V P                   f   R # V P                  4       # r   )rv   rK   s   &r   _stream_reader#StreamReaderProtocol._stream_reader   s     !!)%%''r   c                Z    V P                   pWn        VP                  R 4      RJV n        R# )
sslcontextN)r?   r{   get_extra_infor}   )rE   r!   r   s   && r   _replace_transport'StreamReaderProtocol._replace_transport   s'    zz#"11,?tKr   c                  a a S P                   '       dS   R R/pS P                  '       d   S P                  VR&   S P                  P                  V4       SP	                  4        R# SS n        S P                  pVe   VP                  S4       SP                  R4      RJS n	        S P                  e   \        SS VS P                  4      pS P                  W44      p\        P                  ! V4      '       dC   V V3R lpS P                  P                  V4      S n        S P                  P!                  V4       RS n        R# R# )messagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.source_tracebackNr   c                    < V P                  4       '       d   SP                  4        R # V P                  4       pVe4   SP                  P	                  RRRVRS/4       SP                  4        R # R # )Nr   z*Unhandled exception in client_connected_cb	exceptionr!   )	cancelledcloser   r?   call_exception_handler)taskrY   rE   r!   s   & r   callback6StreamReaderProtocol.connection_made.<locals>.callback   sf    ~~''!)..*C

99%'S''; 
 ") 'r   )ry   rw   r?   r   abortr{   r   set_transportr   r}   r|   r   r   iscoroutinecreate_taskrz   add_done_callbackrx   )rE   r!   contextr    r#   resr   s   ff     r   connection_made$StreamReaderProtocol.connection_made   s   """ @G
 %%%.2.D.D*+JJ--g6OO#$$  +"11,?tK$$0!)T64::FF++F;C%%c*** "ZZ33C8


,,X6"&D) 1r   c                  < V P                   pVe'   Vf   VP                  4        MVP                  V4       V P                  P	                  4       '       g<   Vf   V P                  P                  R 4       MV P                  P                  V4       \        SV `  V4       R V n        R V n	        R V n
        R V n        R # r   )r   feed_eofrW   r~   rO   rP   rs   rZ   rv   _stream_writerrz   r{   )rE   rY   r    r   s   && r   rZ   $StreamReaderProtocol.connection_lost  s    $${!$$S)||  ""{''-**3/$!%"
r   c                L    V P                   pVe   VP                  V4       R # R # r   )r   	feed_data)rE   datar    s   && r   data_received"StreamReaderProtocol.data_received  s&    $$T" r   c                n    V P                   pVe   VP                  4        V P                  '       d   R# R# )NFT)r   r   r}   )rE   r    s   & r   eof_received!StreamReaderProtocol.eof_received  s.    $$OO>>> r   c                    V P                   # r   )r~   re   s   &&r   rg   &StreamReaderProtocol._get_close_waiter&  s    ||r   c                     V P                   pVP                  4       '       d+   VP                  4       '       g   VP                  4        R # R # R #   \         d     R # i ; ir   )r~   rO   r   r   AttributeError)rE   closeds   & r   __del__StreamReaderProtocol.__del__)  sR    	#\\F {{}}V%5%5%7%7  " &8}  		s   A AA)
r|   r~   r}   ry   rw   rv   r   rx   rz   r{   NN)ri   rj   rk   rl   rw   rF   propertyr   r   r   rZ   r   r   rg   r   rm   rn   __classcell__)r   rp   s   @@r   r   r      sP      2& ( (
L
%'N$#
		# 	#r   c                      a  ] tR tRt o R tR t]R 4       tR tR t	R t
R tR	 tR
 tR tRR ltR tRRRRRR/R lt]3R ltRtV tR# )r   i5  c                    Wn         W n        W0n        W@n        V P                  P	                  4       V n        V P
                  P                  R 4       R # r   )r{   	_protocol_readerr?   r^   _complete_futrP   )rE   r!   r   r    r   s   &&&&&r   rF   StreamWriter.__init__?  sA    #! 
!ZZ557%%d+r   c                    V P                   P                  R V P                  : 2.pV P                  e    VP	                  RV P                  : 24       RP                  RP                  V4      4      # )
transport=zreader=<{}> )r   ri   r{   r   r_   formatjoinrE   infos   & r   __repr__StreamWriter.__repr__I  s[    '':doo5H)IJ<<#KK'$,,!123}}SXXd^,,r   c                    V P                   # r   r{   rK   s   &r   r!   StreamWriter.transportO  s    r   c                <    V P                   P                  V4       R # r   )r{   writerE   r   s   &&r   r   StreamWriter.writeS  s    d#r   c                <    V P                   P                  V4       R # r   )r{   
writelinesr   s   &&r   r   StreamWriter.writelinesV  s    ""4(r   c                6    V P                   P                  4       # r   )r{   	write_eofrK   s   &r   r   StreamWriter.write_eofY  s    ((**r   c                6    V P                   P                  4       # r   )r{   can_write_eofrK   s   &r   r   StreamWriter.can_write_eof\  s    ,,..r   c                6    V P                   P                  4       # r   )r{   r   rK   s   &r   r   StreamWriter.close_  s    $$&&r   c                6    V P                   P                  4       # r   )r{   
is_closingrK   s   &r   r   StreamWriter.is_closingb  s    ))++r   c                X   "   V P                   P                  V 4      G R j  xL
  R #  L5ir   )r   rg   rK   s   &r   wait_closedStreamWriter.wait_closede  s     nn..t444s   *(*Nc                8    V P                   P                  W4      # r   )r{   r   )rE   namedefaults   &&&r   r   StreamWriter.get_extra_infoh  s    --d<<r   c                  "   V P                   e!   V P                   P                  4       pVe   VhV P                  P                  4       '       d   \	        ^ 4      G R j  xL
  V P
                  P                  4       G R j  xL
  R #  L( L5ir   )r   r   r{   r   r   r   ra   )rE   rY   s   & r   drainStreamWriter.draink  sk      <<#,,((*C	??%%'' (NNnn**,,, ,s*   ABBB !BB
B
Bserver_hostnamessl_handshake_timeoutssl_shutdown_timeoutc          
        "   V P                   P                  R JpV P                   pV P                  4       G R j  xL
  V P                  P	                  V P
                  WaWRVVR7      G R j  xL
 pWpn        VP                  V4       R #  LO L5i)N)server_sider   r   r   )r   r|   r   r?   	start_tlsr{   r   )rE   r   r   r   r   r   r   new_transports   &&$$$   r   r   StreamWriter.start_tls  s     
 nn99E>>jjl"jj22OOX#"7!5	 3 7 7
 (##M2 	7s!   8BB
1B,B-BBc                   V P                   P                  4       '       gg   V P                  P                  4       '       d   VP                  ! R \
        4       R# V P                  4        VP                  ! RV : 2\
        4       R# R# )zloop is closedz	unclosed N)r{   r   r?   	is_closedwarnResourceWarningr   )rE   warningss   &&r   r   StreamWriter.__del__  sZ    ))++zz##%%.@

	$2OD ,r   )r   r?   r   r   r{   r   )ri   rj   rk   rl   rF   r   r   r!   r   r   r   r   r   r   r   r   r   r   r   r   rm   rn   ro   s   @r   r   r   5  s     ,-  $)+/',5=-23(,3.23 .23   ( E Er   c                      a  ] tR tRt o Rt]R3R ltR tR tR t	R t
R tR	 tR
 tR tR tR tR tRR ltRR ltR tR tR tRtV tR# )r   i  Nc                   V^ 8:  d   \        R4      hWn        Vf   \        P                  ! 4       V n        MW n        \        4       V n        RV n        RV n        RV n	        RV n
        RV n        V P                  P                  4       '       d2   \        P                  ! \        P                   ! ^4      4      V n        R# R# )    zLimit cannot be <= 0NF)
ValueError_limitr   r>   r?   	bytearray_buffer_eof_waiter
_exceptionr{   r@   rI   r	   extract_stacksys	_getframerw   )rE   r   r   s   &&&r   rF   StreamReader.__init__  s     A:344<..0DJJ {	::!!%3%A%Aa &"D" "r   c                   R .pV P                   '       d(   VP                  \        V P                   4       R24       V P                  '       d   VP                  R4       V P                  \
        8w  d   VP                  RV P                   24       V P                  '       d    VP                  RV P                  : 24       V P                  '       d    VP                  RV P                  : 24       V P                  '       d    VP                  RV P                  : 24       V P                  '       d   VP                  R4       RP                  R	P                  V4      4      # )
r   z byteseofzlimit=zwaiter=z
exception=r   pausedr   r   )r   r_   lenr   r   _DEFAULT_LIMITr   r   r{   r@   r   r   r   s   & r   r   StreamReader.__repr__  s    <<<KK3t||,-V45999KK;;.(KK&./<<<KK'$,,!123???KK*T__$789???KK*T__$789<<<KK!}}SXXd^,,r   c                    V P                   # r   )r   rK   s   &r   r   StreamReader.exception  s    r   c                    Wn         V P                  pVe3   R V n        VP                  4       '       g   VP                  V4       R # R # R # r   )r   r   r   rW   rX   s   && r   rW   StreamReader.set_exception  sD    DL##%%$$S) & r   c                    V P                   pVe3   R V n         VP                  4       '       g   VP                  R 4       R # R # R # r   )r   r   rP   rQ   s   & r   _wakeup_waiterStreamReader._wakeup_waiter  s?    DL##%%!!$' & r   c                    Wn         R # r   r   )rE   r!   s   &&r   r   StreamReader.set_transport  s    #r   c                    V P                   '       dJ   \        V P                  4      V P                  8:  d$   R V n         V P                  P                  4        R# R# R# )FN)r@   r  r   r   r{   resume_readingrK   s   &r   _maybe_resume_transport$StreamReader._maybe_resume_transport  s=    <<<C-< DLOO**, =<r   c                4    R V n         V P                  4        R# rV   )r   r
  rK   s   &r   r   StreamReader.feed_eof  s    	r   c                L    V P                   ;'       d    V P                  '       * # r   )r   r   rK   s   &r   at_eofStreamReader.at_eof  s    yy----r   c                   V'       g   R # V P                   P                  V4       V P                  4        V P                  ef   V P                  '       gR   \        V P                   4      ^V P                  ,          8  d%    V P                  P                  4        RV n        R # R # R # R #   \         d    R T n         R # i ; i)NT)	r   extendr
  r{   r@   r  r   pause_readingrd   r   s   &&r   r   StreamReader.feed_data  s     D!OO'LLLDLL!AO3$--/  $ 4 ! (
 ' ' #'	's   B+ +C Cc                >  "   V P                   e   \        V R24      hV P                  '       d"   RV n        V P                  P	                  4        V P
                  P                  4       V n          V P                   G R j  xL
  R V n         R #  L  R T n         i ; i5i)NzF() called while another coroutine is already waiting for incoming dataF)r   RuntimeErrorr@   r{   r  r?   r^   )rE   	func_names   &&r   _wait_for_dataStreamReader._wait_for_data  s      <<#+ 4 56 6 <<< DLOO**,zz//1	 ,,DL DLs5   .BA B2B BB 	BB 	BBc                  "   R p\        V4      p V P                  V4      G Rj  xL
 pV#  L  \        P                   d   pTP                  u Rp?# Rp?i\        P
                   d   pT P                  P                  YP                  4      '       d"   T P                  RTP                  T,           1 MT P                  P                  4        T P                  4        \        TP                  ^ ,          4      hRp?ii ; i5i)   
N)r  	readuntilr   IncompleteReadErrorpartialLimitOverrunErrorr   
startswithconsumedclearr  r   args)rE   sepseplenlinees   &    r   readlineStreamReader.readline  s       S
	(,,D  --- 	99++ 	(||&&sJJ77LL!5!**v"5!56""$((*QVVAY''	(sP   D. ,. D. DADDD+D,BC>>DDc                N  "   \        V\        4      '       d   \        V\        R 7      pMV.pV'       g   \	        R4      h\        V^ ,          4      p\        VR,          4      pV^ 8X  d   \	        R4      hV P
                  e   V P
                  h^ p \        V P                  4      pWT,
          V8  d   RpRpV FI  pV P                  P                  W4      p	V	R8w  g   K'  V	\        V4      ,           p
Ve	   W8  g   KE  T
pT	pKK  	  Ve   M\        ^ V^,           V,
          4      pW@P                  8  d   \        P                  ! RV4      hV P                  '       dG   \        V P                  4      pV P                  P                  4        \        P                  ! VR4      hV P!                  R4      G Rj  xL
  EK0  W`P                  8  d   \        P                  ! RV4      hV P                  RV pV P                  RV1 V P#                  4        \        V4      #  Lg5i))keyz-Separator should contain at least one elementz,Separator should be at least one-byte stringNz2Separator is not found, and chunk exceed the limitr"  z2Separator is found, but chunk is longer than limit)
isinstancetuplesortedr  r   r   r   findmaxr   r   r%  r   bytesr(  r#  r  r  )rE   	separator
min_seplen
max_seplenoffsetbuflenmatch_start	match_endr*  isependchunks   &&          r   r"  StreamReader.readuntil>  s    4 i''yc2I"ILMM1&
2'
?KLL??&//!*  &F *," 	$C<<,,S9Drz #SXo$,(+I*.K % ( Q
Z 78KK'$66L    yyydll+""$ 44UDAA %%k222$..DkS S Zi(LL)$$$&U| 3s,   3H%B(H%#H%AH%!AH%;H#<A(H%c                
  "   V P                   e   V P                   hV^ 8X  d   R# V^ 8  dT   . p V P                  V P                  4      G R j  xL
 pV'       g   MVP                  V4       K@  RP	                  V4      # V P
                  '       g,   V P                  '       g   V P                  R4      G R j  xL
  \        \        V P
                  4      R V 4      pV P
                  R V1 V P                  4        V#  L LH5i)Nr   read)r   rE  r   r_   r   r   r   r  r8  
memoryviewr  )rE   nblocksblockr   s   &&   r   rE  StreamReader.read  s     , ??&//!6q5
 F"ii44e$88F##|||DIII%%f--- Z-bq12LL!$$& 5 .s7   ADC?D6DD$D8D9ADDc                  "   V^ 8  d   \        R4      hV P                  e   V P                  hV^ 8X  d   R# \        V P                  4      V8  ds   V P                  '       dF   \        V P                  4      pV P                  P                  4        \        P                  ! W!4      hV P                  R4      G Rj  xL
  K  \        V P                  4      V8X  d1   \        V P                  4      pV P                  P                  4        M0\        \        V P                  4      RV 4      pV P                  RV1 V P                  4        V#  L5i)r   z*readexactly size can not be less than zeroNr   readexactly)r   r   r  r   r   r8  r(  r   r#  r  rF  r  )rE   rG  
incompleter   s   &&  r   rL  StreamReader.readexactly  s     q5IJJ??&//!6$,,!#yyy"4<<0
""$ 44ZCC%%m444t||!&DLL DLL1"156DRaR $$& 5s   A!E$AE=E>BEc                    V # r   r   rK   s   &r   	__aiter__StreamReader.__aiter__  s    r   c                \   "   V P                  4       G R j  xL
 pVR8X  d   \        hV#  L5i)Nr   )r.  StopAsyncIteration)rE   vals   & r   	__anext__StreamReader.__anext__  s*     MMO##:$$
 $s   ,*,)	r   r   r   r   r?   r@   rw   r{   r   )r!  )r2  )ri   rj   rk   rl   rw   r  rF   r   r   rW   r
  r   r  r   r  r   r  r.  r"  rE  rL  rP  rU  rm   rn   ro   s   @r   r   r     sn     +$ ",-$*($-
.$, 8>pd1f'R r   )r   r   r   r$   r/   )r5   r:   i   r   r   )__all__rA   socketr   r   rt   hasattr r   r   r   r	   r
   logr   tasksr   r  r$   r/   r5   r:   Protocolr<   r   r   r   r   r   r   <module>r^     s   '   
  
69<<G         .8A+AB 69
)7
D&4D="y)) ="@~#+Y-?-? ~#BeE eENw wr   