^j\dZddlZddlZddlZddlZddlmZddlmZejZ ejZ ddl mZedeeDZdD]Z eeeee<ej*d cZZej0j3d Zer eeeecZZerd hneZerd hneZd Zd d edhZd d ddddddeddddddhZ dgZ!dZ"dZ#dZ$e fdZ dZ%d Z&d!Z'd"Z(e&dfd#Z)Gd$d%Z*y#e$rYwxYw)&ze This module contains utilities added by billiard, to keep "non-core" functionality out of ``.util``.N)RestartFreqExceeded) monotonicBytesIOc#dK|](}|jdstt||f*yw)SIGN) startswithgetattrsignal).0ns Q/var/www/html/metafoliadorv2/venv/lib/python3.12/site-packages/billiard/common.py rs, !ALL4GWVQs00)SIGHUPSIGABRTSIGTERM REMAP_SIGTERMSIGQUITFrSIGUSR1SIGTRAPrSIGEMTSIGSYSSIGPIPESIGALRMSIGXCPUSIGXFSZ SIGVTALRMSIGPROFSIGUSR2FctdS)aHas this process's own terminate-signal handler already fired? A `SystemExit` seen after that point was raised by :func:`_shutdown_cleanup`, not by whatever the process happened to be running, and means the process is on its way out. Strictly about *this* process having already run the handler -- a process that has been sent a terminate signal but has not yet handled it answers False, which is why this is not named ``terminating()``. r_should_have_exitedrterminate_handler_firedr'Ms q !!r&cdtd<y)aForget that a terminate handler ran -- for use after :func:`fork`. The flag is a module global and so is inherited across ``fork()``. A fresh child has not run a terminate handler, whatever it inherited from a parent that had, and must say so before it runs any user code: a stale True makes :func:`_shutdown_cleanup` take its "something is very wrong" :func:`os._exit` branch on the child's first terminate signal. FrNr#r%r&rclear_terminate_handler_firedr)[s#r&c|xsddkr dj| t| Sdj|S#t$rdj| cYSwxYw)Nrzsignal {0} ({1})z signal {0}z exitcode {0})formatSIGMAPKeyError)statuss r human_statusr/gse !q 0%,,fWffWoF F   (( 0&&w/ / 0s7AAc$|t|SNr)sloads r pickle_loadsr4ps  r&cp tj||y#ttttf$rYywxYwr1)r OSErrorAttributeError ValueError RuntimeError)signumhandlers rmaybe_setsignalr<us0  fg& ^Z >   s 55ctdrtjtt |t j dtd<tjd|z y)NrT) r$os_exit EX_SOFTWAREr<r SIG_DFLsysexit)r:frames r_shutdown_cleanuprF|sC1 FFNN+!HHsV|_r&c$tt|dSr1)r r )sigs rr:r:s 63 %%r&cH|tvxs|duxr|tjk7Sr1)TERMSIGS_FORCEr SIG_IGN)rHcurrents r_should_override_term_signalrMs* ~ <   :FNN!:r&c|rtntD]<}t|}|st|t j |s1t ||>tD]*}t|}|st |tj,yr1) TERMSIGS_FULLTERMSIGS_DEFAULTr:rMr getsignalr<TERMSIGS_IGNORErK)r;fullrHnums r reset_signalsrUsl $}*:.Sk +C1A1A#1FGW- . 1Sk  C 01r&ceZdZeZdZddZy) restart_statec@||c|_|_d\|_|_y)N)rN)maxRmaxTRT)selfrYrZs r__init__zrestart_state.__init__s#T 49 r&Nc| tn|}|j}|jr,||jz |jk\r|dc|_|_nY|jrM|j|jk\r4|jr(d|_|j |d|jd|j||_|xjdz c_y)Nrz in r2r)rr[r\rZrYr)r]nowr[s rstepzrestart_state.steps [ikc FF 66cDFFldii/ !NDFDF YY466TYY. vv..a/KLL 66>DF ! r&r1)__name__ __module__ __qualname__rr^rar%r&rrWrWs-!r&rW)+__doc__r?r rCpickle exceptionsrtimerr3 pickle_loadloadsr4iordictdirr, _alias_sigr r7r TERM_SIGNAL TERM_SIGNAMEenvirongetrsetrRrJrArPrOr$r'r)r/r<rFr:rMrUrWr%r&rrts. +kk ||  %([ ( J .8wvz*+ #NNI \ /  & K"/9+CE -)35                  ,g " #)%  &,% 1C    s C==DD