File: //usr/lib/python3.5/multiprocessing/__pycache__/process.cpython-35.pyc
Fa" @ sv 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 xP e e j j D]9 \ Z Z e d d d k r,d e k r,e e e <q,We Z d S) BaseProcesscurrent_processactive_children N)WeakSetc C s t S)z@
Return process object representing the current process
)_current_process r r -/usr/lib/python3.5/multiprocessing/process.pyr # s c C s t t t S)zN
Return list of process objects corresponding to live child processes
)_cleanuplist _childrenr r r r r ) s c C s= x6 t t D]( } | j j d k r
t j | q
Wd S)N)r
r _popenpolldiscard)pr r r r 4 s r c @ sK e Z d Z d Z d d Z d d d f i d d d d Z d d Z d
d Z d d
Z d d d Z d d Z
e d d Z e j
d d Z e d d Z e j
d d Z e d d Z e j
d d Z e d d Z e d d Z e Z e d d Z d! d" Z d# d$ Z d S)%r z
Process objects represent activity that is run in a separate process
The class is analogous to `threading.Thread`
c C s
t d S)N)NotImplementedError)selfr r r _PopenD s zBaseProcess._PopenNdaemonc C s | d k s t d t t } t j | f | _ t j j | _ t j | _ d | _
| | _ t | | _
t | | _ | p t | j d d j d d | j D | _ | d k r | | _ t j | d S)Nz#group argument must be None for now-:c s s | ] } t | Vq d S)N)str).0ir r r <genexpr>S s z'BaseProcess.__init__.<locals>.<genexpr>)AssertionErrornext_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 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 s | j d k s t d | j t j k s< t d t j j d s[ t d t | j | | _ | j j
| _ t j
| d S)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)r r r" r r! r r getr 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 r: m s zBaseProcess.terminatec C sk | j t j k s! t d | j d k s< t d | j j | } | d k rg t j | d S)z5
Wait until child process terminates
z can only join a child processNz can only join a started process)r" r r! r r waitr r )r ZtimeoutZresr r r r* s s
! zBaseProcess.joinc C sa | t k r d S| j t j k s1 t d | j d k rD d S| j j | j j d k S)z1
Return whether process is alive
Tz can only test a child processNF)r r" r r! r r r
returncode)r r r r is_alive} s !
zBaseProcess.is_alivec C s | j S)N)r+ )r r r r r0 s zBaseProcess.namec C s( t | t s t d | | _ d S)Nzname must be a string)
isinstancer r r+ )r r0 r r r r0 s c C s | j j d d S)z4
Return whether process is a daemon
r F)r r6 )r r r r r s zBaseProcess.daemonc C s, | j d k s t d | | j d <d S)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)Nauthkey)r )r r r r r? s zBaseProcess.authkeyc C s t | | j d <d S)z2
Set authorization key of process
r? 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)r8 AttributeError
ValueError)r r r r r7 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 } n d t j
| | } 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
rA r( int_exitcode_to_namer6 r) r+ r )r Zstatusr r r __repr__ s zBaseProcess.__repr__c C s d d l m } m } zgy | j d k r; | j | j t j d a t a | j
t } | a z | j j
| j Wd ~ X| j d z | j d } Wd | j XWn t k
rA} zd | j s d } nM t | j d t r| 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) rH rM rN Z
_start_methodZ_force_start_method itertoolsr3 r setr Z _close_stdinr Z_finalizer_registryclearZ_run_after_forkersinfor5 Z_exit_function
SystemExitr1 r> rI sysstderrwriter tracebackr0 print_excstdoutflush)r rM rN Z old_processrA erX r r r
_bootstrap sD
!
zBaseProcess._bootstrap)r)
__module__ __qualname____doc__r r4 r5 r9 r: r* r= propertyr0 setterr r? rA rC rB r7 rK r] r r r r r > s*
c @ s e Z d Z d d Z d S)r@ c C s> d d l m } | d k r+ t d t t | f f S)NrL )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rN rc TypeErrorr@ bytes)r rc r r r
__reduce__ s
z AuthenticationString.__reduce__N)r) r^ r_ rf r r r r r@ s r@ c @ s e Z d Z d d Z d S) _MainProcessc C sL f | _ d | _ d | _ d | _ d t t j d d d i | _ d S)NZ MainProcessr? Z semprefixz/mp)r r+ r" r r@ r urandomr )r r r r r4 % s z_MainProcess.__init__N)r) r^ r_ r4 r r r r rg # s rg rL ZSIG_) __all__r rU signalrP _weakrefsetr pathabspathgetcwdZ ORIGINAL_DIROSErrorr r r objectr re r@ rg r r3 r rQ r rJ r
__dict__itemsr0 Zsignumr, r r r r <module>
s0
""