ux_@ /SQrSSKrSSKrSSKrSSKrSSKrSSKJr \RR\R"55r Sr SrSrSr"SS \5r"S S \5r"S S \5r"SS\5rSq\"5q\R2"S5q\"5qC0r\"\R>RA55H"ur!r"\!SSS:XdMS\!;dMS\!3\\"*'M$ C!C"\"5r#g!\ a Sr Nf=f)) BaseProcesscurrent_processactive_childrenparent_processN)WeakSetc[$)z8 Return process object representing the current process )_current_process>/opt/alt/python313/lib64/python3.13/multiprocessing/process.pyrr%s  r c4[5 [[5$)zF Return list of process objects corresponding to live child processes )_cleanuplist _childrenr r r rr+s J  ?r c[$)z7 Return process object representing the parent process )_parent_processr r r rr3s  r c[[5H@nUR=n(dMUR5cM+[R U5 MB gN)rr_popenpolldiscard)p child_popens r rr=s; )_88 #K #)9)9);)G   a r c^\rSrSrSrSrSSSS04SS.SjjrSrS rS r S r S r SS jr Sr Sr\S5r\R"S5r\S5r\R"S5r\S5r\R"S5r\S5r\S5r\r\S5rSrSSjr\S5rSrg)rGzt Process objects represent activity that is run in a separate process The class is analogous to `threading.Thread` c[er)NotImplementedErrorselfs r _PopenBaseProcess._PopenMs!!r Nr )daemonc.[[5n[RU4-Ul[RR 5Ul[ R"5Ul[RUl SUl SUl X l [U5Ul[!U5UlU=(d; [%U5R&S-SR)SUR55-UlUbX`l[.R1U5 g)NF-:c38# UHn[U5v M g7fr)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)rgrouptargetr4argskwargsr"counts r __init__BaseProcess.__init__Ps%&)33uh>'//446 99;,11   4[ F| >T$Z0036XX=dnn==>   K dr c<UR(a [S5eg)Nzprocess object is closed)r6 ValueErrorrs r _check_closedBaseProcess._check_closedcs <<78 8 r ctUR(a'UR"UR0URD6 gg)zA Method to be run in sub-process; can be overridden in sub-class N)r7r9r;rs r runBaseProcess.rungs) << LL$** 5 5 r cUR5 [5 URU5UlURRUlU?U?U?[RU5 g)z Start child process N) rKrr rsentinel _sentinelr7r9r;rrArs r startBaseProcess.startnsS   kk$' -- L$*dl dr cXUR5 URR5 g)zD Terminate process; sends SIGTERM signal or uses TerminateProcess() N)rKr terminaters r rVBaseProcess.terminates   r cXUR5 URR5 g)zD Terminate process; sends SIGKILL signal or uses TerminateProcess() N)rKrkillrs r rYBaseProcess.kills   r cUR5 URRU5nUb[R U5 gg)z% Wait until child process terminates N)rKrwaitrr)rtimeoutress r r>BaseProcess.joins> kkw' ?   d # r cUR5 U[LagURcgURR5nUcg[R U5 g)z! Return whether process is alive TF)rKr rrrr)r returncodes r is_aliveBaseProcess.is_alivesW  # # ;; [[%%'     d #r cURb^URR5c [S5eURR5 SUlU?[ R U5 SUlg)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)rrrJcloserRrrr6rs r reBaseProcess.closesg ;; "{{!) "PQQ KK   DK   d # r cUR$rr?rs r r4BaseProcess.names zzr cXlgrrh)rr4s r r4ris  r c:URRSS5$)z$ Return whether process is a daemon r"F)r/getrs r r"BaseProcess.daemons ||%00r c XRS'g)z! Set whether process is a daemon r"Nr/)rdaemonics r r"rms "* Xr c URS$)Nauthkeyrors r rrBaseProcess.authkeys||I&&r c4[U5URS'g)z" Set authorization key of process rrN)AuthenticationStringr/)rrrs r rrrss #7w"? Yr cUR5 URc UR$URR5$)z= Return exit code of process or `None` if it has yet to stop )rKrrrs r exitcodeBaseProcess.exitcodes7  ;; ;; {{!!r cUR5 U[La[R"5$UR=(a URR $)zE Return identifier (PID) of process or `None` if it has yet to start )rKr r1r2rpidrs r identBaseProcess.idents<  # #99; ;;24;;?? 2r cpUR5 UR$![a [S5Sef=f)zc Return a file descriptor (Unix) or handle (Windows) suitable for waiting for process termination. zprocess not startedN)rKrRAttributeErrorrJrs r rQBaseProcess.sentinels<  >>> ! >23 = >s 5cSnU[LaSnOlUR(aSnOXUR[R"5:waSnO2UR cSnO"UR R 5nUbSnOSn[U5RSUR-/nUR b(URSUR R-5 URSUR-5 URU5 Ub)[RX5nURS U-5 UR(aURS 5 S S RU5-$) Nstartedclosedunknowninitialstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr"z<%s> )r r6r3r1r2rrr<r=r?appendrz_exitcode_to_namerlr"r>)rrwstatusinfos 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 cSSKJnJn URbUR UR5 [ R "S5q[5q UR5 [nUq [URURU5q[ R"(a#[ R$"5R'5 UR)5 AUR+S5 UR-5 Sn[ RD"5 UR+SU-5 URG5 U$!Af=f![.anUR0cSnSnAN_[3UR0[45(aUR0nSnAN[6R8R;[=UR05S-5 SnSnANSnAf SnSSKn[6R8R;SUR@-5 URC5 GN=f![ RD"5 UR+SW-5 URG5 f=f)N)utilcontextz child process calling self.run()r z Process %s: z process exiting with exitcode %d)$rr _start_method_force_start_method itertoolsrFr-setr _close_stdinr _ParentProcessr5r3r threading_HAVE_THREAD_NATIVE_ID main_thread_set_native_id _after_forkrrN SystemExitcode isinstanceintsysstderrwriter' tracebackr4 print_exc _shutdown_flush_std_streams)rparent_sentinelrr old_processrwers r _bootstrapBaseProcess._bootstrap"s#% &!!-++D,>,>?(q1 I    *K# ,!!4#3#3_FO//%%'668   " II8 9 HHJH    ! II88C D  # # %-  vv~AFFC((66   QVVt!34 "H  JJ  _tyy8 9    !    ! II88C D  # # %s[B9D9D3$D93D66D99 H GH+GH7G>HAH  H;I cdSSKJn URR5 UR 5 g)Nrr)rr_finalizer_registryclear_run_after_forkersrs r rBaseProcess._after_forkOs#   &&( !r ) r9r6r/r.r;r?r5r3rrRr7r"r)r= __module__ __qualname____firstlineno____doc__r rGrKrNrSrVrYr>rbrepropertyr4setterr"rrrwr{rzrQrr staticmethodr__static_attributes__r r r rrGs4 ""$T2&96$  $&" [[11  ]]**'' ^^@@ ""33 C  > >'>+Z""r rc\rSrSrSrSrg)ruiZcXSSKJn U"5c [S5e[[ U544$)Nr)get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rr TypeErrorrubytes)rrs r __reduce__AuthenticationString.__reduce__[s3/   '2 $eDk^33r r N)r=rrrrrr r r ruruZs4r ruc>\rSrSrSrSr\S5rSSjr\r Sr g) riicnSUlXlX lSUlSUlSUlX0l0Ulg)Nr F)r.r?_pidr3rr6rRr/)rr4rzrQs r rG_ParentProcess.__init__ks5    ! r c<SSKJn U"UR/SS9(+$)Nrr\r]multiprocessing.connectionr\rR)rr\s r rb_ParentProcess.is_aliveus3(!444r cUR$r)rrs r r{_ParentProcess.identys yyr Nc4SSKJn U"UR/US9 g)z& Wait until parent process terminates rrrNr)rr]r\s r r>_ParentProcess.join}s 4 dnn w/r )r6r/r.r?r3rrrRr) r=rrrrGrbrr{r>rzrr r r rris,50 Cr rc \rSrSrSrSrSrg) _MainProcessicSUlSUlSUlSUlSUl[ [ R"S55SS.Ulg)Nr MainProcessF z/mp)rr semprefix) r.r?r3rr6rur1urandomr/rs r rG_MainProcess.__init__sB"   #7 2#G%*, r cgrr rs r re_MainProcess.closes r )r6r/r.r?r3rN)r=rrrrGrerr r r rrs ,$ r rrSIG_r$)$__all__r1rsignalrr _weakrefsetrpathabspathgetcwd ORIGINAL_DIROSErrorrrrrobjectrrrurrrr rFr-rrrr__dict__itemsr4signumr@r r r rs"   77??299;/L !L"&L"f454[B ; 0>??1% E  ..01LD& BQx3d?'(Z6'"2 & I m Ls*C77DD