U e5d(@sxdZGdddZGdddeZGdddeZGdddeeZGd d d eZGd d d eZGd ddeZdS)) BaseTransport ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc@sDeZdZdZdddZdddZddZd d Zd d Zd dZ dS)r_extraNcCs|dkr i}||_dSNr)selfextrar */usr/lib64/python3.8/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@sJeZdZdZdddZddZddZd d Zd d Zd dZ 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 r)r datar r r writefszWriteTransport.writecCsd|}||dS)N)joinr()r Z list_of_datar'r r r writelinesns zWriteTransport.writelinescCstdSr rrr r r write_eofwszWriteTransport.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 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)rrrrr/r.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) rrrrr0r1r3r5r6r7r 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)superrr9r:_set_write_buffer_limits)r r Zloop __class__r r rs z_FlowControlMixin.__init__c Cs|}||jkrdS|jsd|_z|jWnRttfk rJYn:tk r}z|j d|||jdW5d}~XYnXdS)NTzprotocol.pause_writing() failedmessageZ exceptionZ transportr) r&r;r: _protocolZ pause_writing SystemExitKeyboardInterrupt BaseExceptionr9call_exception_handler)r sizeexcr r r _maybe_pause_protocols  z'_FlowControlMixin._maybe_pause_protocolc Cs|jr|||jkr|d|_z|jWnRttfk rBYn:tk rz}z|j d|||jdW5d}~XYnXdS)NFz protocol.resume_writing() failedrA) r:r&r<rCZresume_writingrDrErFr9rG)r rIr r r _maybe_resume_protocol!s z(_FlowControlMixin._maybe_resume_protocolcCs |j|jfSr )r<r;rr r r get_write_buffer_limits1sz)_FlowControlMixin.get_write_buffer_limitscCsj|dkr|dkrd}nd|}|dkr.|d}||krBdksZntd|d|d||_||_dS)Nizhigh (z) must be >= low (z) must be >= 0) ValueErrorr;r<r"r r r r>4sz*_FlowControlMixin._set_write_buffer_limitscCs|j||d|dS)N)r#r$)r>rJr"r r r r%Dsz)_FlowControlMixin.set_write_buffer_limitscCstdSr rrr r r r&Hsz'_FlowControlMixin.get_write_buffer_size)NN)NN)NN) rrrrrrJrKrLr>r%r& __classcell__r r r?r r8s  r8N)__all__rrrrrrr8r r r r s%F6