
    -hh8*                         S r  " S S5      r " S S\5      r " S S\5      r " S S\\5      r " S	 S
\5      r " S S\5      r " S S\5      rg))BaseTransportReadTransportWriteTransport	TransportDatagramTransportSubprocessTransportc                   D    \ rS rSrSrS
S jrS
S jrS rS rS r	S	 r
Srg)r   	   _extraNc                     Uc  0 nXl         g Nr
   )selfextras     ;/opt/python-3.13.8/usr/lib/python3.13/asyncio/transports.py__init__BaseTransport.__init__   s    =E    c                 8    U R                   R                  X5      $ r   )r   get)r   namedefaults      r   get_extra_infoBaseTransport.get_extra_info   s    {{t--r   c                     [         er   NotImplementedErrorr   s    r   
is_closingBaseTransport.is_closing       !!r   c                     [         er   r   r   s    r   closeBaseTransport.close   s
     "!r   c                     [         er   r   )r   protocols     r   set_protocolBaseTransport.set_protocol%   r    r   c                     [         er   r   r   s    r   get_protocolBaseTransport.get_protocol)   r    r   r   )__name__
__module____qualname____firstlineno__	__slots__r   r   r   r"   r&   r)   __static_attributes__ r   r   r   r   	   s'     I
.""""r   r   c                   *    \ rS rSrSrS rS rS rSrg)r   .   r1   c                     [         er   r   r   s    r   
is_readingReadTransport.is_reading3   r    r   c                     [         er   r   r   s    r   pause_readingReadTransport.pause_reading7   
     "!r   c                     [         er   r   r   s    r   resume_readingReadTransport.resume_reading?   r:   r   N)	r+   r,   r-   r.   r/   r5   r8   r<   r0   r1   r   r   r   r   .   s     I"""r   r   c                   L    \ rS rSrSrSS jrS rS rS rS r	S	 r
S
 rS rSrg)r   H   r1   Nc                     [         er   r   r   highlows      r   set_write_buffer_limits&WriteTransport.set_write_buffer_limitsM   s
    & "!r   c                     [         er   r   r   s    r   get_write_buffer_size$WriteTransport.get_write_buffer_sizeb   r    r   c                     [         er   r   r   s    r   get_write_buffer_limits&WriteTransport.get_write_buffer_limitsf   s
     "!r   c                     [         er   r   )r   datas     r   writeWriteTransport.writel   r:   r   c                 H    SR                  U5      nU R                  U5        g )Nr   )joinrN   )r   list_of_datarM   s      r   
writelinesWriteTransport.writelinest   s     xx%

4r   c                     [         er   r   r   s    r   	write_eofWriteTransport.write_eof}   
     "!r   c                     [         er   r   r   s    r   can_write_eofWriteTransport.can_write_eof   r    r   c                     [         er   r   r   s    r   abortWriteTransport.abort   rX   r   NN)r+   r,   r-   r.   r/   rD   rG   rJ   rN   rS   rV   rZ   r]   r0   r1   r   r   r   r   H   s1     I"*""""""r   r   c                       \ rS rSrSrSrg)r      r1   N)r+   r,   r-   r.   r/   r0   r1   r   r   r   r      s	    * Ir   r   c                   (    \ rS rSrSrSS jrS rSrg)r      r1   Nc                     [         er   r   )r   rM   addrs      r   sendtoDatagramTransport.sendto   s
     "!r   c                     [         er   r   r   s    r   r]   DatagramTransport.abort   rX   r   r   )r+   r,   r-   r.   r/   rf   r]   r0   r1   r   r   r   r      s     I
""r   r   c                   <    \ rS rSrSrS rS rS rS rS r	S r
Srg	)
r      r1   c                     [         er   r   r   s    r   get_pidSubprocessTransport.get_pid   r    r   c                     [         er   r   r   s    r   get_returncode"SubprocessTransport.get_returncode   r:   r   c                     [         er   r   )r   fds     r   get_pipe_transport&SubprocessTransport.get_pipe_transport   r    r   c                     [         er   r   )r   signals     r   send_signalSubprocessTransport.send_signal   r:   r   c                     [         er   r   r   s    r   	terminateSubprocessTransport.terminate   s
     "!r   c                     [         er   r   r   s    r   killSubprocessTransport.kill   s
     "!r   N)r+   r,   r-   r.   r/   rm   rp   rt   rx   r{   r~   r0   r1   r   r   r   r      s%    I"""""	"r   r   c                   \   ^  \ rS rSrSrSU 4S jjrS rS rS rSS jr	SS jr
S	 rS
rU =r$ )_FlowControlMixin   )_loop_protocol_paused_high_water
_low_waterc                 ^   > [         TU ]  U5        X l        SU l        U R	                  5         g )NF)superr   r   r   _set_write_buffer_limits)r   r   loop	__class__s      r   r   _FlowControlMixin.__init__  s)    
 %%%'r   c                 N   U R                  5       nXR                  ::  a  g U R                  (       d#  SU l         U R                  R	                  5         g g ! [
        [        4 a    e [         a4  nU R                  R                  SUU U R                  S.5         S nAg S nAff = f)NTzprotocol.pause_writing() failedmessage	exception	transportr%   )
rG   r   r   	_protocolpause_writing
SystemExitKeyboardInterruptBaseExceptionr   call_exception_handler)r   sizeexcs      r   _maybe_pause_protocol'_FlowControlMixin._maybe_pause_protocol  s    ))+###$$$(D!
,,. %  12   

11@!$!% $	3  s   A B$0*BB$c                 L   U R                   (       aB  U R                  5       U R                  ::  a#  SU l          U R                  R	                  5         g g g ! [
        [        4 a    e [         a4  nU R                  R                  SUU U R                  S.5         S nAg S nAff = f)NFz protocol.resume_writing() failedr   )
r   rG   r   r   resume_writingr   r   r   r   r   )r   r   s     r   _maybe_resume_protocol(_FlowControlMixin._maybe_resume_protocol)  s    !!**,?$)D!
--/ @ "
  12   

11A!$!% $	3  s   A B#/*BB#c                 2    U R                   U R                  4$ r   )r   r   r   s    r   rJ   )_FlowControlMixin.get_write_buffer_limits9  s    !1!122r   c                     Uc  Uc  SnOSU-  nUc  US-  nXs=:  a  S:  d  O  [        SU< SU< S35      eXl        X l        g )Ni          zhigh (z) must be >= low (z) must be >= 0)
ValueErrorr   r   rA   s      r   r   *_FlowControlMixin._set_write_buffer_limits<  sb    <{ 3w;!)Ca 23'HJ J  r   c                 B    U R                  XS9  U R                  5         g )N)rB   rC   )r   r   rA   s      r   rD   )_FlowControlMixin.set_write_buffer_limitsL  s    %%4%9""$r   c                     [         er   r   r   s    r   rG   '_FlowControlMixin.get_write_buffer_sizeP  s    !!r   )r   r   r   r   r_   )r+   r,   r-   r.   r/   r   r   r   rJ   r   rD   rG   r0   __classcell__)r   s   @r   r   r      s3    " KI($ 3 %" "r   r   N)__all__r   r   r   r   r   r   r   r1   r   r   <module>r      sg   "" ""J"M "4I"] I"X~ 0" "63"- 3"lT"	 T"r   