SfDddlZddlZddlZddlZ ddlZn#e$rddlZYnwxYw ddlmZn#e$rdZYnwxYwddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZddlmZgdZdZdZdZd Zd Zd Zd Z d Z!dZ"dZ#dZ$da%da&dZ'dZ(dZ)dZ*dZ+dZ,dZ-ddZ.dZ/dZ0dZ1dS)N)_args_from_interpreter_flagsc ddddddddd d d }g}|D]@\}}ttj|}|d kr|d ||zzAtjD]}|d|z|S)zrReturn a list of command-line arguments reproducing the current settings in sys.flags and sys.warnoptions.dOBsSEvbR3) debugoptimizedont_write_bytecode no_user_siteno_siteignore_environmentverbose bytes_warninghash_randomization py3k_warningr-z-W)itemsgetattrsysflagsappend warnoptions) flag_opt_mapargsflagoptr s ?/var/www/html/env/lib/python3.11/site-packages/billiard/util.pyrrs#&"% "%   %++-- + +ID# 4((A1uu C#'M***? $ $C KKs # # # # ) _afterfork_registry_afterfork_counter_exit_function_finalizer_registry_finalizer_counterFinalizeForkAwareLocalForkAwareThreadLock get_temp_dir is_exitingregister_after_fork_run_after_forkers_run_finalizers) get_errno) sub_debugrinfo sub_warning get_logger log_to_stderrr.r0r/r+r-r,SUBDEBUG SUBWARNING (multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFcNtrtjt|g|Ri|dSdSN)_loggerlogr:msgr!kwargss r$r5r5`s<4 Hc3D333F3333344r%cNtrtjt|g|Ri|dSdSrE)rFrGDEBUGrHs r$rre<1 E300000000011r%cNtrtjt|g|Ri|dSdSrE)rFrGINFOrHs r$r6r6js<0 D#/////////00r%cNtrtjt|g|Ri|dSdSrE)rFrGr;rHs r$r7r7os<6 J5d555f5555566r%cNtrtjt|g|Ri|dSdSrE)rFrGWARNINGrHs r$warningrSss<3 GS2422262222233r%cNtrtjt|g|Ri|dSdSrE)rFrGERRORrHs r$errorrVwrMr%cddl}| ts|tadt_|td|tdttdr3tj ttj tnNtjtdiftjtdif|n#|wxYwtS)z0 Returns logger used by multiprocessing rNr:r; unregister)logging _acquireLockrF getLogger LOGGER_NAME propagate addLevelNamer:r;hasattratexitrXr(register _exithandlersremover _releaseLock)rZs r$r8r8|s NNN  F'' 44G !G   : 6 6 6  \ : : :v|,, F!.111////$++^R,DEEE$++^R,DEEE Ns C9D((D>cddl}t}|t}|}|||||r||datS)zB Turn on logging and add a handler which prints to stderr rNT) rZr8 FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrrF)levelrZlogger formatterhandlers r$r9r9s NNN \\F!!"899I##%%G ### g N Nr%chtjdst dtjvrut j}|d|d}| d}| t||dStj }tjd}| ttj||jS#t$$rtwxYw)zE Return the current value of the parent process death signal linuxcffiint prctl (int __option, ...);zint *Nr libc.so.6)rplatform startswithOSErrormodulesrtFFIcdefnewdlopenprctlPR_GET_PDEATHSIGctypesc_intcdll LoadLibrarybyrefvalue Exception)ffiargCsiglibcs r$ get_pdeathsigrs < " "7 + +ii S[ (**C HH5 6 6 6'''""C 4  A GG$c * * *q6M,..C;**;77D JJ'c):): ; ; ;9  iisBD2A%DD1c8tjdstd dtjvrnt j}|d|d}| t| d|dStj d}| ttj|dS#t $r}td|d}~wwxYw) am Set the parent process death signal of the calling process to sig (either a signal value in the range 1..maxsig, or 0 to clear). This is the signal that the calling process will get when its parent dies. This value is cleared for the child of a fork(2) and (since Linux 2.4.36 / 2.6.23) when executing a set-user-ID or set-group-ID binary. rsz$pdeathsig is only supported on linuxrtruNintrvz(An error occured while setting pdeathsig)rrwrxryrzrtr{r|r~rPR_SET_PDEATHSIGcastrrrrr)rrrres r$ set_pdeathsigrs < " "7 + +><=== I S[ (**C HH5 6 6 6 4  A GG$chhuc&:&: ; ; ; ; ;;**;77D JJ'c):): ; ; ; ; ; III@AAqHIsA:C:,A C:: DDDcFtjfd}|S)z& Automatic retry after EINTR. c |i|S#t$r(}t|tjkrYd}~nd}~wwxYw?rE)ryr4errnoEINTR)r!rJexcfuncs r$wrappedz_eintr_retry..wrappedsm  tT,V,,,   S>>U[0010000  s >9>) functoolswraps)rrs` r$ _eintr_retryrs: _T Nr%rE)2rrrrart ImportErrorr subprocessrmultiprocessing.utilr&r'r(r)r*r+r,r-r.r/r0r1r2compatr4__all__rrNOTSETr:rLrOr;rRrUr]rhrFrmr5rr6r7rSrVr8r9rrrrYr%r$rsn  KKKKMMMMM77777772            F 444 111 000 666333111 :&0III.     s ##.99