GZF 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.pyr ! 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 | cd d d S | j | r d d d d S 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 d d d d S # 1 swxY w Y d S )Nr r 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
0J
!B,+J
,
B96J
8B99'J
!1DJ
D J
D J
:tU+++++r c 6 | d|| d S )N
UNREGISTERrN rP s r r zResourceTracker.unregister s! @
<u-----r c T | n+# t $ r t j d| d|d Y nw xY wd ||| d }t
| dk rt d t j | j
| }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 long) 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 %??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;|dk r || | n|d k rnt/ d
|z # t $ r, t j t j n# Y nxY wY w xY w d d d 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 wd S # | 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)Nc , i | ]}|t S r
)set).0rR s r
zmain.. s = = =eUCEE = = =r rbrV :zCannot 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 3H:C
GH
G> G32G>3G7 5G>:H=G>>H K HK HK 5&I
I)(I)2JJ:
J6J1,J:1J66J::J< M+ &LM+
L M+L M+ L21M$2
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 r s $
6
6
6 122
M6>2 LL 7g w .. )4
/
M M M M M f M M M ` $O%% "1 %
)
< < < < <r