
    ;e-                         	 d Z  G d d          Z G d de          Z G d de          Z G d de          Z G d	 d
e          Zd ZdS ))BaseProtocolProtocolDatagramProtocolSubprocessProtocolBufferedProtocolc                   ,    e Zd Z	 dZd Zd Zd Zd ZdS )r    c                     d S Nr   )self	transports     (/usr/lib/python3.11/asyncio/protocols.pyconnection_madezBaseProtocol.connection_made       	 	    c                     d S r
   r   r   excs     r   connection_lostzBaseProtocol.connection_lost   r   r   c                     d S r
   r   r   s    r   pause_writingzBaseProtocol.pause_writing%   s    	 	r   c                     d S r
   r   r   s    r   resume_writingzBaseProtocol.resume_writing;       	 	r   N)__name__
__module____qualname__	__slots__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S )r   r   c                     d S r
   r   )r   datas     r   data_receivedzProtocol.data_received^   r   r   c                     d S r
   r   r   s    r   eof_receivedzProtocol.eof_receivedd   r   r   N)r   r   r   r   r"   r$   r   r   r   r   r   B   s>        2 I      r   r   c                   &    e Zd Z	 dZd Zd Zd ZdS )r   r   c                     d S r
   r   )r   sizehints     r   
get_bufferzBufferedProtocol.get_buffer   s    	 	r   c                     d S r
   r   )r   nbytess     r   buffer_updatedzBufferedProtocol.buffer_updated       	 	r   c                     d S r
   r   r   s    r   r$   zBufferedProtocol.eof_received   r   r   N)r   r   r   r   r(   r+   r$   r   r   r   r   r   m   sM        . I	 	 	      r   r   c                        e Zd Z	 dZd Zd ZdS )r   r   c                     d S r
   r   )r   r!   addrs      r   datagram_receivedz"DatagramProtocol.datagram_received   s    44r   c                     d S r
   r   r   s     r   error_receivedzDatagramProtocol.error_received   r   r   N)r   r   r   r   r1   r3   r   r   r   r   r      s:        *I5 5 5    r   r   c                   &    e Zd Z	 dZd Zd Zd ZdS )r   r   c                     d S r
   r   )r   fdr!   s      r   pipe_data_receivedz%SubprocessProtocol.pipe_data_received   r,   r   c                     d S r
   r   )r   r6   r   s      r   pipe_connection_lostz'SubprocessProtocol.pipe_connection_lost   r,   r   c                     d S r
   r   r   s    r   process_exitedz!SubprocessProtocol.process_exited   s    00r   N)r   r   r   r   r7   r9   r;   r   r   r   r   r      sI        6I    1 1 1 1 1r   r   c                 \   t          |          }|r|                     |          }t          |          }|st          d          ||k    r||d |<   |                     |           d S |d |         |d |<   |                     |           ||d          }t          |          }|d S d S )Nz%get_buffer() returned an empty buffer)lenr(   RuntimeErrorr+   )protor!   data_lenbufbuf_lens        r   _feed_data_to_buffered_protorC      s    4yyH
 !x((c(( 	HFGGGh!C		N  ***F 'NCM  )))>D4yyH  ! ! ! ! !r   N)__all__r   r   r   r   r   rC   r   r   r   <module>rE      s    %6 6 6 6 6 6 6 6r( ( ( ( (| ( ( (V2 2 2 2 2| 2 2 2j    |   1 1 1 1 1 1 1 1.! ! ! ! !r   