File manager

U

e5d�.�@s8
dd
ddgZddl
Z
ddlZddlZddlZddlZddlmZ
ze
j�	e
�
��
ZWnek
rl


dZYnXdd
�Z
dd�Zd	d�Zd
d�ZGdd�de�ZGd
d�de�ZGdd�de�ZGdd�de�Zdae�ae�d�
ae�a[iZeej� ��
D]0\Z!Z"e!dd�dkr�de!kr�de!��ee"<q�e�Z#dS)�BaseProcess�current_process�active_children�parent_process�N)
�WeakSetc
CstS)
z@
    Return process object representing the current process
    )
�_current_process�rr�//usr/lib64/python3.8/multiprocessing/process.pyr%scCst�
t
t�
S)
zN
    Return list of process objects corresponding to live child processes
    )�_cleanup�list�	_childrenrrrr	r+s
c
CstS)
z?
    Return process object representing the parent process
    )
�_parent_processrrrr	r3sc
Cs*tt
�
D]}|j��dk	rt
�|�

qdS�
N)rr�_popen�poll�discard)
�
prrr	r
=s

r
c@s�eZ
dZd
Zdd�Zddddifdd�
dd�Zd	d
�Zdd�Zd
d�Zdd�Z	dd�Z
d,dd�
Zdd�Zdd�Z
edd��
Zejdd��
Zedd��
Zejdd��
Zedd ��
Zejd!d ��
Zed"d#��
Zed$d%��
ZeZed&d'��
Zd(d)�Zd-d*d+�
ZdS).r
z�
    Process objects represent activity that is run in a separate process

    The class is analogous to `threading.Thread`
    c


Cst�
dSr)
�NotImplementedError�
�selfrrr	�_PopenMs
zBaseProcess._PopenNr)
�daemonc
Cs�|
dkstd
�
�
t
t�
}tj|f
|_tj��|_t��|_	tj
|_d|_d|_
||_t|�
|_t|�
|_|p�t|�
jdd�dd�|jD�
�
|_|dk	r�||_t�|�

dS)Nz#group argument must be None for nowF�
-�
:c
ss|]}
t|
�
V
qdSr)
�str)�.0�
irrr	�	<genexpr>^sz'BaseProcess.__init__.<locals>.<genexpr>)�AssertionError�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�countrrr	�__init__Ps"














�

zBaseProcess.__init__c

Cs|jrt
d
�
�
dS)Nzprocess object is closed)r)�
ValueErrorrrrr	�
_check_closedcs

zBaseProcess._check_closedc

Cs|jr|j|j
|j�

d
S)zQ
        Method to be run in sub-process; can be overridden in sub-class
        N)r*r,r.rrrr	�rungs
zBaseProcess.runc

Csz|��
|j
d
kstd�
�
|jt��ks0td�
�
tj�d�
rDtd�
�
t	�
|�
|�
|_
|j
j|_|`
|`|`t�|�

d
S)z%
        Start child process
        Nzcannot start a process twicez:can only start a process object created by current processrz3daemonic processes are not allowed to have children)r<rrr&r$r%rr"�getr
r�sentinel�	_sentinelr*r,r.rr4rrrr	�startns


�
�



zBaseProcess.startc

Cs|��
|j
��
d
S)zT
        Terminate process; sends SIGTERM signal or uses TerminateProcess()
        N)r<r�	terminaterrrr	rB�s
zBaseProcess.terminatec

Cs|��
|j
��
d
S)zT
        Terminate process; sends SIGKILL signal or uses TerminateProcess()
        N)r<r�killrrrr	rC�s
zBaseProcess.killcCsR|��
|j
t��kstd
�
�
|jdk	s0td�
�
|j�|
�
}|dk	rNt�|�

dS)z5
        Wait until child process terminates
        zcan only join a child processNzcan only join a started process)	r<r&r$r%rr�waitrr)r�timeout�resrrr	r1�s




zBaseProcess.joinc
Cs`|��
|t
krd
S|jt��ks*td�
�
|jdkr8dS|j��}
|
dkrNd
St�	|�

dSdS)z1
        Return whether process is alive
        Tzcan only test a child processNF)
r<rr&r$r%rrrrr)r�
returncoderrr	�is_alive�s









zBaseProcess.is_alivec

