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�
N)
�_current_process�r	r	�//usr/lib64/python3.8/multiprocessing/process.pyr%scCst�
t
t�
Sr)�_cleanup�list�	_childrenr	r	r	r
r+s
c
CstSr)
�_parent_processr	r	r	r
r3sc
Cs*tt
�
D]}|j��dk	rt
�|�

qdSr)rr
�_popen�poll�discard)
�
pr	r	r
r=s

rc@s�eZ
dZd
d�Zddddifdd�
dd�Zdd	�Zd
d�Zdd
�Zdd�Zdd�Z	d+dd�
Z
dd�Zdd�Ze
dd��
Zejdd��
Ze
dd��
Zejdd��
Ze
dd��
Zejd d��
Ze
d!d"��
Ze
d#d$��
ZeZe
d%d&��
Zd'd(�Zd,d)d*�
ZdS)-r
c


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

dS)NF�
-�
:c
ss|]}
t|
�
V
qdSr)
�str)�.0�
ir	r	r
�	<genexpr>^sz'BaseProcess.__init__.<locals>.<genexpr>)�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__Ps 













�

zBaseProcess.__init__c

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

zBaseProcess._check_closedc

Cs|jr|j|j
|j�

dSr)r)r+r-rr	r	r
�rungs
zBaseProcess.runc

Cs>|��
t
�
|�|�
|_|jj|_|`|`|`t	�
|�

dSr)r;rrr�sentinel�	_sentinelr)r+r-r
r3rr	r	r
�startns



zBaseProcess.startc

Cs|��
|j
��
dSr)r;r�	terminaterr	r	r
r@�s
zBaseProcess.terminatec

Cs|��
|j
��
dSr)r;r�killrr	r	r
rA�s
zBaseProcess.killcCs*|��
|j
�|
�
}|dk	r&t�|�

dSr)r;r�waitr
r)r�timeout�resr	r	r
r0�s

zBaseProcess.joinc
CsJ|��
|t
krd
S|jdkr"dS|j��}
|
dkr8d
St�|�

dSdS)NTF)r;rrrr
r)r�
returncoder	r	r
�is_alive�s








zBaseProcess.is_alivec

CsH|jdk	r>|j�
�dkr td
�
�
|j��
d|_|`t�|�

d|_dS)Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)rrr:�closer>r
rr(rr	r	r
rG�s








zBaseProcess.closec


Cs|jSr�
r1rr	r	r
r&�szBaseProcess.namecCs
|
|_dSrrH)rr&r	r	r
r&�sc

Cs|j�
d
d�S)NrF)r!�getrr	r	r
r�szBaseProcess.daemoncCs|
|jd
<dS)Nr�
r!)rZdaemonicr	r	r
r�sc

Cs
|jd
S�N�authkeyrJrr	r	r
rL�szBaseProcess.authkeycCst|
�
|j
d
<dSrK)�AuthenticationStringr!)rrLr	r	r
rL�sc

Cs"|��
|j
dkr|j
S|j
��Sr)r;rrrr	r	r
�exitcode�s



zBaseProcess.exitcodec

Cs*|��
|t
krt��S|jo$|jjSdSr)r;rr#r$r�pidrr	r	r
�ident�s

zBaseProcess.identc

Cs4|��
z|j
WStk
r.


td
�
d�YnXdS)Nzprocess not started)r;r>�AttributeErrorr:rr	r	r
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.r/r1�appendrO�_exitcode_to_namerIrr0)rrNZstatus�infor	r	r
�__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:
)'�r[r\�	threadingZ	_shutdownrXZ_flush_std_streamsZ
_start_methodZ_force_start_method�	itertoolsr8r�setr
Z_close_stdinr�_ParentProcessr'r%rZ_HAVE_THREAD_NATIVE_IDZmain_threadZ_set_native_idZ_finalizer_registry�clearZ_run_after_forkersZ_exit_functionr<�
SystemExitr6�
isinstance�int�sys�stderr�writer�	tracebackr&�	print_exc)rZparent_sentinelr[r\rNZold_process�
erjr	r	r
�
_bootstrap"
sR











�























zBaseProcess._bootstrap)
N)
N)r/�
__module__�__qualname__rr9r;r<r?r@rAr0rFrG�propertyr&�setterrrLrNrPrOr=rYrmr	r	r	r
r
GsB
�














	




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

|
�dkrtd�
�
tt|�
f
fS)NrZ)
�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r\rr�	TypeErrorrM�bytes)rrrr	r	r
�
__reduce__X
s




�zAuthenticationString.__reduce__N)r/rnrorur	r	r	r
rMW
s
rMc@s6eZ
dZd
d�Zdd�Zedd��
Zd
dd	�
ZeZdS)rbcCs4d
|_|
|_
||_d|_d|_d|_||_i|_dS)Nr	F)r r1�_pidr%rr(r>r!)rr&rOr=r	r	r
r9h
s







z_ParentProcess.__init__c
Csd
dlm
}

|
|jg
d
d�S�Nr)
rB)
rC�Zmultiprocessing.connectionrBr>)rrBr	r	r
rFr
s

z_ParentProcess.is_alivec


Cs|jSr)
rvrr	r	r
rPv
sz_ParentProcess.identNcCs d
dlm
}
||jg
|
d�
dSrwrx)rrCrBr	r	r
r0z
s
z_ParentProcess.join)
N)	r/rnror9rFrprPr0rOr	r	r	r
rbf
s



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

Cs8d
|_d|_
d|_d|_d|_tt�d�
�
dd�|_dS)Nr	ZMainProcessF� z/mp)rLZ	semprefix)	r r1r%rr(rMr#�urandomr!rr	r	r
r9�
s






�z_MainProcess.__init__c


CsdSrr	rr	r	r
rG�
s
z_MainProcess.closeN)r/rnror9rGr	r	r	r
ry�
sryrZ�ZSIG�
_r)$�__all__r#rg�signalr`r_Z_weakrefsetr�path�abspath�getcwdZORIGINAL_DIR�OSErrorrrrr�objectr
rtrMrbryrrr8rrar
rWr�__dict__�itemsr&Zsignumr2r	r	r	r
�<module>
s@
�










!