��]R'�@s�ddlmZddddddgZGdd�d�ZGd d�de�ZGd d�de�ZGdd�dee�ZGdd�de�ZGd d�de�ZGdd�de�Z dS)�)�compat� BaseTransport� ReadTransport�WriteTransport� Transport�DatagramTransport�SubprocessTransportc@s^eZdZddd�Zddd�Zdd�Zdd �Zd d�Zdd �ZdS)rNcCs|dkri}||_dS)N)�_extra)�self�extra�r�//opt/alt/python35/lib64/python3.5/transports.py�__init__ szBaseTransport.__init__cCs|jj||�S)N)r �get)r �name�defaultrrr �get_extra_infoszBaseTransport.get_extra_infocCs t�dS)N)�NotImplementedError)r rrr � is_closingszBaseTransport.is_closingcCs t�dS)N)r)r rrr �closeszBaseTransport.closecCs t�dS)N)r)r �protocolrrr �set_protocol$szBaseTransport.set_protocolcCs t�dS)N)r)r rrr �get_protocol(szBaseTransport.get_protocol) �__name__� __module__�__qualname__rrrrrrrrrr r s c@s(eZdZdd�Zdd�ZdS)rcCs t�dS)N)r)r rrr � pause_reading0szReadTransport.pause_readingcCs t�dS)N)r)r rrr �resume_reading8szReadTransport.resume_readingN)rrrrrrrrr r-sc@sjeZdZdddd�Zdd�Zdd�Zdd �Zd d�Zdd �Zdd�Z dS)rNcCs t�dS)N)r)r �high�lowrrr �set_write_buffer_limitsDsz&WriteTransport.set_write_buffer_limitscCs t�dS)N)r)r rrr �get_write_buffer_sizeYsz$WriteTransport.get_write_buffer_sizecCs t�dS)N)r)r �datarrr �write]szWriteTransport.writecCs tj|�}|j|�dS)N)rZflatten_list_bytesr#)r Zlist_of_datar"rrr � writelineseszWriteTransport.writelinescCs t�dS)N)r)r rrr � write_eofnszWriteTransport.write_eofcCs t�dS)N)r)r rrr � can_write_eofwszWriteTransport.can_write_eofcCs t�dS)N)r)r rrr �abort{szWriteTransport.abort) rrrr r!r#r$r%r&r'rrrr rAs c@seZdZdS)rN)rrrrrrr r�sc@s+eZdZddd�Zdd�ZdS)rNcCs t�dS)N)r)r r"�addrrrr �sendto�szDatagramTransport.sendtocCs t�dS)N)r)r rrr r'�szDatagramTransport.abort)rrrr)r'rrrr r�s c@sXeZdZdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd S)rcCs t�dS)N)r)r rrr �get_pid�szSubprocessTransport.get_pidcCs t�dS)N)r)r rrr �get_returncode�sz"SubprocessTransport.get_returncodecCs t�dS)N)r)r �fdrrr �get_pipe_transport�sz&SubprocessTransport.get_pipe_transportcCs t�dS)N)r)r �signalrrr �send_signal�szSubprocessTransport.send_signalcCs t�dS)N)r)r rrr � terminate�szSubprocessTransport.terminatecCs t�dS)N)r)r rrr �kill�s zSubprocessTransport.killN) rrrr*r+r-r/r0r1rrrr r�scs|eZdZdd�fdd�Zdd�Zdd�Zdd �Zddd d�Zdddd �Zdd�Z �S)�_FlowControlMixinNcs0t�j|�||_d|_|j�dS)NF)�superr�_loop�_protocol_paused�_set_write_buffer_limits)r rZloop)� __class__rr r�s z_FlowControlMixin.__init__cCs�|j�}||jkrdS|js�d|_y|jj�WnPtk r�}z0|jjddd|d|d|ji�WYdd}~XnXdS)NT�messagezprotocol.pause_writing() failed� exception� transportr)r!�_high_waterr5� _protocolZ pause_writing� Exceptionr4�call_exception_handler)r �size�excrrr �_maybe_pause_protocol�s z'_FlowControlMixin._maybe_pause_protocolcCs�|jr�|j�|jkr�d|_y|jj�WnPtk r�}z0|jjddd|d|d|ji�WYdd}~XnXdS)NFr8z protocol.resume_writing() failedr9r:r)r5r!� _low_waterr<Zresume_writingr=r4r>)r r@rrr �_maybe_resume_protocols z(_FlowControlMixin._maybe_resume_protocolcCs|j|jfS)N)rBr;)r rrr �get_write_buffer_limitssz)_FlowControlMixin.get_write_buffer_limitscCs�|dkr+|dkr!d}n d|}|dkrA|d}||koXdknsstd||f��||_||_dS)N�@i�rz*high (%r) must be >= low (%r) must be >= 0i)� ValueErrorr;rB)r rrrrr r6s z*_FlowControlMixin._set_write_buffer_limitscCs$|jd|d|�|j�dS)Nrr)r6rA)r rrrrr r -sz)_FlowControlMixin.set_write_buffer_limitscCs t�dS)N)r)r rrr r!1sz'_FlowControlMixin.get_write_buffer_size) rrrrrArCrDr6r r!rr)r7r r2�sr2N) Zasyncior�__all__rrrrrrr2rrrr �s #D4