U d@s~ddlmZddlZddlZddlZddlZz ddlZWnek rTddlZYnXzddl m Z Wnek rddZ YnXddl m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZd d d d d dddddddddgZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&da'd a(d!d Z)d"d Z*d#d Z+d$d Z,d%d&Z-d'd(Z.d)d Z/d1d*dZ0d+d,Z1d-d.Z2d/d0Z3dS)2)absolute_importN)_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-lulkwrw3/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)sFcOstrtjt|f||dSN)_loggerlogr8msgrkwargsr"r"r#r3ascOstrtjt|f||dSrB)rCrDDEBUGrEr"r"r#rfscOstrtjt|f||dSrB)rCrDINFOrEr"r"r#r4kscOstrtjt|f||dSrB)rCrDr9rEr"r"r#r5pscOstrtjt|f||dSrB)rCrDWARNINGrEr"r"r#warningtsrKcOstrtjt|f||dSrB)rCrDERRORrEr"r"r#errorxsrMcCsddl}|ztts|tadt_|td|t dt t dr^t t t t n$t jt dift jt difW5|XtS)z0 Returns logger used by multiprocessing rNr8r9 unregisterr")logging _acquireLock _releaseLockrC getLogger LOGGER_NAME propagate addLevelNamer8r9hasattratexitrNr&registerZ _exithandlersremover)rOr"r"r#r6}s       cCsJddl}t}|t}|}|||||rB||dat S)zB Turn on logging and add a handler which prints to stderr rNT) rOr6 FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrrC)levelrOlogger formatterhandlerr"r"r#r7s    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 startswithOSErrormodulesrfFFIcdefnewdlopenprctlPR_GET_PDEATHSIGctypesc_intcdll LoadLibrarybyrefvalue Exception)ffiargCsiglibcr"r"r# get_pdeathsigs          rcCstjdstzXdtjkrPt}|d|d}| t | d|nt j d}| t |Wntk rtYnXdS)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. rerfrgNintrh)rrirjrkrlrfrmrnrprqPR_SET_PDEATHSIGcastrsrurvry)r}rzr|r~r"r"r# set_pdeathsigs     rcstfdd}|S)z& Automatic retry after EINTR. c sFz ||WStk r>}zt|tjkr.W5d}~XYqXqdSrB)rkr2errnoZEINTR)rrGexcfuncr"r#wrappeds  z_eintr_retry..wrapped) functoolswraps)rrr"rr# _eintr_retrysr)N)4 __future__rrrrrWrf ImportErrorrs subprocessrZmultiprocessing.utilr$r%r&r'r(r)r*r+r,r-r.r/r0compatr2__all__rrrNOTSETr8rHrIr9rJrLrSr[rCr`r3rr4r5rKrMr6r7rrrr"r"r"r# sj  <