$82 GRAYBYTE WORDPRESS FILE MANAGER $58

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
dk	rRtj|j
tj�\}
}|
s0dStj|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||_|
|_
Wdtj|�

XWdQRXdS)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)NZREGISTER)
�_send)r
�namerrrrQszSemaphoreTracker.registercCs|jd
|
�
dS)NZ
UNREGISTER)
r#)r
r$rrrrUszSemaphoreTracker.unregistercCs@|j�
d
j
|
|�jd�
}t|�
dkr.td�
�
tj|j|�}dS)Nz{0}:{1}
�asciiiz
name too long)r�format�encode�len�
ValueErrorr�writer)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)	N�rb�
:sREGISTERs
UNREGISTERzunrecognized command %rzRsemaphore_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































(rH)rr2rr	rrB�rr�__all__�objectrZ_semaphore_trackerrrrrrHrrrr�<module>s






I