File: //lib64/python3.8/multiprocessing/__pycache__/process.cpython-38.opt-2.pyc
U
e5d. @ s8 d dddgZ ddlZddlZddlZddlZddlZddlmZ zej e
Z W n e k
rl dZ Y nX dd Z
dd Zd d Zd
d ZG d d d eZG d
d deZG dd deZG dd deZdae aedae a [i Z e ej D ]0\Z!Z"e!dd dkrde!krde! e e" < qe Z#dS ) BaseProcesscurrent_processactive_childrenparent_process N)WeakSetc C s t S N)_current_process r r //usr/lib64/python3.8/multiprocessing/process.pyr % s c C s t ttS r )_cleanuplist _childrenr r r r
r + s c C s t S r )_parent_processr r r r
r 3 s c C s* t tD ] } | j d k rt| qd S r )r r
_popenpolldiscard)pr r r
r = s r c @ s e Zd Zdd Zddddi fddddZdd Zd
d Zd d
Zdd Zdd Z d+ddZ
dd Z dd Z e
dd Zejdd Ze
dd Zejd d Ze
d d Zejd d Ze
d!d" Ze
d#d$ ZeZe
d%d& Zd'd( Zd,d)d*ZdS )-r c C s t d S r )NotImplementedErrorselfr r r
_PopenM s zBaseProcess._PopenNr )daemonc C s t t}tj|f | _tj | _t | _tj | _
d | _ d| _ || _
t|| _t|| _|pt| jd ddd | jD | _|d k r|| _t| d S )NF-:c s s | ]}t |V qd S r )str).0ir r r
<genexpr>^ s z'BaseProcess.__init__.<locals>.<genexpr>)next_process_counterr _identity_configcopyosgetpid _parent_pidname _parent_namer _closed_targettuple_argsdict_kwargstype__name__join_namer _danglingadd)r grouptargetr& argskwargsr countr r r
__init__P s
zBaseProcess.__init__c C s | j rtdd S )Nzprocess object is closed)r(
ValueErrorr r r r
_check_closedc s zBaseProcess._check_closedc C s | j r| j | j| j d S r )r) r+ r- r r r r
rung s zBaseProcess.runc C s> | t | | | _| jj| _| `| `| `t
| d S r ) r; r r r sentinel _sentinelr) r+ r- r
r3 r r r r
startn s
zBaseProcess.startc C s | | j d S r )r; r terminater r r r
r@ s zBaseProcess.terminatec C s | | j d S r )r; r killr r r r
rA s zBaseProcess.killc C s* | | j|}|d k r&t| d S r )r; r waitr
r )r timeoutresr r r
r0 s zBaseProcess.joinc C sJ | | tkrdS | jd kr"dS | j }|d kr8dS t| dS d S )NTF)r; r r r r
r )r
returncoder r r
is_alive s
zBaseProcess.is_alivec C sH | j d k r>| j d kr td| j d | _ | `t| d| _d S )Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r r: closer> r
r r( r r r r
rG s
zBaseProcess.closec C s | j S r r1 r r r r
r& s zBaseProcess.namec C s
|| _ d S r rH )r r& r r r
r& s c C s | j ddS )Nr F)r! getr r r r
r s zBaseProcess.daemonc C s || j d< d S )Nr r! )r Zdaemonicr r r
r s c C s
| j d S NauthkeyrJ r r r r
rL s zBaseProcess.authkeyc C s t || jd< d S rK )AuthenticationStringr! )r rL r r r
rL s c C s" | | jd kr| jS | j S r )r; r r r r r r
exitcode s
zBaseProcess.exitcodec C s* | | tkrt S | jo$| jjS d S r )r; r r# r$ r pidr r r r
ident s zBaseProcess.identc C s4 | z| jW S tk
r. tdd Y nX d S )Nzprocess not started)r; r> AttributeErrorr: r r r r
r= s
zBaseProcess.sentinelc C s d }| t krd}nL| jr d}n@| jt kr2d}n,| jd krBd}n | j }|d k rZd}nd}t| jd| j g}| jd k r|
d| jj |
d| j |
| |d k rt
||}|
d | | jr|
d
d d | S )
NZstartedclosedunknowninitialZstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr z<%s> )r r( r% r# r$ r r r. r/ r1 appendrO _exitcode_to_namerI r r0 )r rN Zstatusinfor r r
__repr__ s0
zBaseProcess.__repr__c
C sv ddl m}m} z>z| jd k r,|| j t
da t a
| t}| at| j| j|atjrnt z|j | W 5 ~X |d z| d}W 5 | X W n t k
r } zJ|j sd}n:t |j d t r|j d }n t j!"t#|j d d d}W 5 d }~X Y n2 d}dd l$}t j!"d| j% |& Y nX W 5 t |d| | X |S )N )utilcontextz process exiting with exitcode %dz child process calling self.run()r
z Process %s:
)' r[ r\ threadingZ _shutdownrX Z_flush_std_streamsZ
_start_methodZ_force_start_method itertoolsr8 r setr
Z _close_stdinr _ParentProcessr' r% r Z_HAVE_THREAD_NATIVE_IDZ main_threadZ_set_native_idZ_finalizer_registryclearZ_run_after_forkersZ_exit_functionr<
SystemExitr6
isinstanceintsysstderrwriter tracebackr& print_exc)r Zparent_sentinelr[ r\ rN Z old_processerj r r r
_bootstrap" sR
zBaseProcess._bootstrap)N)N)r/
__module__ __qualname__r r9 r; r< r? r@ rA r0 rF rG propertyr& setterr rL rN rP rO r= rY rm r r r r
r G sB
c @ s e Zd Zdd ZdS )rM c C s, ddl m} | d kr tdtt| ffS )NrZ )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r\ rr TypeErrorrM bytes)r rr r r r
__reduce__X s
z AuthenticationString.__reduce__N)r/ rn ro ru r r r r
rM W s rM c @ s6 e Zd Zdd Zdd Zedd Zd
dd ZeZdS ) rb c C s4 d| _ || _|| _d | _d | _d| _|| _i | _d S )Nr F)r r1 _pidr% r r( r> r! )r r& rO r= r r r
r9 h s z_ParentProcess.__init__c C s ddl m} || jgdd S Nr )rB )rC Zmultiprocessing.connectionrB r> )r rB r r r
rF r s z_ParentProcess.is_alivec C s | j S r )rv r r r r
rP v s z_ParentProcess.identNc C s ddl m} || jg|d d S rw rx )r rC rB r r r
r0 z s z_ParentProcess.join)N) r/ rn ro r9 rF rp rP r0 rO r r r r
rb f s
rb c @ s e Zd Zdd Zdd ZdS ) _MainProcessc C s8 d| _ d| _d | _d | _d| _ttddd| _d S )Nr Z MainProcessF z/mp)rL Z semprefix) r r1 r% r r( rM r# urandomr! r r r r
r9 s z_MainProcess.__init__c C s d S r r r r r r
rG s z_MainProcess.closeN)r/ rn ro r9 rG r r r r
ry s ry rZ ZSIG_r )$__all__r# rg signalr` r_ Z _weakrefsetr pathabspathgetcwdZ ORIGINAL_DIROSErrorr r r r objectr rt rM rb ry r r r8 r ra r
rW r __dict__itemsr& Zsignumr2 r r r r
<module>
s@
!