U bhs@srddlZddlZddlZddlZz ddlZWnek rHddlZYnXzddlmZWnek rvddZYnXddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZddlmZdd d d d d ddddddddgZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$da%da&d dZ'd!d Z(d"d Z)d#d Z*d$d%Z+d&d'Z,d(d Z-d0d)d Z.d*d+Z/d,d-Z0d.d/Z1dS)1N)_args_from_interpreter_flagsc Cstddddddddd d d }g}|D].\}}ttj|}|d kr&|d ||q&tjD]}|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_randomizationZ py3k_warningr-z-W)itemsgetattrsysflagsappend warnoptions) flag_opt_mapargsflagoptr r!1/tmp/pip-unpacked-wheel-5abm461f/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)sFcOstrtjt|f||dSN)_loggerlogr7msgrkwargsr!r!r"r2`scOstrtjt|f||dSrA)rBrCDEBUGrDr!r!r"r escOstrtjt|f||dSrA)rBrCINFOrDr!r!r"r3jscOstrtjt|f||dSrA)rBrCr8rDr!r!r"r4oscOstrtjt|f||dSrA)rBrCWARNINGrDr!r!r"warningssrJcOstrtjt|f||dSrA)rBrCERRORrDr!r!r"errorwsrLcCsddl}z|j|j}}Wn"tk r<|j|j}}YnX|ztts|tadt_ | t d| t dt tdrttttn$tjtdiftjtdifW5|XtS)z0 Returns logger used by multiprocessing rNr7r8 unregisterr!)loggingZ _prepareForkZ _afterForkAttributeError _acquireLock _releaseLockrB getLogger LOGGER_NAME propagate addLevelNamer7r8hasattratexitrMr%registerZ _exithandlersremover)rNacquirereleaser!r!r"r5|s&      cCsJddl}t}|t}|}|||||rB||dat S)zB Turn on logging and add a handler which prints to stderr rNT) rNr5 FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrrB)levelrNlogger formatterhandlerr!r!r"r6s    cCstjdstzxdtjkrZt}|d|d}| d}| t ||dWSt }t jd}| t t ||jWSWntk rtYnXdS)zE Return the current value of the parent process death signal linuxcffiint prctl (int __option, ...);zint *Nr libc.so.6)rplatform startswithOSErrormodulesrhFFIcdefnewdlopenprctlPR_GET_PDEATHSIGctypesc_intcdll LoadLibrarybyrefvalue Exception)ffiargCsiglibcr!r!r" get_pdeathsigs          rc Cstjdstdz^dtjkrRt}|d|d}| t | d|nt j d}| t t |Wn,tk r}ztd|W5d}~XYnXdS) 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. rgz$pdeathsig is only supported on linuxrhriNintrjz(An error occured while setting pdeathsig)rrkrlrmrnrhrorprrrsPR_SET_PDEATHSIGcastrurwrxrvr{)rr|r~rer!r!r" set_pdeathsigs     rcstfdd}|S)z& Automatic retry after EINTR. c sFz ||WStk r>}zt|tjkr.W5d}~XYqXqdSrA)rmr1errnoZEINTR)rrFexcfuncr!r"wrappeds  z_eintr_retry..wrapped) functoolswraps)rrr!rr" _eintr_retrysr)N)2rrrrWrh ImportErrorru subprocessrZmultiprocessing.utilr#r$r%r&r'r(r)r*r+r,r-r.r/compatr1__all__rtrNOTSETr7rGrHr8rIrKrSr]rBrbr2r r3r4rJrLr5r6rrrr!r!r!r" sh <  "