Ñò
§ÚêLc @ s7 d d d g Z d d k Z d d k Z d d k Z d d k Z y e i i e i ƒ ƒ Z Wn e j
o
d Z n Xd „ Z d „ Z d „ Z
d e f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ e ƒ a [ h Z xJ e i i ƒ D]9 \ Z Z e d
d j o d e j o e e e Q s ( R t _countert nextt _identityt _authkeyt _daemonict _tempdirt ost getpidt _parent_pidR R t _targett tuplet _argst dictt _kwargst typet __name__t joint _name( t selft groupt targett namet argst kwargst count( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt __init__D s c C s( | i o | i | i | i Ž n d S( sQ
Method to be run in sub-process; can be overridden in sub-class
N( R R R ( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt runS s
c C sW t ƒ | i d j o
| i } n d d k l } | | ƒ | _ t i i | ƒ d S( s%
Start child process
i ( t PopenN( R t _PopenR t forkingR, R R R t add( R# R, ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt startZ s
c C s | i i ƒ d S( sT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N( R t terminate( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR1 k s c C s7 | i i | ƒ } | d j o t i i | ƒ n d S( s5
Wait until child process terminates
N( R t waitR R R R
( R# t timeoutt res( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR! q s
c C sD | t j o t S| i d j o t S| i i ƒ | i i d j S( s1
Return whether process is alive
N( R t TrueR R t FalseR t
returncode( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt is_alive{ s
c C s | i S( N( R" ( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR& ‡ s c C s
| | _ d S( N( R" ( R# R& ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR& ‹ s c C s | i S( s4
Return whether process is a daemon
( R ( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt daemon s c C s
| | _ d S( s1
Set whether process is a daemon
N( R ( R# t daemonic( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR9 — s c C s | i S( N( R ( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt authkeyŸ s c C s t | ƒ | _ d S( s2
Set authorization key of process
N( t AuthenticationStringR ( R# R; ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR; £ s c C s% | i d j o | i S| i i ƒ S( sM
Return exit code of process or `None` if it has yet to stop
N( R R R ( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt exitcodeª s c C s0 | t j o t i ƒ S| i o
| i i Sd S( sV
Return indentifier (PID) of process or `None` if it has yet to start
N( R R R R t pid( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt ident³ s
c C sï | t j o
d } nd | i t i ƒ j o
d } nD | i d j o
d } n* | i i ƒ d j o
| i } n d } t | ƒ t j o1 | d j o
d } q¾ d t
i | | ƒ } n d t | ƒ i | i
| | i o d p d f S(
Nt startedt unknownt initiali t stoppeds stopped[%s]s <%s(%s, %s%s)>s daemont ( R R R R R R R R= R t intt _exitcode_to_namet getR R" R ( R# t status( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt __repr__¿ s
c
C s d d k l } y t ƒ | _ t i d ƒ | _ y# t i i ƒ t
t i ƒ t _ Wn t
t f j
o n X| a | i i ƒ | i ƒ | i d ƒ z | i ƒ d } Wd | i ƒ XWnÈ t j
ov } | i p
d } qˆt | i d ƒ t j o | i d } qˆt i i | i d d ƒ t i i ƒ d } nH d } d d k } t i i d | i ƒ t i i ƒ | i ƒ n X| i d | ƒ | S( Ni ( t utils child process calling self.run()i s
iÿÿÿÿs Process %s:
s process exiting with exitcode %d( RD RJ t setR t itertoolsR) R t syst stdint closet openR t devnullt OSErrort
ValueErrorR t _finalizer_registryt cleart _run_after_forkerst infoR+ t _exit_functiont
SystemExitR' R RE t stderrt writet flusht tracebackR& t print_exc( R# RJ R= t eR] ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt
_bootstrap× sB
N( ( R t
__module__t __doc__R R- R* R+ R0 R1 R! R8 t propertyR& t setterR9 R; R= R? R> RI R` ( ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR < s&
R< c B s e Z d „ Z RS( c C s@ d d k l } | i ƒ p t d ƒ ‚ n t t | ƒ f f S( Ni ( R, sJ Pickling an AuthenticationString object is disallowed for security reasons( R. R, t thread_is_spawningt TypeErrorR< t bytes( R# R, ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt
__reduce__ s
( R Ra Rh ( ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR< s t _MainProcessc B s e Z d „ Z RS( c C sp d | _ t | _ d | _ d | _ d | _ t i d ƒ | _ t
ƒ | _ t t
i d ƒ ƒ | _ d | _ d S( Nt MainProcessi i ( ( R R6 R R" R R R RL R) R RK R R< R t urandomR R ( R# ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyR* s ( R Ra R* ( ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyRi s i t SIGt _( t __all__R RM t signalRL t patht abspatht getcwdt ORIGINAL_DIRRR R R R R t objectR Rg R< Ri R RF t __dict__t itemsR& t signum( ( ( s/ /usr/lib64/python2.6/multiprocessing/process.pyt s*
Ç