o
0¦i9/ ã @ s2 g d ¢Z ddlZddlZddlZddlZddlZddlmZ z
ej e
¡ ¡Z W n e y3 dZ Y nw dd„ Z
dd„ Zdd „ Zd
d „ ZG d d
„ d
eƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZdaeƒ ae d¡aeƒ a [i Z e ej ¡ ƒD ]\Z!Z"e!dd… dkr“de!vr“de!› e e" < q{eƒ Z#dS ))Ú BaseProcessÚcurrent_processÚactive_childrenÚparent_processé N)ÚWeakSetc C ó t S )z@
Return process object representing the current process
)Ú_current_process© r r ú>/opt/alt/python310/lib64/python3.10/multiprocessing/process.pyr % ó r c C s t ƒ ttƒS )zN
Return list of process objects corresponding to live child processes
)Ú_cleanupÚlistÚ _childrenr r r r
r + s r c C r )z?
Return process object representing the parent process
)Ú_parent_processr r r r
r 3 r r c C s* t tƒD ]} | j ¡ d urt | ¡ qd S ©N)r
r Ú_popenÚpollÚdiscard)Úpr r r
r = s
€þr c @ s e Zd ZdZdd„ Zddddi fddœdd„Zd d
„ Zd d „ Zd
d„ Zdd„ Z dd„ Z
d.dd„Z dd„ Z dd„ Z
edd„ ƒZejdd„ ƒZed d „ ƒZejd d „ ƒZed d „ ƒZejd!d „ ƒZed"d#„ ƒZed$d%„ ƒZeZed&d'„ ƒZd(d)„ Zd.d*d+„Zed,d-„ ƒZdS )/r z€
Process objects represent activity that is run in a separate process
The class is analogous to `threading.Thread`
c C s t ‚r )ÚNotImplementedError©Úselfr r r
Ú_PopenM ó zBaseProcess._PopenNr )Údaemonc C s° |d u sJ dƒ‚t tƒ}tj|f | _tj ¡ | _t ¡ | _tj | _
d | _ d| _ || _
t|ƒ| _t|ƒ| _|pHt| ƒjd d dd„ | jD ƒ¡ | _|d urQ|| _t | ¡ d S )Nz#group argument must be None for nowFú-ú:c s s | ]}t |ƒV qd S r )Ústr)Ú.0Úir r r
Ú ^ s € z'BaseProcess.__init__..)ÚnextÚ_process_counterr Ú _identityÚ_configÚcopyÚosÚgetpidÚ _parent_pidÚnameÚ _parent_namer Ú_closedÚ_targetÚtupleÚ_argsÚdictÚ_kwargsÚtypeÚ__name__ÚjoinÚ_namer Ú _danglingÚadd)r ÚgroupÚtargetr) ÚargsÚkwargsr Úcountr r r
Ú__init__P s"
ÿzBaseProcess.__init__c C s | j rtdƒ‚d S )Nzprocess object is closed)r+ Ú
ValueErrorr r r r
Ú
_check_closedc s ÿzBaseProcess._check_closedc C s" | j r| j | ji | j¤Ž dS dS )zQ
Method to be run in sub-process; can be overridden in sub-class
N)r, r. r0 r r r r
Úrung s ÿzBaseProcess.runc C sz | ¡ | jdu s
J dƒ‚| jt ¡ ksJ dƒ‚tj d¡r"J dƒ‚tƒ | | ¡| _| jj
| _ | ` | `
| `t | ¡ dS )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)r> r r( r& r' r r$ Úgetr r ÚsentinelÚ _sentinelr, r. r0 r r6 r r r r
Ústartn s ÿÿ
zBaseProcess.startc C ó | ¡ | j ¡ dS )zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)r> r Ú terminater r r r
rE € ó zBaseProcess.terminatec C rD )zT
Terminate process; sends SIGKILL signal or uses TerminateProcess()
N)r> r Úkillr r r r
rG ‡ rF zBaseProcess.killc C sV | ¡ | jt ¡ ksJ dƒ‚| jdusJ dƒ‚| j |¡}|dur)t | ¡ dS dS )z5
Wait until child process terminates
z can only join a child processNz can only join a started process)r> r( r& r' r Úwaitr r )r ÚtimeoutÚresr r r
r3 Ž s ÿzBaseProcess.joinc C s\ | ¡ | tu r
dS | jt ¡ ksJ dƒ‚| jdu r dS | j ¡ }|du r'dS t | ¡ dS )z1
Return whether process is alive
Tz can only test a child processNF) r> r r( r& r' r r r r )r Ú
returncoder r r
Úis_alive™ s
zBaseProcess.is_alivec C sH | j dur | j ¡ du rtdƒ‚| 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 r= ÚcloserB r r r+ r r r r
rM ¬ s
zBaseProcess.closec C ó | j S r )r4 r r r r
r) ½ ó zBaseProcess.namec C s t |tƒs J dƒ‚|| _d S )Nzname must be a string)Ú
isinstancer r4 )r r) r r r
r) Á s
c C s | j dd¡S )z4
Return whether process is a daemon
r F)r$ r@ r r r r
r Æ s zBaseProcess.daemonc C s | j du s J dƒ‚|| jd< dS )z1
Set whether process is a daemon
Nzprocess has already startedr )r r$ )r Zdaemonicr r r
r Í s c C s
| j d S )NÚauthkey)r$ r r r r
rQ Õ s
zBaseProcess.authkeyc C s t |ƒ| jd< dS )z2
Set authorization key of process
rQ N)ÚAuthenticationStringr$ )r rQ r r r
rQ Ù s c C s" | ¡ | jdu r | jS | j ¡ S )zM
Return exit code of process or `None` if it has yet to stop
N)r> r r r r r r
Úexitcodeà s
zBaseProcess.exitcodec C s& | ¡ | tu r t ¡ S | jo| jjS )zU
Return identifier (PID) of process or `None` if it has yet to start
)r> r r& r' r Úpidr r r r
Úidentê s zBaseProcess.identc C s* | ¡ z| jW S ty tdƒd‚w )z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)r> rB ÚAttributeErrorr= r r r r
rA ÷ s
ÿzBaseProcess.sentinelc C sè d }| t u r d}n&| jrd}n | jt ¡ krd}n| jd u r!d}n| j ¡ }|d ur-d}nd}t| ƒjd| j g}| jd urG|
d| jj ¡ |
d| j ¡ |
|¡ |d uret
||¡}|
d | ¡ | jrm|
d
¡ d d |¡ S )
NZstartedÚclosedÚunknownÚinitialZstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr z<%s>ú )r r+ r( r& r' r r r1 r2 r4 ÚappendrT Ú_exitcode_to_namer@ r r3 )r rS ZstatusÚinfor r r
Ú__repr__ s0
zBaseProcess.__repr__c
C sÌ ddl m}m} zÍzO| jd ur| | j¡ t d¡atƒ a |
¡ t }| a t | j
| j|ƒatjr6t ¡ ¡ z| ¡ W ~n~w | d¡ z | ¡ d}W | ¡ n| ¡ w W nY ty‰ } z%|jd u rhd}nt|jtƒrr|j}n
t j t |jƒd ¡ d}W Y d }~n?d }~w d}dd l }t j d| j! ¡ | "¡ Y W t #¡ | d| ¡ | $¡ |S W t #¡ | d| ¡ | $¡ |S W t #¡ | d| ¡ | $¡ |S t #¡ | d| ¡ | $¡ w )Né )ÚutilÚcontextz child process calling self.run()r Ú
z Process %s:
z process exiting with exitcode %d)%Ú r` ra Z
_start_methodZ_force_start_methodÚ itertoolsr; r" Úsetr Z _close_stdinr Ú_ParentProcessr* r( r Ú threadingZ_HAVE_THREAD_NATIVE_IDZ main_threadZ_set_native_idÚ _after_forkr] r? Z_exit_functionÚ
SystemExitÚcoderP ÚintÚsysÚstderrÚwriter Ú tracebackr) Ú print_excZ _shutdownZ_flush_std_streams)r Zparent_sentinelr` ra Z old_processrS Úero r r r
Ú
_bootstrap" sh
ÿ
€ í€üü
zBaseProcess._bootstrapc C s" ddl m} | j ¡ | ¡ d S )Nr_ ©r` )rc r` Z_finalizer_registryÚclearZ_run_after_forkersrs r r r
rh R s
zBaseProcess._after_forkr )r2 Ú
__module__Ú __qualname__Ú__doc__r r< r> r? rC rE rG r3 rL rM Úpropertyr) Úsetterr rQ rS rU rT rA r^ rr Ú staticmethodrh r r r r
r G sJ ÿ
0r c @ s e Zd Zdd„ ZdS )rR c C s, ddl m} |ƒ d u rtdƒ‚tt| ƒffS )Nr_ )Úget_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)ra r{ Ú TypeErrorrR Úbytes)r r{ r r r
Ú
__reduce__^ s
ÿz AuthenticationString.__reduce__N)r2 ru rv r~ r r r r
rR ] s rR c @ s6 e Zd Zdd„ Zdd„ Zedd„ ƒZd
dd „ZeZdS ) rf c C s4 d| _ || _|| _d | _d | _d| _|| _i | _d S )Nr F)r# r4 Ú_pidr( r r+ rB r$ )r r) rT rA r r r
r< n s
z_ParentProcess.__init__c C s ddl m} || jgdd S )Nr ©rH ©rI ©Zmultiprocessing.connectionrH rB )r rH r r r
rL x s z_ParentProcess.is_alivec C rN r )r r r r r
rU | rO z_ParentProcess.identNc C s ddl m} || jg|d dS )z6
Wait until parent process terminates
r r€ r Nr‚ )r rI rH r r r
r3 € s z_ParentProcess.joinr ) r2 ru rv r< rL rx rU r3 rT r r r r
rf l s
rf c @ s e Zd Zdd„ Zdd„ ZdS )Ú _MainProcessc C s8 d| _ d| _d | _d | _d| _tt d¡ƒddœ| _d S )Nr Z MainProcessFé z/mp)rQ Z semprefix) r# r4 r( r r+ rR r& Úurandomr$ r r r r
r< s ÿz_MainProcess.__init__c C s d S r r r r r r
rM ¡ r z_MainProcess.closeN)r2 ru rv r< rM r r r r
rƒ s rƒ r_ é ZSIGÚ_r )$Ú__all__r& rl Úsignalrd rg Z _weakrefsetr ÚpathÚabspathÚgetcwdZ ORIGINAL_DIRÚOSErrorr r r r Úobjectr r} rR rf rƒ r r r; r" re r r\ r
Ú__dict__Úitemsr) Zsignumr5 r r r r
Ú sB ÿ
!
€