File: //lib64/python3.9/multiprocessing/__pycache__/resource_tracker.cpython-39.opt-1.pyc
a
�DOg�! � @ s� d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ g d�Ze ed�Z
ej ej fZ
ddd � iZe jd
kr�d dlZd dlZe�ejejd �� G d d
� d
e�Ze� ZejZejZejZejZdd� Z dS )� N� )�spawn)�util)�ensure_running�register�
unregister�pthread_sigmaskZnoopc C s d S �N� r
r
r
�8/usr/lib64/python3.9/multiprocessing/resource_tracker.py�<lambda>! � r �posix)� semaphoreZ
shared_memoryc @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )�ResourceTrackerc C s t �� | _d | _d | _d S r )� threading�Lock�_lock�_fd�_pid��selfr
r
r �__init__0 s
zResourceTracker.__init__c C sj | j �P | jd u r"W d � d S t�| j� d | _t�| jd� d | _W d � n1 s\0 Y d S )Nr )r r �os�close�waitpidr r r
r
r �_stop5 s
zResourceTracker._stopc C s | � � | jS r )r r r r
r
r �getfdB s zResourceTracker.getfdc C s� | j ��� | jdur~| �� r,W d � dS t�| j� z | jdurRt�| jd� W n tyf Y n0 d| _d| _t� d� g }z|�
t j �
� � W n ty� Y n0 d}t�� \}}z�z�|�
|� t�� }|gt�� }|d|| g7 }z:t�rt�tjt� t�|||�}W t�r@t�tjt� nt�r>t�tjt� 0 W n t�|� � Y n0 || _|| _W t�|� n t�|� 0 W d � n1 �s�0 Y dS )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)r r � _check_aliver r r r �ChildProcessError�warnings�warn�append�sys�stderr�fileno� Exception�piper Zget_executabler � _args_from_interpreter_flags�
_HAVE_SIGMASK�signalr � SIG_BLOCK�_IGNORED_SIGNALS�spawnv_passfds� SIG_UNBLOCK)r Z fds_to_pass�cmd�r�wZexe�args�pidr
r
r r F sN
�
z ResourceTracker.ensure_runningc C s0 zt �| jd� W n ty& Y dS 0 dS dS )z;Check that the pipe has not been closed by sending a probe.s
PROBE:0:noop
FTN)r �writer �OSErrorr r
r
r r � s
z ResourceTracker._check_alivec C s | � d||� dS )z0Register name of resource with resource tracker.�REGISTERN��_send�r �name�rtyper
r
r r � s zResourceTracker.registerc C s | � d||� dS )z2Unregister name of resource with resource tracker.�
UNREGISTERNr7 r9 r
r
r r � s zResourceTracker.unregisterc C sB | � � d�|||��d�}t|�dkr0td��t�| j|�}d S )Nz {0}:{1}:{2}
�asciii z
name too long)r �format�encode�len�
ValueErrorr r4 r )r r/ r: r; �msg�nbytesr
r
r r8 � s zResourceTracker._sendN) �__name__�
__module__� __qualname__r r r r r r r r8 r
r
r
r r . s
@ r c
C s� t � t jt j� t � t jt j� tr2t �t jt� tj tj
fD ]$}z |� � W q> t y` Y q>0 q>dd� t
�� D �}�z�t| d���}|D ]�}z�|�� �d��d�\}}}t
�|d�}|du r�td|� d|� ���|d kr�|| �|� n2|d
k�r|| �|� n|d k�rn td | ��W q� t �yR ztjt�� � W n Y n0 Y q�0 q�W d � n1 �sl0 Y W |�� D ]�\}}|�r�zt� d
t |�|f � W n t �y� Y n0 |D ]X}zNzt
| |� W n8 t �y } z t� d|| f � W Y d} ~ n
d} ~ 0 0 W n0 �qq�n�|�� D ]�\}}|�rhzt� d
t |�|f � W n t �yf Y n0 |D ]X}zNzt
| |� W n8 t �y� } z t� d|| f � W Y d} ~ n
d} ~ 0 0 W n0 �ql�q*0 dS )zRun resource tracker.c S s i | ] }|t � �qS r
)�set)�.0r; r
r
r �
<dictcomp>� r
zmain.<locals>.<dictcomp>�rbr= �:NzCannot register z. for automatic cleanup: unknown resource type r6 r< 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) r r. r, r# �stdin�stdoutr r& �_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_funcZ rtype_cache�er
r
r �main� s� ��
0
�
*�
�
*rc ) r r* r# r r � r r �__all__�hasattrr) rL rN r, rQ r: �_multiprocessingZ _posixshmem�update�
sem_unlinkZ
shm_unlink�objectr �_resource_trackerr r r r rc r
r
r
r �<module> s2
�
�w