ó
L]c           @   s7   d  Z  d d l Z d   Z d d d  Z d g Z d S(   st   pure Python monitored_queue function

For use when Cython extension is unavailable (PyPy).

Authors
-------
* MinRK
i˙˙˙˙Nc         C   sU   |  j    } | r0 | d  d  d  d  | d *n  | j |  | j | g |  d  S(   Ni   i˙˙˙˙(   t   recv_multipartt   send_multipart(   t   inst   outst   sidest   prefixt   swap_idst   msg(    (    s9   lib/python2.7/site-packages/zmq/devices/monitoredqueue.pyt   _relay   s
    t   int   outc         C   sĂ   |  j  t j k o! | j  t j k } t j   } | j |  t j  | j | t j  xf t rž t | j    } |  | k r t	 |  | | | |  n  | | k rY t	 | |  | | |  qY qY Wd  S(   N(
   t   typet   zmqt   ROUTERt   Pollert   registert   POLLINt   Truet   dictt   pollR   (   t	   in_sockett
   out_sockett
   mon_sockett	   in_prefixt
   out_prefixR   t   pollert   events(    (    s9   lib/python2.7/site-packages/zmq/devices/monitoredqueue.pyt   monitored_queue   s    $	R   (   t   __doc__R   R   R   t   __all__(    (    (    s9   lib/python2.7/site-packages/zmq/devices/monitoredqueue.pyt   <module>   s   	