o Df@sVddlZddlZddlZddlZzddlZWn ey#ddlZYnwzddlmZWn ey9ddZYnwddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZddlmZgdZd ZdZdZd Zd Zd Zd Z dZ!dZ"dZ#dZ$da%da&ddZ'ddZ(ddZ)ddZ*ddZ+ddZ,dd Z-d)d!d"Z.d#d$Z/d%d&Z0d'd(Z1dS)*N)_args_from_interpreter_flagsc Cstddddddddd d d }g}|D]\}}ttj|}|d kr*|d ||qtjD] }|d|q.|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 r"F/home/ubuntu/webapp/venv/lib/python3.10/site-packages/billiard/util.pyrs(   r) _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_debugr info sub_warning get_logger log_to_stderrr,r.r-r)r+r*SUBDEBUG SUBWARNING (multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFcO&trtjt|g|Ri|dSdSN)_loggerlogr8msgrkwargsr"r"r#r3`r3cOrBrC)rDrEDEBUGrFr"r"r#r erIr cOrBrC)rDrEINFOrFr"r"r#r4jrIr4cOrBrC)rDrEr9rFr"r"r#r5orIr5cOrBrC)rDrEWARNINGrFr"r"r#warningsrIrMcOrBrC)rDrEERRORrFr"r"r#errorwrIrOcCsddl}|zMtsH|tadt_|td|tdt t dr/t t t t n t jt dift jt difW|tSW|tSW|tS|w)z0 Returns logger used by multiprocessing rNr8r9 unregisterr")logging _acquireLockrD getLogger LOGGER_NAME propagate addLevelNamer8r9hasattratexitrPr&register _exithandlersremover _releaseLock)rQr"r"r#r6|s,       r6cCsJddl}t}|t}|}|||||r!||dat S)zB Turn on logging and add a handler which prints to stderr rNT) rQr6 FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrrD)levelrQlogger formatterhandlerr"r"r#r7s    r7cCstjds tz:dtjvr-t}|d|d}| d}| t ||dWSt }t jd}| t t ||jWStyMtw)zE Return the current value of the parent process death signal linuxcffiint prctl (int __option, ...);zint *Nr libc.so.6)rplatform startswithOSErrormodulesriFFIcdefnewdlopenprctlPR_GET_PDEATHSIGctypesc_intcdll LoadLibrarybyrefvalue Exception)ffiargCsiglibcr"r"r# get_pdeathsigs"         rc Cstjds tdz2dtjvr+t}|d|d}| t | d|WdSt j d}| t t |WdStyM}ztd|d}~ww) 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. rhz$pdeathsig is only supported on linuxrirjNintrkz(An error occured while setting pdeathsig)rrlrmrnrorirprqrsrtPR_SET_PDEATHSIGcastrvrxryrwr|)rr}rrer"r"r# set_pdeathsigs      rcstfdd}|S)z& Automatic retry after EINTR. c sJ z|i|WSty#}zt|tjkrWYd}~nd}~wwqrC)rnr2errnoEINTR)rrHexcfuncr"r#wrappeds z_eintr_retry..wrapped) functoolswraps)rrr"rr# _eintr_retrysrrC)2rrrrXri ImportErrorrv subprocessrmultiprocessing.utilr$r%r&r'r(r)r*r+r,r-r.r/r0compatr2__all__rurNOTSETr8rJrKr9rLrNrTr^rDrcr3r r4r5rMrOr6r7rrrr"r"r"r#sR      <