e f# @ sy d d d g Z d d l Z d d l Z d d l Z d d l Z d d l m Z y e j j e j Z
Wn e k
r d Z
Yn Xd d Z d d Z
d d Z Gd
d d e Z Gd d d e Z Gd
d d e Z e a e j d a e a [ i Z xS e e j j D]< \ Z Z e d d d k r,d e k r,e e e S s z'BaseProcess.__init__..)next_process_counterr _identity_configcopyosgetpid _parent_pidr _targettuple_argsdict_kwargstype__name__join_namer _danglingadd)r grouptargetnameargskwargsr countr r r __init__G s # zBaseProcess.__init__c C s& | j r" | j | j | j n d S)zQ
Method to be run in sub-process; can be overridden in sub-class
N)r" r$ r& )r r r r runX s zBaseProcess.runc C s9 t | j | | _ | j j | _ t j | d S)z%
Start child process
N)r r r sentinel _sentinelr r, )r r r r start_ s zBaseProcess.startc C s | j j d S)zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)r terminate)r r r r r8 m s zBaseProcess.terminatec C s2 | j j | } | d k r. t j | n d S)z5
Wait until child process terminates
N)r waitr r )r Ztimeoutresr r r r) s s zBaseProcess.joinc C s@ | t k r d S| j d k r# d S| j j | j j d k S)z1
Return whether process is alive
TNF)r r r
returncode)r r r r is_alive} s
zBaseProcess.is_alivec C s | j S)N)r* )r r r r r/ s zBaseProcess.namec C s
| | _ d S)N)r* )r r/ r r r r/ s c C s | j j d d S)z4
Return whether process is a daemon
r F)r get)r r r r r s zBaseProcess.daemonc C s | | j d s zBaseProcess.authkeyc C s t | | j d N)AuthenticationStringr )r r> r r r r> s c C s# | j d k r | j S| j j S)zM
Return exit code of process or `None` if it has yet to stop
N)r r
)r r r r exitcode s zBaseProcess.exitcodec C s- | t k r t j S| j o( | j j Sd S)zU
Return identifier (PID) of process or `None` if it has yet to start
N)r r r r pid)r r r r ident s
zBaseProcess.identc C s0 y | j SWn t k
r+ t d Yn Xd S)z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)r6 AttributeError
ValueError)r r r r r5 s
zBaseProcess.sentinelc C s | t k r d } n] | j t j k r3 d } n? | j d k rK d } n' | j j d k rl | j } n d } t | t k r | d k r d } q d t j
| | } n d t | j | j | | j
r d p d f S)
NZstartedunknowninitialr Zstoppedz stopped[%s]z<%s(%s, %s%s)>z daemon )r r! r r r r
r@ r' int_exitcode_to_namer= r( r* r )r Zstatusr r r __repr__ s zBaseProcess.__repr__c ( C s d d l m } m } zy | j d k r> | j | j n t j d a t a t
j d k r y# t
j j t
t j t
_ Wq t t f k
r Yq Xn t } | a z | j j | j Wd ~ X| j d z | j d } Wd | j XWn t k
r} zd | j s+d } nM t | j d t rQ| j d } n' t
j j t | j d d d } WYd d } ~ Xn; d } d d l } t
j j d | j! | j" Yn XWd | j d | t
j# j$ t
j j$ X| S)N )utilcontextz child process calling self.run()r
z Process %s:
z process exiting with exitcode %d)%rG rL rM Z
_start_methodZ_force_start_method itertoolsr2 r setr sysstdincloseopenr devnullOSErrorrD r Z_finalizer_registryclearZ_run_after_forkersinfor4 Z_exit_function
SystemExitr0
isinstancerH stderrwriter tracebackr/ print_excstdoutflush)r rL rM Z old_processr@ er] r r r
_bootstrap sN
!
zBaseProcess._bootstrap)r(
__module__ __qualname____doc__r r3 r4 r7 r8 r) r< propertyr/ setterr r> r@ rB rA r5 rJ rb r r r r r > s*
c @ s e Z d Z d d Z d S)r? c C sA d d l m } | d k r. t d n t t | f f S)NrK )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rM rh TypeErrorr? bytes)r rh r r r
__reduce__ s
z AuthenticationString.__reduce__N)r( rc rd rk r r r r r? s r? c @ s e Z d Z d d Z d S) _MainProcessc C sN f | _ d | _ d | _ d | _ i t t j d d 6d d 6| _ d S)NZ MainProcess r> z/mpZ semprefix)r r* r! r r? r urandomr )r r r r r3 * s z_MainProcess.__init__N)r( rc rd r3 r r r r rl ( s rl rK ZSIG_) __all__r rQ signalrO _weakrefsetr pathabspathgetcwdZ ORIGINAL_DIRrV r r r objectr rj r? rl r r2 r rP r rI r
__dict__itemsr/ Zsignumr+ r r r r
s0
""