a
    	3j                     @   s^   d Z G dd dZG dd deZG dd deZG dd deZG d	d
 d
eZdd ZdS ))BaseProtocolProtocolDatagramProtocolSubprocessProtocolBufferedProtocolc                   @   s0   e Zd ZdZdd Zdd Zdd Zdd	 Zd
S )r    c                 C   s   d S Nr   )selfZ	transportr   r   M/www/server/python_manager/versions/3.9.10/lib/python3.9/asyncio/protocols.pyconnection_made   s    zBaseProtocol.connection_madec                 C   s   d S r   r   r   excr   r   r	   connection_lost   s    zBaseProtocol.connection_lostc                 C   s   d S r   r   r   r   r   r	   pause_writing%   s    zBaseProtocol.pause_writingc                 C   s   d S r   r   r   r   r   r	   resume_writing;   s    zBaseProtocol.resume_writingN)__name__
__module____qualname__	__slots__r
   r   r   r   r   r   r   r	   r   	   s
   
r   c                   @   s    e Zd ZdZdd Zdd ZdS )r   r   c                 C   s   d S r   r   )r   datar   r   r	   data_received^   s    zProtocol.data_receivedc                 C   s   d S r   r   r   r   r   r	   eof_receivedd   s    zProtocol.eof_receivedN)r   r   r   r   r   r   r   r   r   r	   r   B   s   r   c                   @   s(   e Zd ZdZdd Zdd Zdd ZdS )	r   r   c                 C   s   d S r   r   )r   sizehintr   r   r	   
get_buffer   s    zBufferedProtocol.get_bufferc                 C   s   d S r   r   )r   nbytesr   r   r	   buffer_updated   s    zBufferedProtocol.buffer_updatedc                 C   s   d S r   r   r   r   r   r	   r      s    zBufferedProtocol.eof_receivedN)r   r   r   r   r   r   r   r   r   r   r	   r   m   s   r   c                   @   s    e Zd ZdZdd Zdd ZdS )r   r   c                 C   s   d S r   r   )r   r   addrr   r   r	   datagram_received   s    z"DatagramProtocol.datagram_receivedc                 C   s   d S r   r   r   r   r   r	   error_received   s    zDatagramProtocol.error_receivedN)r   r   r   r   r   r   r   r   r   r	   r      s   r   c                   @   s(   e Zd ZdZdd Zdd Zdd ZdS )	r   r   c                 C   s   d S r   r   )r   fdr   r   r   r	   pipe_data_received   s    z%SubprocessProtocol.pipe_data_receivedc                 C   s   d S r   r   )r   r   r   r   r   r	   pipe_connection_lost   s    z'SubprocessProtocol.pipe_connection_lostc                 C   s   d S r   r   r   r   r   r	   process_exited   s    z!SubprocessProtocol.process_exitedN)r   r   r   r   r    r!   r"   r   r   r   r	   r      s   r   c                 C   s   t |}|r| |}t |}|s*td||krL||d |< | | d S |d | |d |< | | ||d  }t |}qd S )Nz%get_buffer() returned an empty buffer)lenr   RuntimeErrorr   )protor   Zdata_lenbufZbuf_lenr   r   r	   _feed_data_to_buffered_proto   s    


r'   N)__all__r   r   r   r   r   r'   r   r   r   r	   <module>   s   9+9