python (3.12.0)
̑e
# 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 e Zej0 Zej2 Zej4 Zej6 Zd Z y) N )spawn)util)ensure_runningregister
unregisterpthread_sigmasknoopc y N r
T/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/multiprocessing/resource_tracker.py<lambda>r ! s r posix
sem_unlink semaphore
shared_memoryc < e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
y )
ResourceTrackerc R t j | _ d | _ d | _ y r ) threadingLock_lock_fd_pidselfs r __init__zResourceTracker.__init__8 s ^^%
r c | j 5 | j
d d d y t j | j d | _ t j | j
d d | _ d d d y # 1 sw Y y xY w)Nr )r r osclosewaitpidr r s r _stopzResourceTracker._stop= sg
ZZ
xx
HHTXX DH JJtyy! $ DI
s A:A
A::Bc : | j | j S r )r r r s r getfdzResourceTracker.getfdJ s xxr c | j 5 | j | j r
ddd yt 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
} t( r(t+ j, t* j. t0 t% j2 ||| }t( r)t+ j, t* j4 t0 || _ || _ t j | ddd y# t $ r Y cw xY w# t $ r Y w xY w# t( r)t+ j, t* j4 t0 w w xY w# t j | xY w# t j | w xY w# 1 sw Y yxY w)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 get_executabler _args_from_interpreter_flags
_HAVE_SIGMASKsignalr SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_UNBLOCK)r fds_to_passcmdrwexeargspids r r z ResourceTracker.ensure_runningN s
ZZ 9 xx#$$& 9 9 " yy,
499a0
I J K
""3::#4#4#67 OC779DAq
""1%**,ut @ @ BBsQw'U$ ..v/?/?AQR --c4EC$ ..v/A/ACST
s9 9 )
* % ..v/A/ACST %
s9 9 s I I ,G %I &-G'I -AH+5AG7:/H+)I8I G$ I #G$$I ' G40I 3G44I 71H((H++III I I)c d t j | j d y# t $ r Y yw 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 r( z ResourceTracker._check_alive s5
HHTXX 0 1 s # //c * | j d|| y)z0Register name of resource with resource tracker.REGISTERN_sendr namertypes r r zResourceTracker.register s
:tU+r c * | j d|| y)z2Unregister name of resource with resource tracker.
UNREGISTERNrF rH s r r zResourceTracker.unregister s
<u-r c 6 | j dj ||| j d }t | dkD r t d t j | j | }|t | k( s J dj |t | y )Nz {0}:{1}:{2}
asciii z msg too longz nbytes {0:n} but len(msg) {1:n})r formatencodelen
ValueErrorr! rB r )r r; rI rJ msgnbytess r rG zResourceTracker._send s $$S$6==gF s8c> ^, ,$((C(S! #D#K#K CH$ !r N) __name__
__module__ __qualname__r r$ r& r r( r r rG r
r r r r 6 s+
> @ ,. 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 ] } |j t j D ci c]
}|t }} t! | d 5 }|D ] } |j# j% d j' d \ }}}t j) |d }|t+ d| d| |dk( r|| j- | n.|dk( r|| j/ | n|d k( rnt1 d
|z ddd |j7 D ]B \ }}|r$ t9 j: d t= | |fz |D ] } t | | D y# t $ r Y dw xY wc c}w # t $ r1 t j2 t j4 n# Y nxY wY Vw xY w# 1 sw Y xY w# t $ r Y w xY w# t $ r%} t9 j: d |d
| Y d} ~ d} ~ ww xY w# w xY w# |j7 D ] \ }}|r4 t9 j: d t= | |fz n# t $ r Y nw xY w|D ]I } t | | n1# t $ r%} t9 j: d |d
| Y d} ~ nd} ~ ww xY wF# w xY w w xY w)zRun resource tracker.rbrN :NzCannot register z. for automatic cleanup: unknown resource type rE rL PROBEzunrecognized command %rzQresource_tracker: There appear to be %d leaked %s objects to clean up at shutdownzresource_tracker: z: ) r5 SIGINTSIG_IGNSIGTERMr4 r r9 r7 r- stdinstdoutr" r0 _CLEANUP_FUNCSkeyssetopenstripdecodesplitgetrR addremove RuntimeError
excepthookexc_infoitemsr* r+ rQ )
fdfrJ cacheliner; rI cleanup_func rtype_cachees
r mainrv s9 MM&-- 0
MM&..&..1 v 1 13CDii
$
GGI (6':':'< =eUCE\ =E =-
"d^ q
'+zz|':':7'C'I'I#'N$Cu#1#5#5eT#BL#+ ( .tf 555:G = > > j( e ((. , e ++D1 *+Ds+J KK!
2 #(++- E; MM #N#&{#3U";#< =
$
N&u-d3
?
>* ! 7 % > ! % N
D!&LMMN % #(++- E; MM #N#&{#3U";#< = ! #
N&u-d3$ N
D!&LMMN D
s 7H H4 J. I B#H *I -J. #I)8I8 HH I*$III II II I&"J. ) I54I58 J&J! J)!J&&J))J+.M #K,+M , K8 5M 7K8 8M LM L? L: 5M:L? ?MM M M ) r! r5 r- r r* r r __all__hasattrr4 r\ r^ r7 ra rI _multiprocessing _posixshmemupdater
shm_unlinkobjectr _resource_trackerr r r r& rv r
r r <module>r s $
6 12
MM6>>2 L 77g . )44
//
t f t n $% "11 % %
)
)
<r 
Browse
Usage
Versions