
     h                     r    d dl mZ d dlmZ g dZdgZ G d de          Zd Zdd	Z	 G d
 de          Z
dS )    )absolute_import)Queue)ClientListenerPipeNc                   F    e Zd Zd	dZd Zd Z ed           Zd Zd Z	dS )
r   N   c                 .    t          |          | _        d S N)r   _backlog_queue)selfaddressfamilybacklogs       U/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/billiard/dummy/connection.py__init__zListener.__init__-   s    #Gnn    c                 B    t          | j                                         S r   )
Connectionr   getr   s    r   acceptzListener.accept0   s    4.224455r   c                     d | _         d S r   r   r   s    r   closezListener.close3   s    "r   c                     | j         S r   r   r   s    r   <lambda>zListener.<lambda>6   s	    D$7 r   c                     | S r    r   s    r   	__enter__zListener.__enter__8   s    r   c                 .    |                                   d S r   )r   )r   exc_infos     r   __exit__zListener.__exit__;   s    

r   )NNr	   )
__name__
__module____qualname__r   r   r   propertyr   r    r#   r   r   r   r   r   +   sy        - - - -6 6 6# # # h7788G      r   r   c                     t                      t                      }}|                     ||f           t          ||          S r   )r   putr   )r   _in_outs      r   r   r   ?   s9    CKKsc4   r   Tc                 z    t                      t                      }}t          ||          t          ||          fS r   )r   r   )duplexabs      r   r   r   E   s2    77EGGqAaZ1----r   c                   "    e Zd Zd ZddZd ZdS )r   c                 n    || _         || _        |j        x| _        | _        |j        x| _        | _        d S r   )r+   r*   r)   send
send_bytesr   recv
recv_bytes)r   r*   r+   s      r   r   zConnection.__init__L   s4    	&*h.	DO&)g-	DOOOr           c                 @   | j                                         dk    rdS |dk    rdS | j         j                                         | j         j                            |           | j         j                                         | j                                         dk    S )Nr   Tr6   F)r*   qsize	not_emptyacquirewaitrelease)r   timeouts     r   pollzConnection.pollR   s    8>>a4c>>5""$$$(((""$$$x~~!##r   c                     d S r   r   r   s    r   r   zConnection.close\   s    r   N)r6   )r$   r%   r&   r   r>   r   r   r   r   r   r   J   sF        . . .$ $ $ $    r   r   )T)
__future__r   billiard.fiver   __all__familiesobjectr   r   r   r   r   r   r   <module>rE      s   D ' & & & & &      
(
(
(6    v   (! ! !. . . .
         r   