*j/
/ S Qr SSKrSSKrSSKrSSKrSSKrSSKJr \R R \R " 5 5 r S r
S rS rS r " S S \5 r " S
S \5 r " S S
\5 r " S S\5 rSq\" 5 q\R2 " S5 q\" 5 q C0 r \ " \R> RA 5 5 H" u r!r"\!SS S:X d M S\!; d M S\! 3\ \"* ' M$ C!C"\" 5 r#g! \ a Sr Nf = f)) BaseProcesscurrent_processactive_childrenparent_process N)WeakSetc [ $ )z8
Return process object representing the current process
)_current_process >/opt/alt/python313/lib64/python3.13/multiprocessing/process.pyr r % s
r c 4 [ 5 [ [ 5 $ )zF
Return list of process objects corresponding to live child processes
)_cleanuplist _childrenr
r r r r + s
J ?r c [ $ )z7
Return process object representing the parent process
)_parent_processr
r r r r 3 s
r c [ [ 5 H@ n U R =n( d M UR 5 c M+ [ R U 5 MB g N)r r _popenpolldiscard)p child_popens r r r = s;
)_ 88 #K #)9)9);)G a r c ^ \ rS rSrSrS rSSSS0 4SS.S jjrS rS rS
r S r
S r S S
jr S r
S r\S 5 r\R" S 5 r\S 5 r\R" S 5 r\S 5 r\R" S 5 r\S 5 r\S 5 r\r\S 5 rS rS S jr\S 5 rS r g) r G zt
Process objects represent activity that is run in a separate process
The class is analogous to `threading.Thread`
c [ er )NotImplementedErrorselfs r _PopenBaseProcess._PopenM s !!r Nr
)daemonc B Ub S5 e[ [ 5 n[ R U4- U l [ R R 5 U l [ R " 5 U l [ R U l
S U l SU l X l
[ U5 U l [! U5 U l U=( d; [% U 5 R& S- SR) S U R 5 5 - U l Ub X`l [. R1 U 5 g )Nz#group argument must be None for nowF-:c 3 8 # U H n[ U5 v M g 7fr )str).0is r 'BaseProcess.__init__..^ s =nc!ffns )next_process_counterr _identity_configcopyosgetpid _parent_pidname _parent_namer _closed_targettuple_argsdict_kwargstype__name__join_namer" _danglingadd)r grouptargetr4 argskwargsr" counts r __init__BaseProcess.__init__P s }C CC}%&)33uh>'//446 99; , 1 1 4[
F| >T$Z 0 03 6XX =dnn == >
K
dr c < U R ( a [ S5 eg )Nzprocess object is closed)r6
ValueErrorr s r
_check_closedBaseProcess._check_closedc s << 78 8 r c t U R ( a' U R " U R 0 U R D6 gg)zA
Method to be run in sub-process; can be overridden in sub-class
N)r7 r9 r; r s r runBaseProcess.rung s) << LL$** 5 5 r c U R 5 U R b S5 eU R [ R " 5 :X d S5 e[
R R S5 ( a S5 e[ 5 U R U 5 U l U R R U l U ? U ?
U ?[ R! U 5 g)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)rK r r3 r1 r2 r r/ getr r sentinel _sentinelr7 r9 r; r rA r s r startBaseProcess.startn s
{{"B$BB" 299;. LK L.#++//99 ED E9
kk$' --
L$*dl
dr c X U R 5 U R R 5 g)zD
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)rK r terminater s r rW BaseProcess.terminate s
r c X U R 5 U R R 5 g)zD
Terminate process; sends SIGKILL signal or uses TerminateProcess()
N)rK r killr s r rZ BaseProcess.kill s
r c U R 5 U R [ R " 5 :X d S5 eU R c S5 eU R R U5 nUb [ R U 5 gg)z%
Wait until child process terminates
z can only join a child processNz can only join a started process)rK r3 r1 r2 r waitr r )r timeoutress r r> BaseProcess.join sr
299;.O0OO.{{&I(II&kk w' ? d # r c U R 5 U [ L a gU R [ R " 5 :X d S5 eU R
c gU R
R
5 nUc g[ R U 5 g)z!
Return whether process is alive
Tz can only test a child processF) rK r r3 r1 r2 r r r r )r
returncodes r is_aliveBaseProcess.is_alive su
# # 299;.O0OO. ;; [[%%'
d #r c U R b^ U R R 5 c [ S5 eU R R 5 SU l U ?[
R
U 5 SU l g)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 rJ closerS r r r6 r s r rf BaseProcess.close sg ;; "{{ !) "P Q Q KK DK d # r c U R $ r )r? r s r r4 BaseProcess.name s zzr c H [ U[ 5 ( d S5 eXl g )Nzname must be a string)
isinstancer' r? )r r4 s r r4 ri s $$$=&==$
r c : U R R SS5 $ )z$
Return whether process is a daemon
r" F)r/ rQ r s r r" BaseProcess.daemon s
|| %00r c H U R b S5 eXR S' g)z!
Set whether process is a daemon
Nzprocess has already startedr" )r r/ )r daemonics r r" rm s&
{{"A$AA"!) X r c U R S $ )Nauthkey)r/ r s r rq BaseProcess.authkey s ||I&&r c 4 [ U5 U R S' g)z"
Set authorization key of process
rq N)AuthenticationStringr/ )r rq s r rq rr s
#7w"? Y r c U R 5 U R c U R $ U R R 5 $ )z=
Return exit code of process or `None` if it has yet to stop
)rK r r r s r exitcodeBaseProcess.exitcode s7
;; ;; {{ !!r c U R 5 U [ L a [ R " 5 $ U R =( a U R R
$ )zE
Return identifier (PID) of process or `None` if it has yet to start
)rK r r1 r2 r pidr s r identBaseProcess.ident s<
# #99; ;;24;;?? 2r c p U R 5 U R $ ! [ a
[ S5 Sef = f)zc
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)rK rS AttributeErrorrJ r s r rR BaseProcess.sentinel s<
>>> ! > 23 = >s 5c S nU [ L a SnOlU R ( a SnOXU R [ R " 5 :w a SnO2U R
c SnO"U R
R
5 nUb SnOSn[ U 5 R SU R - /nU R
b( UR SU R
R - 5 UR SU R - 5 UR U5 Ub) [ R X5 nUR S U- 5 U R ( a UR S
5 S S R U5 - $ )
Nstartedclosedunknowninitialstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr" z<%s> )r r6 r3 r1 r2 r r r< r= r? appendry _exitcode_to_namerQ r" r> )r rv statusinfos r __repr__BaseProcess.__repr__ s # # F
\\ F
, F
[[
F{{'')H#""T
##Y%;< ;; " KK4;;??2 3 K$"2"223 F (,,X@H KK
0 1 ;; KK !&&r c SSK JnJn U R b UR U R 5 [
R " S5 q[ 5 q UR 5 [ nU q [ U R U R U5 q[ R" ( a# [ R$ " 5 R' 5 U R) 5 AUR+ S5 U R- 5 Sn[ RD " 5 UR+ SU- 5 URG 5 U$ ! Af = f! [. a nUR0 c Sn S nAN_[3 UR0 [4 5 ( a UR0 n S nAN[6 R8 R; [= UR0 5 S- 5 Sn S nANS nAf SnSS K n[6 R8 R; SU R@ - 5 URC 5 GN= f! [ RD " 5 UR+ SW- 5 URG 5 f = f)N )utilcontextz child process calling self.run()r
z Process %s:
z process exiting with exitcode %d)$ r r
_start_method_force_start_method itertoolsrF r- setr _close_stdinr _ParentProcessr5 r3 r threading_HAVE_THREAD_NATIVE_ID main_thread_set_native_id _after_forkr rN
SystemExitcoderk intsysstderrwriter' tracebackr4 print_exc _shutdown_flush_std_streams)r parent_sentinelr r old_processrv er s r
_bootstrapBaseProcess._bootstrap" s #% &!!-++D,>,>? (q 1 I *K # ,!!4#3#3_ FO//%%'668
" II8 9 HHJH
! II88C D # # %- vv~ AFFC(( 66
QVVt!34 "H JJ _tyy 8 9 ! ! II88C D # # %s[ B9D9 D3 $D9 3D66D9 9
H
GH +GH 7G>H AH
H ;I c d SSK Jn U R R 5 U R 5 g )Nr r )r r _finalizer_registryclear_run_after_forkersr s r r BaseProcess._after_forkO s# &&( !r ) r9 r6 r/ r. r; r? r5 r3 r rS r7 r" r ) r=
__module__ __qualname____firstlineno____doc__r rG rK rN rT rW rZ r> rc rf propertyr4 setterr" rq rv rz ry rR r r staticmethodr __static_attributes__r
r r r r G s4
" "$T2 &96 $ $& "
[[ 1 1 ]]* * ' '
^^@ @ " " 3 3 C
> >'>+Z " "r r c \ rS rSrS rSrg)rt iZ c X SSK Jn U" 5 c [ S5 e[ [ U 5 44$ )Nr )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r r TypeErrorrt bytes)r r s r
__reduce__ AuthenticationString.__reduce__[ s3 / '2
$eDk^33r r
N)r= r r r r r r
r r rt rt Z s 4r rt c > \ rS rSrS rS r\S 5 rSS jr\r Sr
g) r ii c n SU l Xl X l S U l S U l SU l X0l 0 U l g )Nr
F)r. r? _pidr3 r r6 rS r/ )r r4 ry rR s r rG _ParentProcess.__init__k s5
! r c < SSK Jn U" U R /SS9( + $ )Nr r] r^ multiprocessing.connectionr] rS )r r] s r rc _ParentProcess.is_aliveu s 3 (!444r c U R $ r )r r s r rz _ParentProcess.identy s yyr Nc 4 SSK Jn U" U R /US9 g)z&
Wait until parent process terminates
r r r Nr )r r^ r] s r r> _ParentProcess.join} s 4 dnn
w/r )r6 r/ r. r? r3 r r rS r ) r= r r r rG rc r rz r> ry r r
r r r r i s, 5 0 Cr r c \ rS rSrS rS rSrg) _MainProcessi c SU l SU l S U l S U l SU l [ [ R " S5 5 SS.U l g )Nr
MainProcessF z/mp)rq semprefix) r. r? r3 r r6 rt r1 urandomr/ r s r rG _MainProcess.__init__ sB "
#7
2#G%*, r c g r r
r s r rf _MainProcess.close s r )r6 r/ r. r? r3 r N)r= r r r rG rf r r
r r r r s ,$
r r r SIG_r$ )$__all__r1 r signalr r _weakrefsetr pathabspathgetcwd ORIGINAL_DIROSErrorr r r r objectr r rt r r r r rF r- r r r r __dict__itemsr4 signumr@ r
r r r s"
77??299;/L !L"& L"f45 4 [ B
;
0 > ??1% E ..01LD& BQx3d?'(Z6'" 2 &
I m Ls *C7 7DD