آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ U ،ê,aه.م@s8ddddgZddlZddlZddlZddlZddlZddlmZzej e ،،ZWnek rldZYnXdd„Z dd„Zd d„Zd d„ZGdd„deƒZGd d„deƒZGdd„deƒZGdd„deƒZdaeƒae d،aeƒa[iZeej ،ƒD]0\Z!Z"e!dd…dkrüde!krüde!›‌ee"<qüeƒZ#dS)عBaseProcessعcurrent_processعactive_childrenعparent_processéN)عWeakSetcCstS©N)ع_current_process©r r ْ^sz'BaseProcess.__init__..)عnextع_process_counterrع _identityع_configعcopyعosعgetpidع_parent_pidعnameع_parent_namerع_closedع_targetعtupleع_argsعdictع_kwargsعtypeع__name__عjoinع_namerع _danglingعadd)rعgroupعtargetr&عargsعkwargsrعcountr r r ع__init__Ps ےzBaseProcess.__init__cCs|jrtdƒ‚dS)Nzprocess object is closed)r(ع ValueErrorrr r r ع _check_closedcszBaseProcess._check_closedcCs|jr|j|j|jژdSr)r)r+r-rr r r عrungszBaseProcess.runcCs>| ،tƒ| |،|_|jj|_|`|`|`t |،dSr)r;rrrعsentinelع _sentinelr)r+r-r r3rr r r عstartns zBaseProcess.startcCs| ،|j ،dSr)r;rع terminaterr r r r@€szBaseProcess.terminatecCs| ،|j ،dSr)r;rعkillrr r r rA‡szBaseProcess.killcCs*| ،|j |،}|dk r&t |،dSr)r;rعwaitr r)rعtimeoutعresr r r r0ژszBaseProcess.joincCsJ| ،|tkrdS|jdkr"dS|j ،}|dkr8dSt |،dSdS)NTF)r;rrrr r)rع returncoder r r عis_alive™s zBaseProcess.is_alivecCsH|jdk r>|j ،dkr tdƒ‚|j ،d|_|`t |،d|_dS)Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)rrr:عcloser>r rr(rr r r rG¬s zBaseProcess.closecCs|jSr©r1rr r r r&½szBaseProcess.namecCs ||_dSrrH)rr&r r r r&ءscCs|j dd،S)NrF)r!عgetrr r r rئszBaseProcess.daemoncCs||jd<dS)Nr©r!)rZdaemonicr r r rحscCs |jdS©NعauthkeyrJrr r r rLصszBaseProcess.authkeycCst|ƒ|jd<dSrK)عAuthenticationStringr!)rrLr r r rLظscCs"| ،|jdkr|jS|j ،Sr)r;rrrr r r عexitcodeàs zBaseProcess.exitcodecCs*| ،|tkrt ،S|jo$|jjSdSr)r;rr#r$rعpidrr r r عidentêszBaseProcess.identcCs4| ،z|jWStk r.tdƒd‚YnXdS)Nzprocess not started)r;r>عAttributeErrorr:rr r r r=÷s zBaseProcess.sentinelcCsèd}|tkrd}nL|jrd}n@|jt ،kr2d}n,|jdkrBd}n|j ،}|dk rZd}nd}t|ƒjd|j g}|jdk rژ| d|jj،| d|j،| |،|dk rتt ||،}| d |،|jrع| d ،dd |،S) NZstartedعclosedعunknownعinitialZstoppedzname=%rzpid=%sz parent=%szexitcode=%srz<%s>ْ )rr(r%r#r$rrr.r/r1عappendrOع_exitcode_to_namerIrr0)rrNZstatusعinfor r r ع__repr__s0 zBaseProcess.__repr__c Csvddlm}m}گz>z‍|jdk r,| |j،t d،atƒa | ،t}|at|j|j|ƒatjrnt ، ،z|j ،| ،W5~X| d،z| ،d}W5| ،XWnڑtk گr}zJ|jsزd}n:t|jdtƒrî|jd}nt j! "t#|jdƒd،d}W5d}~XYn2d}ddl$}t j! "d|j%،| &،YnXW5t ،| d|،| ،X|S)Né)عutilعcontextz process exiting with exitcode %dz child process calling self.run()rع zProcess %s: )'عr[r\ع threadingZ _shutdownrXZ_flush_std_streamsZ _start_methodZ_force_start_methodع itertoolsr8rعsetr Z_close_stdinrع_ParentProcessr'r%rZ_HAVE_THREAD_NATIVE_IDZmain_threadZ_set_native_idZ_finalizer_registryعclearZ_run_after_forkersZ_exit_functionr<ع SystemExitr6ع isinstanceعintعsysعstderrعwriterع tracebackr&ع print_exc)rZparent_sentinelr[r\rNZold_processعerjr r r ع _bootstrap"sR ے zBaseProcess._bootstrap)N)N)r/ع __module__ع__qualname__rr9r;r<r?r@rAr0rFrGعpropertyr&عsetterrrLrNrPrOr=rYrmr r r r rGsBے c@seZdZdd„ZdS)rMcCs,ddlm}|ƒdkrtdƒ‚tt|ƒffS)NrZ)عget_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r\rrع TypeErrorrMعbytes)rrrr r r ع __reduce__Xs ےzAuthenticationString.__reduce__N)r/rnrorur r r r rMWsrMc@s6eZdZdd„Zdd„Zedd„ƒZd dd „ZeZdS)rbcCs4d|_||_||_d|_d|_d|_||_i|_dS)Nr F)r r1ع_pidr%rr(r>r!)rr&rOr=r r r r9hsz_ParentProcess.__init__cCsddlm}||jgddچS©Nr)rB)rC©Zmultiprocessing.connectionrBr>)rrBr r r rFrsz_ParentProcess.is_alivecCs|jSr)rvrr r r rPvsz_ParentProcess.identNcCs ddlm}||jg|dچdSrwrx)rrCrBr r r r0zsz_ParentProcess.join)N) r/rnror9rFrprPr0rOr r r r rbfs rbc@seZdZdd„Zdd„ZdS)ع_MainProcesscCs8d|_d|_d|_d|_d|_tt d،ƒddœ|_dS)Nr ZMainProcessFé z/mp)rLZ semprefix) r r1r%rr(rMr#عurandomr!rr r r r9‰sےz_MainProcess.__init__cCsdSrr rr r r rG›sz_MainProcess.closeN)r/rnror9rGr r r r ry‡sryrZéZSIGع_r)$ع__all__r#rgعsignalr`r_Z_weakrefsetrعpathعabspathعgetcwdZORIGINAL_DIRعOSErrorrrrrعobjectrrtrMrbryrrr8rrar rWrع__dict__عitemsr&Zsignumr2r r r r ع s@ے !