ó ßüÚ\c@`sAddlmZmZmZddlmZddlZddlZddlZddl Z ddl Z ddl m Z ddl Z ddlZddlmZddlmZddlm Z ddlmZdd lmZdd lmZmZmZd „Zd „Zdd „Zd„Zd„Z d„Z!eeƒd„ƒƒZ"eƒd„ƒZ#ej$j%ej&dkddƒeƒd„ƒƒZ'eƒd„ƒZ(eƒd„ƒZ)eƒd„ƒZ*eƒd„ƒZ+ej$j%e j,j-dƒddƒeƒd„ƒƒZ.eƒd„ƒZ/d„Z0d „Z1d!„Z2dS("i(tprint_functiontdivisiontabsolute_import(t timedeltaN(tsleep(tgen(tEvent(ttime(t AsyncProcess(t mp_context(tgen_testt pristine_looptnodebugcC`s#|jddƒ}|j|ƒdS(Nttimeouti(tgettput(tin_qtout_qtobj((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pytfeedscC`stj|jƒƒdS(N(tsystexitR(tq((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyRscC`stj|ƒdS(N(RR(trc((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pytexit_nowscC`sGtjtjtjƒx*trBtjtjƒ|ƒtdƒqWdS(Ng{®Gáz„?(tsignaltSIGINTtSIG_DFLtTruetostkilltgetpidR(tsignum((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pytexit_with_signal#s cC`sxtrtdƒqWdS(Ng{®Gáz„?(RR(((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pytwait*s cC`s3|jttjƒƒƒ|jtjƒjƒdS(N(Rtlent threadingt enumeratetcurrent_threadtname(R((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt threads_info/sc c`s)tjƒ}tjƒ}tdtd||fƒ}|jƒ sFt‚|jdks[t‚|jdkspt‚|j s€t‚t |_ |j s˜t‚t j |ƒ}t j |j ƒ}tjtƒ|jƒVWdQX|jƒV|jƒs÷t‚|jdk s t‚|jdks!t‚tƒ}|jddƒVtƒ|}d|ko_dknsjt‚|jƒs|t‚|jdk s‘t‚|jdks¦t‚tjtƒt|_ WdQX|jdƒ|jƒdksêt‚tƒ}|jddƒVtƒ|}|d ks#t‚|jƒ s6t‚|jdk sKt‚|jd ks`t‚tƒ}|jƒVtƒ|}|d ks“t‚~tjƒtƒ}x:|ƒdk råtƒ|d kråtd ƒtjƒq¬W|ƒdk rÏd dlm}|ƒ} | dk r¿tj| ƒ} tj| ƒ} ~ td| | ƒg| D]} t| |ƒrR| ^qR} xIt | ƒD]8\}}td||j!j"|j!j#t$|j%ƒƒq€Wntj&dƒntƒ}xJ|ƒdk r$t'jdƒVtjƒtƒ|}|dksÛt‚qÛWdS(NttargettargsR g{®Gáz”?gš™™™™™É?g{®Gáz„?ii gð?ig333333ã?igü©ñÒMbP?(t FrameTypes refs to proc:s frames #%d:s'AsyncProcess should have been destroyedg@((R tQueueRRtis_alivetAssertionErrortpidtNonetexitcodetdaemonRtweakreftreft_processtpytesttraisestjointstartRtFalseRRtgctcollectRttypesR+Rt getrefcountt get_referrerstprintt isinstanceR%tf_codetco_namet co_filenametsortedtf_localstfailR(tto_childt from_childtproctwr1twr2tt1tdtR9R+tpRtrefstrtframestitf((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt test_simple4s†      "        %   (     cc`sÕtjƒ}tdtdi|d6ƒ}t|_|jƒ sDt‚|jdksYt‚|j ƒV|jƒsvt‚|jdks‹t‚|j dƒ|j ddƒV|jƒ s¼t‚|jdksÑt‚dS(NR)tkwargsRiR g@( R R,RRRR2R-R.R1R0R9RR8(RRJ((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt test_exitcodes    tnttreasons POSIX onlycc`stdtdtjfƒ}t|_|jƒ s7t‚|jdksLt‚|j ƒV|j ddƒV|jƒ s{t‚|jtj dfksšt‚tdt ƒ}|j ƒVt j|jtjƒ|j ddƒV|jƒ sît‚|jtj dfks t‚dS(NR)R*R g@iÿ(RR!RRRR2R-R.R1R0R9R8R"RRR/tSIGTERM(RJ((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt test_signal¢s   cc`sutdtƒ}t|_|jƒV|jƒV|jddƒV|jƒ sRt‚|j t j dfksqt‚dS(NR)R g@iÿ( RR"RR2R9t terminateR8R-R.R1RRZ(RJ((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyttest_terminateºs   cc`sÝtdtƒ}|jƒtjtƒ|jƒVWdQXtdtƒ}|jƒV|jƒtjtƒ|jƒVWdQXtdtƒ}|jƒV|jƒV|jƒtjtƒ|jƒVWdQX|jƒdS(NR)( RRtcloseR6R7t ValueErrorR9R\R8(RJ((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt test_closeÆs       c#`s£tjƒ}tjƒ}tƒ‰tj‡‡fd†ƒ}tdtd||fƒ‰ˆjƒˆj|ƒt ˆ_ ˆj ƒVtj dƒVˆj ƒs¢t‚ˆjƒ sµt‚|jdƒˆjtddƒƒVˆjƒsët‚ˆj ƒ sþt‚tdtƒ‰ˆjƒˆj|ƒt ˆ_ ˆj ƒVtj dƒVˆj ƒsXt‚ˆjƒ skt‚ˆjƒVˆjtddƒƒVˆjƒsŸt‚dS(Nc3`s(|ˆkst‚tjVˆjƒdS(N(R.Rtmomenttset(t_proc(tevtRJ(sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyton_stopâsR)R*gš™™™™™©?tsecondsi(R R,RRt coroutineRRtcleartset_exit_callbackRR2R9RR-R.tis_setRR0R"RR\(RHRIRe((RdRJsBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyttest_exit_callbackÜs6             cc`sžtjƒ}tdtd|fƒ}|jƒV|jƒV|jƒ}|jƒ}|dksdt‚|dksvt‚|jƒ|j jƒ|j jƒdS(sE The main thread in the child should be called "MainThread". R)R*it MainThreadN( R R,RR(R9R8RR.R^t_readert_writer(RRJt n_threadst main_name((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyttest_child_main_threads       twins num_fds not supported on windowscc`stjdƒ}tdtƒ}t|_|jƒV|jƒV|jƒ}|j ƒ}tdtƒ}t|_|jƒV|jƒV|j ƒ s–t ‚|j dks«t ‚t ƒ}xS|j ƒ|kr tjdƒVtd||j ƒƒt ƒ|dks·t ‚q·WdS(NtpsutilR)igš™™™™™¹?sfds:i (R6t importorskipRRRR2R9R8tProcesstnum_fdsR-R.R1RRRR@(RsRJROtbeforeR9((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt test_num_fdss$         cc`s=tdtddƒ}|jƒVtjdƒV|jƒVdS(NR)R*igš™™™™™¹?(i(RRR9RR\(RJ((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyttest_terminate_after_stop8s cC`s+|jƒd}t|ƒ|jdƒdS(Ng@schild should have exited by now(RbRtsend(t worker_readyt child_pipetshorter_timeout((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt_worker_process@s  c `s_‡fd†}tƒA}z |jtj|ƒddƒWd|jƒtdƒ‚XWdQXdS(s¶ Simulate starting an AsyncProcess and then dying. The child_alive pipe is held open for as long as the child is alive, and can be used to determine if it exited correctly. c3`sMtjƒ}tdtd|ˆfƒ}|jƒV|jƒtjdƒdS(NR)R*iÿ(R RRR~R9R"Rt_exit(R{tworker(R|(sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pytparent_process_coroutineZs    R i Ns*this should be unreachable due to os._exit(R trun_syncRRgtstopt RuntimeError(R|Rtloop((R|sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt_parent_processTs    cC`s+tjdtƒ\}}ztjdtd|fƒ}|jƒ|jƒ|jƒd}y|j|ƒ}Wn5t k r¤t j j dƒs›t dƒ‚t}nX|s±t ‚y|jƒ}Wn?tk rÔnDt k rt j j dƒst dƒ‚nXtdj|ƒƒ‚Wd|jƒXdS( sI Check that a child process started by AsyncProcess exits if its parent exits. The motivation is to ensure that if an AsyncProcess is created and the creator process dies unexpectedly (e.g, via Out-of-memory SIGKILL), the child process and resources held by it should not be leaked. The child should monitor its parent and exit promptly if the parent exits. [test process] -> [parent using AsyncProcess (dies)] -> [worker process] \ / \________ <-- child_pipe <-- ________/ tduplexR)R*g@Rrsshould only raise on windowssunreachable: {}N(R tPipeR:RuR†R9R^R8tpolltEnvironmentErrorRtplatformt startswithR.RtrecvtEOFErrorR„tformat(tchildren_aliveR|tparentt short_timeouttreadabletresult((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pyt/test_asyncprocess_child_teardown_on_parent_exitrs*        "(3t __future__RRRtdatetimeRR;RRRR$RRR3R6ttornadoRt tornado.locksRtdistributed.metricstdistributed.processRtdistributed.utilsR tdistributed.utils_testR R R RRRR!R"R(RURWtmarktskipifR'R[R]R`RkRqR‹RŒRxRyR~R†R•(((sBlib/python2.7/site-packages/distributed/tests/test_asyncprocess.pytsJ             Z ,