3 2a @sddlZddlZddlZddlZddlZddlZddlmZmZddl m Z dgZ ej dkrvddl Z GdddeZn,Gd ddeZd d Zd d ZejeeGdddeZGdddeZdS)N) reductionassert_spawning)util BufferWrapperwin32c@s,eZdZejZddZddZddZdS)ArenacCsz||_xTtdD]@}dtjt|jf}tjd||d}tjdkrHP|j qWt d||_ ||_ |j|j f|_ dS)Ndz pym-%d-%sr)tagnamerzCannot find name for new mmap)sizerangeosgetpidnext_randmmap_winapiZ GetLastErrorcloseFileExistsErrornamebuffer_state)selfr irbufr)/opt/alt/python36/lib64/python3.6/heap.py__init__"s  zArena.__init__cCst||jS)N)rr)rrrr __getstate__1szArena.__getstate__cCs,|\|_|_|_tjd|j|jd|_dS)Nr)r r )r rrrr)rstaterrr __setstate__5szArena.__setstate__N) __name__ __module__ __qualname__tempfileZ_RandomNameSequencerrrr!rrrrrsrc@seZdZdddZdS)rrc Cs||_||_|d krtjdtjtjd\|_}tj|tj |tj |jft |jdddN}d }||krd|}xt ||D]}|j |qW~|j d||WdQRXtj|j|j|_dS) Nrzpym-%d-)prefixdirwbF)closefdir i)r fdr%ZmkstemprrrZ get_temp_dirunlinkFinalizeropenr writerr)rr r+rfbsZzeros_rrrr@s"  zArena.__init__Nr )r )r"r#r$rrrrrr>scCs(|jdkrtdt|jtj|jffS)NrzDArena is unpicklable because forking was enabled when it was createdr )r+ ValueError rebuild_arenar rZDupFd)arrr reduce_arenaSs r6cCst||jS)N)rdetach)r Zdupfdrrrr4Ysr4c@sZeZdZdZejfddZeddZddZ dd Z d d Z d d Z ddZ ddZdS)HeapcCsJtj|_tj|_||_g|_i|_i|_ i|_ t |_ g|_ g|_dS)N)rr_lastpid threadingZLock_lock_size_lengths _len_to_seq_start_to_block_stop_to_blockset_allocated_blocks_arenas_pending_free_blocks)rr rrrrfs  z Heap.__init__cCs|d}|||@S)Nrr)nZ alignmentmaskrrr_roundupssz Heap._roundupc Cstj|j|}|t|jkrj|jt|j|tj}|jd9_t j d|t |}|j j ||d|fS|j|}|j|}|j}|s|j|=|j|=|\}}}|j||f=|j||f=|S)Nz"allocating a new mmap of length %dr)bisectZ bisect_leftr>lenrHmaxr=rPAGESIZErinforrDappendr?popr@rA) rr rlengtharenaseqblockstartstoprrr_mallocys"        z Heap._mallocc Cs|\}}}y|j||f}Wntk r0YnX|j|\}}y|j||f}Wntk rfYnX|j|\}}|||f}||}y|j|j|Wn.tk r|g|j|<tj|j|YnX||j||f<||j||f<dS)N) rAKeyError_absorbr@r?rOrJZinsortr>) rrTrRrUrVZ prev_blockr2Z next_blockrQrrr_frees(   z Heap._freecCs^|\}}}|j||f=|j||f=||}|j|}|j||sV|j|=|jj|||fS)N)r@rAr?remover>)rrTrRrUrVrQrSrrrrYs      z Heap._absorbc CsFx@y|jj}Wntk r&PYnX|jj||j|qWdS)N)rErP IndexErrorrCr[rZ)rrTrrr_free_pending_blockss zHeap._free_pending_blocksc CsN|jjds|jj|n0z"|j|jj||j|Wd|jjXdS)NF) r<acquirerErOr]rCr[rZrelease)rrTrrrfrees  z Heap.freec Cstj|jkr|j|jh|j|jt|d|j}|j |\}}}||}||krj|j |||f|||f}|j j ||SQRXdS)Nr) rrr:rr<r]rHrL _alignmentrWrZrCadd)rr rRrUrVZnew_stoprTrrrmallocs  z Heap.mallocN)r"r#r$rarrMr staticmethodrHrWrZrYr]r`rcrrrrr8bs  r8c@s"eZdZeZddZddZdS)rcCs0tjj|}||f|_tj|tjj|fddS)N)args)r_heaprcrrr-r`)rr rTrrrrs  zBufferWrapper.__init__cCs&|j\\}}}}t|j|||S)N)r memoryviewr)rrRrUrVr rrrcreate_memoryviewszBufferWrapper.create_memoryviewN)r"r#r$r8rfrrhrrrrrs)rJrrsysr%r;contextrrr__all__platformrobjectrr6r4registerr8rrrrr s$