File manager

U

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

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

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



zResourceTracker.__init__c

	CsT|j�D
|j
dkr W5QR�dSt�|j
�

d|_
t�|jd
�
d|_W5QRXdS)Nr
)rr�os�close�waitpidrrr
r
r�_stop5s




zResourceTracker._stopc

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

zResourceTracker.getfdc
Cst
|j�
�b
|j
d
k	r~|��r*W5QR�d
St�|j
�

z|jd
k	rPt�|jd�
Wntk
rf


YnXd
|_
d
|_t�	d�

g}
z|
�
tj�
��

Wntk
r�


YnXd}t��\}}z�zr|
�
|�

t��}|g
t��}|d||g7}z&t�
rt�tjt�
t�|||
�}W5t�
r,t�tjt�
XWn


t�|�

�YnX||_
||_W5t�|�

XW5QRXd
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_executablerZ_args_from_interpreter_flags�
_HAVE_SIGMASK�signalr�SIG_UNBLOCK�_IGNORED_SIGNALS�	SIG_BLOCKZspawnv_passfds)rZfds_to_pass�cmd�
r�
wZexe�args�pidr
r
rrFsJ





























zResourceTracker.ensure_runningc

Cs2zt�
|jd
�
Wntk
r(


YdSXdSdS)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.�
UNREGISTERNr3r5r
r
rr�szResourceTracker.unregistercCsb|��
d
�
|
||��d�
}t|�
dkr0td�
�
t�|j|�}|t|�
ks^td�
|t|�
��
�
dS)Nz{0}:{1}:{2}
�asciiiz
name too longznbytes {0:n} but len(msg) {1:n})	r�format�encode�len�
ValueErrorrr0r�AssertionError)rr+r6r7�msg�nbytesr
r
rr4�s





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

Cst�tj
tj�
t�tjtj�
tr2t�tjt�
tj	tj
fD]&}
z|
��
Wq>tk
rb


Yq>Xq>d
d�t
��D�
}z�t|d���}
|
D]�}z�|���d�
�d�
\}}}t
�|d�}	|	dkr�td	|�d
|���
�
|dkr�||�|�

n2|dk�
r||�|�

n|d
k�
rntd|�
�
Wq�tk
�
rT


ztjt���
Wn


YnXYq�Xq�W5QRXW5|��D]�\}}|�
r�zt�dt|�
|f�

Wntk
�
r�


YnX|D]V}zLzt
||�

Wn6tk
�
r�
}
zt�d||f�

W5d}~XYnXW5X�
q��
qnXdS)zRun resource tracker.c
Ssi|]}
|
t��qSr
)
�set)�.0r7r
r
r�
<dictcomp>�szmain.<locals>.<dictcomp>zQresource_tracker: There appear to be %d leaked %s objects to clean up at shutdownzresource_tracker: %r: %sN�rbr9�
:zCannot register z. for automatic cleanup: unknown resource type r2r8ZPROBEzunrecognized command %r)r'�SIGINT�SIG_IGN�SIGTERMr&rr(r)r!�stdin�stdoutrr$�_CLEANUP_FUNCS�keys�itemsrrr<�open�strip�decode�split�getr=�add�remove�RuntimeError�
excepthook�exc_info)
�fd�
f�cacher7Zrtype_cacher6�
e�liner+Zcleanup_funcr
r
r�main�s^














�















�






(r`)rr'r!rr�rr�__all__�hasattrr&rIrKr)rNr6Z_multiprocessingZ_posixshmem�updateZ
sem_unlinkZ
shm_unlink�objectrZ_resource_trackerrrrrr`r
r
r
r�<module>s4







�




�w