⾙h,dZddlZddlZddlZddlZddlmZddlmZejZ ejZ ddl mZedeeDZdD]Z eeeee<ej*d cZZej0j3d Zer eeeecZZerd hneZerd hneZd Zd d edhZd d ddddddeddddddhZ dgZ!dZ"e fdZ dZ#dZ$dZ%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 K/var/www/Befach/backend/env/lib/python3.12/site-packages/billiard/common.py rs, !ALL4GWVQs00)SIGHUPSIGABRTSIGTERM REMAP_SIGTERMSIGQUITFrSIGUSR1SIGTRAPrSIGEMTSIGSYSSIGPIPESIGALRMSIGXCPUSIGXFSZ SIGVTALRMSIGPROFSIGUSR2Fc|xsddkr dj| t| Sdj|S#t$rdj| cYSwxYw)Nrzsignal {0} ({1})z signal {0}z exitcode {0})formatSIGMAPKeyError)statuss r human_statusr'Mse !q 0%,,fWffWoF F   (( 0&&w/ / 0s7AAc$|t|SNr)sloads r pickle_loadsr,Vs  cp tj||y#ttttf$rYywxYwr))r OSErrorAttributeError ValueError RuntimeError)signumhandlers rmaybe_setsignalr5[s0  fg& ^Z >   s 55ctdrtjtt |t j dtd<tjd|z y)NrT) _should_have_exitedos_exit EX_SOFTWAREr5r SIG_DFLsysexit)r3frames r_shutdown_cleanupr@bsC1 FFNN+!HHsV|_r-c$tt|dSr))r r )sigs rr3r3ms 63 %%r-cH|tvxs|duxr|tjk7Sr))TERMSIGS_FORCEr SIG_IGN)rBcurrents r_should_override_term_signalrGqs* ~ <   :FNN!:r-c|rtntD]<}t|}|st|t j |s1t ||>tD]*}t|}|st |tj,yr)) TERMSIGS_FULLTERMSIGS_DEFAULTr3rGr getsignalr5TERMSIGS_IGNORErE)r4fullrBnums r reset_signalsrOxse $}*::Sk +C1A1A#1FGW- ; Sk  C 0r-ceZdZeZdZddZy) restart_statec@||c|_|_d\|_|_y)N)rN)maxRmaxTRT)selfrSrTs 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 r*r)rrUrVrTrSr)rWnowrUs rstepzrestart_state.steps [ikc FF 66cDFFldii/ !NDFDF YY466TYY. vv..a/KLL 66>DF ! r-r))__name__ __module__ __qualname__rrXr[r-rrQrQs-!r-rQ))__doc__r9r r=pickle exceptionsrtimerr+ pickle_loadloadsr,iordictdirr$ _alias_sigr r0r TERM_SIGNAL TERM_SIGNAMEenvirongetrsetrLrDr;rJrIr8r'r5r@r3rGrOrQr_r-rrosu. +kk ||  %([ (J .8wvz*+(#NNI \ /  & K"/9+CE -)35                  ,g)%  &,% 1O    s C77C?>C?