o svXj@sbddlmZddlZddlZddlZddlZzddlZWn ey)ddlZYnwzddl m Z Wn ey?ddZ Ynwddl m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZgd Zd ZdZdZd Zd Z d Z!dZ"dZ#dZ$dZ%dZ&da'da(ddZ)ddZ*ddZ+ddZ,ddZ-ddZ.d d!Z/d*d"d#Z0d$d%Z1d&d'Z2d(d)Z3dS)+)absolute_importN)_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#J/var/www/html/myproject/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_debugrinfo 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)_loggerlogr9msgr kwargsr#r#r$r4ar4cOrCrD)rErFDEBUGrGr#r#r$rfrJrcOrCrD)rErFINFOrGr#r#r$r5krJr5cOrCrD)rErFr:rGr#r#r$r6prJr6cOrCrD)rErFWARNINGrGr#r#r$warningtrJrNcOrCrD)rErFERRORrGr#r#r$errorxrJrPcCsddl}|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 rNr9r: unregisterr#)logging _acquireLockrE getLogger LOGGER_NAME propagate addLevelNamer9r:hasattratexitrQr'register _exithandlersremover _releaseLock)rRr#r#r$r7}s,       r7cCsJddl}t}|t}|}|||||r!||dat S)zB Turn on logging and add a handler which prints to stderr rNT) rRr7 FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrrE)levelrRlogger formatterhandlerr#r#r$r8s    r8cCstjds 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 startswithOSErrormodulesrjFFIcdefnewdlopenprctlPR_GET_PDEATHSIGctypesc_intcdll LoadLibrarybyrefvalue Exception)ffiargCsiglibcr#r#r$ get_pdeathsigs"         rcCstjds tz/dtjvr*t}|d|d}| t | d|WdSt j d}| t |WdStyBtw)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. rirjrkNintrl)rrmrnrorprjrqrrrtruPR_SET_PDEATHSIGcastrwryrzr})rr~rrr#r#r$ set_pdeathsigs      rcstfdd}|S)z& Automatic retry after EINTR. c sJ z|i|WSty#}zt|tjkrWYd}~nd}~wwqrD)ror3errnoEINTR)r rIexcfuncr#r$wrappeds z_eintr_retry..wrapped) functoolswraps)rrr#rr$ _eintr_retrysrrD)4 __future__rrrrrYrj ImportErrorrw subprocessrmultiprocessing.utilr%r&r'r(r)r*r+r,r-r.r/r0r1compatr3__all__rvrNOTSETr9rKrLr:rMrOrUr_rErdr4rr5r6rNrPr7r8rrrr#r#r#r$sT      <