grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026a ´iä)ã@sxdZGdd„dƒZGdd„deƒZGdd„deƒZGdd„deeƒZGd d „d eƒZGd d „d eƒZGd d„deƒZdS))Ú BaseTransportÚ ReadTransportÚWriteTransportÚ TransportÚDatagramTransportÚSubprocessTransportc@sDeZdZdZddd„Zddd„Zdd„Zd d „Zd d „Zd d„Z dS)r©Ú_extraNcCs|dur i}||_dS©Nr)ÚselfÚextra©r ú*/usr/lib64/python3.9/asyncio/transports.pyÚ__init__szBaseTransport.__init__cCs|j ||¡Sr )rÚget)r ÚnameÚdefaultr r r Úget_extra_infoszBaseTransport.get_extra_infocCst‚dSr ©ÚNotImplementedError©r r r r Ú is_closingszBaseTransport.is_closingcCst‚dSr rrr r r ÚcloseszBaseTransport.closecCst‚dSr r)r Úprotocolr r r Ú set_protocol%szBaseTransport.set_protocolcCst‚dSr rrr r r Ú get_protocol)szBaseTransport.get_protocol)N)N) Ú__name__Ú __module__Ú __qualname__Ú __slots__rrrrrrr r r r r s   rc@s(eZdZdZdd„Zdd„Zdd„ZdS) rr cCst‚dSr rrr r r Ú is_reading3szReadTransport.is_readingcCst‚dSr rrr r r Ú pause_reading7szReadTransport.pause_readingcCst‚dSr rrr r r Úresume_reading?szReadTransport.resume_readingN)rrrrrr r!r r r r r.src@sReZdZdZddd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dS)rr NcCst‚dSr r©r ÚhighÚlowr r r Úset_write_buffer_limitsMsz&WriteTransport.set_write_buffer_limitscCst‚dSr rrr r r Úget_write_buffer_sizebsz$WriteTransport.get_write_buffer_sizecCst‚dSr rrr r r Úget_write_buffer_limitsfsz&WriteTransport.get_write_buffer_limitscCst‚dSr r)r Údatar r r ÚwritelszWriteTransport.writecCsd |¡}| |¡dS)Nó)Újoinr))r Z list_of_datar(r r r Ú writelinests zWriteTransport.writelinescCst‚dSr rrr r r Ú write_eof}szWriteTransport.write_eofcCst‚dSr rrr r r Ú can_write_eof†szWriteTransport.can_write_eofcCst‚dSr rrr r r ÚabortŠszWriteTransport.abort)NN) rrrrr%r&r'r)r,r-r.r/r r r r rHs   rc@seZdZdZdS)rr N)rrrrr r r r r”src@s"eZdZdZddd„Zdd„ZdS)rr NcCst‚dSr r)r r(Úaddrr r r Úsendto±szDatagramTransport.sendtocCst‚dSr rrr r r r/»szDatagramTransport.abort)N)rrrrr1r/r r r r r¬s rc@s@eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dS)rr cCst‚dSr rrr r r Úget_pidÉszSubprocessTransport.get_pidcCst‚dSr rrr r r Úget_returncodeÍsz"SubprocessTransport.get_returncodecCst‚dSr r)r Úfdr r r Úget_pipe_transportÕsz&SubprocessTransport.get_pipe_transportcCst‚dSr r)r Úsignalr r r Ú send_signalÙszSubprocessTransport.send_signalcCst‚dSr rrr r r Ú terminateás zSubprocessTransport.terminatecCst‚dSr rrr r r Úkillïs zSubprocessTransport.killN) rrrrr2r3r5r7r8r9r r r r rÅsrcsVeZdZdZd‡fdd„ Zdd„Zdd„Zd d „Zdd d „Zdd d„Z dd„Z ‡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|js„d|_z|j ¡WnRttfyH‚Yn<ty‚}z$|j  d|||jdœ¡WYd}~n d}~00dS)NTzprotocol.pause_writing() failed©ÚmessageÚ exceptionZ transportr) r&r=r<Ú _protocolZ pause_writingÚ SystemExitÚKeyboardInterruptÚ BaseExceptionr;Úcall_exception_handler)r ÚsizeÚexcr r r Ú_maybe_pause_protocols  üz'_FlowControlMixin._maybe_pause_protocolc Cs€|jr|| ¡|jkr|d|_z|j ¡WnRttfy@‚Yn<tyz}z$|j  d|||jdœ¡WYd}~n d}~00dS)NFz protocol.resume_writing() failedrC) r<r&r>rFZresume_writingrGrHrIr;rJ)r rLr 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)Niéézhigh (z) must be >= low (z) must be >= 0)Ú ValueErrorr=r>r"r r r r@:sÿz*_FlowControlMixin._set_write_buffer_limitscCs|j||d�| ¡dS)N)r#r$)r@rMr"r r r r%Jsz)_FlowControlMixin.set_write_buffer_limitscCst‚dSr rrr r r r&Nsz'_FlowControlMixin.get_write_buffer_size)NN)NN)NN) rrrrrrMrNr'r@r%r&Ú __classcell__r r rAr r:ûs  r:N)Ú__all__rrrrrrr:r r r r Ús%L6