Mh1DdZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z ddlmZddlmZddlmZddlZddlmZmZmZejrdd lmZejZd efd Zdd Zda dd eedeed efdZd eefdZ GddZ!dS)zUtilities for working with multiple processes, including both forking the server into multiple processes and managing subprocesses. N)hexlify)Future"future_set_result_unless_cancelled%future_set_exception_unless_cancelled)ioloop) PipeIOStream)gen_log)OptionalAnyCallable)ListreturnctdS tjS#t$rYnwxYw tjdS#t t f$rYnwxYwtjddS)z1Returns the number of processors on this machine.NSC_NPROCESSORS_CONFz1Could not detect number of processors; assuming 1) multiprocessing cpu_countNotImplementedErrorossysconfAttributeError ValueErrorr errorO/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/tornado/process.pyrr1sq (***       z/000 J '      MEFFF 1s ++AAAcHdtjvrdSddl} tt t jdd}nG#t$r:ttjdzt j z }YnwxYw| |dS)Nrandomri) sysmodulesrintrrurandomrtimegetpidseed)rr&s r_reseed_randomr'Ass{""MMM 572:b>>**B// 55549;;%&&45 KKs/AAB  B  num_processes max_restartscR tjdkrtd|d}tJ||dkrt }t jd|i dtdttf fd }t|D]}||}||cSd} rtj \}}| vr |}tj |r*t jd ||tj|nYtj|dkr*t jd ||tj|nt jd |||d z }||krt#d||}||S tjddS)aqStarts 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`` calls ``sys.exit(0)`` after all child processes have exited normally. max_restarts defaults to 100. Availability: Unix win32zfork not available on windowsNdrzStarting %d processesirchtj}|dkrt|a|S||<dSNr)rforkr'_task_id)r-pidchildrens r start_childz#fork_processes..start_childs;gii !88    HHHSM4rz1child %d (pid %d) killed by signal %d, restartingz3child %d (pid %d) exited with status %d, restartingz!child %d (pid %d) exited normallyrz"Too many child restarts, giving up)r platform Exceptionr1rr infor"r rangerwaitpop WIFSIGNALEDwarningWTERMSIG WEXITSTATUS RuntimeErrorexit) r(r)r4r-id num_restartsr2statusnew_idr3s @rfork_processesrESs < |w7888       2 2!  L(-888H s x}      = ! ! [^^ >III L gii V h    \\#   >& ! !  OC F##      ^F # #q ( ( OEv&&      L >D4&& >dGDIt$<$<==="s F44Gcallbackc||_t|tj|j<t|jdS)aRuns ``callback`` when this process exits. The callback takes one argument, the return code of the process. This method uses a ``SIGCHLD`` handler, which is a global setting and may conflict if you have other libraries trying to handle the same signal. If you are using more than one ``IOLoop`` it may be necessary to call `Subprocess.initialize` first to designate one ``IOLoop`` to run the signal handlers. In many cases a close callback on the stdout or stderr streams can be used as an alternative to an exit callback if the signal handler is causing a problem. Availability: Unix N)r_rI initialize_waitingr2_try_cleanup_process)rarms rset_exit_callbackzSubprocess.set_exit_callbacksI"'(, DH%''11111rT raise_errorz Future[int]cptdtddffd }||S)a2Returns a `.Future` which resolves when the process exits. Usage:: ret = yield proc.wait_for_exit() This is a coroutine-friendly alternative to `set_exit_callback` (and a replacement for the blocking `subprocess.Popen.wait`). By default, raises `subprocess.CalledProcessError` if the process has a non-zero exit status. Use ``wait_for_exit(raise_error=False)`` to suppress this behavior and return the exit status without raising. .. versionadded:: 4.2 Availability: Unix retrNcx|dkr"r tt|ddSt|dS)Nrunknown)rCalledProcessErrorr)rufuturerss rrmz*Subprocess.wait_for_exit..callback(sTaxxKx5.sI>>363?????r)rr"rr)rarsrmrys ` @r wait_for_exitzSubprocess.wait_for_exitsd$ @# @$ @ @ @ @ @ @ @ x((( rc|jrdStj}|tj|jd|_dS)aInitializes the ``SIGCHLD`` handler. The signal handler is run on an `.IOLoop` to avoid locking issues. Note that the `.IOLoop` used for signal handling need not be the same one used by individual Subprocess objects (as long as the ``IOLoops`` are each running in separate threads). .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. Availability: Unix NT) _initializedasyncioget_event_loopadd_signal_handlersignalSIGCHLD_cleanupclsloops rrozSubprocess.initialize4sJ    F%''  ===rc|jsdStj}|tjd|_dS)z Removes the ``SIGCHLD`` handler.NF)r|r}r~remove_signal_handlerrrrs r uninitializezSubprocess.uninitializeIsF  F%'' ""6>222 rct|jD]}||dSN)listrpkeysrq)rr2s rrzSubprocess._cleanupRsH ))++,, * *C  $ $S ) ) ) ) * *rr2c tj|tj\}}n#t$rYdSwxYw|dkrdS||ksJ|j|}|j|j|dSr/) rwaitpidWNOHANGChildProcessErrorrpr:rR add_callback_set_returncode)rr2ret_pidrCsubprocs rrqzSubprocess._try_cleanup_processWs  jbj99OGVV     FF  a<< F#~~~~,""3''$$W%rZr_)rarCrms rrzSubprocess._set_returncodecs <7 " " DOO~f%% 9#%;v#6#6"6|F+++++"$."8"8 $    &*H"&D  HT_ % % % % % & &r)TrN)__name__ __module__ __qualname____doc__objectrTr|rpr rlr r"rrboolrz classmethodrorrrqrrrrrIrIsj*VXXFLH%c%S%T%%%%N2(C5$;*?2D2222,@   [ (!!![!***[* Fs Ft F F F[ F&c&d&&&&&&rrIrr)"rr}rrrrXr r$binasciirtornado.concurrentrrrtornadortornado.iostreamr tornado.logr typingr r r TYPE_CHECKINGr rxr"rr'r1rErGrIrrrrs     )))))) **********  2  3         AE]]C=]08 ]]]]]@#w&w&w&w&w&w&w&w&w&w&r