a Šxd…ã@sbddlmZddlZddlZddlZddlZz ddlZWneyRddlZYn0zddl m Z Wney~dd„Z Yn0ddl m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZgd ¢Zd ZdZdZd Zd Z d Z!dZ"dZ#dZ$dZ%dZ&da'da(dd„Z)dd„Z*dd„Z+dd„Z,dd„Z-dd„Z.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 ||¡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"úE/var/www/html/Ranjet/env/lib/python3.9/site-packages/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)sFcOs"trtjt|g|¢Ri|¤ŽdS©N)Ú_loggerÚlogr8©ÚmsgrÚkwargsr"r"r#r3asr3cOs"trtjt|g|¢Ri|¤ŽdSrB)rCrDÚDEBUGrEr"r"r#rfsrcOs"trtjt|g|¢Ri|¤ŽdSrB)rCrDÚINFOrEr"r"r#r4ksr4cOs"trtjt|g|¢Ri|¤ŽdSrB)rCrDr9rEr"r"r#r5psr5cOs"trtjt|g|¢Ri|¤ŽdSrB)rCrDÚWARNINGrEr"r"r#ÚwarningtsrKcOs"trtjt|g|¢Ri|¤ŽdSrB)rCrDÚERRORrEr"r"r#ÚerrorxsrMcCsœddl}| ¡z|ts‚| t¡adt_| td¡| td¡t t dƒr^t   t ¡t   t ¡n$t j t dif¡t j t dif¡W| ¡n | ¡0tS)z0 Returns logger used by multiprocessing rNr8r9Ú unregisterr")ÚloggingÚ _acquireLockrCÚ getLoggerÚ LOGGER_NAMEÚ propagateÚ addLevelNamer8r9ÚhasattrÚatexitrNr&ÚregisterZ _exithandlersÚremoverÚ _releaseLock)rOr"r"r#r6}s      r6cCsJddl}tƒ}| t¡}| ¡}| |¡| |¡|rB| |¡dat S)zB Turn on logging and add a handler which prints to stderr rNT) rOr6Ú FormatterÚDEFAULT_LOGGING_FORMATÚ StreamHandlerÚ setFormatterÚ addHandlerÚsetLevelÚ_log_to_stderrrC)ÚlevelrOÚloggerÚ formatterÚhandlerr"r"r#r7šs    r7cCs¨tj d¡stƒ‚zxdtjvrZt ¡}| d¡| d¡}|  d¡}|  t |¡|dWSt   ¡}t j d¡}|  t t  |¡¡|jWSWnty¢tƒ‚Yn0dS)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ÚmodulesrfÚ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           rcCsˆtj d¡stƒ‚zXdtjvrPt ¡}| d¡| d¡}|  t |  d|¡¡nt j  d¡}|  t |¡Wnty‚tƒ‚Yn0dS)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. rerfrgNÚintrh)rrirjrkrlrfrmrnrprqÚPR_SET_PDEATHSIGÚcastrsrurvry)r}rzr|r~r"r"r#Ú set_pdeathsigÅs      rƒcst ˆ¡‡fdd„ƒ}|S)z& Automatic retry after EINTR. c sLzˆ|i|¤ŽWStyD}zt|ƒtjkr0‚WYd}~qd}~00qdSrB)rkr2ÚerrnoZEINTR)rrGÚexc©Úfuncr"r#Úwrappedás z_eintr_retry..wrapped)Ú functoolsÚwraps)r‡rˆr"r†r#Ú _eintr_retryÜsr‹)N)4Ú __future__rrr„r‰rVrfÚ ImportErrorrsÚ subprocessrZmultiprocessing.utilr$r%r&r'r(r)r*r+r,r-r.r/r0Úcompatr2Ú__all__rrrÚNOTSETr8rHrIr9rJrLrRr[rCr`r3rr4r5rKrMr6r7rrƒr‹r"r"r"r#Ú sN    <