File manager

3


 \�@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZ
ddlmZ
dddgZ	Gdd	�d	e
�Ze�Zej
Z
ejZejZejZd
d�Zd
S)�N�
)
�spawn)
�util�ensure_running�register�
unregisterc@s<eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
S)�SemaphoreTrackerc

Cstj
�|_d|_d|_dS)
N)�	threadingZLock�_lock�_fd�_pid)
�self�r�9/usr/lib64/python3.6/multiprocessing/semaphore_tracker.py�__init__s



zSemaphoreTracker.__init__c


Cs|j�
|j
S)
N)rr)
r
rrr�getfd"s

zSemaphoreTracker.getfdc
	Cs
|j�
�
|j
d
k	rRtj|j
tj�\}
}|
s0d
Stj|j�

d
|_d
|_
tjd�

g}y|j	t
jj��

Wnt
k
r~


YnXd}tj�\}}zlyB|j	|�

tj�}|g
tj�}|d||g7}tj|||�}
Wn


tj|�

�YnX||_|
|_
Wd
tj|�

XWd
QRXd
S)z�Make sure that semaphore tracker process is running.

        This can be run from any process.  Usually a child process will use
        the semaphore created by its parent.NzWsemaphore_tracker: process died unexpectedly, relaunching.  Some semaphores might leak.z;from multiprocessing.semaphore_tracker import main;main(%d)z-c)r
r�os�waitpid�WNOHANG�closer�warnings�warn�append�sys�stderr�fileno�	Exception�piperZget_executablerZ_args_from_interpreter_flagsZspawnv_passfds)	r
�pidZstatusZfds_to_pass�cmd�
r�
wZexe�argsrrrr&s8
























zSemaphoreTracker.ensure_runningcCs|jd
|
�
dS)z2Register name of semaphore with semaphore tracker.ZREGISTERN)
�_send)r
�namerrrrQszSemaphoreTracker.registercCs|jd
|
�
dS)z4Unregister name of semaphore with semaphore tracker.Z
UNREGISTERN)
r#)r
r$rrrrUszSemaphoreTracker.unregistercCsP|j�
d
j
|
|�jd�
}t|�
dkr.td�
�
tj|j|�}|t|�
ksLt�
dS)Nz{0}:{1}
�asciiiz
name too long)	r�format�encode�len�
ValueErrorr�writer�AssertionError)r
rr$�msg�nbytesrrrr#Ys




zSemaphoreTracker._sendN)	�__name__�
__module__�__qualname__rrrrrr#rrrrrs+rc
-Cs�
tjtj
tj�
tjtjtj�
x6tjtjfD]&}
y|
j�
Wq.tk
rR


Yq.Xq.Wt	�}z�t
|d
���}
x�|
D]�}yJ|j�jd�
\}}|dkr�|j
|�

n |dkr�|j|�

ntd|�
�
Wqrtk
r�


ytjtj��
Wn


YnXYqrXqrWWdQRXWd|�
r<ytjdt|�
�

Wntk
�
r:


YnXxf|D]^}zT|jd�
}ytj|�

Wn6tk
�
r�
}
ztjd	||f�

WYdd}~XnXWdX�
qBWXdS)
zRun semaphore tracker.�rb�
:sREGISTERs
UNREGISTERzunrecognized command %rNzRsemaphore_tracker: There appear to be %d leaked semaphores to clean up at shutdownr%zsemaphore_tracker: %r: %s)�signal�SIGINT�SIG_IGN�SIGTERMr�stdin�stdoutrr�set�open�strip�split�add�remove�RuntimeError�
excepthook�exc_inforrr(�decode�_multiprocessingZ
sem_unlink)�fd�
f�cache�linerr$�
errr�mainksJ































(rI)rr3rr	rrC�rr�__all__�objectrZ_semaphore_trackerrrrrrIrrrr�<module>s






I