File "heap.pyc"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/lib64/python2.7/multiprocessing/heap.pyc
File size: 6.75 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


{fc@s

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

ddlmZ
dg
Z
ejdkrddlmZ
def
dYZndef
d	YZd
ef
dYZdef
dYZd
S(
iN(tFinalizetinfo(
tassert_spawningt
BufferWrappertwin32(
RtArenac
Bs/eZ
ejZdZd
ZdZRS(cCs|
|_d
t
jtjjf|_tjd|jd|j
|_t	j
dksjtd

|j|jf|_dS(Ns	pym-%d-%dittagnameistagname already in use(
tsizetostgetpidRt_countertnexttnametmmaptbufferRtGetLastErrortAssertionErrort_state(tselfR((s,/usr/lib64/python2.7/multiprocessing/heap.pyt__init__=s

	
"
!

c

Cst|

|j
S(
N(RR(
R((s,/usr/lib64/python2.7/multiprocessing/heap.pyt__getstate__Ds


cCsY|
\|_|_
|_tjd
|jd|j

|_tjtjksUt
dS(NiR(	RRRR
RRRtERROR_ALREADY_EXISTSR(Rtstate((s,/usr/lib64/python2.7/multiprocessing/heap.pyt__setstate__Hs

!
(t__name__t
__module__t	itertoolstcountR
RRR(((s,/usr/lib64/python2.7/multiprocessing/heap.pyR9s		c
BseZ
dZRS(
cCs+tjd
|
|_
|
|_d|_dS(Ni(R
RRtNoneR(RR((s,/usr/lib64/python2.7/multiprocessing/heap.pyRQs

	
(RRR(((s,/usr/lib64/python2.7/multiprocessing/heap.pyROstHeapcBsbeZ
dZejd

Zed
ZdZdZ	dZ
dZdZdZ
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,/usr/lib64/python2.7/multiprocessing/heap.pyR^s


	
	
	
	
	

	cCs|
d
}|||@S(Ni
((t
nt	alignmenttmask((s,/usr/lib64/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,/usr/lib64/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,/usr/lib64/python2.7/multiprocessing/heap.pyt_frees(















cCs|
\}}}|j||f=|j
||f=||}|j|}|j|


|sv|j|=|jj|

n||fS(
N(R%R&R$tremoveR#(RR:R8R;R<R7R9((s,/usr/lib64/python2.7/multiprocessing/heap.pyR?s










c
CsVxOtrQy|j
j}
Wntk
r0


Pn
X|jj|


|j|


qWdS(
N(tTrueR*R5t
IndexErrorR(RERD(RR:((s,/usr/lib64/python2.7/multiprocessing/heap.pyt_free_pending_blockss	






cCstj
|jkst
|jjt
s@|jj|


n<z+|j	
|j
j|


|j|


Wd|jj

XdS(
N(RR	RRR!tacquiretFalseR*R4RHR(RERDtrelease(RR:((s,/usr/lib64/python2.7/multiprocessing/heap.pytfrees





cCsd
|
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,/usr/lib64/python2.7/multiprocessing/heap.pytmallocs%
















(RRROR
R3RtstaticmethodR.R=RDR?RHRLRR(((s,/usr/lib64/python2.7/multiprocessing/heap.pyRZs
				
	c
Bs,eZ
eZdZd
ZdZRS(cCsfd
|
k
otj
kn
s%t
tjj|

}||
f|_t|tjjd|f


dS(Nitargs(	RMRNRRt_heapRRRRRL(RRR:((s,/usr/lib64/python2.7/multiprocessing/heap.pyRs
%


c
CsJ|j\\}
}}}t
j|
j
\}}||k
sBt
||S(
N(Rt_multiprocessingtaddress_of_bufferRR(RR8R;R<RtaddressR7((s,/usr/lib64/python2.7/multiprocessing/heap.pytget_addresss



c

Cs|jd
S(Ni
(
R(
R((s,/usr/lib64/python2.7/multiprocessing/heap.pytget_sizes
(RRRRURRYRZ(((s,/usr/lib64/python2.7/multiprocessing/heap.pyRs			(R/R
ttempfileRRMRRRVtmultiprocessing.utilRR
tmultiprocessing.forkingRt__all__tplatformRtobjectRRR(((s,/usr/lib64/python2.7/multiprocessing/heap.pyt<module>#s