o
0¦i- ã @ s` d Z G dd„ dƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG d d
„ d
eƒZd d „ Zd
S ))Ú BaseProtocolÚProtocolÚDatagramProtocolÚSubprocessProtocolÚBufferedProtocolc @ s2 e Zd Z dZdd„ Zdd„ Zdd„ Zdd „ Zd
S ) r © c C ó d S ©Nr )ÚselfZ transportr r ú8/opt/alt/python310/lib64/python3.10/asyncio/protocols.pyÚconnection_made ó z BaseProtocol.connection_madec C r r r ©r Úexcr r r
Úconnection_lost r z BaseProtocol.connection_lostc C r r r ©r r r r
Ú
pause_writing% r zBaseProtocol.pause_writingc C r r r r r r r
Úresume_writing; r zBaseProtocol.resume_writingN)Ú__name__Ú
__module__Ú __qualname__Ú __slots__r r r r r r r r
r s r c @ ó" e Zd Z dZdd„ Zdd„ ZdS )r r c C r r r )r Údatar r r
Ú
data_received^ r zProtocol.data_receivedc C r r r r r r r
Ú eof_receivedd r zProtocol.eof_receivedN)r r r r r r r r r r
r B s
r c @ ó* e Zd Z dZdd„ Zdd„ Zdd„ ZdS ) r r c C r r r )r Úsizehintr r r
Ú
get_buffer‡ r zBufferedProtocol.get_bufferc C r r r )r Únbytesr r r
Úbuffer_updated’ r z BufferedProtocol.buffer_updatedc C r r r r r r r
r ™ r z BufferedProtocol.eof_receivedN)r r r r r r r r r r r
r m s r c @ r )r r c C r r r )r r Zaddrr r r
Údatagram_received§ r z"DatagramProtocol.datagram_receivedc C r r r r
r r r
Úerror_receivedª r z DatagramProtocol.error_receivedN)r r r r r r! r r r r
r ¢ s
r c @ r ) r r c C r r r )r Úfdr r r r
Úpipe_data_received¶ r z%SubprocessProtocol.pipe_data_receivedc C r r r )r r" r r r r
Úpipe_connection_lost½ r z'SubprocessProtocol.pipe_connection_lostc C r r r r r r r
Úprocess_exitedÄ r z!SubprocessProtocol.process_exitedN)r r r r r# r$ r% r r r r
r ± s r c C sŠ t |ƒ}|rC| |¡}t |ƒ}|stdƒ‚||kr&||d |…< | |¡ d S |d |… |d |…< | |¡ ||d … }t |ƒ}|sd S d S )Nz%get_buffer() returned an empty buffer)Úlenr Ú RuntimeErrorr )Úprotor Zdata_lenZbufZbuf_lenr r r
Ú _feed_data_to_buffered_protoÈ s
òr) N)Ú__all__r r r r r r) r r r r
Ú s 9+5