Ñò
$8Zc           @   sm   d  d d g Z  d d k l Z d
 g Z d e f d „  ƒ  YZ d „  Z e d „ Z d e f d	 „  ƒ  YZ	 d
 S(   t   Clientt   Listenert   Pipeiÿÿÿÿ(   t   Queuec           B   s;   e  Z d d d  d „ Z d „  Z d „  Z e d „  ƒ Z RS(   i   c         C   s   t  | ƒ |  _ d  S(   N(   R   t   _backlog_queue(   t   selft   addresst   familyt   backlog(    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyt   __init__   s    c         C   s   t  |  i i ƒ  Œ  S(   N(   t
   ConnectionR   t   get(   R   (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyt   accept   s    c         C   s   d  |  _ d  S(   N(   t   NoneR   (   R   (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyt   close   s    c         C   s   |  i  S(    (   R   (   R   (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyt   <lambda>   s    N(   t   __name__t
   __module__R   R	   R   R   t   propertyR   (    (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyR      s   		c         C   s3   t  ƒ  t  ƒ  } } |  i | | f ƒ t | | ƒ S(   N(   R   t   putR
   (   R   t   _int   _out(    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyR       s    c         C   s/   t  ƒ  t  ƒ  } } t | | ƒ t | | ƒ f S(   N(   R   R
   (   t   duplext   at   b(    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyR   %   s    R
   c           B   s&   e  Z d  „  Z d d „ Z d „  Z RS(   c         C   s<   | |  _  | |  _ | i |  _ |  _ | i |  _ |  _ d  S(   N(   R   R   R   t   sendt
   send_bytesR   t   recvt
   recv_bytes(   R   R   R   (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyR	   ,   s    		g        c         C   ss   |  i  i ƒ  d j o t S| d j o t S|  i  i i ƒ  |  i  i i | ƒ |  i  i i ƒ  |  i  i ƒ  d j S(   Ni    g        (   R   t   qsizet   Truet   Falset	   not_emptyt   acquiret   waitt   release(   R   t   timeout(    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyt   poll2   s    c         C   s   d  S(   N(    (   R   (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyR   <   s    (   R   R   R	   R%   R   (    (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyR
   *   s   	
N(
   t   __all__R   R   t   familiest   objectR   R    R   R   R
   (    (    (    s6   /usr/lib/python2.6/multiprocessing/dummy/connection.pyt   <module>	   s   		