֦iE+ d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ g dZ e ed Z
ej ej fZ
dd iZe j d k( rKd dlZd dlZ e ed
r ej% d ej& i ej% d ej( i G d
de Z G d de Z e Zej4 Zej6 Zej8 Z ej: Z d Z y) N )spawn)util)ensure_runningregister
unregisterpthread_sigmasknoopc y N r
9/usr/lib64/python3.12/multiprocessing/resource_tracker.pyr ! s Dr posix
sem_unlink semaphore
shared_memoryc e Zd Zy)ReentrantCallErrorN)__name__
__module__ __qualname__r
r r r r 6 s r r c e Zd Zd Zd Zd Zd
dZej ej ej fdZ d Z d Z
d Zd Zd
Zd Zy )ResourceTrackerc R t j | _ d | _ d | _ y 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 Hr c ( | j d y )NF)use_blocking_lock)_stopr" s r __del__zResourceTracker.__del__I s
U
+r c D |r&| j 5 | j d d d y | j j d } | j |r| j j y y # 1 sw Y y xY w# |r| j j w w xY w)NF)blocking)r _stop_lockedacquirerelease)r# r( acquireds r r) zResourceTracker._stopO s !!# zz))5)9H
)!!#JJ&&( JJ&&( s A4B 4A= B c | j j dkD r| j S | j y | j y || j d | _ || j d d | _ y )Nr r )r _recursion_countr& r r! )r# closewaitpidwaitstatus_to_exitcodes r r- z ResourceTracker._stop_locked[ sk :: & & (1 ,--/ / 88 99 dhh 1 r c : | j | j S r )r r r" s r getfdzResourceTracker.getfdr s xxr c * | j 5 | j j dkD r| j cd d d S | j | j r
d d d y t j | j | j t j | j d d | _ d | _ t j d g } |j t j j d}t j" \ }} |j | t% j& }|gt) j* z }|d||z gz
}d } t, r(t/ j0 t. j2 t4 }t) j6 ||| }|%t/ j0 t. j8 | || _ || _ t j | d d d y # t $ r Y ]w xY w# t $ r Y w xY w# |%t/ j0 t. j8 | w w xY w# t j | xY w# t j | w xY w# 1 sw Y y xY w)Nr r zUresource_tracker: process died unexpectedly, relaunching. Some resources might leak.z:from multiprocessing.resource_tracker import main;main(%d)z-c) r r2 r& r _check_aliveosr3 r! r4 ChildProcessErrorwarningswarnappendsysstderrfileno Exceptionpiper get_executabler _args_from_interpreter_flags
_HAVE_SIGMASKsignalr SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_SETMASK) r# fds_to_passcmdrwexeargs prev_sigmaskpids r r z ResourceTracker.ensure_runningv s* / ZZzz**,q0113 Z xx#$$& Z " yy,
499a0
I J K
""3::#4#4#67 OC779DAq
""1%**,ut @ @ BBsQw' $ Q$'-'='=f>N>NP`'a --c4EC#/ ..v/A/A<P
{ Z$ )
, $/ ..v/A/A<P 0
{ Zs -J J + J ,H7%J -H
J $A I.AH(3'II/)J HJ HJ H%!J $H%%J ()III,,I//JJ Jc f t j | j d y# t $ r Y yw xY w)Ns
PROBE:0:noop
TF)r: writer OSErrorr" s r r9 z ResourceTracker._check_alive s8 I
HHTXX 0 1 s $ 00c , | j d|| y )NREGISTER_sendr# namertypes r r zResourceTracker.register s >
:tU+r c , | j d|| y )N
UNREGISTERrY r[ s r r zResourceTracker.unregister s @
<u-r c 2 | j dj ||| j d }t
| dkD r t d t j | j | }y # t $ r t j d| d|d Y w xY w)NzSResourceTracker called reentrantly for resource cleanup, which is unsupported. The z object z might leak.z {0}:{1}:{2}
asciii z msg too long) r r r< r= formatencodelen
ValueErrorr: rU r )r# rM r\ r] msgnbytess r rZ zResourceTracker._send s
< ! $$S$6==gF s8c> ^, ,$((C( " <
MM gXdX\;
< > j( e ((. , e ++D1 *+Ds+J KK! 2 #(++- E; MM #N#&{#3U";#< =
$N&u-d3 $ #0?
>* ! 7 % ^> ! % N
D!&LMMN % #(++- E; MM #N#&{#3U";#< = ! #N&u-d3$ N
D!&LMMN D $ #0s 8H H 5 J/ I B#H!+I .J/ #I*9I9 HH! I+$III II II I'#J/ * I65I69 J'J" J*"J''J**J,/M
#K-,M
- K9 6M
8K9 9M
LM M L; 6M;M MM
M M
) r: rG r? r r< r r __all__hasattrrF rl rn rI rr r\ _multiprocessing _posixshmemupdater
shm_unlinkr| r objectr _resource_trackerr r r r7 r r
r r r s $
6 12
MM6>>2 L 77g . )44
//
f f f R $% "11 % %
)
)
<r