o ?Og)@sz dZGdddZGdddeZGdddeZGdddeeZGd d d eZGd d d eZGd ddeZdS)) BaseTransport ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc@sFeZdZ dZdddZdddZddZd d Zd d Zd dZ dS)r_extraNcCs|duri}||_dSNr)selfextrar 9/opt/alt/python310/lib64/python3.10/asyncio/transports.py__init__s zBaseTransport.__init__cCs |j||Sr )rget)r namedefaultr r r get_extra_infoszBaseTransport.get_extra_infocC tr NotImplementedErrorr r r r is_closingzBaseTransport.is_closingcCrr rrr r r closezBaseTransport.closecCrr r)r protocolr r r set_protocol%rzBaseTransport.set_protocolcCrr rrr r r get_protocol)rzBaseTransport.get_protocolr ) __name__ __module__ __qualname__ __slots__rrrrrrr r r r r s   rc@s*eZdZ dZddZddZddZdS) rr cCrr rrr r r is_reading3rzReadTransport.is_readingcCrr rrr r r pause_reading7zReadTransport.pause_readingcCrr rrr r r resume_reading?r$zReadTransport.resume_readingN)rrr r!r"r#r%r r r r r.s  rc@sTeZdZ dZdddZddZddZd d Zd d Zd dZ ddZ ddZ dS)rr NcCrr rr highlowr r r set_write_buffer_limitsMsz&WriteTransport.set_write_buffer_limitscCrr rrr r r get_write_buffer_sizebrz$WriteTransport.get_write_buffer_sizecCrr rrr r r get_write_buffer_limitsfsz&WriteTransport.get_write_buffer_limitscCrr r)r datar r r writelr$zWriteTransport.writecCs d|}||dS)N)joinr-)r Z list_of_datar,r r r writelinests zWriteTransport.writelinescCrr rrr r r write_eof}zWriteTransport.write_eofcCrr rrr r r can_write_eofrzWriteTransport.can_write_eofcCrr rrr r r abortr2zWriteTransport.abortNN) rrr r!r)r*r+r-r0r1r3r4r r r r rHs   rc@seZdZ dZdS)rr N)rrr r!r r r r rsrc@s$eZdZ dZdddZddZdS)rr NcCrr r)r r,Zaddrr r r sendtorzDatagramTransport.sendtocCrr rrr r r r4r2zDatagramTransport.abortr )rrr r!r6r4r r r r rs   rc@s@eZdZdZddZddZddZdd Zd d Zd d Z dS)rr cCrr rrr r r get_pidrzSubprocessTransport.get_pidcCrr rrr r r get_returncoder$z"SubprocessTransport.get_returncodecCrr r)r fdr r r get_pipe_transportrz&SubprocessTransport.get_pipe_transportcCrr r)r signalr r r send_signalr$zSubprocessTransport.send_signalcCrr rrr r r terminates zSubprocessTransport.terminatecCrr rrr r r killszSubprocessTransport.killN) rrr r!r7r8r:r<r=r>r r r r rs rcsXeZdZ dZdfdd ZddZddZd d Zdd d Zdd dZ ddZ Z S)_FlowControlMixin)_loop_protocol_paused _high_water _low_waterNcs$t|||_d|_|dS)NF)superrr@rA_set_write_buffer_limits)r r Zloop __class__r r rs  z_FlowControlMixin.__init__c Cs|}||jkr dS|jsBd|_z|jWdSttfy#tyA}z|j d|||jdWYd}~dSd}~wwdS)NTzprotocol.pause_writing() failedmessageZ exceptionZ transportr) r*rBrA _protocolZ pause_writing SystemExitKeyboardInterrupt BaseExceptionr@call_exception_handler)r sizeexcr r r _maybe_pause_protocols& z'_FlowControlMixin._maybe_pause_protocolc Cs|jr>||jkr@d|_z|jWdSttfyty=}z|j d|||jdWYd}~dSd}~wwdSdS)NFz protocol.resume_writing() failedrH) rAr*rCrJZresume_writingrKrLrMr@rN)r rPr r r _maybe_resume_protocol's$z(_FlowControlMixin._maybe_resume_protocolcCs |j|jfSr )rCrBrr r r r+7s z)_FlowControlMixin.get_write_buffer_limitscCsj|dur|dur d}nd|}|dur|d}||kr!dks-ntd|d|d||_||_dS)Nizhigh (z) must be >= low (z) must be >= 0) ValueErrorrBrCr&r r r rE:s z*_FlowControlMixin._set_write_buffer_limitscCs|j||d|dS)N)r'r()rErQr&r r r r)Js z)_FlowControlMixin.set_write_buffer_limitscCstr rrr r r r*Nsz'_FlowControlMixin.get_write_buffer_sizer5) rrr r!rrQrRr+rEr)r* __classcell__r r rFr r?s  r?N)__all__rrrrrrr?r r r r s%L6