
    h[                     Z    S SK Jr  / SQrS/r " S S\5      rS rS
S jr " S S	\5      rg)    )Queue)ClientListenerPipeNc                   H    \ 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       AD:\TimeStamps\venv\Lib\site-packages\billiard/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.close2   s
    "r   c                     U R                   $ r
   r   r   s    r   <lambda>Listener.<lambda>5   s
    D$7$7r   c                     U $ r
    r   s    r   	__enter__Listener.__enter__7   s    r   c                 $    U R                  5         g r
   )r   )r   exc_infos     r   __exit__Listener.__exit__:   s    

r   r   )NN   )__name__
__module____qualname____firstlineno__r   r   r   propertyr   r#   r'   __static_attributes__r"   r   r   r   r   *   s(    -6# 78G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   D   s"    7EGqaZ---r   c                   *    \ rS rSrS rSS jrS rSrg)r   I   c                 |    X l         Xl        UR                  =U l        U l        UR
                  =U l        U l        g r
   )r3   r2   r1   send
send_bytesr   recv
recv_bytes)r   r2   r3   s      r   r   Connection.__init__K   s0    	&*hh.	DO&)gg-	DOr   c                 b   U R                   R                  5       S:  a  gUS::  a  gU R                   R                  R                  5         U R                   R                  R	                  U5        U R                   R                  R                  5         U R                   R                  5       S:  $ )Nr   T        F)r2   qsize	not_emptyacquirewaitrelease)r   timeouts     r   pollConnection.pollQ   s|    88>>ac>""$(""$xx~~!##r   c                     g r
   r"   r   s    r   r   Connection.close[   s    r   )r2   r3   r=   r>   r;   r<   N)rA   )r*   r+   r,   r-   r   rH   r   r/   r"   r   r   r   r   I   s    .$r   r   )T)	queuer   __all__familiesobjectr   r   r   r   r"   r   r   <module>rP      s9   F 
(6v (!.
 r   