a XC?h�)�@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 �7/opt/alt/python39/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(Zaddrr r r �sendto�szDatagramTransport.sendtocCst�dSr rrr r r r/�szDatagramTransport.abort)N)rrrrr0r/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) rrrrr1r2r4r6r7r8r 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��messageZ 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() 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)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?rKr"r r r r%Jsz)_FlowControlMixin.set_write_buffer_limitscCst�dSr rrr r r r&Nsz'_FlowControlMixin.get_write_buffer_size)NN)NN)NN) rrrrrrKrLr'r?r%r&� __classcell__r r r@r r9�s  r9N)�__all__rrrrrrr9r r r r �s%L6