a DOg)@sxdZGdddZGdddeZGdddeZGdddeeZGd d d eZGd d d eZGd ddeZdS)) BaseTransport ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc@sDeZdZdZdddZdddZddZd d Zd d Zd dZ dS)r_extraNcCs|dur i}||_dSNr)selfextrar 7/opt/alt/python39/lib64/python3.9/asyncio/transports.py__init__szBaseTransport.__init__cCs|j||Sr )rget)r namedefaultr r r get_extra_infoszBaseTransport.get_extra_infocCstdSr NotImplementedErrorr r r r is_closingszBaseTransport.is_closingcCstdSr rrr r r closeszBaseTransport.closecCstdSr r)r protocolr r r set_protocol%szBaseTransport.set_protocolcCstdSr rrr r r get_protocol)szBaseTransport.get_protocol)N)N) __name__ __module__ __qualname__ __slots__rrrrrrr r r r r s   rc@s(eZdZdZddZddZddZdS) rr cCstdSr rrr r r is_reading3szReadTransport.is_readingcCstdSr rrr r r pause_reading7szReadTransport.pause_readingcCstdSr rrr r r resume_reading?szReadTransport.resume_readingN)rrrrrr r!r r r r r.src@sReZdZdZdddZddZddZd d Zd d Zd dZ ddZ ddZ dS)rr NcCstdSr rr highlowr r r set_write_buffer_limitsMsz&WriteTransport.set_write_buffer_limitscCstdSr rrr r r get_write_buffer_sizebsz$WriteTransport.get_write_buffer_sizecCstdSr rrr r r get_write_buffer_limitsfsz&WriteTransport.get_write_buffer_limitscCstdSr r)r datar r r writelszWriteTransport.writecCsd|}||dS)N)joinr))r Z list_of_datar(r r r writelinests zWriteTransport.writelinescCstdSr rrr r r write_eof}szWriteTransport.write_eofcCstdSr rrr r r can_write_eofszWriteTransport.can_write_eofcCstdSr rrr r r abortszWriteTransport.abort)NN) rrrrr%r&r'r)r,r-r.r/r r r r rHs   rc@seZdZdZdS)rr N)rrrrr r r r rsrc@s"eZdZdZdddZddZdS)rr NcCstdSr r)r r(Zaddrr r r sendtoszDatagramTransport.sendtocCstdSr rrr r r r/szDatagramTransport.abort)N)rrrrr0r/r r r r rs rc@s@eZdZdZddZddZddZdd Zd d Zd d Z dS)rr cCstdSr rrr r r get_pidszSubprocessTransport.get_pidcCstdSr rrr r r get_returncodesz"SubprocessTransport.get_returncodecCstdSr r)r fdr r r get_pipe_transportsz&SubprocessTransport.get_pipe_transportcCstdSr r)r signalr r r send_signalszSubprocessTransport.send_signalcCstdSr rrr r r terminates zSubprocessTransport.terminatecCstdSr rrr r r kills zSubprocessTransport.killN) rrrrr1r2r4r6r7r8r r r r rsrcsVeZdZdZdfdd ZddZddZd d Zdd d Zdd dZ ddZ Z S)_FlowControlMixin)_loop_protocol_paused _high_water _low_waterNcs$t|||_d|_|dS)NF)superrr:r;_set_write_buffer_limits)r r Zloop __class__r r rs z_FlowControlMixin.__init__c Cs|}||jkrdS|jsd|_z|jWnRttfyHYn<ty}z$|j d|||jdWYd}~n d}~00dS)NTzprotocol.pause_writing() failedmessageZ exceptionZ transportr) r&r<r; _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|jWnRttfy@Yn<tyz}z$|j d|||jdWYd}~n d}~00dS)NFz protocol.resume_writing() failedrB) r;r&r=rDZresume_writingrErFrGr:rH)r rJr r r _maybe_resume_protocol's z(_FlowControlMixin._maybe_resume_protocolcCs |j|jfSr )r=r<rr r r r'7sz)_FlowControlMixin.get_write_buffer_limitscCsj|dur|durd}nd|}|dur.|d}||krBdksZntd|d|d||_||_dS)Nizhigh (z) must be >= low (z) must be >= 0) ValueErrorr<r=r"r r r r?:sz*_FlowControlMixin._set_write_buffer_limitscCs|j||d|dS)N)r#r$)r?rKr"r r r r%Jsz)_FlowControlMixin.set_write_buffer_limitscCstdSr rrr r r r&Nsz'_FlowControlMixin.get_write_buffer_size)NN)NN)NN) rrrrrrKrLr'r?r%r& __classcell__r r r@r r9s  r9N)__all__rrrrrrr9r r r r s%L6