$88 GRAYBYTE WORDPRESS FILE MANAGER $23

3

��2a �@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZmZ
ddl	m
Z

dg
Zejdkrvdd
l
Z
Gdd�de�Zn,Gd	d�de�Zd
d�Zdd
�Zejee�
Gdd�de�ZGdd�de�Zd
S)�N�
)�	reduction�assert_spawning)
�util�
BufferWrapper�win32c@s,eZ
dZej�Zd
d�Zdd�Zdd�ZdS)�ArenacCsz|
|_xTt
d
�
D]@}dtj�t|j�
f}tjd|
|d�}tj�dkrHP|j	�
qWt
d�
�
||_||_|j|jf|_
dS)N�dz	pym-%d-%sr)
�tagnamer
zCannot find name for new mmap���)�size�range�os�getpid�next�_rand�mmap�_winapiZGetLastError�close�FileExistsError�name�buffer�_state)�selfr�
ir�buf�r�)/opt/alt/python36/lib64/python3.6/heap.py�__init__"s








zArena.__init__c

Cst|�

|j
S)
N)rr)
rrrr�__getstate__1s

zArena.__getstate__cCs,|
\|_|_
|_tjd|j|j
d�|_dS)Nr)
r
r)rrrrr)r�staterrr�__setstate__5s

zArena.__setstate__N)	�__name__�
__module__�__qualname__�tempfileZ_RandomNameSequencerrrr!rrrrrsrc@seZ
dZddd�
ZdS)rrcCs�|
|_||_
|d	kr�tjdtj�tj�d�\|_
}tj|�

tj	|tj
|j
f
�
t|j
ddd��N}d
}|
|kr�d|}xt|
|�
D]}|j
|�

q�W~|j
d|
|�

WdQRXtj|j
|j�|_dS)Nrzpym-%d-)�prefix�dir�wbF)
�closefdi�
ri)r�fdr%ZmkstemprrrZget_temp_dir�unlink�Finalizer�openr
�writerr)rrr+r�
f�bsZzeros�
_rrrr@s"


















zArena.__init__Nr)
r)r"r#r$rrrrrr>sc

Cs(|jdkrt
d�
�
t|jtj|j�
ffS)NrzDArena is unpicklable because forking was enabled when it was createdr)r+�
ValueError�
rebuild_arenarrZDupFd)
�
arrr�reduce_arenaSs


r6cCst||
j
��S)
N)r�detach)rZdupfdrrrr4Ys
r4c@sZeZ
dZd
Zejf
dd�
Zedd��
Zdd�Z	dd	�Z
d
d�Zdd
�Zdd�Z
dd�ZdS)�Heap�cCsJtj
�|_tj�|_|
|_g|_i|_i|_	i|_
t�|_g|_
g|_dS)
N)rr�_lastpid�	threadingZLock�_lock�_size�_lengths�_len_to_seq�_start_to_block�_stop_to_block�set�_allocated_blocks�_arenas�_pending_free_blocks)rrrrrrfs










z
Heap.__init__cCs|
d
}|||@S)Nrr)�
nZ	alignment�maskrrr�_roundupss
z
Heap._roundupc	Cs�tj
|j|
�}|t|j�
krj|jt|j|
�tj�}|jd
9_t	j
d|�
t|�
}|jj
|�

|d|fS|j|}|j|}|j�}|s�|j|=|j|=|\}}}|j||f=|j||f=|S)N�z"allocating a new mmap of length %dr
)�bisectZbisect_leftr>�lenrH�maxr=r�PAGESIZEr�inforrD�appendr?�popr@rA)	rrr�length�arena�seq�block�start�stoprrr�_mallocys"

















zHeap._mallocc	Cs�|
\}}}y|j||f}Wnt
k
r0


YnX|j|�
\}}y|j||f}Wnt
k
rf


YnX|j|�
\}}|||f}
||}y|j|j|
�

Wn.t
k
r�


|
g
|j|<tj|j|�
YnX|
|j||f<|
|j||f<dS)
N)	rA�KeyError�_absorbr@r?rOrJZinsortr>)	rrTrRrUrVZ
prev_blockr2Z
next_blockrQrrr�_free�s(













z
Heap._freecCs^|
\}}}|j||f=|j
||f=||}|j|}|j|
�

|sV|j|=|jj|�

||fS)
N)r@rAr?�remover>)rrTrRrUrVrQrSrrrrY�s









zHeap._absorbc
CsFx@y|jj
�}
Wntk
r&


PYnX|jj|
�

|j|
�

qWdS)
N)rErP�
IndexErrorrCr[rZ)rrTrrr�_free_pending_blocks�s





zHeap._free_pending_blocksc
CsN|jj
d
�
s|jj|
�

n0z"|j�
|jj|
�

|j|
�

Wd|jj�
XdS)NF)	r<�acquirerErOr]rCr[rZ�release)rrTrrr�free�s


z	Heap.freecCs�tj
�|jkr|j�
|j�h
|j�
|jt|
d
�|j�}
|j	|
�
\}}}||
}||krj|j
|||f�

|||f}|jj|�

|SQRXdS)Nr)
rrr:rr<r]rHrL�
_alignmentrWrZrC�add)rrrRrUrVZnew_stoprTrrr�malloc�s











zHeap.mallocN)r"r#r$rarrMr�staticmethodrHrWrZrYr]r`rcrrrrr8bs

r8c@s"eZ
dZe�Zd
d�Zdd�ZdS)rcCs0tj
j|
�
}||
f|_tj|tj
j|f
d
�
dS)N)
�args)r�_heaprcrrr-r`)rrrTrrrr�s


zBufferWrapper.__init__c
Cs&|j\\}
}}}t
|
j�
|||�S)
N)r�
memoryviewr)rrRrUrVrrrr�create_memoryview�s

zBufferWrapper.create_memoryviewN)r"r#r$r8rfrrhrrrrr�s)rJrr�sysr%r;�contextrr�r�__all__�platformr�objectrr6r4�registerr8rrrrr�<module>
s$