B 2*™\¯*ã@sdddgZddlZddlZddlZddlZddlZddlmZyej  e  ¡¡Z Wne k rjdZ YnXdd„Z dd„Zdd „ZGd d„deƒZGd d „d eƒZGd d„deƒZeƒae d¡aeƒa[iZxUsz'BaseProcess.__init__..)ÚnextÚ_process_counterrÚ _identityÚ_configÚcopyÚosÚgetpidÚ _parent_pidr Ú_closedÚ_targetÚtupleÚ_argsÚdictÚ_kwargsÚtypeÚ__name__ÚjoinÚ_namerÚ _danglingÚadd)rÚgroupÚtargetÚnameÚargsÚkwargsrÚcountrrrÚ__init__Hs    zBaseProcess.__init__cCs|jrtdƒ‚dS)Nzprocess object is closed)r"Ú ValueError)rrrrÚ _check_closedZszBaseProcess._check_closedcCs|jr|j|j|jŽdS)N)r#r%r')rrrrÚrun^szBaseProcess.runcCs>| ¡tƒ| |¡|_|jj|_|`|`|`t   |¡dS)N) r6r rr ÚsentinelÚ _sentinelr#r%r'r r-)rrrrÚstartes    zBaseProcess.startcCs| ¡|j ¡dS)N)r6r Ú terminate)rrrrr;wszBaseProcess.terminatecCs| ¡|j ¡dS)N)r6r Úkill)rrrrr<~szBaseProcess.killcCs*| ¡|j |¡}|dk r&t |¡dS)N)r6r Úwaitr r)rZtimeoutÚresrrrr*…s zBaseProcess.joincCsJ| ¡|tkrdS|jdkr"dS|j ¡}|dkr8dSt |¡dSdS)NTF)r6rr r r r)rÚ returncoderrrÚis_alives   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)r r r5Úcloser9r rr")rrrrrA£s   zBaseProcess.closecCs|jS)N)r+)rrrrr0´szBaseProcess.namecCs ||_dS)N)r+)rr0rrrr0¸scCs|j dd¡S)NrF)rÚget)rrrrr½szBaseProcess.daemoncCs||jd<dS)Nr)r)rZdaemonicrrrrÄscCs |jdS)NÚauthkey)r)rrrrrCÌszBaseProcess.authkeycCst|ƒ|jd<dS)NrC)ÚAuthenticationStringr)rrCrrrrCÐscCs"| ¡|jdkr|jS|j ¡S)N)r6r r )rrrrÚexitcode×s zBaseProcess.exitcodecCs*| ¡|tkrt ¡S|jo$|jjSdS)N)r6rrr r Úpid)rrrrÚidentászBaseProcess.identcCs2| ¡y|jStk r,tdƒd‚YnXdS)Nzprocess not started)r6r9ÚAttributeErrorr5)rrrrr8îs zBaseProcess.sentinelcCs¤|tkrd}nJ|jrd}n>|jt ¡kr.d}n*|jdkr>d}n|j ¡dk rT|j}nd}t|ƒt kr‚|dkrrd}ndt   ||¡}dt|ƒj |j ||jrœd pžd fS) NZstartedÚclosedÚunknownÚinitialrZstoppedz stopped[%s]z<%s(%s, %s%s)>z daemonÚ)rr"r!rr r r rEr(ÚintÚ_exitcode_to_namerBr)r+r)rÚstatusrrrÚ__repr__ús"  zBaseProcess.__repr__c CsRddlm}m}zy||jdk r,| |j¡t d¡atƒa |  ¡t }|a z|j   ¡| ¡Wd~X| d¡z| ¡d}Wd| ¡XWn˜tk rø}zJ|js®d}n:t|jdtƒrÊ|jd}ntj t|jdƒd¡d}Wdd}~XYn2d}ddl}tj d|j¡| ¡YnXWdt ¡| d|¡| ¡X|S)Né)ÚutilÚcontextz child process calling self.run()rÚ z Process %s: z process exiting with exitcode %d) rLrRrSZ _start_methodZ_force_start_methodÚ itertoolsr3rÚsetr Z _close_stdinrZ_finalizer_registryÚclearZ_run_after_forkersÚinfor7Z_exit_functionÚ SystemExitr1Ú isinstancerMÚsysÚstderrÚwriterÚ tracebackr0Ú print_excÚ threadingZ _shutdownZ_flush_std_streams)rrRrSZ old_processrEÚer^rrrÚ _bootstrapsD        zBaseProcess._bootstrap)N)r)Ú __module__Ú __qualname__rr4r6r7r:r;r<r*r@rAÚpropertyr0ÚsetterrrCrErGrFr8rPrbrrrrr?s.       c@seZdZdd„ZdS)rDcCs,ddlm}|ƒdkrtdƒ‚tt|ƒffS)NrQ)Úget_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rSrgÚ TypeErrorrDÚbytes)rrgrrrÚ __reduce__Fs   zAuthenticationString.__reduce__N)r)rcrdrjrrrrrDEsrDc@seZdZdd„Zdd„ZdS)Ú _MainProcesscCs8d|_d|_d|_d|_d|_tt d¡ƒddœ|_dS)NrZ MainProcessFé z/mp)rCZ semprefix) rr+r!r r"rDrÚurandomr)rrrrr4Us z_MainProcess.__init__cCsdS)Nr)rrrrrAgsz_MainProcess.closeN)r)rcrdr4rArrrrrkSsrkrQéZSIGÚ_)!Ú__all__rr[ÚsignalrUr`Z _weakrefsetrÚpathÚabspathÚgetcwdZ ORIGINAL_DIRÚOSErrorrrr ÚobjectrrirDrkrr3rrVr rNr Ú__dict__Úitemsr0Zsignumr,rrrrÚ s6