֦ik/ g d Z ddlZddlZddlZddlZddlZddlmZ ej j ej Z d Z
d Zd Zd Z G d d e Z G d
d e Z G d d
e Z G d de Zda e a ej2 d a e a [i Z e ej> jA D ] \ Z!Z"e!dd dk( sde!vsde! e e" < [![" e Z#y# e $ r dZ Y w xY w)) BaseProcesscurrent_processactive_childrenparent_process N)WeakSetc t S )z@
Return process object representing the current process
)_current_process 0/usr/lib64/python3.12/multiprocessing/process.pyr r % s
r c 4 t t t S )zN
Return list of process objects corresponding to live child processes
)_cleanuplist _childrenr
r r r r + s
J ?r c t S )z?
Return process object representing the parent process
)_parent_processr
r r r r 3 s
r c t t D ]7 } | j x}s|j #t j | 9 y N)r r _popenpolldiscard)p child_popens r r r = s;
)_ 88 #K #)9)9);)G a r c N e Zd ZdZd Zddddi fdddZd Zd Zd Zd
Z d Z
dd Z d
Z d Z
ed Zej d Zed Zej d Zed Zej d Zed Zed ZeZed Zd ZddZed Zy) r z
Process objects represent activity that is run in a separate process
The class is analogous to `threading.Thread`
c t r )NotImplementedErrorselfs r _PopenzBaseProcess._PopenM s !!r Nr
)daemonc $ t t }t j |fz | _ t j j | _ t
j | _ t j | _
d | _ d| _ || _
t | | _ t! | | _ |xs; t% | j& dz dj) d | j D z | _ ||| _ t. j1 | y )NF-:c 3 2 K | ] }t | y wr )str).0is r z'BaseProcess.__init__..^ s =nc!fns )next_process_counterr _identity_configcopyosgetpid _parent_pidname _parent_namer _closed_targettuple_argsdict_kwargstype__name__join_namer _danglingadd)r grouptargetr1 argskwargsr counts r __init__zBaseProcess.__init__P s %&)33uh>'//446 99; , 1 1 4[
F| >T$Z 0 03 6XX =dnn == >
DK
dr c 2 | j r t d y )Nzprocess object is closed)r3
ValueErrorr s r
_check_closedzBaseProcess._check_closedc s << 78 8 r c j | j r' | j | j i | j yy)zQ
Method to be run in sub-process; can be overridden in sub-class
N)r4 r6 r8 r s r runzBaseProcess.rung s+ << DLL$** 5 5 r c | j t | j | | _ | j j | _ | `| `| `t j | y)z%
Start child process
N) rG r r r sentinel _sentinelr4 r6 r8 r r> r s r startzBaseProcess.startn sS
kk$' --
L$*dl
dr c X | j | j j y)zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)rG r terminater s r rO zBaseProcess.terminate s
r c X | j | j j y)zT
Terminate process; sends SIGKILL signal or uses TerminateProcess()
N)rG r killr s r rQ zBaseProcess.kill s
r c | j | j j | }|t j | yy)z5
Wait until child process terminates
N)rG r waitr r )r timeoutress r r; zBaseProcess.join s>
kk w' ? d # r c | j | t u ry| j y| j j }|yt j | y)z1
Return whether process is alive
TF)rG r r r r r )r
returncodes r is_alivezBaseProcess.is_alive sW
# # ;; [[%%'
d #r c | j ]| j j t d | j j d| _ | `t
j
| d| _ y)z
Close the Process object.
This method releases resources held by the Process object. It is
an error to call this method if the child process is still running.
Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r rF closerL r r r3 r s r rZ zBaseProcess.close sg ;; "{{ !) "P Q Q KK DK d # r c | j S r r< r s r r1 zBaseProcess.name s zzr c || _ y r r\ )r r1 s r r1 zBaseProcess.name s
r c : | j j dd S )z4
Return whether process is a daemon
r F)r, getr s r r zBaseProcess.daemon s
|| %00r c " || j d< y)z1
Set whether process is a daemon
r Nr, )r daemonics r r zBaseProcess.daemon s "* X r c | j d S )Nauthkeyra r s r rd zBaseProcess.authkey s ||I&&r c 4 t | | j d< y)z2
Set authorization key of process
rd N)AuthenticationStringr, )r rd s r rd zBaseProcess.authkey s
#7w"? Y r c | j | j | j S | j j S )zM
Return exit code of process or `None` if it has yet to stop
)rG r r r s r exitcodezBaseProcess.exitcode s7
;; ;; {{ !!r c | j | t u rt j S | j xr | j j
S )zU
Return identifier (PID) of process or `None` if it has yet to start
)rG r r. r/ r pidr s r identzBaseProcess.ident s<
# #99; ;;24;;?? 2r c n | j | j S # t $ r
t d dw xY w)z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)rG rL AttributeErrorrF r s r rK zBaseProcess.sentinel s<
>>> ! > 23 = >s 4c d }| t u rd}nc| j rd}nT| j t j k7 rd}n0| j
d}n!| j
j
}|d}nd}t | j d| j z g}| j
(|j d| j
j z |j d| j z |j | |*t j || }|j d |z | j r|j d
d d j | z S )
Nstartedclosedunknowninitialstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr z<%s> )r r3 r0 r. r/ r r r9 r: r< appendrj _exitcode_to_namer_ r r; )r rh statusinfos r __repr__zBaseProcess.__repr__ s # # F
\\ F
, F
[[
F{{'')H#""T
##Y%;< ;; " KK4;;??2 3 K$"2"223 F (,,Xx@H KK
0 1 ;; KK !&&r c ddl m}m} | j |j | j t j d at a |j t }| a t | j | j | at j" r"t! j$ j' | j) ~|j+ d | j- d}|j/ t! jF |j+ d|z |jI |S # ~w xY w# |j/ w xY w# t0 $ rw}|j2 d}n^t5 |j2 t6 r
|j2 }n7t8 j: j= t? |j2 dz d}Y d }~d }~w d}dd l }t8 j: j= d| jB z |jE Y xY w# t! jF |j+ dz |jI w xY w)N )utilcontextz child process calling self.run()r
z Process %s:
z process exiting with exitcode %d)% r| r}
_start_method_force_start_method itertoolsrC r* setr _close_stdinr _ParentProcessr2 r0 r threading_HAVE_THREAD_NATIVE_ID main_thread_set_native_id _after_forkrx rI _exit_function
SystemExitcode
isinstanceintsysstderrwriter% tracebackr1 print_exc _shutdown_flush_std_streams)r parent_sentinelr| r} old_processrh er s r
_bootstrapzBaseProcess._bootstrap" s #( &!!-++D,>,>? (q 1 I *K # ,!!4#3#3_ FO//%%'668
" II8 9
&
##%
! II88C D # # %3 ##% vv~ AFFC( 66
QVVt!34 "H JJ _tyy 8 9 ! ! II88C D # # %sb B1E <D< E E 1E H <D??E EE H A-G
H AH H :Ic d ddl m} | j j | j y )Nr{ r| )r r| _finalizer_registryclear_run_after_forkersr s r r zBaseProcess._after_forkR s# &&( !r r )r:
__module__ __qualname____doc__r rD rG rI rM rO rQ r; rX rZ propertyr1 setterr rd rh rk rj rK ry r staticmethodr r
r r r r G s4
" "$T2 &96 $ $& "
[[ 1 1 ]]* * ' '
^^@ @ " " 3 3 C
> >'>.` " "r r c e Zd Zd Zy)rf c V ddl m} | t d t t | ffS )Nr{ )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r} r TypeErrorrf bytes)r r s r
__reduce__z AuthenticationString.__reduce__^ s3 / '2
$eDk^33r N)r: r r r r
r r rf rf ] s 4r rf c 4 e Zd Zd Zd Zed ZddZeZy)r c t d| _ || _ || _ d | _ d | _ d| _ || _ i | _ y )Nr
F)r+ r< _pidr0 r r3 rL r, )r r1 rj rK s r rD z_ParentProcess.__init__n s;
! r c : ddl m} || j gd S )Nr rS rT multiprocessing.connectionrS rL )r rS s r rX z_ParentProcess.is_alivex s 3 (!444r c | j S r )r r s r rk z_ParentProcess.ident| s yyr Nc : ddl m} || j g| y)z6
Wait until parent process terminates
r r r Nr )r rT rS s r r; z_ParentProcess.join s 4 dnn
w/r r ) r: r r rD rX r rk r; rj r
r r r r l s, 5 0 Cr r c e Zd Zd Zd Zy) _MainProcessc d| _ d| _ d | _ d | _ d| _ t t
j d dd| _ y )Nr
MainProcessF z/mp)rd semprefix) r+ r< r0 r r3 rf r. urandomr, r s r rD z_MainProcess.__init__ sB "
#7
2#G%*, r c y r r
r s r rZ z_MainProcess.close s r N)r: r r rD rZ r
r r r r s ,$
r r r{ SIG_r" )$__all__r. r signalr r _weakrefsetr pathabspathgetcwd ORIGINAL_DIROSErrorr r r r objectr r rf r r r r rC r* r r rv r __dict__itemsr1 signumr= r
r r r s&
77??9299;/L !O"& O"l45 4 [ B
;
0 > "9??1% E ..01LD& BQx3d?'(Z6'" 2 &
I s Ls *C0 0C:9C: