��]/�@ssdddgZddlmZdgZGdd�de�Zdd�Zdd d�ZGd d�de�ZdS)�Client�Listener�Pipe�)�QueueNc@sgeZdZddddd�Zdd�Zdd�Zed d ��Zdd�Zd d�Z dS)rN�cCst|�|_dS)N)r�_backlog_queue)�self�address�family�backlog�r�//opt/alt/python35/lib64/python3.5/connection.py�__init__szListener.__init__cCst|jj��S)N)� Connectionr�get)rrrr �acceptszListener.acceptcCs d|_dS)N)r)rrrr �closeszListener.closecCs|jS)N)r)rrrr �szListener.cCs|S)Nr)rrrr � __enter__szListener.__enter__cCs|j�dS)N)r)r�exc_type� exc_value�exc_tbrrr �__exit__"szListener.__exit__) �__name__� __module__�__qualname__rrr�propertyr rrrrrr rscCs3t�t�}}|j||f�t||�S)N)r�putr)r �_in�_outrrr r&sTcCs/t�t�}}t||�t||�fS)N)rr)�duplex�a�brrr r,sc@sOeZdZdd�Zddd�Zdd�Zdd �Zd d�ZdS) rcCs<||_||_|j|_|_|j|_|_dS)N)rrr�send� send_bytesr�recv� recv_bytes)rrrrrr r3s zConnection.__init__gc Csc|jj�dkrdS|dkr)dS|jj�|jjj|�WdQRX|jj�dkS)NrTgF)r�qsize� not_empty�wait)r�timeoutrrr �poll9s zConnection.pollcCsdS)Nr)rrrr rBszConnection.closecCs|S)Nr)rrrr rEszConnection.__enter__cCs|j�dS)N)r)rrrrrrr rHszConnection.__exit__N)rrrrr+rrrrrrr r1s r) �__all__�queuer�families�objectrrrrrrrr � s