R?g1TSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r J r J r SSKJr SSKJr SSKJr SSKrSSKJrJrJr \R0(aSS KJr \R4rS \4S jrSS jrSqSS \\S\\S \4SjjrS \\4Sjr "SS\!5r"g)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)Listreturnc[cg[R"5$![a Of=f[R"S5$![ [ 4a Of=f[R"S5 g)z1Returns the number of processors on this machine.SC_NPROCESSORS_CONFz1Could not detect number of processors; assuming 1) multiprocessing cpu_countNotImplementedErrorossysconfAttributeError ValueErrorr error1/usr/lib/python3/dist-packages/tornado/process.pyrr1sm ((**     zz/00 J '    MMEF s ,,AAAc:S[R;agSSKn[[ [ R "S55S5nURU5 g![a: [[R"5S-5[ R"5- nNUf=f)Nrandomri) sysmodulesrintrrurandomrtimegetpidseed)rr&s r_reseed_randomr'Asqs{{" 572::b>*B/ KK 5499;%&45s)AABB num_processes max_restartsc|^ [RS:Xa [S5eUcSn[beUbUS::a [ 5n[ R "SU5 0m S[S[[4U 4S jjn[U5HnU"U5nUcMUs $ SnT (Ga[R"5upgUT ;aM'T RU5n[R"U5(a.[ R"S UU[R"U55 Oa[R "U5S:wa.[ R"S UU[R "U55 O[ R "S XF5 MUS - nXQ:a [#S5eU"U5nUbU$T (aGM[R$"S5 g)a!Starts 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 processesircb>[R"5nUS:Xa[5 UqU$UTU'gNr)rforkr'_task_id)r-pidchildrens r start_child#fork_processes..start_childs1ggi !8  HHHSMrz1child %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_processesrFSs< ||w788      2!  LL(-8H s x} = ! ^ >I"L ggi  h   \\#  >>& ! ! OOC F#   ^^F #q ( OOEv&   LLUS:waT(a[T[US55 g[TU5 g)Nrunknown)rCalledProcessErrorr)ryfuturerws rrp*Subprocess.wait_for_exit..callback(s-axK5.sI>363?r)rr"ru)rcrwrpr}s ` @r wait_for_exitSubprocess.wait_for_exits=$ @# @$ @ @ x( rcUR(ag[R"5nUR[R UR 5 SUlg)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 rrrSubprocess.initialize4s>    %%'  =rcUR(dg[R"5nUR[R 5 SUlg)z Removes the ``SIGCHLD`` handler.NF)rrrremove_signal_handlerrrrs r uninitializeSubprocess.uninitializeIs8 %%' ""6>>2 rcz[URR55HnURU5 M gN)listrskeysrt)rr2s rrSubprocess._cleanupRs, ))+,C  $ $S )-rr2c[R"U[R5up#US:XagX!:XdeURR U5nUR RURU5 g![a gf=fr/) rwaitpidWNOHANGChildProcessErrorrsr;rT add_callback_set_returncode)rr2ret_pidrDsubprocs rrtSubprocess._try_cleanup_processWsu  jjbjj9OG a< ~~,,""3'$$W%<% WIFEXITEDr?r\ra)rcrDrps rrSubprocess._set_returncodecs <<7 " DO~~f%%#%;;v#6"6||F++++"$.."8 $    **H"&D  T__ % r)rarTr2r\rbrQrOrP)TrN)__name__ __module__ __qualname____firstlineno____doc__objectrVrrsr rnr r"ruboolr classmethodrrrrrtr__static_attributes__rrrrJrJs*XFLH%c%S%T%N2(C5$;*?2D2,@  (!!** Fs Ft F F&c&d&rrJrr)#rrrrrrZr r$binasciirtornado.concurrentrrrtornadortornado.iostreamr tornado.logr typingr r r TYPE_CHECKINGr r|r"rr'r1rFrHrrJrrrrs     ) **  22  3   AE]C=]08 ]]@#w&w&r