ó
ßüÚ\c           @` s   d  d l  m Z m Z m Z d  d l Z d  d l Z d  d l Z d  d l m Z d  d l	 m
 Z
 d  d l m Z d „  Z d „  Z d „  Z d S(	   i    (   t   print_functiont   divisiont   absolute_importN(   t   metrics(   t   PY3(   t   run_forc          C` s  xt  d ƒ D]	}  t j d ƒ t j ƒ  } g  t  d ƒ D] } t j ƒ  ^ q9 } g  t  t | ƒ d ƒ D] } | | d | | ^ qh } t | ƒ d k s¨ t | ƒ ‚ t | ƒ d k sÆ t | ƒ ‚ t d „  | Dƒ ƒ sè t | ƒ ‚ | d | d	 k  o| d k  n s t ‚ q Wd  S(
   Ni   g{®Gáz„?i2   i   g        g      ð?c         s` s   |  ] } d  „  Vq d S(   c         S` s   d |  k  o d k  SS(   Ng        g-Cëâ6?(    (   t   d(    (    s=   lib/python2.7/site-packages/distributed/tests/test_metrics.pyt   <lambda>   t    N(    (   t   .0R   (    (    s=   lib/python2.7/site-packages/distributed/tests/test_metrics.pys	   <genexpr>   s    g      à?i    (	   t   ranget   timet   sleepR   t   lent   mint   AssertionErrort   maxt   any(   t   it   tt   jt   samplest   deltas(    (    s=   lib/python2.7/site-packages/distributed/tests/test_metrics.pyt   test_wall_clock   s    %9"c          C` sê   t  j ƒ  }  t d ƒ t  j ƒ  |  } d | k o= d k n sH t ‚ t j d t d d ƒ } t  j ƒ  }  | j ƒ  | j ƒ  t  j ƒ  |  } | d k s¢ t ‚ t ræ t  j ƒ  }  t	 j
 d ƒ t  j ƒ  |  } | d k sæ t ‚ n  d  S(   Ngš™™™™™©?g¸…ëQ¸ž?gš™™™™™É?t   targett   argsgš™™™™™¹?(   gš™™™™™¹?(   R   t   process_timeR   R   t	   threadingt   Threadt   startt   joinR   R   R   (   R   t   dtR   (    (    s=   lib/python2.7/site-packages/distributed/tests/test_metrics.pyt   test_process_time   s    
"

c          C` sü   t  j ƒ  }  t d ƒ t  j ƒ  |  } d | k o= d k n sH t ‚ t rø t  j ƒ  }  t j d ƒ t  j ƒ  |  } | d k s‰ t ‚ t j d k rø t	 j
 d t d d ƒ } t  j ƒ  }  | j ƒ  | j ƒ  t  j ƒ  |  } | d k sõ t ‚ qø n  d  S(	   Ngš™™™™™©?g¸…ëQ¸ž?gš™™™™™É?gš™™™™™¹?t   linuxR   R   (   gš™™™™™¹?(   R   t   thread_timeR   R   R   R   R   t   syst   platformR   R   R   R   (   R   R   R   (    (    s=   lib/python2.7/site-packages/distributed/tests/test_metrics.pyt   test_thread_time0   s     
"

(   t
   __future__R    R   R   R#   R   R   t   distributedR   t   distributed.compatibilityR   t   distributed.utils_testR   R   R    R%   (    (    (    s=   lib/python2.7/site-packages/distributed/tests/test_metrics.pyt   <module>   s   		