o h,@spdZddlZddlZddlZddlZddlmZddlmZej Z ej Z ddl mZeddeeDZd D]Zz eeeee<Wq7eyKYq7wejd ZZejd ZerbeeeeZZergd hneZerod hneZd Zdd edhZdd ddddddeddddddhZ dgZ!ddZ"e fddZ d d!Z#d"d#Z$d$d%Z%d&d'Z&e$dfd(d)Z'Gd*d+d+Z(dS),ze This module contains utilities added by billiard, to keep "non-core" functionality out of ``.util``.N)RestartFreqExceeded) monotonicBytesIOccs(|]}|drtt||fVqdS)SIGN) startswithgetattrsignal).0nr A/var/www/html/env/lib/python3.10/site-packages/billiard/common.py s    r)SIGHUPSIGABRTSIGTERM REMAP_SIGTERMSIGQUITFrSIGUSR1SIGTRAPrSIGEMTSIGSYSSIGPIPESIGALRMSIGXCPUSIGXFSZ SIGVTALRMSIGPROFSIGUSR2FcCsL|pddkr!z d| t| WSty d| YSwd|S)Nrzsignal {0} ({1})z signal {0}z exitcode {0})formatSIGMAPKeyError)statusr r r human_statusMs   r%cCs |t|SNr)sloadr r r pickle_loadsVs r)c Cs0z t||WdSttttfyYdSwr&)r OSErrorAttributeError ValueError RuntimeError)signumhandlerr r rmaybe_setsignal[s r0cCs:tdr ttt|tjdtd<td| dS)NrT) _should_have_exitedos_exit EX_SOFTWAREr0r SIG_DFLsysexit)r.framer r r_shutdown_cleanupbs   r:cCs tt|dSr&)r r )sigr r rr.ms r.cCs|tvp |duo |tjkSr&)TERMSIGS_FORCEr SIG_IGN)r;currentr r r_should_override_term_signalqsr?cCs^|rtntD]}t|}|rt|t|rt||qtD]}t|}|r,t|tjqdSr&) TERMSIGS_FULLTERMSIGS_DEFAULTr.r?r getsignalr0TERMSIGS_IGNOREr=)r/fullr;numr r r reset_signalsxs  rFc@s"eZdZeZddZdddZdS) restart_statecCs|||_|_d\|_|_dS)N)rN)maxRmaxTRT)selfrHrIr r r__init__szrestart_state.__init__NcCs|durtn|}|j}|jr||j|jkr|d|_|_n|jr8|j|jkr8|jr8d|_|d||jf|jdur@||_|jd7_dS)Nrz %r in %rsr)rrJrKrIrHr)rLnowrJr r rsteps zrestart_state.stepr&)__name__ __module__ __qualname__rrMrOr r r rrGsrG))__doc__r3r r7pickle exceptionsrtimerr( pickle_loadloadsr)iordictdirr" _alias_sigr r+r TERM_SIGNAL TERM_SIGNAMEenvirongetrsetrCr<r5rAr@r2r%r0r:r.r?rFrGr r r rsr