B ;TJ]@sxdZGdddZGdddeZGdddeZGdddeeZGd d d eZGd d d eZGd ddeZdS)) BaseTransport ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc@s@eZdZdddZdddZddZdd Zd d Zd d ZdS)rNcCs|dkr i}||_dS)N)_extra)selfextrar 5/opt/alt/python37/lib/python3.7/asyncio/transports.py__init__ szBaseTransport.__init__cCs|j||S)N)rget)rnamedefaultr r r get_extra_infoszBaseTransport.get_extra_infocCstdS)N)NotImplementedError)rr r r is_closingszBaseTransport.is_closingcCstdS)N)r)rr r r closeszBaseTransport.closecCstdS)N)r)rprotocolr r r set_protocol#szBaseTransport.set_protocolcCstdS)N)r)rr r r get_protocol'szBaseTransport.get_protocol)N)N) __name__ __module__ __qualname__r rrrrrr r r r r s    rc@s$eZdZddZddZddZdS)rcCstdS)N)r)rr r r is_reading/szReadTransport.is_readingcCstdS)N)r)rr r r pause_reading3szReadTransport.pause_readingcCstdS)N)r)rr r r resume_reading;szReadTransport.resume_readingN)rrrrrrr r r r r,src@sFeZdZdddZddZddZdd Zd d Zd d ZddZ dS)rNcCstdS)N)r)rhighlowr r r set_write_buffer_limitsGsz&WriteTransport.set_write_buffer_limitscCstdS)N)r)rr r r get_write_buffer_size\sz$WriteTransport.get_write_buffer_sizecCstdS)N)r)rdatar r r write`szWriteTransport.writecCsd|}||dS)N)joinr")rZ list_of_datar!r r r writelineshs zWriteTransport.writelinescCstdS)N)r)rr r r write_eofqszWriteTransport.write_eofcCstdS)N)r)rr r r can_write_eofzszWriteTransport.can_write_eofcCstdS)N)r)rr r r abort~szWriteTransport.abort)NN) rrrrr r"r%r&r'r(r r r r rDs   rc@s eZdZdS)rN)rrrr r r r rsrc@seZdZdddZddZdS)rNcCstdS)N)r)rr!Zaddrr r r sendtoszDatagramTransport.sendtocCstdS)N)r)rr r r r(szDatagramTransport.abort)N)rrrr)r(r r r r rs rc@s<eZdZddZddZddZddZd d Zd d Zd S)rcCstdS)N)r)rr r r get_pidszSubprocessTransport.get_pidcCstdS)N)r)rr r r get_returncodesz"SubprocessTransport.get_returncodecCstdS)N)r)rfdr r r get_pipe_transportsz&SubprocessTransport.get_pipe_transportcCstdS)N)r)rsignalr r r send_signalszSubprocessTransport.send_signalcCstdS)N)r)rr r r terminates zSubprocessTransport.terminatecCstdS)N)r)rr r r kills zSubprocessTransport.killN) rrrr*r+r-r/r0r1r r r r rs rcsReZdZdfdd ZddZddZdd Zdd d Zdd d ZddZ Z S)_FlowControlMixinNcs$t|||_d|_|dS)NF)superr _loop_protocol_paused_set_write_buffer_limits)rr Zloop) __class__r r r s z_FlowControlMixin.__init__c Csp|}||jkrdS|jsld|_y|jWn:tk rj}z|jd|||jdWdd}~XYnXdS)NTzprotocol.pause_writing() failed)message exception transportr)r _high_waterr5 _protocolZ pause_writing Exceptionr4call_exception_handler)rsizeexcr r r _maybe_pause_protocols z'_FlowControlMixin._maybe_pause_protocolc Csh|jrd||jkrdd|_y|jWn:tk rb}z|jd|||jdWdd}~XYnXdS)NFz protocol.resume_writing() failed)r8r9r:r)r5r _low_waterr<Zresume_writingr=r4r>)rr@r r r _maybe_resume_protocolsz(_FlowControlMixin._maybe_resume_protocolcCs |j|jfS)N)rBr;)rr r r get_write_buffer_limitssz)_FlowControlMixin.get_write_buffer_limitscCsj|dkr|dkrd}nd|}|dkr.|d}||krBdksZntd|d|d||_||_dS)Nizhigh (z) must be >= low (z) must be >= 0) ValueErrorr;rB)rrrr r r r6"sz*_FlowControlMixin._set_write_buffer_limitscCs|j||d|dS)N)rr)r6rA)rrrr r r r2sz)_FlowControlMixin.set_write_buffer_limitscCstdS)N)r)rr r r r 6sz'_FlowControlMixin.get_write_buffer_size)NN)NN)NN) rrrr rArCrDr6rr __classcell__r r )r7r r2s  r2N)__all__rrrrrrr2r r r r s#D4