
    d>                     f    g d Z ddlmZ dgZ G d de          Zd ZddZ G d	 d
e          ZdS ))ClientListenerPipe    )QueueNc                   D    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       2  /croot/python-split_1694437901252/_h_env_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_plac/lib/python3.11/multiprocessing/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.close   s    "r   c                     | j         S r
   r   r   s    r   r   zListener.address   s    ""r   c                     | S r
    r   s    r   	__enter__zListener.__enter__!       r   c                 .    |                                   d S r
   r   r   exc_type	exc_valueexc_tbs       r   __exit__zListener.__exit__$       

r   )NNr   )
__name__
__module____qualname__r   r   r   propertyr   r   r&   r   r   r   r   r      s        - - - -6 6 6# # # # # X#      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   .   s2    77EGGqAaZ1----r   c                   .    e Zd Zd ZddZd Z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__5   s4    	&*h.	DO&)g-	DOOOr           c                    | j                                         dk    rdS |dk    rdS | j         j        5  | j         j                            |           d d d            n# 1 swxY w Y   | j                                         dk    S )Nr   Tr:   F)r.   qsize	not_emptywait)r   timeouts     r   pollzConnection.poll;   s    8>>a4c>>5X 	- 	-H##G,,,	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	-x~~!##s    A  A$'A$c                     d S r
   r   r   s    r   r   zConnection.closeD   s    r   c                     | S r
   r   r   s    r   r   zConnection.__enter__G   r   r   c                 .    |                                   d S r
   r!   r"   s       r   r&   zConnection.__exit__J   r'   r   N)r:   )r(   r)   r*   r   r@   r   r   r&   r   r   r   r   r   3   sd        . . .$ $ $ $        r   r   )T)	__all__queuer   familiesobjectr   r   r   r   r   r   r   <module>rH      s    +
*
*       6    v   ,! ! !. . . .
         r   