f\( d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ g dZ e ed Z
ej ej fZ
dd iZe j d k rLd dlZd dlZ e ed
r e d ej i e d ej i G d
de Z G d de Z e Zej Zej Zej Z ej Z d Z dS ) N )spawn)util)ensure_runningregister
unregisterpthread_sigmasknoopc d S N r
G/opt/alt/python311/lib64/python3.11/multiprocessing/resource_tracker.py<lambda>r ! s D r posix
sem_unlink semaphore
shared_memoryc e Zd ZdS )ReentrantCallErrorN)__name__
__module__ __qualname__r
r r r r 6 s Dr r c D e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) ResourceTrackerc R t j | _ d | _ d | _ d S r ) threadingRLock_lock_fd_pidselfs r __init__zResourceTracker.__init__< s# _&&
r c t d )Nz8Reentrant call into the multiprocessing resource tracker)r r" s r _reentrant_call_errorz%ResourceTracker._reentrant_call_errorA s
! FH H Hr c l | j 5 | j dk r | cd d d S | j d d d d S t j | j d | _ t j | j d d | _ d d d d S # 1 swxY w Y d S )Nr r )r _recursion_countr& r osclosewaitpidr! r" s r _stopzResourceTracker._stopI s+
Z z**,,q001133
x
HTX DH Jty! $ $ $ DI s 1B)B)AB))B-0B-c 8 | | j S r )r r r" s r getfdzResourceTracker.getfdZ s xr c , | j 5 | j dk r | cddd S | j | r ddd dS t j | j | j t j | j d n# t $ r Y nw xY wd| _ d| _ t j d g } | t j n# t $ r Y nw xY wd}t j \ }} | | t% j }|gt) j z }|d||z gz
} t, r$t/ j t. j t4 t) j ||| }t, r$t/ j t. j t4 n1# t, r%t/ j t. j t4 w w xY w|| _ || _ n# t j | xY w t j | n# t j | w xY w ddd dS # 1 swxY w 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.r Nr zUresource_tracker: process died unexpectedly, relaunching. Some resources might leak.z:from multiprocessing.resource_tracker import main;main(%d)z-c) r r( r& r _check_aliver) r* r! r+ ChildProcessErrorwarningswarnappendsysstderrfileno Exceptionpiper get_executabler _args_from_interpreter_flags
_HAVE_SIGMASKsignalr SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_UNBLOCK)r# fds_to_passcmdrwexeargspids r r z ResourceTracker.ensure_running^ s
Z < < z**,,q001133< < < < < < < < x#$$&& < < < < < < < < """ y,
49a000( D
I J J J K
""3:#4#4#6#67777
NC799DAq
""1%%%*,,ut @ B BBsQw'U$ S .v/?AQRRR -c4EEC$ U .v/ACSTTT % U .v/ACSTTTTU
y< < < < < < < < < < < < < < < < < < s 1J J /J !B+*J +
B85J 7B88'J 1DJ
D J D J ;A H2AG2,H22.H H2#I"2I I"
J "I88J J
J
c ^ t j | j d dS # t $ r Y dS w xY w)z;Check that the pipe has not been closed by sending a probe.s
PROBE:0:noop
TF)r) writer OSErrorr" s r r0 z ResourceTracker._check_alive sI
HTX 0 1 1 1 4 55 s
,,c 4 | d|| dS )z0Register name of resource with resource tracker.REGISTERN_sendr# namertypes r r zResourceTracker.register s
:tU+++++r c 4 | d|| dS )z2Unregister name of resource with resource tracker.
UNREGISTERNrN rP s r r zResourceTracker.unregister s
<u-----r c | n+# t $ r t j d| d|d Y nw xY wd ||| d }t
| dk rt d t j | j
| }|t
| k s+J d |t
| d S ) NzSResourceTracker called reentrantly for resource cleanup, which is unsupported. The z object z might leak.z {0}:{1}:{2}
asciii z msg too longz nbytes {0:n} but len(msg) {1:n}) r r r2 r3 formatencodelen
ValueErrorr) rJ r )r# rC rQ rR msgnbytess r rO zResourceTracker._send s
< ! ! ! !! < < <
M; ; ;&*; ; ;
<
<
<
<
< < $$S$66==gFF s88c>> ^,, ,$(C((S!!!#D#K#K CHH$ $ !!!!!s %??N) r r r r$ r& r, r. r r0 r r rO r
r r r r : s
H H H " A A A F , , ,. . . r r c t j t j t j t j t j t j t r$t j t j t t j t j
fD ]'} | # t $ r Y $w xY wd t D } t | d 5 }|D ] } | d d \ }}}t |d }|t) d| d| |dk r || | n;|d k r || | n|d
k rnt/ d |z # t $ r, t j t j n# Y nxY wY w xY w ddd n # 1 swxY w Y | D ]\ }}|r8 t7 j d t; | |fz n# t $ r Y nw xY w|D ]P} t | | n1# t $ r$} t7 j d
|d| Y d} ~ nd} ~ ww xY wL# w xY wdS # | D ]\ }}|r8 t7 j d t; | |fz n# t $ r Y nw xY w|D ]P} t | | n1# t $ r$} t7 j d
|d| Y d} ~ nd} ~ ww xY wL# w xY ww xY w)zRun resource tracker.c , i | ]}|t S r
)set).0rR s r
<dictcomp>zmain.<locals>.<dictcomp> s = = =eUCEE = = =r rbrV :NzCannot register z. for automatic cleanup: unknown resource type rM rT PROBEzunrecognized command %rzQresource_tracker: There appear to be %d leaked %s objects to clean up at shutdownzresource_tracker: z: ) r= SIGINTSIG_IGNSIGTERMr< r rA r? r5 stdinstdoutr* r8 _CLEANUP_FUNCSkeysopenstripdecodesplitgetrZ addremove RuntimeError
excepthookexc_infoitemsr2 r3 rY )
fdfcachelinerC rQ rR cleanup_func rtype_cachees
r mainr~ s M&- 000
M&.&.111 E v 13CDDDi
$
GGIIII D
> =~':':'<'< = = =E-
"d^^ q
'+zz||':':7'C'C'I'I#'N'N$Cu#1#5#5eT#B#BL#+ ( =t = =5: = = > > > j(( e ((.... ,, e ++D1111 *+Ds+J K KK 777 #
2 #(++-- E;
M #N#&{#3#3U";#< = = = = ! D#
N&u-d3333$ N N N
DDD!!&LMMMMMMMMN DDDD
%++-- E;
M #N#&{#3#3U";#< = = = = ! D#
N&u-d3333$ N N N
DDD!!&LMMMMMMMMN DDDD
s! B..
B;:B;"K 2H
9C
GH
G= G21G=2G6 4G=9H
<G==H
K
HK HK 4&I
I('I(1JJ9
J5J0+J90J55J99J; M* &LM*
L M*L M*L10M#1
M ;M M#M M#"M*#M% %M*) r) r= r5 r r2 r r __all__hasattrr< re rg r? rj rQ _multiprocessing _posixshmemupdater
shm_unlinkrs r objectr _resource_trackerr r r r. r~ r
r r <module>r s $
6
6
6 122
M6>2 LL 7g w .. )4
/
M M M M M f M M M ` $O%% "1 %
)
< < < < <r