File manager

�
e f�#�@sy
dd
dgZddl
Z
ddlZddlZddlZddlmZ
ye
jje
j	��
Z
Wnek
r�


dZ
Yn
Xdd
�Zdd�Z
dd	�ZGd
d�de�ZGdd�de�ZGd
d�de�Ze�aejd�
ae�a[iZxSeejj��
D]<\ZZedd�dkr,
dekr,
eee<q,
q,
We�ZdS)�BaseProcess�current_process�active_children�N)
�WeakSetc
CstS)
z@
    Return process object representing the current process
    )
�_current_process�rr�</opt/alt/python34/lib64/python3.4/multiprocessing/process.pyr#scCst�
t
t�
S)
zN
    Return list of process objects corresponding to live child processes
    )�_cleanup�list�	_childrenrrrrr)s
c
Cs@x9tt
�
D]+}|jj�dk	r
t
j|�

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

r	c	@sK
eZ
dZd
Zdd�Zdddfidddd�
Zdd	�Zd
d�Zdd
�Zddd�
Z	dd�Z
edd��
Zej
dd��
Zedd��
Zej
dd��
Zedd��
Zej
dd��
Zedd��
Zedd��
ZeZedd ��
Zd!d"�Zd#d$�ZdS)%r
z�
    Process objects represent activity that is run in a separate process

    The class is analogous to `threading.Thread`
    c


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

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�
nd
S)zQ
        Method to be run in sub-process; can be overridden in sub-class
        N)r"r$r&)
rrrr�runXs	
zBaseProcess.runc

Cs9t�
|j
|�
|_|jj|_tj|�

d
S)z%
        Start child process
        N)r	rr�sentinel�	_sentinelrr,)
rrrr�start_s	


zBaseProcess.startc


Cs|jj
�
d
S)zT
        Terminate process; sends SIGTERM signal or uses TerminateProcess()
        N)r�	terminate)
rrrrr8mszBaseProcess.terminatecCs2|jj
|
�
}|d
k	r.tj|�

nd
S)z5
        Wait until child process terminates
        N)r�waitrr)rZtimeout�resrrrr)ss

zBaseProcess.joinc

Cs@|tkrd
S|j
dkr#dS|j
j�
|j
jdkS)z1
        Return whether process is alive
        TNF)rrr
�
returncode)
rrrr�is_alive}s




zBaseProcess.is_alivec


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

Cs|jj
d
d�S)z4
        Return whether process is a daemon
        rF)r�get)
rrrrr�szBaseProcess.daemoncCs|
|jd
<dS)z1
        Set whether process is a daemon
        rN)
r)rZdaemonicrrrr�sc

Cs|jd
S)N�authkey)
r)
rrrrr>�szBaseProcess.authkeycCst|
�
|j
d
<dS)z2
        Set authorization key of process
        r>N)�AuthenticationStringr)rr>rrrr>�sc

Cs#|jd
kr|jS|jj
�S)zM
        Return exit code of process or `None` if it has yet to stop
        N)rr
)
rrrr�exitcode�s

zBaseProcess.exitcodec

Cs-|tkrt
j�S|jo(|jjSd
S)zU
        Return identifier (PID) of process or `None` if it has yet to start
        N)rrr r�pid)
rrrr�ident�s

zBaseProcess.identc

Cs0y|jSWnt
k
r+


td
�
�
Yn
XdS)z{
        Return a file descriptor (Unix) or handle (Windows) suitable for
        waiting for process termination.
        zprocess not startedN)r6�AttributeError�
ValueError)
rrrrr5�s



zBaseProcess.sentinelc
Cs�|tkrd
}
n]|j
tj�kr3d}
n?|jdkrKd}
n'|jj�dk	rl|j}
nd
}
t|
�
tkr�|
dkr�d}
q�dt	j
|
|
�}
ndt|�
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
(Cs�
d
dlm
}
m}
z�
y�|jdk	r>|j|j�

ntjd
�
at�a	t
jdk	r�y#t
jj�
t
tj�
t
_Wq�ttfk
r�


Yq�Xnt}|az|
jj�
|
j�
Wd~X|
jd�

z|j�
d}Wd|
j�
XWn�tk
r�

}
zd|js+
d
}nMt|jdt�rQ
|jd}n't
jjt|jd�
d�

d
}WYdd}~Xn;


d
}ddl }t
jjd|j!�

|j"�
Yn
XWd|
jd|�

t
j#j$�
t
jj$�
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�setr�sys�stdin�close�openr�devnull�OSErrorrDrZ_finalizer_registry�clearZ_run_after_forkers�infor4Z_exit_function�
SystemExitr0�
isinstancerH�stderr�writer�	tracebackr/�	print_exc�stdout�flush)rrLrMZold_processr@�
er]rrr�
_bootstrap�sN




	





















	
	

!








zBaseProcess._bootstrap)r(�
__module__�__qualname__�__doc__rr3r4r7r8r)r<�propertyr/�setterrr>r@rBrAr5rJrbrrrrr
>s*


	
c@seZ
dZd
d�ZdS)r?c
CsAd
dlm
}

|
�dkr.td�
�
ntt|�
f
fS)NrK)
�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rMrh�	TypeErrorr?�bytes)rrhrrr�
__reduce__
s




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

CsNf|_d
|_
d|_d|_ittjd�
�
d6dd6|_dS)NZMainProcess� r>z/mpZ	semprefix)rr*r!rr?r�urandomr)
rrrrr3*
s
	
	
	
	

z_MainProcess.__init__N)r(rcrdr3rrrrrl(
srlrK�ZSIG�
_) �__all__rrQ�signalrO�_weakrefsetr�path�abspath�getcwdZORIGINAL_DIRrVrrr	�objectr
rjr?rlrr2rrPrrIr
�__dict__�itemsr/Zsignumr+rrrr�<module>
s0








�	

	
"
"