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 | jd ur@| r W d d S t| j z| jd ur*t| jd W n ty4 Y nw d | _d | _t d g }z
|
t j
W n tyU 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 d S 1 sw Y d S )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 )Ns
PROBE:0:noop
FT)r writer OSErrorr r
r
r r s z ResourceTracker._check_alivec C | d|| d S )NREGISTER_sendr namertyper
r
r r zResourceTracker.registerc C r2 )N
UNREGISTERr4 r6 r
r
r r r9 zResourceTracker.unregisterc C sB | d|||d}t|dkrtdt| j|}d S )Nz {0}:{1}:{2}
asciii z msg too long)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 y1 Y q w dd t
D }zt| dj}|D ]_}zF| dd\}}}t
|d }|d u rhtd| d| |dkrt|| | n|d kr|| | n |d
krntd | W qD t y z tjt W n Y Y qDw 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 qd S | D ]N\}}|r'z
t d t ||f W n
t y& Y nw |D ]+}z(zt
| | W n t yP } zt d
|| f W Y d } ~ nd } ~ ww W q)w qw )Nc S s i | ]}|t qS r
)set).0r8 r
r
r
s zmain..rbr; :zCannot 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