e f@s#ddlZddlZddlZddlZddlZddlZddlmZddlmZddlm Z dgZ ej dkrddl Z Gdd d e Zn>Gd d d e Zd d Zd dZejeeGddde ZGddde ZdS)N)context) reduction)util BufferWrapperwin32c@s@eZdZejZddZddZddZdS)ArenacCs||_xwtdD]]}dtjt|jf}tjd|d|}tjdkriPn|j qWt d||_ ||_ |j|j f|_ dS)Ndz pym-%d-%srtagnamerzCannot find name for new mmap)sizerangeosgetpidnext_randmmap_winapiZ GetLastErrorcloseFileExistsErrornamebuffer_state)selfr irZbufr9/opt/alt/python34/lib64/python3.4/multiprocessing/heap.py__init__#s    zArena.__init__cCstj||jS)N)rZassert_spawningr)rrrr __getstate__2s zArena.__getstate__cCs>|\|_|_|_tjd|jd|j|_dS)Nrr r )r rrrr)rstaterrr __setstate__6s!zArena.__setstate__N) __name__ __module__ __qualname__tempfileZ_RandomNameSequencerrrr rrrrrs    rc@seZdZdddZdS)rrc Cs||_||_|d krtjddtjdtj\|_}tj|tj |tj |jft |jddd}|j d|WdQXnt j |j|j|_dS) Nrprefixzpym-%d-dirwbclosefdFsr )r fdr$ZmkstemprrrZ get_temp_dirunlinkFinalizeropenwriterr)rr r)rfrrrr?s    ( zArena.__init__Nr )r!r"r#rrrrrr=s cCs=|jdkrtdnt|jtj|jffS)NrzDArena is unpicklable because forking was enabled when it was createdr )r) ValueError rebuild_arenar rZDupFd)arrr reduce_arenaKsr2cCst||jS)N)rdetach)r Zdupfdrrrr0Qsr0c@seZdZdZejddZeddZddZ dd Z d d Z d d Z ddZ ddZdS)HeapcCsmtj|_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 rrrr^s       z Heap.__init__cCs|d}|||@S)Nrr)nZ alignmentmaskrrr_roundupks z Heap._roundupc Cs tj|j|}|t|jkr|jt|j|tj}|jd9_t j d|t |}|j j ||d|fS|j|}|j|}|j}|s|j|=|j|=n|\}}}|j||f=|j||f=|S)Nz"allocating a new mmap of length %dr)bisectZ bisect_leftr:lenrDmaxr9rPAGESIZErinforr@appendr;popr<r=) rr rlengtharenaseqblockstartstoprrr_mallocqs"!     z Heap._mallocc Cs$|\}}}y|j||f}Wntk r:YnX|j|\}}y|j||f}Wntk r{YnX|j|\}}|||f}||}y|j|j|Wn5tk r|g|j| s$