֦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 N)_current_process 0/usr/lib64/python3.12/multiprocessing/process.pyr r % s r c 6 t t t S r )_cleanuplist _childrenr r r
r r + s
J ?r c t S r )_parent_processr r r
r r 3 s r c t t D ]7 } | j x}s|j #t j | 9 y r )r r _popenpolldiscard)p child_popens r
r r = s;
)_ 88 #K #)9)9);)G a r c L e Zd Z d Zddddi fdddZd Zd Zd Zd Zd
Z dd Z
d Z d
Z e
d Zej d Ze
d Zej d Ze
d Zej d Ze
d Ze
d ZeZe
d Zd ZddZed Zy)r 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 l | j r' | j | j i | j y y r )r4 r6 r8 r s r
runzBaseProcess.rung s0 << DLL$** 5 5 r c | j t | j | | _ | j j | _ | `| `| `t j | y r ) rG r r r sentinel _sentinelr4 r6 r8 r r> r s r
startzBaseProcess.startn sX
kk$' --
L$*dl
dr c Z | j | j j y r )rG r terminater s r
rO zBaseProcess.terminate s%
r c Z | j | j j y r )rG r killr s r
rQ zBaseProcess.kill s%
r c | j | j j | }|t j | y y r )rG r waitr r )r timeoutress r
r; zBaseProcess.join sC
kk w' ? d # r c | j | t u ry| j y| j j }|yt j | y)NTF)rG r
r r r r )r
returncodes r
is_alivezBaseProcess.is_alive s\
# # ;; [[%%'
d #r c | j ]| j j t d | j j d | _ | `t
j
| d| _ y )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 sl ;; "{{ !) "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 )Nr F)r, getr s r
r zBaseProcess.daemon s || %00r c $ || j d< y )Nr r, )r daemonics r
r zBaseProcess.daemon s "* X r c | j d S Nauthkeyra r s r
re zBaseProcess.authkey s ||I&&r c 6 t | | j d< y rd )AuthenticationStringr, )r re s r
re zBaseProcess.authkey s #7w"? Y r c | j | j | j S | j j S r )rG r r r s r
exitcodezBaseProcess.exitcode s<
;; ;; {{ !!r c | j | t u rt j S | j xr | j j
S r )rG r
r. r/ r pidr s r
identzBaseProcess.ident sA
# #99; ;;24;;?? 2r c p | j | j S # t $ r
t d d w xY w)Nzprocess not started)rG rL AttributeErrorrF r s r
rK zBaseProcess.sentinel sA
>>> ! > 23 = >s 5c 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< appendrk _exitcode_to_namer_ r r; )r ri 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_forkry rI _exit_function
SystemExitcode
isinstanceintsysstderrwriter% tracebackr1 print_exc _shutdown_flush_std_streams)r parent_sentinelr} r~ old_processri 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__r rD rG rI rM rO rQ r; rX rZ propertyr1 setterr re ri rl rk rK rz r staticmethodr r r r
r r G s4
" "$T2 &96 $ $& "
[[ 1 1 ]]* * ' '
^^@ @ " " 3 3 C
> >'>.` " "r r c e Zd Zd Zy)rg c V ddl m} | t d t t | ffS )Nr| )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r~ r TypeErrorrg bytes)r r s r
__reduce__z AuthenticationString.__reduce__^ s3 / '2
$eDk^33r N)r: r r r r r r
rg rg ] s 4r rg 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 rk 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
rl z_ParentProcess.ident| s yyr Nc < ddl m} || j g| y r r )r rT rS s r
r; z_ParentProcess.join s 4 dnn
w/r r ) r: r r rD rX r rl r; rk 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)re semprefix) r+ r< r0 r r3 rg 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 rg r r r r
rC r* r r rw 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: