3 \/�@sRdddgZddlmZdgZGdd�de�Zdd�Zdd d�ZGd d�de�ZdS) �Client�Listener�Pipe�)�QueueNc@sBeZdZddd�Zdd�Zdd�Zed d ��Zdd�Zd d�Z dS)rN�cCst|�|_dS)N)r�_backlog_queue)�self�addressZfamilyZbacklog�r �8/usr/lib64/python3.6/multiprocessing/dummy/connection.py�__init__szListener.__init__cCst|jj��S)N)� Connectionr�get)rr r r�acceptszListener.acceptcCs d|_dS)N)r)rr r r�closeszListener.closecCs|jS)N)r)rr r r�szListener.cCs|S)Nr )rr r r� __enter__szListener.__enter__cCs|j�dS)N)r)r�exc_type� exc_value�exc_tbr r r�__exit__"szListener.__exit__)NNr) �__name__� __module__�__qualname__rrr�propertyr rrr r r rrs cCs&t�t�}}|j||f�t||�S)N)r�putr )r �_in�_outr r rr&sTcCs"t�t�}}t||�t||�fS)N)rr )Zduplex�a�br r rr,sc@s6eZdZdd�Zd dd�Zdd�Zdd �Zd d�ZdS)r cCs,||_||_|j|_|_|j|_|_dS)N)rrr�sendZ send_bytesrZrecvZ recv_bytes)rrrr r rr3szConnection.__init__�c CsN|jj�dkrdS|dkrdS|jj�|jjj|�WdQRX|jj�dkS)NrTgF)rZqsizeZ not_empty�wait)rZtimeoutr r r�poll9s zConnection.pollcCsdS)Nr )rr r rrBszConnection.closecCs|S)Nr )rr r rrEszConnection.__enter__cCs|j�dS)N)r)rrrrr r rrHszConnection.__exit__N)r!)rrrrr#rrrr r r rr 1s r )T) �__all__ZqueuerZfamilies�objectrrrr r r r r� s