!A?hk/ & g d Z ddlZddlZddlZddlZddlZddlmZ ej ej
Z n
# e $ r dZ Y nw xY wd 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 ej d a e a [i Z e ej D ] \ Z!Z"e!dd dk r
de!vr de! e e" < ![![" e Z#dS )) BaseProcesscurrent_processactive_childrenparent_process N)WeakSetc t S )z@
Return process object representing the current process
)_current_process D/opt/alt/python-internal/lib64/python3.11/multiprocessing/process.pyr r % s
r c F t t t S )zN
Return list of process objects corresponding to live child processes
)_cleanuplist _childrenr
r r r r + s
JJJ ??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 ]9} | j x}r.| t | :d S N)r r _popenpolldiscard)p child_popens r r r = sV
)__ ! ! 8 #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 ZdS ) 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 6 t t }t j |fz | _ t j | _ t
j | _ t j | _
d | _ d| _ || _
t | | _ t! | | _ |p;t% | j dz d d | j D z | _ ||| _ t. | d S )NF-:c 3 4 K | ]}t | V d S r )str).0is r <genexpr>z'BaseProcess.__init__.<locals>.<genexpr>^ s( = =c!ff = = = = = =r )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 %&&)3uh>'/4466 9;; , 1 4[[
F|| >T$ZZ 03 6XX = =dn = = === >
DK
dr c 2 | j rt d d S )Nzprocess object is closed)r3
ValueErrorr s r
_check_closedzBaseProcess._check_closedc s% < 9 788 8 9 9r c F | j r | j | j i | j dS dS )zQ
Method to be run in sub-process; can be overridden in sub-class
N)r4 r6 r8 r s r runzBaseProcess.rung s9 < 6 DL$* 5 5 5 5 5 5 6 6r c | t | | | _ | j j | _ | `| `| `t
| dS )z%
Start child process
N) rG r r r sentinel _sentinelr4 r6 r8 r r> r s r startzBaseProcess.startn sg
kk$'' -
L$*dl
dr c ` | | j dS )zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)rG r terminater s r rO zBaseProcess.terminate s0
r c ` | | j dS )zT
Terminate process; sends SIGKILL signal or uses TerminateProcess()
N)rG r killr s r rQ zBaseProcess.kill s0
r c | | j | }| t | dS dS )z5
Wait until child process terminates
N)rG r waitr r )r timeoutress r r; zBaseProcess.join sS
k w'' ? d # # # # # ?r c | | t u rdS | j dS | j }|dS t | dS )z1
Return whether process is alive
TNF)rG r r r r r )r
returncodes r is_alivezBaseProcess.is_alive sm
# # #4 ; 5[%%''
4 d # # #5r c | j d| j t d | j d| _ | `t
| d| _ dS )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 sz ; "{ !!) "P Q Q Q K DK d # # # r c | j S r r< r s r r1 zBaseProcess.name s
zr c || _ d S r r\ )r r1 s r r1 zBaseProcess.name s
r c 8 | j dd S )z4
Return whether process is a daemon
r F)r, getr s r r zBaseProcess.daemon s
| %000r c || j d< dS )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< dS )z2
Set authorization key of process
rd N)AuthenticationStringr, )r rd s r rd zBaseProcess.authkey s
#7w"?"? Y r c x | | j | j S | j S )zM
Return exit code of process or `None` if it has yet to stop
)rG r r r s r exitcodezBaseProcess.exitcode s:
; ; { !!!r c | | t u rt j S | j o | 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?
# # #9;; ;24;? 2r c v | | 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 sO
>> ! > > > 233 = >s 8c d }| t u rd}nS| j rd}nI| j t j k rd}n*| j d}n | j }|d}nd}t | j d| j z g}| j "|
d| j j z |
d| j z |
| |3t
|| }|
d |z | j r|
d
d d | 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__ sF # # # FF
\ # FF
,
, FF
[
FF{''))H#""T
#Y%;< ; " KK4;?2 3 3 3 K$"22333 F (,,Xx@@H KK
0 1 1 1 ; " KK ! ! !&&r c ddl m}m} | j | | j t j d at a |
t }| a t | j
| j | at j r%t! j | ~n# ~w xY w| d | d}| n# | w xY wn# t0 $ rl}|j d}nXt5 |j t6 r|j }n6t8 j t? |j dz d}Y d }~nKd }~w d}dd l }t8 j d| j! z |" Y nxY wt! j# | d|z |$ nD# t! j# | d|z |$ w xY w|S )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 1 I *K # ,!4#3_ F FO/
9%''66888
""" KK II8 9 9 9
&
##%%%%##%%%%% v~ AFC((
6
QVt!3444 "H J _ty 8 9 9 9 ! ! ! ! ! ! ! ! II88C D D D # # % % % %
! ! ! II88C D D D # # % % % %sc B,D. 7C
D.
CD. )D ?D. D**D. -H* .
G'8A"F H* AG'%H* *AI+c l ddl m} | j | d S )Nr{ r| )r r| _finalizer_registryclear_run_after_forkersr s r r zBaseProcess._after_forkR sA &&((( !!!!!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 s
" " " "$T2 &9 9 96 6 6 $ $ $ $ $ & " X
[ [ 1 1 X1 ]* * ]* ' ' X'
^@ @ ^@ " " X" 3 3 X3 C
> > X >' ' '>. . . .` " " \" " "r r c e Zd Zd ZdS )rf c n 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__^ sO ////// '2
$eDkk^33r N)r: r r r r
r r rf rf ] s# 4 4 4 4 4r rf c < e Zd Zd Zd Zed ZddZeZdS )r c v d| _ || _ || _ d | _ d | _ d| _ || _ i | _ d S )Nr
F)r+ r< _pidr0 r r3 rL r, )r r1 rj rK s r rD z_ParentProcess.__init__n s?
! r c 6 ddl m} || j gd S )Nr rS rT multiprocessing.connectionrS rL )r rS s r rX z_ParentProcess.is_alivex s1 3333334 (!44444r c | j S r )r r s r rk z_ParentProcess.ident| s
yr Nc 8 ddl m} || j g| dS )z6
Wait until parent process terminates
r r r Nr )r rT rS s r r; z_ParentProcess.join s6 433333 dn
w//////r r ) r: r r rD rX r rk r; rj r
r r r r l sb 5 5 5 X0 0 0 0 CCCr r c e Zd Zd Zd ZdS ) _MainProcessc d| _ d| _ d | _ d | _ d| _ t t
j d dd| _ d S )Nr
MainProcessF z/mp)rd semprefix) r+ r< r0 r r3 rf r. urandomr, r s r rD z_MainProcess.__init__ sN "
#7
2#G#G%*, , r c d S r r
r s r rZ z_MainProcess.close s r N)r: r r rD rZ r
r r r r s2 , , ,$
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 <module>r s:
7??929;;//LL LLL ! ! !O" O" O" O" O"& O" O" O"l4 4 4 4 45 4 4 4 [ B
;
0 <>> "9?1%% CEE D ..0011 0 0LD& BQBx3d??%/ZZ6'"&
GII s 'A AA