B
f4) ã @ s d ddgZ ddlZddlZddlZddlZddlZddlmZ yej e
¡ ¡Z W n e k
rj dZ Y nX dd„ Z
dd„ Zdd „ ZG d
d „ d eƒZG d d „ d eƒZG d
d„ deƒZeƒ ae d¡aeƒ a[i ZxU s z'BaseProcess.__init__..)ÚAssertionErrorÚ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 Úcountr r r Ú__init__H s
zBaseProcess.__init__c C s | j rtdƒ‚d S )Nzprocess object is closed)r# Ú
ValueError)r r r r Ú
_check_closedZ s zBaseProcess._check_closedc C s | j r| j | j| jŽ dS )zQ
Method to be run in sub-process; can be overridden in sub-class
N)r$ r& r( )r r r r Úrun^ s zBaseProcess.runc C sz | ¡ | jdkstdƒ‚| jt ¡ ks0tdƒ‚tj d¡rDtdƒ‚t ƒ |
| ¡| _| jj | _ | `
| `| `t | ¡ dS )z%
Start child process
Nz cannot start a process twicez:can only start a process object created by current processr z3daemonic processes are not allowed to have children)r7 r r r" r r! r r Úgetr r ÚsentinelÚ _sentinelr$ r& r( r r. )r r r r Ústarte s
zBaseProcess.startc C s | ¡ | j ¡ dS )zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)r7 r Ú terminate)r r r r r= w s zBaseProcess.terminatec C s | ¡ | j ¡ dS )zT
Terminate process; sends SIGKILL signal or uses TerminateProcess()
N)r7 r Úkill)r r r r r> ~ s zBaseProcess.killc C sR | ¡ | jt ¡ ks tdƒ‚| jdk s0tdƒ‚| j |¡}|dk rNt | ¡ dS )z5
Wait until child process terminates
z can only join a child processNz can only join a started process) r7 r" r r! r r Úwaitr r )r ZtimeoutZresr r r r+ … s zBaseProcess.joinc C s` | ¡ | tkrdS | jt ¡ ks*tdƒ‚| jdkr8dS | j ¡ }|dkrNdS t | ¡ dS dS )z1
Return whether process is alive
Tz can only test a child processNF)
r7 r r" r r! r r r
r r )r Ú
returncoder r r Úis_alive s
zBaseProcess.is_alivec C sH | j dk r>| j ¡ dkr tdƒ‚| j ¡ d| _ | `t | ¡ d| _dS )zÂ
Close the Process object.
This method releases resources held by the Process object. It is
an error to call this method if the child process is still running.
Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r
r6 Úcloser; r r r# )r r r r rB £ s
zBaseProcess.closec C s | j S )N)r, )r r r r r1 ´ s zBaseProcess.namec C s t |tƒstdƒ‚|| _d S )Nzname must be a string)Ú
isinstancer r r, )r r1 r r r r1 ¸ s c C s | j dd¡S )z4
Return whether process is a daemon
r F)r r9 )r r r r r ½ s zBaseProcess.daemonc C s | j dkstdƒ‚|| jd< dS )z1
Set whether process is a daemon
Nzprocess has already startedr )r r r )r Zdaemonicr r r r Ä s c C s
| j d S )NÚauthkey)r )r r r r rD Ì s zBaseProcess.authkeyc C s t |ƒ| jd< dS )z2
Set authorization key of process
rD N)ÚAuthenticationStringr )r rD r r r rD Ð s c C s" | ¡ | jdkr| jS | j ¡ S )zM
Return exit code of process or `None` if it has yet to stop
N)r7 r r
)r r r r Úexitcode× s
zBaseProcess.exitcodec C s* | ¡ | tkrt ¡ S | jo$| jjS dS )zU
Return identifier (PID) of process or `None` if it has yet to start
N)r7 r r r! r Úpid)r r r r Úidentá s zBaseProcess.identc C s2 | ¡ y| jS tk
r, tdƒd‚Y nX dS )z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)r7 r; ÚAttributeErrorr6 )r r r r r: î s
zBaseProcess.sentinelc C s¤ | t krd}nJ| jrd}n>| jt ¡ kr.d}n*| jd kr>d}n| j ¡ d k rT| j}nd}t|ƒt kr‚|dkrrd}ndt
||¡ }dt| ƒj | j
|| jrœd pžd
f S ) NZstartedÚclosedÚunknownÚinitialr Zstoppedz stopped[%s]z<%s(%s, %s%s)>z daemonÚ )r r# r" r r! r r
rF r) ÚintÚ_exitcode_to_namer9 r* r, r )r Zstatusr r r Ú__repr__ú s"
zBaseProcess.__repr__c
C sR ddl m}m} zy|| jd k r,| | j¡ t d¡atƒ a |
¡ t }| a z|j
¡ | ¡ W d ~X | d¡ z| ¡ d}W d | ¡ X W n˜ tk
rø } zJ|js®d}n:t|jd tƒrÊ|jd }n tj t|jd ƒd ¡ d}W d d }~X Y n2 d}dd l}tj d| j ¡ | ¡ Y nX W d t ¡ | d| ¡ | ¡ X |S )Né )ÚutilÚcontextz child process calling self.run()r Ú
z Process %s:
z process exiting with exitcode %d) rM rR rS Z
_start_methodZ_force_start_methodÚ itertoolsr4 r Úsetr Z _close_stdinr Z_finalizer_registryÚclearZ_run_after_forkersÚinfor8 Z_exit_functionÚ
SystemExitr2 rC rN ÚsysÚstderrÚwriter Ú tracebackr1 Ú print_excÚ threadingZ _shutdownZ_flush_std_streams)r rR rS Z old_processrF Úer] r r r Ú
_bootstrap sD
zBaseProcess._bootstrap)N)r* Ú
__module__Ú __qualname__Ú__doc__r r5 r7 r8 r< r= r> r+ rA rB Úpropertyr1 Úsetterr rD rF rH rG r: rP ra r r r r r ? s0
c @ s e Zd Zdd„ ZdS )rE c C s, ddl m} |ƒ d kr tdƒ‚tt| ƒffS )NrQ )Úget_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rS rg Ú TypeErrorrE Úbytes)r rg r r r Ú
__reduce__F s
z AuthenticationString.__reduce__N)r* rb rc rj r r r r rE E s rE c @ s e Zd Zdd„ Zdd„ ZdS )Ú _MainProcessc C s8 d| _ d| _d | _d | _d| _tt d¡ƒddœ| _d S )Nr Z MainProcessFé z/mp)rD Z semprefix) r r, r" r r# rE r Úurandomr )r r r r r5 U s z_MainProcess.__init__c C s d S )Nr )r r r r rB g s z_MainProcess.closeN)r* rb rc r5 rB r r r r rk S s rk rQ é ZSIGÚ_)!Ú__all__r rZ ÚsignalrU r_ Z _weakrefsetr ÚpathÚabspathÚgetcwdZ ORIGINAL_DIRÚOSErrorr r r Úobjectr ri rE rk r r4 r rV r rO r
Ú__dict__Úitemsr1 Zsignumr- r r r r Ú
s6