
    2\h)                         	 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dS ))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	dS )
r   _extraNc                     |i }|| _         d S Nr	   )selfextras     </opt/python-3.11.14/usr/lib/python3.11/asyncio/transports.py__init__zBaseTransport.__init__   s    =E    c                 :    	 | 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dS )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   .   sI        -I" " "" " "" " " " "r   r   c                   F    e Zd Z	 dZddZd Zd Zd Zd Zd Z	d	 Z
d
 ZdS )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                 \    	 d                     |          }|                     |           d S )Nr   )joinr=   )r   list_of_datar<   s      r   
writelineszWriteTransport.writelinest   s2    	
 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   s        .I" " " "*" " "" " "" " "  " " "" " "" " " " "r   r   c                       e Zd Z	 dZdS )r   r(   N)r$   r%   r&   r'   r(   r   r   r   r      s        ( IIIr   r   c                   "    e Zd Z	 dZddZd ZdS )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                   6    e Zd ZdZd Zd Zd Zd Zd Zd Z	dS )	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      ss        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_waterNc                     t                                          |           || _        d| _        |                                  d S )NF)superr   ra   rb   _set_write_buffer_limits)r   r   loop	__class__s      r   r   z_FlowControlMixin.__init__  sB    
 %%%'''''r   c                 6   |                                  }|| j        k    rd S | j        spd| _        	 | j                                         d S # t
          t          f$ r  t          $ r/}| j        	                    d|| | j        d           Y d }~d S d }~ww xY wd S )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###F$ 	$(D!
,,..... 12       
11@!$!% $	3 3         	 	s   A B'$BBc                 2   | j         r|                                 | j        k    rrd| _         	 | j                                         d S # t
          t          f$ r  t          $ r/}| j        	                    d|| | j        d           Y d }~d S d }~ww xY wd S d S )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 3         	 	??s   A B#$BBc                     | j         | j        fS r   )rd   rc   r   s    r   r:   z)_FlowControlMixin.get_write_buffer_limits7  s    !122r   c                     |
|d}nd|z  }||dz  }||cxk    rdk    sn t          d|d|d          || _        || _        d S )Ni          zhigh (z) must be >= low (z) must be >= 0)
ValueErrorrc   rd   r3   s      r   rg   z*_FlowControlMixin._set_write_buffer_limits:  s    <{ 3w;!)CsaHHH3HHHJ J J  r   c                 \    |                      ||           |                                  d S )N)r4   r5   )rg   rw   r3   s      r   r6   z)_FlowControlMixin.set_write_buffer_limitsJ  s3    %%4S%99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`      s          KI( ( ( ( ( (  $   3 3 3    % % % %" " " " " " "r   r`   N)__all__r   r   r   r   r   r   r`   r(   r   r   <module>r      sT   "" "" "" "" "" "" "" ""J" " " " "M " " "4I" I" I" I" I"] I" I" I"X    ~   0" " " " " " " "23" 3" 3" 3" 3"- 3" 3" 3"lT" T" T" T" T"	 T" T" T" T" T"r   