File "heap.cpython-33.pyc"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python33/lib64/python3.3/multiprocessing/__pycache__/heap.cpython-33.pyc
File size: 8.55 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


fec@sdd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZddlmZm	Z	
ddl
mZ
dg
Zej
dkrdd
lZGdddeZnGdddeZGd	d
d
eZGdddeZd
S(iN(uFinalizeuinfo(
uassert_spawningu
BufferWrapperuwin32c

BsD|EeZ
dZejZd
dZddZddZdS(uArenacCs|
|_d
t
jttj
f|_tjd|jd|j
|_t	j
dksjtd

|j|jf|_dS(Nu	pym-%d-%di
utagnameiutagname already in usei(
usizeuosugetpidunextuArenau_counterunameummapubufferu_winapiuGetLastErroruAssertionErroru_state(uselfusize((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu__init__#s

	
"
!

uArena.__init__c

Cst|

|j
S(
N(uassert_spawningu_state(
uself((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu__getstate__*s


uArena.__getstate__cCsY|
\|_|_
|_tjd|jd|j

|_tjtjksUt
dS(Ni
utagnamei(	usizeunameu_stateummapubufferu_winapiuGetLastErroruERROR_ALREADY_EXISTSuAssertionError(uselfustate((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu__setstate__.s

!
uArena.__setstate__N(	u__name__u
__module__u__qualname__u	itertoolsucountu_counteru__init__u__getstate__u__setstate__(
u
__locals__((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyuArenasuArenac

Bs |EeZ
dZd
dZdS(uArenacCs+tjd|
|_
|
|_d|_dS(Ni
i(ummapubufferusizeuNoneuname(uselfusize((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu__init__7s

	
uArena.__init__N(u__name__u
__module__u__qualname__u__init__(
u
__locals__((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyuArena5sc

Bs|EeZ
dZd
Zejdd
Zedd
ZddZ	dd	Z
d
dZdd
ZddZ
ddZdS(uHeapicCsmtj
|_tj|_|
|_g|_i|_i|_	i|_
t|_g|_
g|_dS(
N(uosugetpidu_lastpidu	threadinguLocku_locku_sizeu_lengthsu_len_to_sequ_start_to_blocku_stop_to_blockusetu_allocated_blocksu_arenasu_pending_free_blocks(uselfusize((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu__init__Ds


	
	
	
	
	

	u
Heap.__init__cCs|
d
}|||@S(Ni
((u
nu	alignmentumask((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu_roundupQs

u
Heap._roundupc	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(Niu"allocating a new mmap of length %di(ubisectubisect_leftu_lengthsulenu_roundupumaxu_sizeummapuPAGESIZEuinfouArenau_arenasuappendu_len_to_sequpopu_start_to_blocku_stop_to_block(	uselfusizeu
iulengthuarenausequblockustartustop((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu_mallocWs"

!















uHeap._mallocc	Cs$
|
\}}}y|j||f}Wnt
k
r:


YnX|j|
\}}y|j||f}Wnt
k
r{


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


Wn5t
k
r


|
g
|j|<tj|j|
Yn
X|
|j||f<|
|j||f<dS(
N(	u_stop_to_blockuKeyErroru_absorbu_start_to_blocku_len_to_sequappendubisectuinsortu_lengths(	uselfublockuarenaustartustopu
prev_blocku
_u
next_blockulength((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu_freems(















u
Heap._freecCs|
\}}}|j||f=|j
||f=||}|j|}|j|


|sv|j|=|jj|

n||fS(
N(u_start_to_blocku_stop_to_blocku_len_to_sequremoveu_lengths(uselfublockuarenaustartustopulengthuseq((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu_absorbs










uHeap._absorbc
CsPxIy|jj
}
Wntk
r+


PYn
X|jj|


|j|


qdS(
N(u_pending_free_blocksupopu
IndexErroru_allocated_blocksuremoveu_free(uselfublock((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu_free_pending_blockss






uHeap._free_pending_blocksc
Cstj
|jkst
|jjd

s@|jj|


n<z+|j	
|j
j|


|j|


Wd|jj

XdS(NF(uosugetpidu_lastpiduAssertionErroru_lockuacquireuFalseu_pending_free_blocksuappendu_free_pending_blocksu_allocated_blocksuremoveu_freeurelease(uselfublock((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyufrees





u	Heap.freecCsd
|
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
(usysumaxsizeuAssertionErroruosugetpidu_lastpidu__init__u_lockuacquireu_free_pending_blocksu_roundupumaxu
_alignmentu_mallocu_freeu_allocated_blocksuaddurelease(uselfusizeuarenaustartustopunew_stopublock((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyumallocs%
















uHeap.mallocN(u__name__u
__module__u__qualname__u
_alignmentummapuPAGESIZEu__init__ustaticmethodu_roundupu_mallocu_freeu_absorbu_free_pending_blocksufreeumalloc(
u
__locals__((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyuHeap@s

uHeapc

Bs5|EeZ
dZeZd
dZddZdS(u
BufferWrappercCsfd
|
k
otj
kn
s%t
tjj|

}||
f|_t|tjjd|f


dS(Niuargs(	usysumaxsizeuAssertionErroru
BufferWrapperu_heapumallocu_stateuFinalizeufree(uselfusizeublock((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu__init__s
%


uBufferWrapper.__init__c
Cs3|j\\}
}}}t
|
j
|||S(
N(u_stateu
memoryviewubuffer(uselfuarenaustartustopusize((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyucreate_memoryviews

uBufferWrapper.create_memoryviewN(u__name__u
__module__u__qualname__uHeapu_heapu__init__ucreate_memoryview(
u
__locals__((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu
BufferWrappers	(ubisectummapuosusysu	threadingu	itertoolsu_multiprocessingumultiprocessing.utiluFinalizeuinfoumultiprocessing.forkinguassert_spawningu__all__uplatformu_winapiuobjectuArenauHeapu
BufferWrapper(((u9/opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu<module>
s