관리-도구

편집 파일: resource_tracker.cpython-39.pyc

a �����DOg�!����������������������@���s����d�d
l�Z�d�d
l
Z
d�d
lZd�d
lZd�d
lZddlmZ
�ddlmZ
�g�d�
Ze e
d�Z e
je
jfZ ddd ��i
Ze�jd kr�d�d
lZd�d
lZe�ejejd��

�G�dd ��d e�Ze��ZejZejZejZejZdd��Zd
S�)�����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�Z
d�Zd
d��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__0���s����


zResourceTracker.__init__c
�����������
������C���sj���|�j��P
�|�j
d�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���|�����
�|�j
S�r ���)r���r���r���r ���r ���r����getfdB���s����

zResourceTracker.getfdc
�����������������C���s�
��|�j��
��
�|�j
d
u
r~|����r,W�d
���
�d
S�t�|�j
�

�z|�jd
u
rRt�|�jd�
�W�n�tyf
�
�
�Y�n0�d
|�_
d
|�_t� d�

�g�}
z|
� tj� ���

�W�n�ty�
�
�
�Y�n0�d}t���\}}z�z�|
� |�

�t���}|g
t����}|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�
�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)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���F���sN����




 













�




zResourceTracker.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 ����

zResourceTracker._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|�}|t|�
ks^J�d�
|t|�
��
�
d�S�)Nz{0}:{1}:{2} �asciii���z name too longznbytes {0:n} but len(msg) {1:n})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�j
t�j�
�t���t�jt�j�
�tr2t��t�jt�
�tj tj fD�]$}
z|
���
�W�q>�ty`
�
�
�Y�q>0�q>d
d��t ���D��
}�
z�t|�d���}
|
D�]�}z�|����d�
�d�
\}}}t �|d�}|du�r�td|��d|����
�
|d kr�||��|�

�n2|d k�
r||��|�

�n|dk�
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
�}
�zt�d|| f��

�W�Y�d} ~ n d} ~ 0�0�W�n0��
q
q�n�|���D�]�\}}|�rhzt�d t|�
|f��

�W�n�t�yf
�
�
�Y�n0�|D�]X}zNzt |�|�

�W�n8�t�y�
�}
�zt�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_funcZrtype_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