U
if! @ s d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ dddgZe edZ
ej ej fZ
d d
d iZe jd krd dlZd dlZeejejd
G dd deZe ZejZejZejZejZdd Z dS ) N )spawn)utilensure_runningregister
unregisterpthread_sigmaskZnoopc C s d S N r
r
r
E/opt/alt/python38/lib64/python3.8/multiprocessing/resource_tracker.py! 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_pidselfr
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 osclosewaitpidr 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 \}}zzr|
| t }|gt }|d|| g7 }z&trttjt t|||}W 5 tr,ttjt X W n t| Y nX || _|| _W 5 t| X W 5 Q R X 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_UNBLOCK_IGNORED_SIGNALS SIG_BLOCKZspawnv_passfds)r Z fds_to_passcmdrwZexeargspidr
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_sendr namertyper
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|dkr0tdt| j|}|t|ks^td|t|d S )Nz {0}:{1}:{2}
asciii z
name too longz nbytes {0:n} but len(msg) {1:n}) r formatencodelen
ValueErrorr r0 r AssertionError)r r+ r6 r7 msgnbytesr
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 }zt| d}|D ]}z| dd\}}}t
|d} | dkrtd | d
| |d kr|| | n2|d kr|| | n|d
krn td| W q t k
rT ztj t W n Y nX Y qX qW 5 Q R X W 5 | D ]\}}|rztdt||f W n t k
r Y nX |D ]V}zLzt
| | W n6 t k
r } ztd||f W 5 d}~X Y nX W 5 X qqnX dS )zRun resource tracker.c S s i | ] }|t qS r
)set).0r7 r
r
r
s zmain..zQresource_tracker: There appear to be %d leaked %s objects to clean up at shutdownzresource_tracker: %r: %sNrbr9 :zCannot register z. for automatic cleanup: unknown resource type r2 r8 ZPROBEzunrecognized command %r) r' SIGINTSIG_IGNSIGTERMr& r r( r) r! stdinstdoutr r$ _CLEANUP_FUNCSkeysitemsr r r< openstripdecodesplitgetr= addremove RuntimeError
excepthookexc_info)
fdfcacher7 Z rtype_cacher6 eliner+ Z cleanup_funcr
r
r main s^
(r` ) r r' r! r r r r __all__hasattrr& rI rK r) rN r6 Z_multiprocessingZ _posixshmemupdateZ
sem_unlinkZ
shm_unlinkobjectr Z_resource_trackerr r r r r` r
r
r
r s4
w