a  ze(@sxdZGdddZGdddeZGdddeZGdddeeZGd d d eZGd d d eZGd ddeZdS)) BaseTransport ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc@sDeZdZdZdddZdddZddZd d Zd d Zd dZ dS)r_extraNcCs|dur i}||_dSNr)selfextrar F/opt/bitninja-python-dojo/embedded/lib/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@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'addrr 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() failedmessage 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=rEZresume_writingrFrGrHr:rI)r rKr 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|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?4sz*_FlowControlMixin._set_write_buffer_limitscCs|j||d|dS)N)r#r$)r?rLr"r r r r%Dsz)_FlowControlMixin.set_write_buffer_limitscCstdSr rrr r r r&Hsz'_FlowControlMixin.get_write_buffer_size)NN)NN)NN) rrrrrrLrMrNr?r%r& __classcell__r r r@r r9s  r9N)__all__rrrrrrr9r r r r s%F6