*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 [ $ N)_current_process >/opt/alt/python313/lib64/python3.13/multiprocessing/process.pyr r % s
r c 4 [ 5 [ [ 5 $ r )_cleanuplist _childrenr r r
r r + s
J ?r c [ $ r )_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 r )r r _popenpolldiscard)p child_popens r
r r = s;
)_ 88 #K #)9)9);)G a r c Z \ rS rSrS rSSSS0 4SS.S jjrS rS rS rS
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 rSrg) r G c [ er )NotImplementedErrorselfs r
_PopenBaseProcess._PopenM s !!r Nr )daemonc . [ [ 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 )NF-: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 %&)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 g g r )r7 r9 r; r s r
runBaseProcess.rung s) << LL$** 5 5 r c U R 5 [ 5 U R U 5 U l U R R U l U ?U ?U ?[ R U 5 g r ) rK r r r sentinel _sentinelr7 r9 r; r rA r s r
startBaseProcess.startn sS
kk$' --
L$*dl
dr c X U R 5 U R R 5 g r )rK r terminater s r
rV BaseProcess.terminate s
r c X U R 5 U R R 5 g r )rK r killr s r
rY BaseProcess.kill s
r c U R 5 U R R U5 nUb [ R U 5 g g r )rK r waitr r )r timeoutress r
r> BaseProcess.join s>
kk w' ? d # r c U R 5 U [ L a gU R c gU R R 5 nUc g[ R U 5 g)NTF)rK r
r r r r )r
returncodes r
is_aliveBaseProcess.is_alive sW
# # ;; [[%%'
d #r c U R b^ U R R 5 c [ S5 eU R R 5 S U l U ?[
R
U 5 SU l g )Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r rJ closerR r r r6 r s r
re BaseProcess.close sg ;; "{{ !) "P Q Q KK DK d # r c U R $ r r? r s r
r4 BaseProcess.name s zzr c Xl g r rh )r r4 s r
r4 ri s
r c : U R R SS5 $ )Nr" F)r/ getr s r
r" BaseProcess.daemon s
|| %00r c XR S' g )Nr" r/ )r daemonics r
r" rm s "* X r c U R S $ Nauthkeyro r s r
rs BaseProcess.authkey s ||I&&r c 4 [ U5 U R S' g rr )AuthenticationStringr/ )r rs s r
rs rt s
#7w"? Y r c U R 5 U R c U R $ U R R 5 $ r )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
$ r )rK r
r1 r2 r pidr s r
identBaseProcess.ident s<
# #99; ;;24;;?? 2r c p U R 5 U R $ ! [ a
[ S5 S ef = f)Nzprocess not started)rK rR AttributeErrorrJ r s r
rQ 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? appendr{ _exitcode_to_namerl r" r> )r rx 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
SystemExitcode
isinstanceintsysstderrwriter' tracebackr4 print_exc _shutdown_flush_std_streams)r parent_sentinelr r old_processrx 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 rR r7 r" r ) r=
__module__ __qualname____firstlineno__r rG rK rN rS rV rY r> rb re propertyr4 setterr" rs rx r| r{ rQ r r staticmethodr __static_attributes__r r r
r r G s/ " "$T2 &96 $ $& "
[[ 1 1 ]]* * ' '
^^@ @ " " 3 3 C
> >'>+Z " "r r c \ rS rSrS rSrg)rv 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 TypeErrorrv bytes)r r s r
__reduce__ AuthenticationString.__reduce__[ s3 / '2
$eDk^33r r N)r= r r r r r r r r
rv rv Z s 4r rv 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 rR r/ )r r4 r{ rQ s r
rG _ParentProcess.__init__k s5
! r c < SSK Jn U" U R /SS9( + $ Nr )r\ )r] multiprocessing.connectionr\ rR )r r\ s r
rb _ParentProcess.is_aliveu s 3 (!444r c U R $ r )r r s r
r| _ParentProcess.identy s yyr Nc 4 SSK Jn U" U R /US9 g r r )r r] r\ s r
r> _ParentProcess.join} s 4 dnn
w/r )r6 r/ r. r? r3 r r rR r ) r= r r r rG rb r r| r> r{ 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)rs semprefix) r. r? r3 r r6 rv r1 urandomr/ r s r
rG _MainProcess.__init__ sB "
#7
2#G%*, r c g r r r s r
re _MainProcess.close s r )r6 r/ r. r? r3 r N)r= r r r rG re 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 rv 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