*jj- S SK r S SKJr S SKrS SKrS SKrS SKrS SKrSSKJ r J
r
SSK J r S/r
\R S:X a S SKr " S S \5 rO$ " S
S \5 rS rS r\ R( " \\5 " S
S\5 r " S S\5 rg) N) defaultdict ) reductionassert_spawning)util
BufferWrapperwin32c L \ rS rSrSr\R " 5 rS rS r S r
Sr g)Arena z<
A shared memory area backed by anonymous memory (Windows).
c v Xl [ S5 Hp nS[ R " 5 [ U R
5 4- n[ R " SXS9n[ R " 5 S:X a O UR 5 Mr [ S5 eX0l X@l U R U R 4U l
g )Nd z pym-%d-%stagnamer z Cannot find name for new mmap)sizerangeosgetpidnext_randmmap_winapi GetLastErrorcloseFileExistsErrornamebuffer_state)selfr ir bufs ;/opt/alt/python313/lib64/python3.13/multiprocessing/heap.py__init__Arena.__init__& s I3Z"biik4
3C%DDiiD7'')Q.
&&EFF I K 99dii0DK c 0 [ U 5 U R $ N)r r )r s r# __getstate__Arena.__getstate__5 s D !;; r& c U=u U l U l U l [ R " SU R U R S9U l g )Nr r )r r r r r )r states r# __setstate__Arena.__setstate__9 s3 16 6 DIty4; ))B 499EDKr& )r r r r N) __name__
__module__ __qualname____firstlineno____doc__tempfile_RandomNameSequencer r$ r) r- __static_attributes__ r& r# r r s' ,,.
1 Fr& r c T \ rS rSrSr\R S:X a S/rO/ rS S jrS r Sr
g)
r C z:
A shared memory area backed by a temporary file (POSIX).
linuxz/dev/shmc Xl X l US:X a [ R " S[ R
" 5 - U R
U5 S9u U l n[ R " U5 [ R " U [ R U R 45 [ R " U R U5 [ R " U R U R 5 U l
g )Nr zpym-%d-)prefixdir)r fdr4 mkstempr r _choose_dirunlinkr Finalizer ftruncater r )r r r> r s r# r$ r% M s IGRx !) 0 0 %biik 1 ))$/!1
$
dBHHtwwj9 TWWd+ ))DGGTYY7DKr& c U R H: n[ R " U5 nUR UR - U: d M8 Us $ [
R " 5 $ r( )_dir_candidatesr statvfsf_bavailf_frsizer get_temp_dir)r r dsts r# r@ Arena._choose_dir[ sL ))ZZ];;,4 H * $$& &r& )r r> r N)r ) r/ r0 r1 r2 r3 sysplatformrE r$ r@ r6 r7 r& r# r r C s+ <<7 " )lO O 8 'r& c U R S:X a [ S5 e[ U R [ R
" U R 5 44$ )Nr zDArena is unpicklable because forking was enabled when it was created)r>
ValueError
rebuild_arenar r DupFd)as r# reduce_arenarT d sC 442: G H
H qvvyqtt'< ===r& c 4 [ XR 5 5 $ r( )r detach)r dupfds r# rQ rQ j s T<<>**r& c \ rS rSrSrSrSr\R 4S jr \
S 5 r S r S r
S rS rS
rS rS rS
rS rSrg)Heaps i @ c [ R " 5 U l [ R " 5 U l Xl / U l 0 U l 0 U l 0 U l
[ [ 5 U l
/ U l / U l SU l SU l g Nr )r r _lastpid threadingLock_lock_size_lengths _len_to_seq_start_to_block_stop_to_blockr set_allocated_blocks_arenas_pending_free_blocks
_n_mallocs_n_frees)r r s r# r$
Heap.__init__{ sw
^^%
" ! "-S!1 %'!
r& c US-
nX- U) - $ )Nr r7 )n alignmentmasks r# _roundup
Heap._roundup s 1}TE!!r& c L U R [ U R U5 [ R 5 nU R U R
: a U =R S- sl [ R " SU5 [ U5 nU R R U5 USU4$ )N z"allocating a new mmap of length %dr ) rr maxrb r PAGESIZE_DOUBLE_ARENA_SIZE_UNTILr infor ri append)r r lengtharenas r#
_new_arenaHeap._new_arena sy s4::t 4dmmD ::55 5 JJ!OJ 6?f
E"q&!!r& c UR nX R : a g U R R U5 nU R US4 U R
X4 U R R U5 U R U nUR USU45 U( d) U R U U R R U5 g g r] )
r _DISCARD_FREE_SPACE_LARGER_THANrh popre rf ri removerd rc )r r| r{ blocksseqs r# _discard_arenaHeap._discard_arena s 88 8 ''++E2 % , 0 E" v&
E1f%& ( MM ( r& c | [ R " U R U5 nU[ U R 5 :X a U R U5 $ U R U nU R
U nUR
5 nU( d U R
U U R U Uu pgnU R Xg4 U R Xh4 U$ r( ) bisect bisect_leftrc lenr} rd r re rf ) r r r! r{ r blockr| startstops r# _malloc Heap._malloc s t}}d 3 DMM" "??4( (]]1%F""6*CGGIE$$V,dmmA.> $ t % 0
. r& c Uu p#n U R X#4 nU R U5 u p6 U R X$4 nU R U5 u pdX#U4nXC-
n U R U R U5 XR X#4' XR X$4' g ! [ a Nvf = f! [ a Nbf = f! [ a4 U/U R U' [ R " U R U5 N|f = fr( ) rf _absorbKeyErrorre rd rz r insortrc ) r r r| r r
prev_block_
next_blockr{ s r# _add_free_blockHeap._add_free_block s
$ t 0 ,,e^ " "5 ) - -u.@ A), ZZs
B D66
E) rh ri r^ rd rc ra rl rk rj rb re rf N)r/ r0 r1 r2 r r rx r rw r$ staticmethodrr r} r r r r r r r r r6 r7 r& r# rY rY s sb J&3# , MM : " "
")$" 3<
'0%8-r& rY c . \ rS rSr\" 5 rS rS rSrg)r iB c L US: a [ SR U5 5 e[ R U:: a [ SR U5 5 e[
R R U5 nX!4U l [ R " U [
R R U4S9 g )Nr r r )args) rP r rM r r r _heapr r r rB r )r r r s r# r$ BufferWrapper.__init__F s !8 6 = =d CD D ;;$ 6 = =d CD D ##**40 m
dM / / 4 4E8Dr& c X U R u u pp4[ UR 5 X"U- $ r( )r
memoryviewr )r r| r r r s r# create_memoryview BufferWrapper.create_memoryviewO s+ %)[[" t%,,'Dj99r& )r N) r/ r0 r1 r2 rY r r$ r r6 r7 r& r# r r B s FEE:r& )r collectionsr r r rM r4 r_ contextr r r __all__rN r objectr rT rQ registerrY r r7 r& r# r s #
/
<<7 F FH ' 'B> + ul+ I-6 I-^:F :r&