tzh
2024-08-22 c7d0944258c7d0943aa7b2211498fd612971ce27
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
]\¬Qc@sÃddlZddlZddlZddlZddlmZddlmZmZdddddd    d
d d d ddddgZ    dZ
dZ dZ dZ dZdZdZdaead„Zd„Zd„Zd„Zd„Zdd„Zd„ZejƒZejƒZd „Z d!„Z!iZ"ejƒZ#d e$fd"„ƒYZ%dd#„Z&d$„Z'ea(eee&eed%„Z)ej*e)ƒde$fd&„ƒYZ+dej,fd'„ƒYZ-dS((iÿÿÿÿN(t_args_from_interpreter_flags(tcurrent_processtactive_childrent    sub_debugtdebugtinfot sub_warningt
get_loggert log_to_stderrt get_temp_dirtregister_after_forkt
is_exitingtFinalizetForkAwareThreadLocktForkAwareLocaltSUBDEBUGt
SUBWARNINGiii
iitmultiprocessings+[%(levelname)s/%(processName)s] %(message)scGs trtjt||ŒndS(N(t_loggertlogR(tmsgtargs((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRCscGs trtjt||ŒndS(N(RRtDEBUG(RR((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRGscGs trtjt||ŒndS(N(RRtINFO(RR((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRKscGs trtjt||ŒndS(N(RRR(RR((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyROscCs×ddl}ddl}|jƒz£tsÄ|jtƒadt_|jtdƒ|jt    dƒt
|dƒr|j t ƒ|j t ƒqÄ|jjt difƒ|jjt difƒnWd|jƒXtS(    s0
    Returns logger used by multiprocessing
    iÿÿÿÿNiRRt
unregister(((tloggingtatexitt _acquireLockRt    getLoggert LOGGER_NAMEt    propagatet addLevelNameRRthasattrRt_exit_functiontregistert _exithandlerstremovetappendt _releaseLock(RR((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRSs
       cCsjddl}tƒ}|jtƒ}|jƒ}|j|ƒ|j|ƒ|r`|j|ƒnta    t
S(sB
    Turn on logging and add a handler which prints to stderr
    iÿÿÿÿN( RRt    FormattertDEFAULT_LOGGING_FORMATt StreamHandlert setFormattert
addHandlertsetLeveltTruet_log_to_stderrR(tlevelRtloggert    formatterthandler((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRps        cCstƒjdkrwddl}ddl}|jddƒ}td|ƒtd|jd|gddƒ|tƒ_ntƒjS(Niÿÿÿÿtprefixspymp-screated temp directory %sRt exitpriorityiœÿÿÿ(    Rt_tempdirtNonetshutilttempfiletmkdtempRR trmtree(R7R8ttempdir((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyR    †s cCsqttjƒƒ}|jƒxN|D]F\\}}}}y||ƒWq#tk
rh}td|ƒq#Xq#WdS(Ns after forker raised exception %s(tlistt_afterfork_registrytitemstsortt    ExceptionR(R>tindextidenttfunctobjte((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt_run_after_forkers—s
cCs#|ttjƒt|ƒ|f<dS(N(R=t_afterfork_countertnexttid(RDRC((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyR
 scBsGeZdZdddd„Zdd„Zd„Zd„Zd„ZRS(sA
    Class which supports object finalization using weakrefs
    cCs¡|dks$t|ƒtks$t‚|dk    rHtj||ƒ|_n|dk    sZt‚||_||_|pui|_    |t
j ƒf|_ |t |j <dS(N(R6ttypetinttAssertionErrortweakreftreft_weakreft    _callbackt_argst_kwargst_finalizer_counterRHt_keyt_finalizer_registry(tselfRDtcallbackRtkwargsR4((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt__init__¯s$         cCsyt|j=Wntk
r+tdƒn^Xtd|j|j|jƒ|j|j|jŽ}d|_|_|_|_|_|SdS(sQ
        Run the callback unless it has already been called or cancelled
        sfinalizer no longer registereds/finalizer calling %s with args %s and kwargs %sN(    RURTtKeyErrorRRPRQRRR6RO(RVtwrtres((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt__call__¾s %cCsKyt|j=Wntk
r!n&Xd|_|_|_|_|_dS(s3
        Cancel finalization of the object
        N(RURTRZR6RORPRQRR(RV((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pytcancelÎs
 cCs |jtkS(sS
        Return whether this finalizer is still waiting to invoke callback
        (RTRU(RV((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt still_activeÚscCsÛy|jƒ}Wnttfk
r/d}nX|dkr@dSdt|jd|jƒ}|jr|dt|jƒ7}n|jr¢|dt|jƒ7}n|j    ddk    rÓ|dt|j    dƒ7}n|dS(    Ns<Finalize object, dead>s<Finalize object, callback=%st__name__s, args=s    , kwargs=is, exitprority=t>(
ROtAttributeErrort    TypeErrorR6tgetattrRPRQtstrRRRT(RVRDtx((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt__repr__às
         (N(    R`t
__module__t__doc__R6RYR]R^R_Rg(((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyR «s          csètdkrdSˆdkr(d„}n‡fd†}gtjƒD]}||ƒrD|^qD}|jdtƒxV|D]N\}}td|ƒy |ƒWqytk
rÆddl}|jƒqyXqyWˆdkrätj    ƒndS(sà
    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.
    NcSs|dddk    S(Ni(R6(tp((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt<lambda>scs&|dddk    o%|ddˆkS(Ni(R6(Rj(t minpriority(s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRkstreverses
calling %siÿÿÿÿ(
RUR6R>R?R-RR@t    tracebackt    print_exctclear(RltfRfR>tkeyt    finalizerRn((Rls\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt_run_finalizersôs    +     cCstptdkS(s6
    Returns true if the process is shutting down
    N(t_exitingR6(((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyR scCs°|dƒ|dƒ|dƒ|ƒdk    r›x:|ƒD]/}|jr7|d|jƒ|jjƒq7q7Wx.|ƒD] }|d|jƒ|jƒqtWn|dƒ|ƒdS(Nsprocess shutting downs2running all "atexit" finalizers with priority >= 0is!calling terminate() for daemon %sscalling join() for process %ss)running the remaining "atexit" finalizers(R6t    _daemonictnamet_popent    terminatetjoin(RRRtRRRj((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyR! s    
 
 
     
cBseZd„Zd„ZRS(cCs|jƒt|tjƒdS(N(t_resetR
R (RV((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRYKs
cCs1tjƒ|_|jj|_|jj|_dS(N(t    threadingtLockt_locktacquiretrelease(RV((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyR{Os(R`RhRYR{(((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyR Js    cBseZd„Zd„ZRS(cCst|d„ƒdS(NcSs |jjƒS(N(t__dict__Rp(RD((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRkVs(R
(RV((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRYUscCst|ƒdfS(N((RJ(RV((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt
__reduce__Ws(R`RhRYR‚(((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyRTs    (.t    itertoolsRMRR|t
subprocessRtmultiprocessing.processRRt__all__tNOTSETRRRRRR(R6RtFalseR.RRRRRRR    tWeakValueDictionaryR=tcountRGRFR
RURStobjectR RtR RuR!R"R tlocalR(((s\/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/util.pyt<module>#sR                                                  I $         "