o ?Og-@s` dZGdddZGdddeZGdddeZGdddeZGd d d eZd d Zd S)) BaseProtocolProtocolDatagramProtocolSubprocessProtocolBufferedProtocolc@s2eZdZ dZddZddZddZdd Zd S) rcCdSNr)selfZ transportrr8/opt/alt/python310/lib64/python3.10/asyncio/protocols.pyconnection_madezBaseProtocol.connection_madecCrrrr excrrr connection_lostr zBaseProtocol.connection_lostcCrrrr rrr pause_writing%r zBaseProtocol.pause_writingcCrrrrrrr resume_writing;r zBaseProtocol.resume_writingN)__name__ __module__ __qualname__ __slots__r rrrrrrr r s  rc@"eZdZ dZddZddZdS)rrcCrrr)r datarrr data_received^r zProtocol.data_receivedcCrrrrrrr eof_receiveddr zProtocol.eof_receivedN)rrrrrrrrrr rBs  rc@*eZdZ dZddZddZddZdS) rrcCrrr)r sizehintrrr get_bufferr zBufferedProtocol.get_buffercCrrr)r nbytesrrr buffer_updatedr zBufferedProtocol.buffer_updatedcCrrrrrrr rr zBufferedProtocol.eof_receivedN)rrrrrrrrrrr rms  rc@r)rrcCrrr)r rZaddrrrr datagram_receivedr z"DatagramProtocol.datagram_receivedcCrrrr rrr error_receivedr zDatagramProtocol.error_receivedN)rrrrr r!rrrr rs  rc@r) rrcCrrr)r fdrrrr pipe_data_receivedr z%SubprocessProtocol.pipe_data_receivedcCrrr)r r"rrrr pipe_connection_lostr z'SubprocessProtocol.pipe_connection_lostcCrrrrrrr process_exitedr z!SubprocessProtocol.process_exitedN)rrrrr#r$r%rrrr rs  rcCst|}|rC||}t|}|std||kr&||d|<||dS|d||d|<||||d}t|}|sdSdS)Nz%get_buffer() returned an empty buffer)lenr RuntimeErrorr)protorZdata_lenZbufZbuf_lenrrr _feed_data_to_buffered_protos      r)N)__all__rrrrrr)rrrr s9+5