U
��,a�! � @ s� d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ dddgZe ed�Z
ej ej fZ
d d
d � iZe jd kr�d dlZd dlZe�ejejd
�� G dd� de�Ze� ZejZejZejZejZdd� Z dS )� N� )�spawn)�util�ensure_running�register�
unregister�pthread_sigmaskZnoopc C s d S �N� r
r
r
�E/opt/alt/python38/lib64/python3.8/multiprocessing/resource_tracker.py�<lambda>! � r �posix)Z 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 )� threadingZLock�_lock�_fd�_pid��selfr
r
r �__init__0 s
zResourceTracker.__init__c C sT | j �D | jd kr W 5 Q R � d S t�| j� d | _t�| jd� d | _W 5 Q R X 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 st | j ��b | jdk r~| �� r*W 5 Q R � dS t�| j� z | jdk rPt�| jd� W n tk
rf Y nX d| _d| _t� d� g }z|�
t j �
� � W n tk
r� Y nX d}t�� \}}z�zr|�
|� t�� }|gt�� }|d|| g7 }z&t�rt�tjt� t�|||�}W 5 t�r,t�tjt� X W n t�|� � Y nX || _|| _W 5 t�|� X W 5 Q R X 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 Z _args_from_interpreter_flags�
_HAVE_SIGMASK�signalr � SIG_UNBLOCK�_IGNORED_SIGNALS� SIG_BLOCKZspawnv_passfds)r Z fds_to_pass�cmd�r�wZexe�args�pidr
r
r r F sJ
z ResourceTracker.ensure_runningc C s2 zt �| jd� W n tk
r( Y dS X 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.�
UNREGISTERNr3 r5 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 r0 r )r r+ r6 r7 �msg�nbytesr
r
r r4 � s zResourceTracker._sendN) �__name__�
__module__� __qualname__r r r r r r r r4 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 k
rb Y q>X q>dd� t
�� D �}z�t| d���}|D ]�}z�|�� �d��d�\}}}t
�|d�} | dkr�td |� d
|� ���|d kr�|| �|� n2|d k�r|| �|� n|d
k�rn td| ��W q� t k
�rT ztj t� � � W n Y nX Y q�X q�W 5 Q R X W 5 |�� D ]�\}}|�r�zt�dt|�|f � W n t k
�r� Y nX |D ]V}zLzt
| |� W n6 t k
�r� } zt�d||f � W 5 d}~X Y nX W 5 X �q��qnX dS )zRun resource tracker.c S s i | ] }|t � �qS r
)�set)�.0r7 r
r
r �
<dictcomp>� s zmain.<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 r2 r8 ZPROBEzunrecognized command %r) r' �SIGINT�SIG_IGN�SIGTERMr& r r( r) r! �stdin�stdoutr r$ �_CLEANUP_FUNCS�keys�itemsr r r< �open�strip�decode�split�getr= �add�remove� RuntimeError�
excepthook�exc_info)
�fd�f�cacher7 Z rtype_cacher6 �e�liner+ Z cleanup_funcr
r
r �main� s^ �
�
(r_ ) r r' r! r r � r r �__all__�hasattrr& rH rJ r) rM r6 Z_multiprocessingZ _posixshmem�updateZ
sem_unlinkZ
shm_unlink�objectr Z_resource_trackerr r r r r_ r
r
r
r �<module> s4
�
�w