o
    h[                     @   sP   d dl mZ g dZdgZG dd deZdd Zdd	d
ZG dd deZdS )    )Queue)ClientListenerPipeNc                   @   sB   e Zd ZdddZdd Zdd Zed	d
 Zdd Zdd Z	dS )r   N   c                 C   s   t || _d S N)r   _backlog_queue)selfaddressfamilybacklog r   [/var/www/html/optinet_system/venv/lib/python3.10/site-packages/billiard/dummy/connection.py__init__,      zListener.__init__c                 C   s   t | j  S r   )
Connectionr   getr	   r   r   r   accept/   r   zListener.acceptc                 C   s
   d | _ d S r   r   r   r   r   r   close2   s   
zListener.closec                 C   s   | j S r   r   r   r   r   r   <lambda>5   s    zListener.<lambda>c                 C   s   | S r   r   r   r   r   r   	__enter__7      zListener.__enter__c                 G   s   |    d S r   )r   )r	   exc_infor   r   r   __exit__:   s   zListener.__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||fS r   )r   r   )duplexabr   r   r   r   D   s   r   c                   @   s&   e Zd Zdd Zd	ddZdd ZdS )
r   c                 C   s,   || _ || _|j | _| _|j | _| _d S r   )r"   r!   r    send
send_bytesr   recv
recv_bytes)r	   r!   r"   r   r   r   r   K   s   zConnection.__init__        c                 C   sR   | j  dkr	dS |dkrdS | j j  | j j| | j j  | j  dkS )Nr   Tr*   F)r!   qsize	not_emptyacquirewaitrelease)r	   timeoutr   r   r   pollQ   s   zConnection.pollc                 C   s   d S r   r   r   r   r   r   r   [   r   zConnection.closeN)r*   )r   r   r   r   r1   r   r   r   r   r   r   I   s    

r   )T)	queuer   __all__familiesobjectr   r   r   r   r   r   r   r   <module>   s   "
