RSidZddlZddlZddlZddlZddlmZ ddlZn #e$rdZYnwxYwddl m Z da dZ dZ d d ZdS) zProcess utils.N)hexlify)loggerctdS tjS#t$rYnwxYw tjdS#t t f$rYnwxYwdS)z1Returns the number of processors on this machine.NrSC_NPROCESSORS_CONF)multiprocessing cpu_countNotImplementedErrorossysconfAttributeError ValueErrorE/home/jrussi/.local/lib/python3.11/site-packages/pyftpdlib/prefork.pyr r sq (***       z/000 J '     1s ++AAAc tttjdd}nG#t$r:tt jdztjz }YnwxYwtj|dS)Ni) intrr urandomr timegetpidrandomseed)rs r_reseed_randomr&s 572:b>>**B// 55549;;%&&45 Ks/2AA65A6dc tJ||dkrt}tjd|i fd}t |D]}||}||cSd} r t j\}}n#t$rY'wxYw| vr0 |}t j |r*tj d||t j |nYt j |dkr*tj d||t j |ntjd|||dz }||krtd ||}||S tjddS) aStarts multiple worker processes. If *number* is None or <= 0, we detect the number of cores available on this machine and fork that number of child processes. If *number* 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. In each child process, *fork_processes* returns its *task id*, a number between 0 and *number*. 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. Nrzstarting %d pre-fork processeschtj}|dkrt|a|S||<dS)Nr)r forkr_task_id)ipidchildrens r start_childz#fork_processes..start_childJs;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)rr rinforanger waitInterruptedErrorpop WIFSIGNALEDwarningWTERMSIG WEXITSTATUS RuntimeErrorsysexit) number max_restartsr#r id num_restartsr!statusnew_idr"s @rfork_processesr62s$     ~1 K0&999H     6]] [^^ >III L  '))KC    H  h    \\#   >& ! !  NC F##      ^F # #q ( ( NEv&&      K;R E E E  , & &CDD DR  M= FHQKKKKKs&A== B  B )r)__doc__r rr.rbinasciirr ImportErrorlogrrr rr6rrrr;s  OOO        LLLLLLs ))