σ ¨œž[c@`s΅dZddlmZmZmZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZmZddlmZddlmZddlmZdd lmZdd lmZdd lmZmZyddlZWnek rdZnXer/eZ ny ej!Z!Wn&e"k rdd ej#kre‚qenXd „Z$d„Z%d„Z&da'dd„Z(d„Z)de*fd„ƒYZ+dS(s„Utilities for working with multiple processes, including both forking the server into multiple processes and managing subprocesses. i(tabsolute_importtdivisiontprint_functionN(thexlify(tFuturet"future_set_result_unless_cancelled(tioloop(t PipeIOStream(tgen_log(tset_close_exec(t stack_context(terrno_from_exceptiontPY3tAPPENGINE_RUNTIMEcC`sntdkrdSytjƒSWntk r1nXytjdƒSWnttfk r\nXtj dƒdS(s1Returns the number of processors on this machine.itSC_NPROCESSORS_CONFs1Could not detect number of processors; assuming 1N( tmultiprocessingtNonet cpu_counttNotImplementedErrortostsysconftAttributeErrort ValueErrorRterror(((s.lib/python2.7/site-packages/tornado/process.pyR;s   cC`s†dtjkrdSddl}y"tttjdƒƒdƒ}Wn1tk rttt j ƒdƒtj ƒA}nX|j |ƒdS(Ntrandomiiiθ( tsystmodulesRtlongRRturandomRtintttimetgetpidtseed(RR ((s.lib/python2.7/site-packages/tornado/process.pyt_reseed_randomKs " $cC`s0tjƒ\}}t|ƒt|ƒ||fS(N(RtpipeR (trtw((s.lib/python2.7/site-packages/tornado/process.pyt _pipe_cloexecYs  idc `sάtd kst‚|d ks*|dkr6tƒ}ntjd|ƒi‰‡fd†}x0t|ƒD]"}||ƒ}|d k rh|SqhWd}x4ˆrΚytjƒ\}}Wn1t k rζ}t |ƒt j krΰq—n‚nX|ˆkrωq—nˆj |ƒ}tj|ƒr9tjd||tj|ƒƒnMtj|ƒdkrptjd||tj|ƒƒntjd||ƒq—|d7}||kr«tdƒ‚n||ƒ} | d k r—| Sq—Wtjdƒd S( seStarts multiple worker processes. If ``num_processes`` is None or <= 0, we detect the number of cores available on this machine and fork that number of child processes. If ``num_processes`` is given and > 0, we fork that specific number of sub-processes. Since we use processes and not threads, there is no shared memory between any server code. Note that multiple processes are not compatible with the autoreload module (or the ``autoreload=True`` option to `tornado.web.Application` which defaults to True when ``debug=True``). When using multiple processes, no IOLoops can be created or referenced until after the call to ``fork_processes``. In each child process, ``fork_processes`` returns its *task id*, a number between 0 and ``num_processes``. Processes that exit abnormally (due to a signal or non-zero exit status) are restarted with the same id (up to ``max_restarts`` times). In the parent process, ``fork_processes`` returns None if all child processes have exited normally, but will otherwise only exit by throwing an exception. isStarting %d processesc`s;tjƒ}|dkr)tƒ|a|S|ˆ|>s(t _initializedRRGRHtsignaltSIGCHLDt _old_sigchldtTrue(Ru((RuRIs.lib/python2.7/site-packages/tornado/process.pyRf,s cC`s0|js dStjtj|jƒt|_dS(s Removes the ``SIGCHLD`` handler.N(RwRxRyRztFalse(Ru((s.lib/python2.7/site-packages/tornado/process.pyt uninitializeAs cC`s1x*t|jjƒƒD]}|j|ƒqWdS(N(tlistRgtkeysRh(RuR)((s.lib/python2.7/site-packages/tornado/process.pyRrIscC`sœytj|tjƒ\}}Wn,tk rM}t|ƒtjkrNdSnX|dkr^dS||kspt‚|jj |ƒ}|j j |j |ƒdS(Ni( RtwaitpidtWNOHANGR0R R1tECHILDR,RgR3RIRqt_set_returncode(RuR)tret_pidR>R?tsubproc((s.lib/python2.7/site-packages/tornado/process.pyRhNs  cC`sŠtj|ƒr%tj|ƒ |_n'tj|ƒs:t‚tj|ƒ|_|j|j_|jr†|j}d|_||jƒndS(N( RR4R6RVt WIFEXITEDR,R7RPRUR(RWR>Ri((s.lib/python2.7/site-packages/tornado/process.pyRƒ\s   (t__name__t __module__t__doc__tobjectRKR|RwRgRdRjR{Rpt classmethodRfR}RrRhRƒ(((s.lib/python2.7/site-packages/tornado/process.pyRC½s  &  (,R‰t __future__RRRR1RRxRNRRtbinasciiRttornado.concurrentRRttornadoRttornado.iostreamRt tornado.logRttornado.platform.autoR R t tornado.utilR R Rt ImportErrorRRRRlRtenvironRR!R%R'RARBRŠRC(((s.lib/python2.7/site-packages/tornado/process.pytsB                Q