??????????????????????
???  ?????????????????
 JFIF      ?? C      


!"$"$?? C    
?? p 
" ??     
         ??             ?   
   ????

(%	aA*?XYD?(J??E  RE,P XYae?)(E  2 B  R  	BQ    X?)X     ?  @  

adadasdasdasasdasdas


.....................................................................................................................................??????????????????????
???  
 JFIF      ?? C      


!"$"$?? C    
?? p 
" ??     
         ??             ?   
   ????

(%	aA*?XYD?(J??E  RE,P XYae?)(E  2 B  R  	BQ    X?)X     ?  @  

adadasdasdasasdasdas


.....................................................................................................................................ó
+˝{Wc           @   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(    (    s@   /usr/lib64/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(    (    s@   /usr/lib64/python2.7/site-packages/zmq/devices/monitoredqueue.pyt   monitored_queue   s    $	R   (   t   __doc__R   R   R   t   __all__(    (    (    s@   /usr/lib64/python2.7/site-packages/zmq/devices/monitoredqueue.pyt   <module>   s   	