آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ U ،ê,aj-م@sزddlZddlmZddlZddlZddlZddlZddlZddlm Z m Z ddlmZdgZ ejdkr‚ddlZGdd „d eƒZn,Gd d „d eƒZdd„Zd d„Ze ee،Gdd„deƒZGdd„deƒZdS)éN)عdefaultdicté)ع reductionعassert_spawning)عutilع BufferWrapperZwin32c@s0eZdZdZe ،Zdd„Zdd„Zdd„Z dS) عArenazL A shared memory area backed by anonymous memory (Windows). cCsx||_tdƒD]B}dt ،t|jƒf}tjd||dچ}t ،dkrHqZ| ،qt dƒ‚||_||_|j|jf|_ dS)Nédz pym-%d-%séےےےے©ZtagnamerzCannot find name for new mmap)عsizeعrangeعosعgetpidعnextع_randعmmapع_winapiZGetLastErrorعcloseعFileExistsErrorعnameعbufferع_state)عselfrعirZbuf©rْ9/opt/alt/python38/lib64/python3.8/multiprocessing/heap.pyع__init__&s ْArena.__init__cCst|ƒ|jS©N)rr)rrrrع__getstate__5szArena.__getstate__cCs,|\|_|_|_tjd|j|jdچ|_dS)Nr r)rrrrr)rعstaterrrع__setstate__9szArena.__setstate__N) ع__name__ع __module__ع__qualname__ع__doc__عtempfileZ_RandomNameSequencerrr r"rrrrrs rc@s8eZdZdZejdkrdgZngZd dd„Zdd„Zd S)rzJ A shared memory area backed by a temporary file (POSIX). Zlinuxz/dev/shmr cCsx||_||_|dkrbtjdt ،| |،dچ\|_}t |،t |tj |jf،t |j|،t |j|j،|_ dS)Nr zpym-%d-)عprefixعdir)rعfdr'Zmkstemprrع_choose_dirعunlinkrعFinalizerع ftruncaterr)rrr*rrrrrMs ‏ rcCs6|jD]&}t |،}|j|j|kr|Sqt ،Sr)ع_dir_candidatesrعstatvfsعf_bavailعf_frsizerZget_temp_dir)rrعdعstrrrr+[s zArena._choose_dirN)r ) r#r$r%r&عsysعplatformr/rr+rrrrrCs cCs(|jdkrtdƒ‚t|jt |j،ffS)Nr zDArena is unpicklable because forking was enabled when it was created)r*ع ValueErrorع rebuild_arenarrZDupFd)عarrrعreduce_arenads r:cCst|| ،ƒSr)rعdetach)rZdupfdrrrr8jsr8c@szeZdZdZdZdZejfdd„Ze dd„ƒZ dd„Zd d „Zdd„Z d d„Zdd„Zdd„Zdd„Zdd„Zdd„ZdS)عHeapéi@cCsXt ،|_t ،|_||_g|_i|_i|_ i|_ ttƒ|_ g|_g|_d|_d|_dS©Nr)rrع_lastpidع threadingZLockع_lockع_sizeع_lengthsع_len_to_seqع_start_to_blockع_stop_to_blockrعsetع_allocated_blocksع_arenasع_pending_free_blocksع _n_mallocsع_n_frees)rrrrrr{s z Heap.__init__cCs|d}|||@S)Nrr)عnZ alignmentعmaskrrrع_roundupکsz Heap._roundupcCsZ| t|j|ƒtj،}|j|jkr0|jd9_t d|،t|ƒ}|j |،|d|fS)Néz"allocating a new mmap of length %dr)rOعmaxrBrعPAGESIZEع_DOUBLE_ARENA_SIZE_UNTILrعinforrIعappend)rrعlengthعarenarrrع _new_arena‍szHeap._new_arenacCs‚|j}||jkrdS|j |،}|r(t‚|j|df=|j||f=|j |،|j |}| |d|f،|s~|j |=|j |،dSr>)rع_DISCARD_FREE_SPACE_LARGER_THANrHعpopعAssertionErrorrErFrIعremoverDrC)rrWrVعblocksعseqrrrع_discard_arenaھs zHeap._discard_arenac Cs|t |j|،}|t|jƒkr&| |،S|j|}|j|}| ،}|sV|j|=|j|=|\}}}|j||f=|j||f=|Sr) عbisectZbisect_leftrCعlenrXrDrZrErF) rrrrVr^عblockrWعstartعstoprrrع_malloc¼s zHeap._mallocc Csى|\}}}z|j||f}Wntk r0YnX| |،\}}z|j||f}Wntk rfYnX| |،\}}|||f}||}z|j| |،Wn.tk rت|g|j|<t |j|،YnX||j||f<||j||f<dSr) rFعKeyErrorع_absorbrErDrUr`ZinsortrC) rrbrWrcrdZ prev_blockع_Z next_blockrVrrrع_add_free_blockحs( zHeap._add_free_blockcCs^|\}}}|j||f=|j||f=||}|j|}| |،|sV|j|=|j |،||fSr)rErFrDr\rC)rrbrWrcrdrVr^rrrrgës zHeap._absorbcCs4|\}}}|j|}| ||f،|s0| |،dSr)rHr\r_)rrbrWrcrdr]rrrع_remove_allocated_blockْs zHeap._remove_allocated_blockcCsBz|j ،}Wntk r&Yq>YnX| |،| |،qdSr)rJrZع IndexErrorrirj©rrbrrrع_free_pending_blockss zHeap._free_pending_blockscCs~t ،|jkr$td t ،|j،ƒ‚|j d،s>|j |،n s& $!P