File: //usr/local/lib/python3.9/site-packages/billiard/dummy/__pycache__/connection.cpython-39.pyc
a
X>h[ � @ sP d dl mZ g d�ZdgZG dd� de�Zdd� Zd
d d
�ZG d d � d e�ZdS )� )�Queue)�Client�Listener�PipeNc @ sB e Zd Zddd�Zdd� Zdd� Zed d
� �Zd d � Zd
d� Z dS )r N� c C s t |�| _d S �N)r �_backlog_queue)�self�address�family�backlog� r
�C/usr/local/lib/python3.9/site-packages/billiard/dummy/connection.py�__init__, s zListener.__init__c C s t | j�� � S r )�
Connectionr �get�r r
r
r �accept/ s zListener.acceptc C s
d | _ d S r �r r r
r
r �close2 s zListener.closec C s | j S r r r r
r
r �<lambda>5 � zListener.<lambda>c C s | S r r
r r
r
r � __enter__7 s zListener.__enter__c G s | � � d S r )r )r �exc_infor
r
r �__exit__: s zListener.__exit__)NNr )
�__name__�
__module__� __qualname__r r r �propertyr
r r r
r
r
r r * s
r c C s& t � t � }}| �||f� t||�S r )r �putr )r
�_in�_outr
r
r r > s r Tc C s" t � t � }}t||�t||�fS r )r r )Zduplex�a�br
r
r r D s r c @ s& e Zd Zdd� Zd dd�Zdd� ZdS )
r c C s, || _ || _|j | _| _|j | _| _d S r )r! r r �sendZ
send_bytesr �recvZ
recv_bytes)r r r! r
r
r r K s zConnection.__init__� c C sR | j �� dkrdS |dkr dS | j j�� | j j�|� | j j�� | j �� dkS )Nr Tr& F)r �qsize� not_empty�acquire�wait�release)r �timeoutr
r
r �pollQ s zConnection.pollc C s d S r r
r r
r
r r [ s zConnection.closeN)r& )r r r r r- r r
r
r
r r I s
r )T) �queuer �__all__Zfamilies�objectr r r r r
r
r
r �<module># s