
    Sf[                     f    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 )    )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       K/var/www/html/env/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.accept/   s    4.224455r   c                     d | _         d S r
   r   r   s    r   closezListener.close2   s    "r   c                     | j         S r
   r   r   s    r   <lambda>zListener.<lambda>5   s	    D$7 r   c                     | S r
    r   s    r   	__enter__zListener.__enter__7   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   D   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__K   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   Tr5   F)r)   qsize	not_emptyacquirewaitrelease)r   timeouts     r   pollzConnection.pollQ   s    8>>a4c>>5""$$$(((""$$$x~~!##r   c                     d S r
   r   r   s    r   r   zConnection.close[   s    r   N)r5   )r#   r$   r%   r   r=   r   r   r   r   r   r   I   sF        . . .$ $ $ $    r   r   )T)	queuer   __all__familiesobjectr   r   r   r   r   r   r   <module>rC      s   F      
(
(
(6    v   (! ! !. . . .
         r   