o
0i
# @ s d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ g dZe edZ
ej ej fZ
ddd iZe jd
krWd dlZd dlZe ed rOed eji ed
eji G dd deZe ZejZejZejZejZdd Z dS ) N )spawn)util)ensure_runningregister
unregisterpthread_sigmaskZnoopc C s d S N r
r
r
G/opt/alt/python310/lib64/python3.10/multiprocessing/resource_tracker.py! s r posix
sem_unlinkZ 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_pidselfr
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 osclosewaitpidr 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
|
t j
W n tyT Y nw d}t \}}zXzA|
| t }|gt }|d|| g7 }ztrttjt t|||}W trttjt n trttjt w w W n t| || _|| _W t| nt| w W d dS 1 sw Y dS )zMake 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 ChildProcessErrorwarningswarnappendsysstderrfileno Exceptionpiper Zget_executabler Z _args_from_interpreter_flags
_HAVE_SIGMASKsignalr SIG_BLOCK_IGNORED_SIGNALSZspawnv_passfds SIG_UNBLOCK)r Z fds_to_passcmdrwZexeargspidr
r
r r N s^
"z ResourceTracker.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 z ResourceTracker._check_alivec C | d|| dS )z0Register name of resource with resource tracker.REGISTERN_sendr namertyper
r
r r zResourceTracker.registerc C r2 )z2Unregister name of resource with resource tracker.
UNREGISTERNr4 r6 r
r
r r r9 zResourceTracker.unregisterc C sb | d|||d}t|dkrtdt| j|}|t|ks/J d|t|d S )Nz {0}:{1}:{2}
asciii z msg too longz nbytes {0:n} but len(msg) {1:n})r formatencodelen
ValueErrorr r0 r )r r+ r7 r8 msgnbytesr
r
r r5 s
zResourceTracker._sendN) __name__
__module__ __qualname__r r r r r r r r5 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 t y0 Y q w dd t
D }zt| dj}|D ]_}zF| dd\}}}t
|d}|du rgtd| d| |d krs|| | n|d
kr|| | n |d krntd | W qC t y z tjt W n Y Y qCw W d n1 sw Y W | D ]I\}}|rz
t d
t ||f W n t y Y nw |D ])}z&zt
| | W n t y } zt d|| f W Y d} ~ nd} ~ ww W qw qdS | 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).0r8 r
r
r
s zmain..rbr; :NzCannot register z. for automatic cleanup: unknown resource type r3 r: ZPROBEzunrecognized command %rzQresource_tracker: There appear to be %d leaked %s objects to clean up at shutdownzresource_tracker: %r: %s) r' SIGINTSIG_IGNSIGTERMr& r r* r) r! stdinstdoutr r$ _CLEANUP_FUNCSkeysopenstripdecodesplitgetr? addremove RuntimeError
excepthookexc_infoitemsr r r> )
fdfcacheliner+ r7 r8 Z cleanup_funcZ rtype_cacheer
r
r main s
ra ) r r' r! r r r r __all__hasattrr& rJ rL r) rO r7 Z_multiprocessingZ _posixshmemupdater Z
shm_unlinkobjectr Z_resource_trackerr r r r ra r
r
r
r s:
w