ó ßüÚ\c@`sddlmZmZmZddlZddlmZddlZddlZ ej ddƒZ e d„Z e dƒZ e dƒZdefd „ƒYZejjd ƒr½eƒjZn e jZd „Zd „Zd „Zd„Zd„Zd„ZeƒZeƒZdS(i(tprint_functiontdivisiontabsolute_importN(twrapst_empty_namedtuplec`sVyddl}Wntk r$ˆSXt||ƒ‰tˆƒ‡‡fd†ƒ}|S(sx Return a function calling the given psutil *method_name*, or returning *default* if psutil is not present. iNc`s'y ˆƒSWntk r"ˆƒSXdS(N(t RuntimeError((tdefaulttmeth(s2lib/python2.7/site-packages/distributed/metrics.pytwrappers  (tpsutilt ImportErrortgetattrR(t method_nameRR R((RRs2lib/python2.7/site-packages/distributed/metrics.pyt_psutil_caller s tdisk_io_counterstnet_io_counterst _WindowsTimecB`sSeZdZdZd„Zejdkr6ejZn ej Zd„Z d„Z RS(sh Combine time.time() and time.perf_counter() to get an absolute clock with fine resolution. iXcC`sd|_tdƒ|_dS(Ns-inf(tNonetdeltatfloatt last_resync(tself((s2lib/python2.7/site-packages/distributed/metrics.pyt__init__2s icC`sK|j}|jƒ}||j|jkrC|jƒ}||_n||S(N(Rt perf_counterRt RESYNC_EVERYtresync(RRtcur((s2lib/python2.7/site-packages/distributed/metrics.pyttime;s     c C`stj}|j}d}xñtr gt|dƒD]}|ƒ|ƒf^q2}tjd„|Dƒƒ}|jƒd\}}||kr‘qqg|D] } | d|kr˜| d^q˜d } t| ƒ|dksät | ƒ‚|t | ƒt| ƒ|_ |j SqWdS(Niics`s|]}|dVqdS(iN((t.0tt((s2lib/python2.7/site-packages/distributed/metrics.pys Isiiiÿÿÿÿ( ttimemodRRtTruetranget collectionstCountert most_commontlentAssertionErrortsumR( Rt_timet _perf_countert min_samplestittimest abs_timestfirsttnfirstRt perf_times((s2lib/python2.7/site-packages/distributed/metrics.pyRCs   / 1"(i( t__name__t __module__t__doc__RRtsyst version_infoRRtclockRR(((s2lib/python2.7/site-packages/distributed/metrics.pyR)s    twincC`s tjƒS(N(Rt thread_time(((s2lib/python2.7/site-packages/distributed/metrics.pyt_native_thread_time]scC`s%tjdkrt‚ntjdƒS(Ntlinuxi(R3tplatformtOSErrorRt clock_gettime(((s2lib/python2.7/site-packages/distributed/metrics.pyt_linux_thread_timebs cC`s tjƒS(N(Rt process_time(((s2lib/python2.7/site-packages/distributed/metrics.pyt_native_process_timeiscC`s tjƒS(N(RR5(((s2lib/python2.7/site-packages/distributed/metrics.pyt_native_clock_funcnscC`sAx:tgD]/}y|ƒ|SWq ttfk r8q Xq WtS(s` Return a per-process CPU timer function if possible, otherwise a wall-clock timer. (R?tAttributeErrorR;R@(tfunc((s2lib/python2.7/site-packages/distributed/metrics.pyt_detect_process_timeuscC`sGx@tttgD]/}y|ƒ|SWqttfk r>qXqWtS(s Return a per-thread CPU timer function if possible, otherwise a per-process CPU timer function, or at worse a wall-clock timer. (R8R=R?RAR;R(RB((s2lib/python2.7/site-packages/distributed/metrics.pyt_detect_thread_time„s((t __future__RRRR!t functoolsRR3RRt namedtupleRR RRtobjectRR:t startswithR8R=R?R@RCRDR>R7(((s2lib/python2.7/site-packages/distributed/metrics.pyts(      -