/opt/alt/python34/lib64/python3.4/multiprocessing/__pycache__
Edit: /opt/alt/python34/lib64/python3.4/multiprocessing/__pycache__/process.cpython-34.pyc (8928B)
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__..)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 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 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 sn | j t j k s! t d | j d k s< t d | j j | } | d k rj t j | n 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 Ztimeoutresr 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 z daemon )r r" r r! r r
rB r( int_exitcode_to_namer6 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)%rI rN rO Z
_start_methodZ_force_start_method itertoolsr3 r setr sysstdincloseopenr devnullOSErrorrF r Z_finalizer_registryclearZ_run_after_forkersinfor5 Z_exit_function
SystemExitr1 r? rJ stderrwriter tracebackr0 print_excstdoutflush)r rN rO Z old_processrB er^ r r r
_bootstrap sN
!
zBaseProcess._bootstrap)r)
__module__ __qualname____doc__r r4 r5 r9 r: r* r> propertyr0 setterr r@ rB rD rC r7 rL rc r r r r r > s*
c @ s e Z d Z d d Z d S)rA c C sA d d l m } | d k r. t d n t t | f f S)NrM )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rO ri TypeErrorrA bytes)r ri r r r
__reduce__ s
z AuthenticationString.__reduce__N)r) rd re rl r r r r rA s rA 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 rA r urandomr )r r r r r4 * s z_MainProcess.__init__N)r) rd re r4 r r r r rm ( s rm rM ZSIG_) __all__r rS signalrQ _weakrefsetr pathabspathgetcwdZ ORIGINAL_DIRrX r r r objectr rk rA rm r r3 r rR r rK r
__dict__itemsr0 Zsignumr, r r r r
s0
""