CsH|jd
k	r>|j�
�d
kr td�
�
|j��
d
|_|`t�|�

d|_d
S)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)rrr;�closer@rrr)rrrr	rI�s








zBaseProcess.closec


Cs|jSr)
r2rrrr	r'�szBaseProcess.namecCst|
t
�std
�
�
|
|_dS)Nzname must be a string)�
isinstancerrr2)rr'rrr	r'�s
c

Cs|j�
d
d�S)z4
        Return whether process is a daemon
        rF)r"r>rrrr	r�szBaseProcess.daemoncCs |jd
kst
d�
�
|
|jd<d
S)z1
        Set whether process is a daemon
        Nzprocess has already startedr)rrr")rZdaemonicrrr	r�s
c

Cs
|jd
S)N�authkey)
r"rrrr	rK�szBaseProcess.authkeycCst|
�
|j
d
<dS)z2
        Set authorization key of process
        rKN)�AuthenticationStringr")rrKrrr	rK�sc

Cs"|��
|j
d
kr|j
S|j
��S)zM
        Return exit code of process or `None` if it has yet to stop
        N)r<rrrrrr	�exitcode�s



zBaseProcess.exitcodec

Cs*|��
|t
krt��S|jo$|jjSd
S)zU
        Return identifier (PID) of process or `None` if it has yet to start
        N)r<rr$r%r�pidrrrr	�ident�s

zBaseProcess.identc

Cs4|��
z|j
WStk
r.


td
�
d�YnXdS)z{
        Return a file descriptor (Unix) or handle (Windows) suitable for
        waiting for process termination.
        zprocess not startedN)r<r@�AttributeErrorr;rrrr	r?�s




zBaseProcess.sentinelc
Cs�d}
|tkrd
}nL|j
rd}n@|jt��kr2d}n,|jdkrBd}n|j��}
|
dk	rZd}nd
}t|�
jd|j	g}|jdk	r�|�
d|jj�

|�
d|j�

|�
|�

|
dk	r�t�
|
|
�}
|�
d	|
�

|jr�|�
d
�

dd�|�
S)
NZstarted�closed�unknown�initialZstoppedzname=%rzpid=%sz	parent=%szexitcode=%srz<%s>�
 )rr)r&r$r%rrr/r0r2�appendrN�_exitcode_to_namer>rr1)rrMZstatus�inforrr	�__repr__
s0

























zBaseProcess.__repr__c
Csv
d
dlm
}m}
�
z>z�|jdk	r,|�|j�

t	�
d
�
at�a
|��
t}|at|j|j|
�atjrnt����
z|j��
|��
W5~X|�d�

z|��
d}W5|��
XWn�tk
�
r
}
zJ|js�d
}n:t|jdt�r�|jd}nt j!�"t#|jd�
d�

d
}W5d}~XYn2


d
}ddl$}t j!�"d|j%�

|�&�
YnXW5t��
|�d|�

|��
X|S)N�
)�util�contextz process exiting with exitcode %dz child process calling self.run()r�

zProcess %s:
)'�rZr[�	threadingZ	_shutdownrWZ_flush_std_streamsZ
_start_methodZ_force_start_method�	itertoolsr9r �setrZ_close_stdinr�_ParentProcessr(r&r
Z_HAVE_THREAD_NATIVE_IDZmain_threadZ_set_native_idZ_finalizer_registry�clearZ_run_after_forkersZ_exit_functionr=�
SystemExitr7rJ�int�sys�stderr�writer�	tracebackr'�	print_exc)rZparent_sentinelrZr[rMZold_process�
erhrrr	�
_bootstrap"
sR











�























zBaseProcess._bootstrap)
N)
N)r0�
__module__�__qualname__�__doc__rr:r<r=rArBrCr1rHrI�propertyr'�setterrrKrMrOrNr?rXrkrrrr	r
GsD

�














	




c@seZ
dZd
d�ZdS)rLc
Cs,d
dlm
}

|
�dkrtd�
�
tt|�
f
fS)NrY)
�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r[rq�	TypeErrorrL�bytes)rrqrrr	�
__reduce__X
s




�zAuthenticationString.__reduce__N)r0rlrmrtrrrr	rLW
s
rLc@s6eZ
dZd
d�Zdd�Zedd��
Zd
dd	�
ZeZdS)racCs4d
|_|
|_
||_d|_d|_d|_||_i|_dS)NrF)r!r2�_pidr&rr)r@r")rr'rNr?rrr	r:h
s







z_ParentProcess.__init__c
Csd
dlm
}

|
|jg
d
d�S)Nr�
rD�
rE�Zmultiprocessing.connectionrDr@)rrDrrr	rHr
s

z_ParentProcess.is_alivec


Cs|jSr)
rurrrr	rOv
sz_ParentProcess.identNcCs d
dlm
}
||jg
|
d�
dS)z6
        Wait until parent process terminates
        rrvrwNrx)rrErDrrr	r1z
s
z_ParentProcess.join)
N)	r0rlrmr:rHrorOr1rNrrrr	raf
s



rac@seZ
dZd
d�Zdd�ZdS)�_MainProcessc

Cs8d
|_d|_
d|_d|_d|_tt�d�
�
dd�|_dS)NrZMainProcessF� z/mp)rKZ	semprefix)	r!r2r&rr)rLr$�urandomr"rrrr	r:�
s






�z_MainProcess.__init__c


CsdSrrrrrr	rI�
s
z_MainProcess.closeN)r0rlrmr:rIrrrr	ry�
sryrY�ZSIG�
_r)$�__all__r$re�signalr_r^Z_weakrefsetr�path�abspath�getcwdZORIGINAL_DIR�OSErrorrrrr
�objectr
rsrLraryr
rr9r r`rrVr�__dict__�itemsr'Zsignumr3rrrr	�<module>
s@
�










!