ej-SSKrSSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r J r SSK J r S/r \RS:XaSSKr"SS \5rO$"S S \5rS rS r\ R("\\5 "S S\5r"SS\5rg)N) defaultdict) reductionassert_spawning)util BufferWrapperwin32cL\rSrSrSr\R "5rSrSr Sr Sr g)Arenaz< A shared memory area backed by anonymous memory (Windows). cvXl[S5HpnS[R"5[ UR 54-n[ R "SXS9n[R"5S:Xa OUR5 Mr [S5eX0l X@l URUR4Ul g)Ndz pym-%d-%stagnamerzCannot find name for new mmap)sizerangeosgetpidnext_randmmap_winapi GetLastErrorcloseFileExistsErrornamebuffer_state)selfrirbufs :/opt/imh/python3.13/lib/python3.13/multiprocessing/heap.py__init__Arena.__init__&sI3Z"biik4 3C%DDiiD7'')Q.  &&EFFIK99dii0DKc0[U5 UR$N)rr)r s r# __getstate__Arena.__getstate__5s D !;; r&cU=uUlUlUl[R"SURURS9Ulg)Nrr)rrrrr)r states r# __setstate__Arena.__setstate__9s316 6 DIty4;))B 499EDKr&)rrrrN) __name__ __module__ __qualname____firstlineno____doc__tempfile_RandomNameSequencerr$r)r-__static_attributes__r&r#r r s' ,,. 1  Fr&r cT\rSrSrSr\R S:XaS/rO/rS SjrSr Sr g) r Cz: A shared memory area backed by a temporary file (POSIX). linuxz/dev/shmcXlX lUS:Xa[R"S[R "5-UR U5S9uUln[R"U5 [R"U[RUR45 [R"URU5 [R"URUR5Ul g)Nrzpym-%d-)prefixdir)rfdr4mkstemprr _choose_dirunlinkrFinalizer ftruncaterr)r rr>rs r#r$r%MsIGRx!) 0 0%biik1))$/!1  $ dBHHtwwj9 TWWd+))DGGTYY7DKr&cURH:n[R"U5nURUR-U:dM8Us $ [ R "5$r()_dir_candidatesrstatvfsf_bavailf_frsizer get_temp_dir)r rdsts r#r@Arena._choose_dir[sL))ZZ];;,4H*$$& &r&)rr>rN)r) r/r0r1r2r3sysplatformrEr$r@r6r7r&r#r r Cs+  <<7 ")lO O 8 'r&cURS:Xa [S5e[UR[R "UR544$)NrzDArena is unpicklable because forking was enabled when it was created)r> ValueError rebuild_arenarrDupFd)as r# reduce_arenarTdsC 442:GH Hqvvyqtt'<===r&c4[XR55$r()r detach)rdupfds r#rQrQjsT<<>**r&c\rSrSrSrSrSr\R4Sjr \ S5r Sr Sr SrS rS rS rS rS rSrSrg)Heapsi@c[R"5Ul[R"5UlXl/Ul0Ul0Ul 0Ul [[5Ul /Ul/UlSUlSUlgNr)rr_lastpid threadingLock_lock_size_lengths _len_to_seq_start_to_block_stop_to_blockrset_allocated_blocks_arenas_pending_free_blocks _n_mallocs_n_frees)r rs r#r$ Heap.__init__{sw  ^^%    "!"-S!1 %'! r&cUS- nX-U)-$)Nrr7)n alignmentmasks r#_roundup Heap._roundups1}TE!!r&cLUR[URU5[R5nURUR :aU=RS-sl[ R"SU5 [U5nURRU5 USU4$)Nz"allocating a new mmap of length %dr) rrmaxrbrPAGESIZE_DOUBLE_ARENA_SIZE_UNTILrinfor riappend)r rlengtharenas r# _new_arenaHeap._new_arenasys4::t4dmmD ::55 5 JJ!OJ 6?f  E"q&!!r&cURnX R:agURRU5nU(aeURUS4 UR X4 UR RU5 URUnURUSU45 U(d)URU URRU5 ggr]) r_DISCARD_FREE_SPACE_LARGER_THANrhpoprerfriremoverdrc)r r|r{blocksseqs r#_discard_arenaHeap._discard_arenas 88 8 ''++E2z  % ,    0 E"v& E1f%&  ( MM  (r&c|[R"URU5nU[UR5:XaUR U5$URUnUR UnUR 5nU(dUR U URU UupgnURXg4 URXh4 U$r() bisect bisect_leftrclenr}rdrrerf) r rr!r{rblockr|startstops r#_malloc Heap._mallocs   t}}d 3 DMM" "??4( (]]1%F""6*CGGIE$$V,dmmA.>$t  % 0    . r&cUup#nURX#4nURU5up6URX$4nURU5updX#U4nXC- nURUR U5 XRX#4'XRX$4'g![a Nvf=f![a Nbf=f![a4 U/URU'[ R"URU5 N|f=fr() rf_absorbKeyErrorrerdrzrinsortrc) r rr|rr prev_block_ next_blockr{s r#_add_free_blockHeap._add_free_blocks $t 0,,e^  " "5 ) - -u.@ A),ZZs BD66 E) rhrir^rdrcrarlrkrjrbrerfN)r/r0r1r2rrrxrrwr$ staticmethodrrr}rrrrrrrrr6r7r&r#rYrYssbJ&3#, MM:"" ")$"3< '0%8-r&rYc.\rSrSr\"5rSrSrSrg)riBcLUS:a[SRU55e[RU::a[ SRU55e[ R RU5nX!4Ul[R"U[ R RU4S9 g)Nrrr)args) rPrrMrrr_heaprrrrBr)r rrs r#r$BufferWrapper.__init__Fs !86==dCD D ;;$  6 = =d CD D##**40m  dM//44E8Dr&cXURuupp4[UR5X"U-$r()r memoryviewr)r r|rrrs r#create_memoryviewBufferWrapper.create_memoryviewOs+%)[["t%,,'Dj99r&)rN) r/r0r1r2rYrr$rr6r7r&r#rrBs FEE:r&)r collectionsrrrrMr4r_contextrrr__all__rNrobjectr rTrQregisterrYrr7r&r#rs# /   <<7FFH''B> +ul+ I-6I-^:F:r&