File manager

3


 \�#�@s
dd
dgZddl
Z
ddlZddlZddlZddlmZ
ye
jje
j	��
Z
Wnek
rb


dZ
YnXdd
�Zdd�Z
dd	�ZGd
d�de�ZGdd�de�ZGd
d�de�Ze�aejd�
ae�a[iZx<eejj��
D]*\ZZedd�dko�dekr�eee<q�We�ZdS)�BaseProcess�current_process�active_children�N)
�WeakSetc
CstS)
N)
�_current_process�rr�//usr/lib64/python3.6/multiprocessing/process.pyr#scCst�
t
t�
S)
N)�_cleanup�list�	_childrenrrrrr)s
c
Cs.x(tt
�
D]}|jj�dk	r
t
j|�

q
WdS)
N)r
r�_popen�poll�discard)
�
prrrr	4s

r	c@s�eZ
dZd
d�Zdddfifdd�
dd�Zdd�Zd	d
�Zdd�Zd$d
d�
Zdd�Z	e
dd��
Zejdd��
Ze
dd��
Z
e
jdd��
Z
e
dd��
Zejdd��
Ze
dd��
Ze
dd��
ZeZe
dd��
Zd d!�Zd"d#�ZdS)%r
c


Cst�
dS)
N)
�NotImplementedError)
�selfrrr�_PopenDs
zBaseProcess._PopenN)
�daemonc
Cs�tt
�
}tj|f
|_tjj�|_tj�|_d|_	||_
t|�
|_t
|�
|_|prt|�
jd
djdd�|jD�
�
|_|dk	r�||_tj|�

dS)N�
-�
:c
ss|]}
t|
�
V
qdS)
N)
�str)�.0�
irrr�	<genexpr>Ssz'BaseProcess.__init__.<locals>.<genexpr>)�next�_process_counterr�	_identity�_config�copy�os�getpid�_parent_pidr�_target�tuple�_args�dict�_kwargs�type�__name__�join�_namer�	_dangling�add)r�group�target�name�args�kwargsr�countrrr�__init__Gs














zBaseProcess.__init__c

Cs|jr|j|j
|j�

dS)
N)r"r$r&)
rrrr�runXs
zBaseProcess.runc

Cs6t�
|j
|�
|_|jj|_|`|`|`tj	|�

dS)
N)
r	rr�sentinel�	_sentinelr"r$r&rr,)
rrrr�start_s
	



zBaseProcess.startc


Cs|jj
�
dS)
N)r�	terminate)
rrrrr8pszBaseProcess.terminatecCs"|jj
|
�
}|dk	rtj|�

dS)
N)r�waitrr)rZtimeout�resrrrr)vs

zBaseProcess.joinc
CsB|tkrd
S|j
dkrdS|j
j�}
|
dkr0d
Stj|�

dSdS)NTF)rrr
rr)r�
returncoderrr�is_alive�s







zBaseProcess.is_alivec


Cs|jS)
N)
r*)
rrrrr/�szBaseProcess.namecCs
|
|_dS)
N)
r*)rr/rrrr/�sc

Cs|jj
d
d�S)NrF)r�get)
rrrrr�szBaseProcess.daemoncCs|
|jd
<dS)Nr)
r)rZdaemonicrrrr�sc

Cs
|jd
S)N�authkey)
r)
rrrrr>�szBaseProcess.authkeycCst|
�
|j
d
<dS)Nr>)�AuthenticationStringr)rr>rrrr>�sc

Cs|jdkr|jS|jj
�S)
N)rr
)
rrrr�exitcode�s


zBaseProcess.exitcodec

Cs"|tkrt
j�S|jo|jjSdS)
N)rrr r�pid)
rrrr�ident�s
zBaseProcess.identc

Cs(y|jSt
k
r"


td
�
�
YnXdS)Nzprocess not started)r6�AttributeError�
ValueError)
rrrrr5�s


zBaseProcess.sentinelc
Cs�|tkrd
}
n>|j
tj�kr"d}
n*|jdkr2d}
n|jj�dk	rH|j}
nd
}
t|
�
tkrv|
dkrfd}
ndt	j
|
|
�}
dt|�
j|j|
|j
r�dp�d	fS)
NZstarted�unknown�initialrZstoppedzstopped[%s]z<%s(%s, %s%s)>z daemon�)rr!rr rr
r@r'�int�_exitcode_to_namer=r(r*r)rZstatusrrr�__repr__�s










zBaseProcess.__repr__c
 CsJ
d
dlm
}
m}
�
zy||jdk	r,|j|j�

tjd
�
at�a	|
j
�
t}|az|
jj
�
|
j�
Wd~X|
jd�

z|j�
d}Wd|
j�
XWn�tk
r�
}
zL|js�d
}n:t|jdt�r�|jd}ntjjt|jd�
d�

d
}WYdd}~Xn2


d
}ddl}tjjd|j�

|j�
YnXWd|
jd|�

|
j�
X|S)N�
)�util�contextz child process calling self.run()r�

zProcess %s:
z process exiting with exitcode %d)rGrLrMZ
_start_methodZ_force_start_method�	itertoolsr2r�setrZ_close_stdinrZ_finalizer_registry�clearZ_run_after_forkers�infor4Z_exit_function�
SystemExitr0�
isinstancerH�sys�stderr�writer�	tracebackr/�	print_excZ_flush_std_streams)rrLrMZold_processr@�
erXrrr�
_bootstrap�sB































zBaseProcess._bootstrap)
N)r(�
__module__�__qualname__rr3r4r7r8r)r<�propertyr/�setterrr>r@rBrAr5rJr[rrrrr
>s(


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

|
�dkrtd�
�
tt|�
f
fS)NrK)
�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rMr`�	TypeErrorr?�bytes)rr`rrr�
__reduce__
s





zAuthenticationString.__reduce__N)r(r\r]rcrrrrr?
s
r?c@seZ
dZd
d�ZdS)�_MainProcessc

Cs2f|_d
|_
d|_d|_ttjd�
�
dd�|_dS)NZMainProcess� z/mp)r>Z	semprefix)rr*r!rr?r�urandomr)
rrrrr3-
s





z_MainProcess.__init__N)r(r\r]r3rrrrrd+
srdrK�ZSIG�
_) �__all__rrU�signalrO�_weakrefsetr�path�abspath�getcwdZORIGINAL_DIR�OSErrorrrr	�objectr
rbr?rdrr2rrPrrIr
�__dict__�itemsr/Zsignumr+rrrr�<module>
s2









`