
    F\h>                     Z    / S Qr SSKJr  S/r " S S\5      rS rS
S jr " S S	\5      rg))ClientListenerPipe    )QueueNc                   F    \ rS rSrS
S jrS rS r\S 5       rS r	S r
S	rg)r      Nc                 $    [        U5      U l        g N)r   _backlog_queue)selfaddressfamilybacklogs       7/usr/lib/python3.13/multiprocessing/dummy/connection.py__init__Listener.__init__   s    #Gn    c                 B    [        U R                  R                  5       6 $ r
   )
Connectionr   getr   s    r   acceptListener.accept   s    4..22455r   c                     S U l         g r
   r   r   s    r   closeListener.close   s
    "r   c                     U R                   $ r
   r   r   s    r   r   Listener.address   s    """r   c                     U $ r
    r   s    r   	__enter__Listener.__enter__!       r   c                 $    U R                  5         g r
   r   r   exc_type	exc_valueexc_tbs       r   __exit__Listener.__exit__$       

r   r   )NN   )__name__
__module____qualname____firstlineno__r   r   r   propertyr   r"   r+   __static_attributes__r!   r   r   r   r      s/    -6# # #r   r   c                 b    [        5       [        5       p!U R                  X!45        [        X5      $ r
   )r   putr   )r   _in_outs      r   r   r   (   s&    KKc  r   c                 T    [        5       [        5       p![        X5      [        X!5      4$ r
   )r   r   )duplexabs      r   r   r   .   s"    7EGqaZ---r   c                   6    \ rS rSrS rS	S jrS rS rS rSr	g)
r   3   c                 |    X l         Xl        UR                  =U l        U l        UR
                  =U l        U l        g r
   )r8   r7   r6   send
send_bytesr   recv
recv_bytes)r   r7   r8   s      r   r   Connection.__init__5   s0    	&*hh.	DO&)gg-	DOr   c                 2   U R                   R                  5       S:  a  gUS::  a  gU R                   R                     U R                   R                  R                  U5        S S S 5        U R                   R                  5       S:  $ ! , (       d  f       N+= f)Nr   T        F)r7   qsize	not_emptywait)r   timeouts     r   pollConnection.poll;   sk    88>>ac>XXHH##G,  xx~~!##  s   &B
Bc                     g r
   r!   r   s    r   r   Connection.closeD   s    r   c                     U $ r
   r!   r   s    r   r"   Connection.__enter__G   r$   r   c                 $    U R                  5         g r
   r&   r'   s       r   r+   Connection.__exit__J   r-   r   )r7   r8   rB   rC   r@   rA   N)rF   )
r/   r0   r1   r2   r   rK   r   r"   r+   r4   r!   r   r   r   r   3   s    .$r   r   )T)	__all__queuer   familiesobjectr   r   r   r   r!   r   r   <module>rW      s:    +  6v ,!.
 r   