$84 GRAYBYTE WORDPRESS FILE MANAGER $83



��Yf��@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@sXeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
S)�SemaphoreTrackerc

Cstj
�|_d|_dS)
N)�	threadingZLock�_lock�_fd)
�self�r
�F/opt/alt/python35/lib64/python3.5/multiprocessing/semaphore_tracker.py�__init__s

zSemaphoreTracker.__init__c


Cs|j�
|j
S)
N)rr)
rr
r
r�getfd!s


zSemaphoreTracker.getfdc
Cs
|j��
|j
d
k	rd
Sg}
y|
jtjj��

Wntk
rQ


Yn
Xd}tj�\}}zyW|
j|�

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


tj|�

�Yn
X||_
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.Nz;from multiprocessing.semaphore_tracker import main;main(%d)z-c)r
r�append�sys�stderr�fileno�	Exception�os�piperZget_executablerZ_args_from_interpreter_flagsZspawnv_passfds�close)rZfds_to_pass�cmd�
r�
wZexe�argsr
r
rr%s*





















zSemaphoreTracker.ensure_runningcCs|jd
|
�
dS)z2Register name of semaphore with semaphore tracker.ZREGISTERN)
�_send)r�namer
r
rrCszSemaphoreTracker.registercCs|jd
|
�
dS)z4Unregister name of semaphore with semaphore tracker.Z
UNREGISTERN)
r)rrr
r
rrGszSemaphoreTracker.unregistercCst|j�
d
j
|
|�jd�
}t|�
dkrCtd�
�
tj|j|�}|t|�
kspt�
dS)Nz{0}:{1}
�asciiiz
name too long)	r�format�encode�len�
ValueErrorr�writer�AssertionError)rrr�msg�nbytesr
r
rrKs





zSemaphoreTracker._sendN)	�__name__�
__module__�__qualname__rrrrrrr
r
r
rrsrc
-Cs�
tjtj
tj�
tjtjtj�
x=tjtjfD])}
y|
j�
Wq?tk
rg


Yq?Xq?Wt	�}z�t
|d
���}
x�|
D]�}yg|j�jd�
\}}|dkr�|j
|�

n,|dkr�|j|�

ntd|�
�
Wq�tk
r4



ytjtj��
Wn


Yn
XYq�Xq�WWdQRXWd|rz
ytjdt|�
�

Wntk
ry



Yn
Xxu|D]m}zc|jd�
}ytj|�

Wn<tk
r�

}
ztjd	||f�

WYdd}~Xn
XWdXq�
WXdS)
zRun semaphore tracker.�rb�
:sREGISTERs
UNREGISTERzunrecognized command %rNzRsemaphore_tracker: There appear to be %d leaked semaphores to clean up at shutdownrzsemaphore_tracker: %r: %s)�signal�SIGINT�SIG_IGN�SIGTERMr�stdin�stdoutrr�set�open�strip�split�add�remove�RuntimeError�
excepthook�exc_info�warnings�warnr"�decode�_multiprocessingZ
sem_unlink)�fd�
f�cache�linerr�
er
r
r�main]sJ





		
















	









.rE)rr-rr	r<r?�rr�__all__�objectrZ_semaphore_trackerrrrrrEr
r
r
r�<module>s





;