��Qc@s

dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZddlm	Z	m
Z

ddlmZ
dg
Z
ejdkr�ddlmZ
def
d��YZndef
d	��YZd
ef
d��YZdef
d��YZd
S(
i�N(tFinalizetinfo(
tassert_spawningt
BufferWrappertwin32(
RtArenac
Bs/eZ
ej�Zd�Zd
�Zd�ZRS(cCs�|
|_d
t
j�tjj�f|_tjd|jd|j�
|_t	j
�dksjtd��|j|jf|_dS(Ns	pym-%d-%di�ttagnameistagname already in use(
tsizetostgetpidRt_countertnexttnametmmaptbufferRtGetLastErrortAssertionErrort_state(tselfR((s*/sys/lib/python2.7/multiprocessing/heap.pyt__init__=s

	
"
!

c

Cst|�
|j
S(
N(RR(
R((s*/sys/lib/python2.7/multiprocessing/heap.pyt__getstate__Ds


cCsY|
\|_|_
|_tjd
|jd|j
�
|_tj�tjksUt�dS(Ni�R(	RRRR
RRRtERROR_ALREADY_EXISTSR(Rtstate((s*/sys/lib/python2.7/multiprocessing/heap.pyt__setstate__Hs

!
(t__name__t
__module__t	itertoolstcountR
RRR(((s*/sys/lib/python2.7/multiprocessing/heap.pyR9s		c
BseZ
d�ZRS(
cCs+tjd
|
�|_
|
|_d|_dS(Ni�(R
RRtNoneR(RR((s*/sys/lib/python2.7/multiprocessing/heap.pyRQs

	
(RRR(((s*/sys/lib/python2.7/multiprocessing/heap.pyROstHeapcBsbeZ
dZejd
�Zed��Zd�Zd�Z	d�Z
d�Zd�Zd�Z
RS(	icCsmtj
�|_tj�|_|
|_g|_i|_i|_	i|_
t�|_g|_
g|_dS(
N(RR	t_lastpidt	threadingtLockt_lockt_sizet_lengthst_len_to_seqt_start_to_blockt_stop_to_blocktsett_allocated_blockst_arenast_pending_free_blocks(RR((s*/sys/lib/python2.7/multiprocessing/heap.pyR^s


	
	
	
	
	

	cCs|
d
}|||@S(Ni
((t
nt	alignmenttmask((s*/sys/lib/python2.7/multiprocessing/heap.pyt_roundupks

c	Cs
tj
|j|
�}|t|j�kr�|jt|j|
�tj�}|jd
9_t	d|�
t
|�}|jj|�
|d|fS|j|}|j
|}|j�}|s�|j
|=|j|=n|\}}}|j||f=|j||f=|S(Nis"allocating a new mmap of length %di(tbisecttbisect_leftR#tlenR.tmaxR"R
tPAGESIZER
RR)tappendR$tpopR%R&(	RRt
itlengthtarenatseqtblocktstarttstop((s*/sys/lib/python2.7/multiprocessing/heap.pyt_mallocqs"

!















c	Cs!
|
\}}}y|j||f}Wnt
k
r9


nX|j|�\}}y|j||f}Wnt
k
ry


nX|j|�\}}|||f}
||}y|j|j|
�
Wn4t
k
r�
|
g
|j|<tj|j|�
n
X|
|j||f<|
|j||f<dS(
N(	R&tKeyErrort_absorbR%R$R4R/tinsortR#(	RR:R8R;R<t
prev_blockt
_t
next_blockR7((s*/sys/lib/python2.7/multiprocessing/heap.pyt_free�s(















cCs�|
\}}}|j||f=|j
||f=||}|j|}|j|
�
|sv|j|=|jj|�
n||fS(
N(R%R&R$tremoveR#(RR:R8R;R<R7R9((s*/sys/lib/python2.7/multiprocessing/heap.pyR?�s










c
CsVxOtrQy|j
j�}
Wntk
r0


Pn
X|jj|
�
|j|
�
qWdS(
N(tTrueR*R5t
IndexErrorR(RERD(RR:((s*/sys/lib/python2.7/multiprocessing/heap.pyt_free_pending_blocks�s	






cCs�tj
�|jkst�|jjt�s@|jj|
�
n<z+|j	�
|j
j|
�
|j|
�
Wd|jj
�
XdS(
N(RR	RRR!tacquiretFalseR*R4RHR(RERDtrelease(RR:((s*/sys/lib/python2.7/multiprocessing/heap.pytfree�s





cCs�d
|
k
otj
kn
s%t�tj�|jkrG|j�
n|jj�
|j	�
z�|j
t|
d�|j�}
|j
|
�\}}}||
}||kr�|j|||f�
n|||f}|jj|�
|SWd|jj�
XdS(Nii
(tsystmaxintRRR	RRR!RIRHR.R2t
_alignmentR=RDR(taddRK(RRR8R;R<tnew_stopR:((s*/sys/lib/python2.7/multiprocessing/heap.pytmalloc�s%
















(RRROR
R3RtstaticmethodR.R=RDR?RHRLRR(((s*/sys/lib/python2.7/multiprocessing/heap.pyRZs
				
	c
Bs,eZ
e�Zd�Zd
�Zd�ZRS(cCsfd
|
k
otj
kn
s%t�tjj|
�}||
f|_t|tjjd|f
�

dS(Nitargs(	RMRNRRt_heapRRRRRL(RRR:((s*/sys/lib/python2.7/multiprocessing/heap.pyR�s
%


c
CsJ|j\\}
}}}t
j|
j�\}}||k
sBt�||S(
N(Rt_multiprocessingtaddress_of_bufferRR(RR8R;R<RtaddressR7((s*/sys/lib/python2.7/multiprocessing/heap.pytget_address�s



c

Cs|jd
S(Ni
(
R(
R((s*/sys/lib/python2.7/multiprocessing/heap.pytget_size�s
(RRRRURRYRZ(((s*/sys/lib/python2.7/multiprocessing/heap.pyR�s			(R/R
ttempfileRRMRRRVtmultiprocessing.utilRR
tmultiprocessing.forkingRt__all__tplatformRtobjectRRR(((s*/sys/lib/python2.7/multiprocessing/heap.pyt<module>#s