
    z%i)                         	 d Z  G d d      Z G d de      Z G d de      Z G d dee      Z G d	 d
e      Z G d de      Z G d de      Zy))BaseTransportReadTransportWriteTransport	TransportDatagramTransportSubprocessTransportc                   :    e Zd Z	 dZd	dZd	dZd Zd Zd Zd Z	y)
r   _extraNc                     |i }|| _         y Nr	   )selfextras     F/home/uftp/.pyenv/versions/3.12.0/lib/python3.12/asyncio/transports.py__init__zBaseTransport.__init__   s    =E    c                 <    	 | j                   j                  ||      S r   )r
   get)r   namedefaults      r   get_extra_infozBaseTransport.get_extra_info   s    1{{tW--r   c                     	 t         r   NotImplementedErrorr   s    r   
is_closingzBaseTransport.is_closing   s    @!!r   c                     	 t         r   r   r   s    r   closezBaseTransport.close       	 "!r   c                     	 t         r   r   )r   protocols     r   set_protocolzBaseTransport.set_protocol%   s    !!!r   c                     	 t         r   r   r   s    r   get_protocolzBaseTransport.get_protocol)   s    *!!r   r   )
__name__
__module____qualname__	__slots__r   r   r   r   r!   r#    r   r   r   r   	   s(    $I
.""""r   r   c                   $    e Zd Z	 dZd Zd Zd Zy)r   r(   c                     	 t         r   r   r   s    r   
is_readingzReadTransport.is_reading3   s    8!!r   c                     	 t         r   r   r   s    r   pause_readingzReadTransport.pause_reading7       	
 "!r   c                     	 t         r   r   r   s    r   resume_readingzReadTransport.resume_reading?   r.   r   N)r$   r%   r&   r'   r+   r-   r0   r(   r   r   r   r   .   s    -I"""r   r   c                   D    e Zd Z	 dZddZd Zd Zd Zd Zd Z	d	 Z
d
 Zy)r   r(   Nc                     	 t         r   r   r   highlows      r   set_write_buffer_limitsz&WriteTransport.set_write_buffer_limitsM   s    	$ "!r   c                     	 t         r   r   r   s    r   get_write_buffer_sizez$WriteTransport.get_write_buffer_sizeb   s    :!!r   c                     	 t         r   r   r   s    r   get_write_buffer_limitsz&WriteTransport.get_write_buffer_limitsf   s    	% "!r   c                     	 t         r   r   )r   datas     r   writezWriteTransport.writel   r.   r   c                 J    	 dj                  |      }| j                  |       y )Nr   )joinr=   )r   list_of_datar<   s      r   
writelineszWriteTransport.writelinest   s#    	
 xx%

4r   c                     	 t         r   r   r   s    r   	write_eofzWriteTransport.write_eof}       	 "!r   c                     	 t         r   r   r   s    r   can_write_eofzWriteTransport.can_write_eof   s    O!!r   c                     	 t         r   r   r   s    r   abortzWriteTransport.abort   rD   r   NN)r$   r%   r&   r'   r6   r8   r:   r=   rA   rC   rF   rH   r(   r   r   r   r   H   s2    .I"*""""""r   r   c                       e Zd Z	 dZy)r   r(   N)r$   r%   r&   r'   r(   r   r   r   r      s    ( Ir   r   c                        e Zd Z	 dZddZd Zy)r   r(   Nc                     	 t         r   r   )r   r<   addrs      r   sendtozDatagramTransport.sendto   r   r   c                     	 t         r   r   r   s    r   rH   zDatagramTransport.abort   rD   r   r   )r$   r%   r&   r'   rN   rH   r(   r   r   r   r      s    2I""r   r   c                   4    e Zd ZdZd Zd Zd Zd Zd Zd Z	y)	r   r(   c                     	 t         r   r   r   s    r   get_pidzSubprocessTransport.get_pid   s     !!r   c                     	 t         r   r   r   s    r   get_returncodez"SubprocessTransport.get_returncode   r.   r   c                     	 t         r   r   )r   fds     r   get_pipe_transportz&SubprocessTransport.get_pipe_transport   s    4!!r   c                     	 t         r   r   )r   signals     r   send_signalzSubprocessTransport.send_signal   r.   r   c                     	 t         r   r   r   s    r   	terminatezSubprocessTransport.terminate   s    
	 "!r   c                     	 t         r   r   r   s    r   killzSubprocessTransport.kill   s    	 "!r   N)
r$   r%   r&   r'   rR   rT   rW   rZ   r\   r^   r(   r   r   r   r      s%    I"""""	"r   r   c                   N     e Zd Z	 dZd	 fd	Zd Zd Zd Zd	dZd	dZ	d Z
 xZS )
_FlowControlMixin)_loop_protocol_paused_high_water
_low_waterc                 `    t         |   |       || _        d| _        | j	                          y )NF)superr   ra   rb   _set_write_buffer_limits)r   r   loop	__class__s      r   r   z_FlowControlMixin.__init__  s+    
 %%%'r   c                 @   | j                         }|| j                  k  ry | j                  s#d| _        	 | j                  j	                          y y # t
        t        f$ r  t        $ r4}| j                  j                  d|| | j                  d       Y d }~y d }~ww xY w)NTzprotocol.pause_writing() failedmessage	exception	transportr    )
r8   rc   rb   	_protocolpause_writing
SystemExitKeyboardInterruptBaseExceptionra   call_exception_handler)r   sizeexcs      r   _maybe_pause_protocolz'_FlowControlMixin._maybe_pause_protocol  s    ))+4###$$$(D!
,,. %  12   

11@!$!% $	3  s   A B)*BBc                 <   | j                   rA| j                         | j                  k  r#d| _         	 | j                  j	                          y y y # t
        t        f$ r  t        $ r4}| j                  j                  d|| | j                  d       Y d }~y d }~ww xY w)NFz protocol.resume_writing() failedrk   )
rb   r8   rd   ro   resume_writingrq   rr   rs   ra   rt   )r   rv   s     r   _maybe_resume_protocolz(_FlowControlMixin._maybe_resume_protocol'  s    !!**,?$)D!
--/ @ "
  12   

11A!$!% $	3  s   A B'*BBc                 2    | j                   | j                  fS r   )rd   rc   r   s    r   r:   z)_FlowControlMixin.get_write_buffer_limits7  s    !1!122r   c                     |
|d}nd|z  }||dz  }||cxk\  rdk\  sn t        d|d|d      || _        || _        y )Ni          zhigh (z) must be >= low (z) must be >= 0)
ValueErrorrc   rd   r3   s      r   rg   z*_FlowControlMixin._set_write_buffer_limits:  sh    <{ 3w;!)Csa 23'HJ J  r   c                 J    | j                  ||       | j                          y )N)r4   r5   )rg   rw   r3   s      r   r6   z)_FlowControlMixin.set_write_buffer_limitsJ  s!    %%4S%9""$r   c                     t         r   r   r   s    r   r8   z'_FlowControlMixin.get_write_buffer_sizeN  s    !!r   rI   )r$   r%   r&   r'   r   rw   rz   r:   rg   r6   r8   __classcell__)ri   s   @r   r`   r`      s3      KI($ 3 %"r   r`   N)__all__r   r   r   r   r   r   r`   r(   r   r   <module>r      sj    "" ""J"M "4I"] I"X~ 0" "23"- 3"lT"	 T"r   