$98 GRAYBYTE WORDPRESS FILE MANAGER $55

B

� f[�@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

Cst�
�|_d|_d|_dS)
N)�	threadingZLock�_lock�_fd�_pid)
�self�r�F/opt/alt/python37/lib64/python3.7/multiprocessing/semaphore_tracker.py�__init__s



zSemaphoreTracker.__init__c

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

zSemaphoreTracker.getfdc
	
Cs
|j�
�
|j
d
k	rRt�|j
tj�\}
}|
s0d
St�|j�

d
|_d
|_
t�d�

g}y|�	t
j���

Wnt
k
r~


YnXd}t��\}}zlyB|�	|�

t��}|g
t��}|d||g7}t�|||�}
Wn


t�|�

�YnX||_|
|_
Wd
t�|�

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|�d
|
�
dS)z2Register name of semaphore with semaphore tracker.ZREGISTERN)
�_send)r
�namerrrrQszSemaphoreTracker.registercCs|�d
|
�
dS)z4Unregister name of semaphore with semaphore tracker.Z
UNREGISTERN)
r#)r
r$rrrrUszSemaphoreTracker.unregistercCs`|��
d
�
|
|��d�
}t|�
dkr.td�
�
t�|j|�}|t|�
ks\td�
|t|�
��
�
dS)Nz{0}:{1}
�asciiiz
name too longznbytes {0:n} but len(msg) {1:n})	r�format�encode�len�
ValueErrorr�writer�AssertionError)r
rr$�msg�nbytesrrrr#Ys





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


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

n |dkr�|�|�

ntd|�
�
Wqrtk
r�


ytjt���
Wn


YnXYqrXqrWWdQRXWd|�
r<yt�dt|�
�

Wntk
�
r:


YnXxf|D]^}zT|�d�
}yt�|�

Wn6tk
�
r�
}
zt�d	||f�

Wdd}~XYnXWdX�
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�mainlsJ































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






J