JiS:XaSr O7\R>RCS5(aSr O\RDS:XaSOSr Sr#Sr$Sr%\RL"5r'\RP"5r)S r*S!r+0r,\RP"5r-"S"S#\.5r/S3S$jr0S%r1S q2\\\0\ Rf\ Rh4S&jr5\Rl"\55 "S'S(\.5r7"S)S*\Rp5r9\Rt"S+5r;S-r=S.r>S/r?S0r@S1rAS2rBg!\<a S,r;Nf=f)4N)_args_from_interpreter_flags)process) sub_debugdebuginfo sub_warning get_logger log_to_stderr get_temp_dirregister_after_fork is_exitingFinalizeForkAwareThreadLockForkAwareLocalclose_all_fds_exceptSUBDEBUG SUBWARNING multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFcZ[(a [R"[U/UQ7SS06 ggN stacklevel)_loggerlogrmsgargss Lib\multiprocessing\util.pyrr-s$w Hc7D7Q7cZ[(a [R"[U/UQ7SS06 ggr)rr DEBUGr!s r$rr1s$w E344!4r%cZ[(a [R"[U/UQ7SS06 ggr)rr INFOr!s r$rr5s$w D#333r%cZ[(a [R"[U/UQ7SS06 ggr)rr WARNINGr!s r$_warnr,9s$w GS646A6r%cZ[(a [R"[U/UQ7SS06 ggr)rr rr!s r$r r =s$w J9d9q9r%cSSKnUR [(dUR[5qS[l[ [S5(a5[R"[5 [R"[5 OL[RR[S045 [RR[S045 SSS5 [$!,(df  [$=f)z( Returns logger used by multiprocessing rN unregister)logging_lockr getLogger LOGGER_NAME propagatehasattratexitr/_exit_functionregister _exithandlersremoveappend)r1s r$r r As  w'' 4G !G v|,,!!.1/$$++^R,DE$$++^R,DE  N  Ns CC!! C4cSSKn[5nUR[5nUR 5nUR U5 UR U5 U(aURU5 Sq[$)z: Turn on logging and add a handler which prints to stderr rNT) r1r FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrr)levelr1logger formatterhandlers r$r r Xsb  \F!!"89I##%G # g N Nr%c([RS;$)N)linuxandroid)sysplatformr0r%r$#_platform_supports_abstract_socketsrNms <</ //r%cU(dg[U[5(aUSS:H$[U[5(aUSS:H$[SU<S35e)NFrzaddress type of z unrecognized) isinstancebytesstr TypeError)addresss r$is_abstract_socket_namespacerVqsT '5!!qzQ GS ! !qzT!! &wk? @@r%rJl)openbsdfreebsdhnt\cdU"U5 [R"5nUbSURS'gg)Ntempdir)rcurrent_process_config)rmtreer^r_s r$_remove_temp_dirrbs4 7O--/O"-1 *#r%c@[RS:XagUR5n[U5S-S-nU[:aU$/SQnUR U5n[SU5 [U5S-S-[:deU$![ a [SX5 Us$f=f)zGet a temporary directory where socket files will be created. To prevent additional imports, pass a pre-imported 'tempfile' module. r[N)z/tmpz/var/tmpz/usr/tmpzProcess-wide temporary directory %s will not be usable for creating socket files and no usable system-wide temporary directory was found in %sz-Ignoring user-defined temporary directory: %s)osname gettempdirlen _SUN_PATH_MAX_get_default_tempdirFileNotFoundErrorr,)tempfile base_tempdir sun_path_lendirlistbase_system_tempdirs r$_get_base_temp_dirrqs  ww$&&(L|$r)B.Lm#/G &;;GD 9<H " #b (2 - == =   *+7 B sBBBcB[R"5RRS5nUcmSSKnSSKn[ U5nURSUS9n[SU5 [S[URU4SS9 U[R"5RS'U$)Nr^rzpymp-)prefixdirzcreated temp directory %si)r# exitpriority) rr_r`getshutilrlrqmkdtemprrrbra)r^rwrlrms r$r r s%%'//33I>G)(3 ""'|"D ('2 'v}}g.F" $7>!)))4 Nr%c[[R55nUR5 UHuupp4U"U5 M g![an[ SU5 SnAM2SnAff=f)Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr)r|indexidentfuncobjes r$_run_after_forkersrs] $**, -E JJL%*!t 8 I&+ 8 3Q 7 7 8sA A' A""A'cHU[[[5[U5U4'gN)r{next_afterfork_counterid)rrs r$r r sEH012c7DABr%cZ\rSrSrSrS SjrS\\\R4Sjr Sr Sr Sr S rg) rz9 Class which supports object finalization using weakrefs NcUb9[U[5(d$[SRU[ U555eUb[ R "X5UlOUc [S5eX l X0l U=(d 0Ul U[[54Ul[R "5UlU[$UR'g)Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)rQintrTformattypeweakrefref_weakref ValueError _callback_args_kwargsr_finalizer_counter_keyregetpid_pid_finalizer_registry)selfrcallbackr#kwargsrus r$__init__Finalize.__init__s  $jc.J.JELL $|"467 7 ?#KK2DM  !JK K! | !4(:#;< IIK )-DII&r%ctX R URU"5:wa U"S5 SnOOU"SURURUR5 UR"UR0URD6nS=Ul=Ul=Ul=UlUlU$![ a U"S5 gf=f)zA Run the callback unless it has already been called or cancelled z+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %szfinalizer no longer registered)rrrrrrKeyError)rwrrrrress r$__call__Finalize.__call__s #II.yyFH$GHK..$**dllDnndjjADLLA7; ) rAttributeErrorrT __class__rgetattrrrrSrr)rrxs r$__repr__Finalize.__repr__>s --/C ;&)@)@@ @ '' DNNC E :: S_, ,A << s4<<00 0A 99Q< # "S1%66 6A3w * C sC66D  D )rrrrrr)r0NN)r __module__ __qualname____firstlineno____doc__rrrrerrrrr__static_attributes__r0r%r$rrs3.&&9$RYY 0 <0 r%rc^[cgTcSnOU4Sjn[[5Vs/sHo!"U5(dMUPM nnURSS9 UH1n[RU5nUcM[ SU5 U"5 M3 Tc[R5 ggs snf![ a SSKnUR5 Mtf=f)z Run all finalizers whose exit priority is not None and at least minpriority Finalizers with highest priority are called first; finalizers with the same priority will be called in reverse order of creation. NcUSSL$Nrr0)ps r$!_run_finalizers..as qt4'r%c0>USSL=(a UST:$rr0)r minprioritys r$rrcsqt4'?AaDK,??r%T)reversez calling %sr) rrzr}rvrr~ traceback print_excclear)rfkeykeys finalizerrs` r$_run_finalizersrSs"  ' ? 34 ?4C#C4D ?IIdI'++C0  lI . & !!# @ & ##% &sB#B#?B((C  C c,[=(d [SL$)z. Returns true if the process is shutting down N)_exitingr0r%r$rrs  'x4''r%c|[(dSqU"S5 U"S5 U"S5 U"5bU"5HCnUR(dMU"SUR5 URR 5 ME U"5H&nU"SUR5 UR 5 M( U"S5 U"5 gg)NTzprocess shutting downz2running all "atexit" finalizers with priority >= 0rz!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)rdaemonrf_popen terminatejoin)rrractive_childrenr_rs r$r8r8s 8 $% BC   (%&888.ss||/A/A/Cr%)r rs r$rForkAwareLocal.__init__s D"CDr%c[U5S4$)Nr0)rrs r$ __reduce__ForkAwareLocal.__reduce__sDz2~r%r0N)rrrrrrrr0r%r$rrs Er%r SC_OPEN_MAXc[U5S[/-nUR5 US[:XdS5e[[ U5S- 5H$n[ R "XS-XS-5 M& g)Nz fd too larger)rzMAXFDr}rangerhre closerange)fdsis r$rrse s)r5k !CHHJ r7e +^+  3s8a<  cfQhaC)!r%c[Rcg[RR5 [ R "[ R[ R5n[ USSS9[lg![[4a N\f=f! [ R"U5 e=f![[4a gf=f)Nzutf-8F)encodingclosefd) rLstdincloseOSErrorrreopendevnullO_RDONLY)fds r$ _close_stdinrs yy   WWRZZ - R'5ACI Z      HHRL  Z    s4A<3B.'B<BBB++B..CCc[RR5 [R R5 g![[4a N2f=f![[4a gf=fr)rLstdoutflushrrstderrr0r%r$_flush_std_streamsrs]     J '    J '   s"AAAAA)(A)cSSKnSSKn[[[ [ U555n[ R"5upVURX/SUSSSSSSSSXVSSSSSSSSUR5[ R"U5 [ R"U5 $![ R"U5 [ R"U5 f=f)NrTrF) _posixsubprocess subprocesstuplesortedmaprrepipe fork_exec _USE_VFORKr)pathr#passfdsr r  errpipe_read errpipe_writes r$spawnv_passfdsrsF3sG,-.G"$'')L )) &$t BBL 5"dD$D  ! ! #    s /B.C cBUHn[R"U5 M g)z/Close each file descriptor given as an argumentN)rer)rrs r$ close_fdsrs  r%cSSKJn [R"5 SSKJn UR R5 SSKJn URR5 [5 UR5 UR5 g)zGCleanup multiprocessing resources when multiprocessing tests completed.r)support) forkserver)resource_trackerN) testrr_cleanuprr _forkserver_stopr_resource_trackerr gc_collect reap_children)rrrs r$_cleanup_testsr#sc +  "1&&,,.  r%r)Cre itertoolsrLrr7rr rr__all__NOTSETrr'r)rr+r4r?rrDrrrr,r r r rNrVabstract_sockets_supportedrMri startswithrfrbrqr WeakValueDictionaryr{countrrr rrobjectrrrrrr_r8r9rlocalrsysconfrr~rrrrrr#r0r%r$r/s   3        F 8547:.*0AAB<<7M\\344MGGtODM26p &113__&8I__&SvSl&$X( E?#*#:#:#*#:#:(T *&*"Y__ JJ} %E* .    Q EsE::FF