✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

a

�i�!�@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
gd�
Ze	e
d�Z
e
je
jfZ
ddd	�i
Zejd
kr�dd
lZdd
lZe�ejejd��

Gdd
�d
e�Ze�ZejZejZejZejZdd�Zd
S)�N�
)
�spawn)
�util)�ensure_running�register�
unregister�pthread_sigmaskZnoopc
CsdS�
N�r
r
r
�8/usr/lib64/python3.9/multiprocessing/resource_tracker.py�<lambda>!�r�posix)�	semaphoreZ
shared_memoryc@sLeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dS)�ResourceTrackerc

Cst�
�|_d|_d|_dSr	)�	threading�Lock�_lock�_fd�_pid�
�selfr
r
r�__init__0s



zResourceTracker.__init__c

Csj|j�P
|j
dur"Wd�
dSt�|j
�

d|_
t�|jd
�
d|_Wd�
n1s\0


Y
dS)Nr
)rr�os�close�waitpidrrr
r
r�_stop5s




zResourceTracker._stopc

Cs|��
|j
Sr	)rrrr
r
r�getfdBs

zResourceTracker.getfdc
Cs�
|j�
��
|j
d
u
r~|��r,Wd
�
d
St�|j
�

z|jd
u
rRt�|jd�
Wntyf


Yn0d
|_
d
|_t�	d�

g}
z|
�
tj�
��

Wnty�


Yn0d}t��\}}z�z�|
�
|�

t��}|g
t��}|d||g7}z:t�
rt�tjt�
t�|||
�}Wt�
r@t�tjt�
nt�
r>t�tjt�
0Wn


t�|�

�Yn0||_
||_Wt�|�

nt�|�

0Wd
�
n1�
s�0


Y
d
S)z�Make sure that resource tracker process is running.

        This can be run from any process.  Usually a child process will use
        the resource created by its parent.Nr
zUresource_tracker: process died unexpectedly, relaunching.  Some resources might leak.z:from multiprocessing.resource_tracker import main;main(%d)z-c)rr�_check_aliverrrr�ChildProcessError�warnings�warn�append�sys�stderr�fileno�	Exception�piperZget_executabler�_args_from_interpreter_flags�
_HAVE_SIGMASK�signalr�	SIG_BLOCK�_IGNORED_SIGNALS�spawnv_passfds�SIG_UNBLOCK)rZfds_to_pass�cmd�
r�
wZexe�args�pidr
r
rrFsN























�





zResourceTracker.ensure_runningc

Cs0zt�
|jd
�
Wnty&


YdS0dSdS)z;Check that the pipe has not been closed by sending a probe.s
PROBE:0:noop
FTN)r�writer�OSErrorrr
r
rr�s


zResourceTracker._check_alivecCs|�d
|
|�
dS)z0Register name of resource with resource tracker.�REGISTERN�
�_send�r�name�rtyper
r
rr�szResourceTracker.registercCs|�d
|
|�
dS)z2Unregister name of resource with resource tracker.�
UNREGISTERNr7r9r
r
rr�szResourceTracker.unregistercCsb|��
d
�
|
||��d�
}t|�
dkr0td�
�
t�|j|�}|t|�
ks^Jd�
|t|�
��
�
dS)Nz{0}:{1}:{2}
�asciiiz
name too longznbytes {0:n} but len(msg) {1:n})r�format�encode�len�
ValueErrorrr4r)rr/r:r;�msg�nbytesr
r
rr8�s





�zResourceTracker._sendN)�__name__�
__module__�__qualname__rrrrrrrr8r
r
r
rr.s
@rc

Cs�t�tj
tj�
t�tjtj�
tr2t�tjt�
tj	tj
fD]$}
z|
��
Wq>ty`


Yq>0q>d
d�t
��D�
}�
z�t|d���}
|
D]�}z�|���d�
�d�
\}}}t
�|d�}|dur�td|�d|���
�
|d	kr�||�|�

n2|d
k�
r||�|�

n|dk�
rntd|�
�
Wq�t�
yR


ztjt���
Wn


Yn0Yq�0q�Wd�
n1�
sl0


Y
W|��D]�\}}|�
r�zt�d
t|�
|f�

Wnt�
y�


Yn0|D]X}zNzt
||�

Wn8t�y
}	
zt�d||	f�

WYd}	~	n
d}	~	00Wn0�
q
q�n�|��D]�\}}|�rhzt�d
t|�
|f�

Wnt�yf


Yn0|D]X}zNzt
||�

Wn8t�y�
}	
zt�d||	f�

WYd}	~	n
d}	~	00Wn0�ql�q*0dS)zRun resource tracker.c
Ssi|]}
|
t��qSr
)
�set)�.0r;r
r
r�
<dictcomp>�r
zmain.<locals>.<dictcomp>�rbr=�
:NzCannot register z. for automatic cleanup: unknown resource type r6r<ZPROBEzunrecognized command %rzQresource_tracker: There appear to be %d leaked %s objects to clean up at shutdownzresource_tracker: %r: %s)r*�SIGINT�SIG_IGN�SIGTERMr)rr.r,r#�stdin�stdoutrr&�_CLEANUP_FUNCS�keys�open�strip�decode�split�getrA�add�remove�RuntimeError�
excepthook�exc_info�itemsr r!r@)
�fd�
f�cache�liner/r:r;Zcleanup_funcZrtype_cache�
er
r
r�main�s�















��











0



�






*�



�






*rc)rr*r#rr �rr�__all__�hasattrr)rLrNr,rQr:�_multiprocessingZ_posixshmem�update�
sem_unlinkZ
shm_unlink�objectr�_resource_trackerrrrrrcr
r
r
r�<module>s2






�




�w