�
!A?h- � � � d Z G d� d� � Z G d� de� � Z G d� de� � Z G d� de� � Z G d � d
e� � Zd � Zd S )
)� BaseProtocol�Protocol�DatagramProtocol�SubprocessProtocol�BufferedProtocolc �, � e Zd Z dZd� Zd� Zd� Zd� ZdS )r � c � � d S �Nr )�self� transports �>/opt/alt/python-internal/lib64/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_writingzBaseProtocol.pause_writing% s � � � r c � � d S r
r r s r
�resume_writingzBaseProtocol.resume_writing; � � � � r N)�__name__�
__module__� __qualname__� __slots__r r r r r r r
r r s\ � � � � � �� �I� � � � � � � � � �, � � � � r r c � � e Zd Z dZd� Zd� ZdS )r r c � � d S r
r )r �datas r
�
data_receivedzProtocol.data_received^ r r c � � d S r
r r s r
� eof_receivedzProtocol.eof_receivedd r r N)r r r r r" r$ r r r
r r B s> � � � � � ��2 �I� � � � � � � � r r c �& � e Zd Z dZd� Zd� Zd� ZdS )r r c � � d S r
r )r �sizehints r
�
get_bufferzBufferedProtocol.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 Zd Z dZd� Zd� ZdS )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 Zd Z dZd� Zd� Zd� ZdS )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 |� � }|st 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� � ��4�y�y�H�
� !�� � �x�(�(���c�(�(��� H� � F�G�G� G� �h� � � !�C� �� �N� � � �� *� *� *� �F� ��'��N�C����M� � � �� )� )� )�����>�D��4�y�y�H� � !� !� !� !� !r N)�__all__r r r r r rC r r r
�rE s� �� %� �� 6 � 6 � 6 � 6 � 6 � 6 � 6 � 6 �r( � ( � ( � ( � ( �|� ( � ( � ( �V2 � 2 � 2 � 2 � 2 �|� 2 � 2 � 2 �j � � � � �|� � � � 1� 1� 1� 1� 1� � 1� 1� 1�.!� !� !� !� !r