@,bij-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 BufferWrapperwin32cH\rSrSr\R "5rSrSrSr Sr g)ArenacvXl[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/alt/python313/lib64/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__tempfile_RandomNameSequencerr$r)r-__static_attributes__r&r#r r s" ,,. 1  Fr&r cP\rSrSr\R S:XaS/rO/rSSjrSrSr g) r Clinuxz/dev/shmcXlX lUS:Xa[R"S[R "5-UR U5S9uUln[R"U5 [R"U[RUR45 [R"URU5 [R"URUR5Ul g)Nrzpym-%d-)prefixdir)rfdr3mkstemprr _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/r0r1r2sysplatformrDr$r?r5r6r&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_arenarSdsC 442:GH Hqvvyqtt'<===r&c4[XR55$r()r detach)rdupfds r#rPrPjsT<<>**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)-$)Nrr6)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) rqmaxrarPAGESIZE_DOUBLE_ARENA_SIZE_UNTILrinfor rhappend)r rlengtharenas r# _new_arenaHeap._new_arenasys4::t4dmmD ::55 5 JJ!OJ 6?f  E"q&!!r&cURnX R:agURRU5nURUS4 UR X4 UR RU5 URUnURUSU45 U(d)URU URRU5 ggr\) r_DISCARD_FREE_SPACE_LARGER_THANrgpoprdrerhremovercrb)r r{rzblocksseqs r#_discard_arenaHeap._discard_arenas 88 8 ''++E2  % ,    0 E"v& E1f%&  ( MM  (r&c|[R"URU5nU[UR5:XaUR U5$URUnUR UnUR 5nU(dUR U URU UupgnURXg4 URXh4 U$r() bisect bisect_leftrblenr|rcrrdre) r rr!rzrblockr{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() re_absorbKeyErrorrdrcryrinsortrb) r rr{rr prev_block_ next_blockrzs r#_add_free_blockHeap._add_free_blocks $t 0,,e^  " "5 ) - -u.@ A),ZZs BD66 E) rgrhr]rcrbr`rkrjrirardreN)r/r0r1r2rrrwrrvr$ staticmethodrqr|rrrrrrrrr5r6r&r#rXrXssbJ&3#, MM:"" ")$"3< '0%8-r&rXc.\rSrSr\"5rSrSrSrg)riBcLUS:a[SRU55e[RU::a[ SRU55e[ R RU5nX!4Ul[R"U[ R RU4S9 g)Nrrr)args) rOrrLrrr_heaprrrrAr)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/r0r1r2rXrr$rr5r6r&r#rrBs FEE:r&)r collectionsrrrrLr3r^contextrrr__all__rMrobjectr rSrPregisterrXrr6r&r#rs# /   <<7FFH''B> +ul+ I-6I-^:F:r&