Da

✏️ Editing: resource_tracker.cpython-310.opt-1.pyc

���w��rA״3��������������������@���s����d�dl�Z�d�dlZd�dlZd�dlZd�dlZddlmZ�ddlmZ�g�d�Ze	ed�Z
ejejfZ
ddd	��iZe�jd
krWd�dlZd�dlZe	ed�rOe�deji��e�d
eji��G�dd��de�Ze��ZejZejZejZejZdd��ZdS�)�����N����)�spawn)�util)�ensure_running�register�
unregister�pthread_sigmaskZnoopc�������������������C���s���d�S��N��r
���r
���r
����F/opt/plesk/python/3/lib/python3.10/multiprocessing/resource_tracker.py�<lambda>!���s����r����posix�
sem_unlink�	semaphoreZ
shared_memoryc�������������������@���sL���e�Zd�Zdd��Zdd��Zdd��Zdd��Zd	d
��Zdd��Zd
d��Z	dd��Z
dS�)�ResourceTrackerc�����������������C���s���t����|�_d�|�_d�|�_d�S�r	���)�	threading�Lock�_lock�_fd�_pid��selfr
���r
���r����__init__8���s���

zResourceTracker.__init__c�����������������C���sn���|�j��*�|�jd�u�r	�W�d�����d�S�t�|�j��d�|�_t�|�jd��d�|�_W�d�����d�S�1�s0w���Y��d�S�)Nr���)r���r����os�close�waitpidr���r���r
���r
���r����_stop=���s���
�"�zResourceTracker._stopc�����������������C���s���|������|�jS�r	���)r���r���r���r
���r
���r����getfdJ���s���zResourceTracker.getfdc�����������������C���s���|�j����|�jdur?|����r	�W�d����dS�t�|�j��z|�jdur)t�|�jd��W�n	�ty3���Y�nw�d|�_d|�_t�	d��g�}z
|�
tj�
����W�n	�tyT���Y�nw�d}t���\}}zXzA|�
|��t���}|gt����}|d||�g7�}ztr�t�tjt��t�|||�}W�tr�t�tjt��ntr�t�tjt��w�w�W�n	���t�|����||�_||�_W�t�|��nt�|��w�W�d����dS�1�s�w���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���Zfds_to_pass�cmd�r�wZexe�args�pidr
���r
���r���r���N���s^���
�
��
�
����
"�zResourceTracker.ensure_runningc�����������������C���s*���z
t��|�jd��W�dS��ty���Y�dS�w�)z;Check that the pipe has not been closed by sending a probe.s
���PROBE:0:noop
FT)r����writer����OSErrorr���r
���r
���r���r�������s�����zResourceTracker._check_alivec�����������������C�������|���d||��dS�)z0Register name of resource with resource tracker.�REGISTERN��_send�r����name�rtyper
���r
���r���r�����������zResourceTracker.registerc�����������������C���r6���)z2Unregister name of resource with resource tracker.�
UNREGISTERNr8���r:���r
���r
���r���r�������r=���zResourceTracker.unregisterc�����������������C���sB���|������d�|||��d�}t|�dkrtd��t�|�j|�}d�S�)Nz{0}:{1}:{2}
�asciii���zmsg too long)r����format�encode�len�
ValueErrorr���r4���r���)r���r/���r;���r<����msg�nbytesr
���r
���r���r9�������s
���zResourceTracker._sendN)�__name__�
__module__�__qualname__r���r���r���r���r���r���r���r9���r
���r
���r
���r���r���6���s����
@r���c�����������
������C���s���t���t�jt�j��t���t�jt�j��trt��t�jt��tj	tj
fD�]}z|����W�q�ty0���Y�qw�dd��t
���D��}z�t|�d��j}|D�]_}zF|����d��d�\}}}t
�|d�}|du�rgtd|��d|�����|d	krs||��|��n|d
kr||��|��n|dkr�ntd|���W�qC�ty����z	tjt������W�n���Y�Y�qCw�W�d����n1�s�w���Y��W�|���D�]I\}}|r�z
t�d
t|�|f���W�n	�ty����Y�nw�|D�])}z&zt
|�|��W�n�ty��}	�zt�d||	f���W�Y�d}	~	nd}	~	ww�W�q�w�q�dS�|���D�]N\}}|�r&z
t�d
t|�|f���W�n
�t�y%���Y�nw�|D�]+}z(zt
|�|��W�n�t�yO�}	�zt�d||	f���W�Y�d}	~	nd}	~	ww�W��q(w��qw�)zRun resource tracker.c�����������������S���s���i�|�]}|t����qS�r
���)�set)�.0r<���r
���r
���r����
<dictcomp>����s����zmain.<locals>.<dictcomp>�rbr?����:NzCannot register z. for automatic cleanup: unknown resource type r7���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�getrC����add�remove�RuntimeError�
excepthook�exc_info�itemsr ���r!���rB���)
�fd�f�cache�liner/���r;���r<���Zcleanup_funcZrtype_cache�er
���r
���r����main����s�������������

�������

�������re���)r���r*���r#���r���r �����r���r����__all__�hasattrr)���rN���rP���r,���rS���r;����_multiprocessingZ_posixshmem�updater���Z
shm_unlink�objectr����_resource_trackerr���r���r���r���re���r
���r
���r
���r����<module>���s:���
�

��w

📁 Sid Gifari File Manager