
    ⾙h[                     X    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y)    )Queue)ClientListenerPipeNc                   >    e Zd ZddZd Zd Z ed       Zd Zd Z	y)	r   Nc                 $    t        |      | _        y N)r   _backlog_queue)selfaddressfamilybacklogs       U/var/www/Befach/backend/env/lib/python3.12/site-packages/billiard/dummy/connection.py__init__zListener.__init__,   s    #Gn    c                 B    t        | j                  j                          S r	   )
Connectionr
   getr   s    r   acceptzListener.accept/   s    4..22455r   c                     d | _         y 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$7r   c                     | S r	    r   s    r   	__enter__zListener.__enter__7   s    r   c                 $    | j                          y r	   )r   )r   exc_infos     r   __exit__zListener.__exit__:   s    

r   )NN   )
__name__
__module____qualname__r   r   r   propertyr   r   r!   r   r   r   r   r   *   s(    -6# 78Gr   r   c                 h    t               t               }}| j                  ||f       t        ||      S r	   )r   putr   )r   _in_outs      r   r   r   >   s,    CKKsc4  r   c                 Z    t               t               }}t        ||      t        ||      fS r	   )r   r   )duplexabs      r   r   r   D   s(    7EGqAaZ1---r   c                        e Zd Zd ZddZd Zy)r   c                     || _         || _        |j                  x| _        | _        |j
                  x| _        | _        y r	   )r*   r)   r(   send
send_bytesr   recv
recv_bytes)r   r)   r*   s      r   r   zConnection.__init__K   s4    	&*hh.	DO&)gg-	DOr   c                 ^   | j                   j                         dkD  ry|dk  ry| j                   j                  j                          | j                   j                  j	                  |       | j                   j                  j                          | j                   j                         dkD  S )Nr   T        F)r)   qsize	not_emptyacquirewaitrelease)r   timeouts     r   pollzConnection.pollQ   s|    88>>ac>""$(""$xx~~!##r   c                      y r	   r   r   s    r   r   zConnection.close[   s    r   N)r6   )r#   r$   r%   r   r=   r   r   r   r   r   r   I   s    .$r   r   )T)	queuer   __all__familiesobjectr   r   r   r   r   r   r   <module>rC      s9   F 
(6v (!.
 r   