a XC?h�)�@sxdZGdd�d�ZGdd�de�ZGdd�de�ZGdd�dee�ZGd d �d e�ZGdd�de�ZGd d�de�ZdS))� BaseTransport� ReadTransport�WriteTransport� Transport�DatagramTransport�SubprocessTransportc@sDeZdZdZddd�Zddd�Zdd�Zd d �Zdd�Zd d�Z dS)r��_extraNcCs|duri}||_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�defaultrrr �get_extra_infoszBaseTransport.get_extra_infocCst�dSr ��NotImplementedError�r rrr � is_closingszBaseTransport.is_closingcCst�dSr rrrrr �closeszBaseTransport.closecCst�dSr r)r �protocolrrr �set_protocol%szBaseTransport.set_protocolcCst�dSr rrrrr �get_protocol)szBaseTransport.get_protocol)N)N) �__name__� __module__�__qualname__� __slots__rrrrrrrrrr r s rc@s(eZdZdZdd�Zdd�Zdd�ZdS) rrcCst�dSr rrrrr � is_reading3szReadTransport.is_readingcCst�dSr rrrrr � pause_reading7szReadTransport.pause_readingcCst�dSr rrrrr �resume_reading?szReadTransport.resume_readingN)rrrrrr r!rrrr r.src@sReZdZdZddd�Zdd�Zdd�Zd d �Zdd�Zd d�Z dd�Z dd�ZdS)rrNcCst�dSr r�r �high�lowrrr �set_write_buffer_limitsMsz&WriteTransport.set_write_buffer_limitscCst�dSr rrrrr �get_write_buffer_sizebsz$WriteTransport.get_write_buffer_sizecCst�dSr rrrrr �get_write_buffer_limitsfsz&WriteTransport.get_write_buffer_limitscCst�dSr r)r �datarrr �writelszWriteTransport.writecCsd�|�}|�|�dS)N�)�joinr))r Zlist_of_datar(rrr � writelinests zWriteTransport.writelinescCst�dSr rrrrr � write_eof}szWriteTransport.write_eofcCst�dSr rrrrr � can_write_eof�szWriteTransport.can_write_eofcCst�dSr rrrrr �abort�szWriteTransport.abort)NN)rrrrr%r&r'r)r,r-r.r/rrrr rHs rc@seZdZdZdS)rrN)rrrrrrrr r�src@s"eZdZdZddd�Zdd�ZdS)rrNcCst�dSr r)r r(Zaddrrrr �sendto�szDatagramTransport.sendtocCst�dSr rrrrr r/�szDatagramTransport.abort)N)rrrrr0r/rrrr r�s rc@s@eZdZdZdd�Zdd�Zdd�Zdd �Zd d�Zdd �Z dS)rrcCst�dSr rrrrr �get_pid�szSubprocessTransport.get_pidcCst�dSr rrrrr �get_returncode�sz"SubprocessTransport.get_returncodecCst�dSr r)r �fdrrr �get_pipe_transport�sz&SubprocessTransport.get_pipe_transportcCst�dSr r)r �signalrrr �send_signal�szSubprocessTransport.send_signalcCst�dSr rrrrr � terminate�szSubprocessTransport.terminatecCst�dSr rrrrr �kill�s zSubprocessTransport.killN) rrrrr1r2r4r6r7r8rrrr r�srcsVeZdZdZd�fdd� Zdd�Zdd�Zd d �Zddd�Zdd d�Z dd�Z �ZS)�_FlowControlMixin)�_loop�_protocol_paused�_high_water� _low_waterNcs$t��|�||_d|_|��dS)NF)�superrr:r;�_set_write_buffer_limits)r rZloop�� __class__rr rsz_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�excrrr �_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 rJrrr �_maybe_resume_protocol's��z(_FlowControlMixin._maybe_resume_protocolcCs|j|jfSr )r=r<rrrr 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"rrr r?:s�z*_FlowControlMixin._set_write_buffer_limitscCs|j||d�|��dS)N)r#r$)r?rKr"rrr r%Jsz)_FlowControlMixin.set_write_buffer_limitscCst�dSr rrrrr r&Nsz'_FlowControlMixin.get_write_buffer_size)NN)NN)NN)rrrrrrKrLr'r?r%r&� __classcell__rrr@r r9�s r9N)�__all__rrrrrrr9rrrr �s%L6