U Íø.eÈã@srddlZddlZddlZddlZz ddlZWnek rHddlZYnXzddlmZWnek rvdd„ZYnXddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZddlmZdd d d d d ddddddddgZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$da%da&d d„Z'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)1éN)Ú_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.ÚdÚOÚBÚsÚSÚEÚvÚbÚRÚ3) ÚdebugÚoptimizeÚdont_write_bytecodeÚ no_user_siteÚno_siteÚignore_environmentÚverboseÚ bytes_warningÚhash_randomizationZ py3k_warningrú-z-W)ÚitemsÚgetattrÚsysÚflagsÚappendÚ warnoptions)Ú flag_opt_mapÚargsÚflagÚoptr ©r!ú1/tmp/pip-unpacked-wheel-39f38r4u/billiard/util.pyrs&ö   r) Ú_afterfork_registryÚ_afterfork_counterÚ_exit_functionÚ_finalizer_registryÚ_finalizer_counterÚFinalizeÚForkAwareLocalÚForkAwareThreadLockÚ get_temp_dirÚ is_exitingÚregister_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|ž|ŽdS©N)Ú_loggerÚlogr7©ÚmsgrÚkwargsr!r!r"r2`scOstrtjt|f|ž|ŽdSrA)rBrCÚDEBUGrDr!r!r"r escOstrtjt|f|ž|ŽdSrA)rBrCÚINFOrDr!r!r"r3jscOstrtjt|f|ž|ŽdSrA)rBrCr8rDr!r!r"r4oscOstrtjt|f|ž|ŽdSrA)rBrCÚWARNINGrDr!r!r"ÚwarningssrJcOstrtjt|f|ž|ŽdSrA)rBrCÚERRORrDr!r!r"ÚerrorwsrLcCs”ddl}| ¡ztts‚| t¡adt_| td¡| t d¡t t dƒr^t   t ¡t  t ¡n$t j t dif¡t j t dif¡W5| ¡XtS)z0 Returns logger used by multiprocessing rNr7r8Ú unregisterr!)ÚloggingÚ _acquireLockÚ _releaseLockrBÚ getLoggerÚ LOGGER_NAMEÚ propagateÚ addLevelNamer7r8ÚhasattrÚatexitrMr%ÚregisterZ _exithandlersÚremover)rNr!r!r"r5|s       cCsJddl}tƒ}| t¡}| ¡}| |¡| |¡|rB| |¡dat S)zB Turn on logging and add a handler which prints to stderr rNT) rNr5Ú FormatterÚDEFAULT_LOGGING_FORMATÚ StreamHandlerÚ setFormatterÚ addHandlerÚsetLevelÚ_log_to_stderrrB)ÚlevelrNÚloggerÚ formatterÚhandlerr!r!r"r6™s    cCsªtj d¡stƒ‚zxdtjkrZt ¡}| d¡| d¡}|  d¡}|  t |¡|dWSt   ¡}t j d¡}|  t t  |¡¡|jWSWntk r¤tƒ‚YnXdS)zE Return the current value of the parent process death signal ÚlinuxÚcffiúint prctl (int __option, ...);zint *Nrú libc.so.6)rÚplatformÚ startswithÚOSErrorÚmodulesreÚFFIÚcdefÚnewÚdlopenÚprctlÚPR_GET_PDEATHSIGÚctypesÚc_intÚcdllÚ LoadLibraryÚbyrefÚvalueÚ Exception)ÚffiÚargÚCÚsigÚlibcr!r!r"Ú get_pdeathsig¬s          r~c Cs¤tj d¡stdƒ‚z^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. rdz$pdeathsig is only supported on linuxrerfNÚintrgz(An error occured while setting pdeathsig)rrhrirjrkrerlrmrorpÚPR_SET_PDEATHSIGÚcastrrrtrursrx)r|ryr{r}Úer!r!r"Ú set_pdeathsigÄs     rƒcst ˆ¡‡fdd„ƒ}|S)z& Automatic retry after EINTR. c sFz ˆ||ŽWStk r>}zt|ƒtjkr.‚W5d}~XYqXqdSrA)rjr1ÚerrnoZEINTR)rrFÚexc©Úfuncr!r"Úwrappedàs  z_eintr_retry..wrapped)Ú functoolsÚwraps)r‡rˆr!r†r"Ú _eintr_retryÛsr‹)N)2rr„r‰rVreÚ ImportErrorrrÚ subprocessrZmultiprocessing.utilr#r$r%r&r'r(r)r*r+r,r-r.r/Úcompatr1Ú__all__rqr€ÚNOTSETr7rGrHr8rIrKrRrZrBr_r2r r3r4rJrLr5r6r~rƒr‹r!r!r!r"Ú sh < ü