1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323
|
from rpython.rlib.rstruct.error import StructError
from rpython.rlib.buffer import StringBuffer, SubBuffer
from rpython.rlib.mutbuffer import MutableStringBuffer
from pypy.interpreter.error import oefmt
class BufferInterfaceNotFound(Exception):
pass
class BufferView(object):
"""Abstract base class for buffers."""
_attrs_ = ['readonly']
_immutable_ = True
def getlength(self):
"""Returns the size in bytes (even if getitemsize() > 1)."""
raise NotImplementedError
def as_str(self):
"Returns an interp-level string with the whole content of the buffer."
return ''.join(self._copy_buffer())
def getbytes(self, start, size):
"""Return `size` bytes starting at byte offset `start`.
This is a low-level operation, it is up to the caller to ensure that
the data requested actually correspond to items accessible from the
BufferView.
Note that `start` may be negative, e.g. if the buffer is reversed.
"""
raise NotImplementedError
def setbytes(self, start, string):
raise NotImplementedError
def get_raw_address(self):
raise ValueError("no raw buffer")
def as_readbuf(self):
# Inefficient. May be overridden.
return StringBuffer(self.as_str())
def as_writebuf(self):
"""Return a writable Buffer sharing the same data as `self`."""
raise BufferInterfaceNotFound
def getformat(self):
raise NotImplementedError
def getitemsize(self):
raise NotImplementedError
def getndim(self):
raise NotImplementedError
def getshape(self):
raise NotImplementedError
def getstrides(self):
raise NotImplementedError
def releasebuffer(self):
pass
def value_from_bytes(self, space, s):
from pypy.module.struct.formatiterator import UnpackFormatIterator
buf = StringBuffer(s)
fmtiter = UnpackFormatIterator(space, buf)
fmtiter.interpret(self.getformat())
return fmtiter.result_w[0]
def bytes_from_value(self, space, w_val):
from pypy.module.struct.formatiterator import PackFormatIterator
itemsize = self.getitemsize()
buf = MutableStringBuffer(itemsize)
fmtiter = PackFormatIterator(space, buf, [w_val])
try:
fmtiter.interpret(self.getformat())
except StructError as e:
raise oefmt(space.w_TypeError,
"memoryview: invalid type for format '%s'",
self.getformat())
return buf.finish()
def _copy_buffer(self):
if self.getndim() == 0:
itemsize = self.getitemsize()
return [self.getbytes(0, itemsize)]
data = []
self._copy_rec(0, data, 0)
return data
def _copy_rec(self, idim, data, off):
shapes = self.getshape()
shape = shapes[idim]
strides = self.getstrides()
if self.getndim() - 1 == idim:
self._copy_base(data, off)
return
for i in range(shape):
self._copy_rec(idim + 1, data, off)
off += strides[idim]
def _copy_base(self, data, off):
shapes = self.getshape()
step = shapes[0]
strides = self.getstrides()
itemsize = self.getitemsize()
bytesize = self.getlength()
copiedbytes = 0
for i in range(step):
bytes = self.getbytes(off, itemsize)
data.append(bytes)
copiedbytes += len(bytes)
off += strides[0]
# do notcopy data if the sub buffer is out of bounds
if copiedbytes >= bytesize:
break
def get_offset(self, space, dim, index):
"Convert index at dimension `dim` into a byte offset"
shape = self.getshape()
nitems = shape[dim]
if index < 0:
index += nitems
if index < 0 or index >= nitems:
raise oefmt(space.w_IndexError,
"index out of bounds on dimension %d", dim + 1)
# TODO suboffsets?
strides = self.getstrides()
return strides[dim] * index
def w_getitem(self, space, idx):
offset = self.get_offset(space, 0, idx)
itemsize = self.getitemsize()
# TODO: this probably isn't very fast
data = self.getbytes(offset, itemsize)
return self.value_from_bytes(space, data)
def new_slice(self, start, step, slicelength):
return BufferSlice(self, start, step, slicelength)
def setitem_w(self, space, idx, w_obj):
offset = self.get_offset(space, 0, idx)
# TODO: this probably isn't very fast
byteval = self.bytes_from_value(space, w_obj)
self.setbytes(offset, byteval)
def w_tolist(self, space):
dim = self.getndim()
if dim == 0:
raise NotImplementedError
elif dim == 1:
n = self.getshape()[0]
values_w = [self.w_getitem(space, i) for i in range(n)]
return space.newlist(values_w)
else:
return self._tolist_rec(space, 0, 0)
def _tolist_rec(self, space, start, idim):
strides = self.getstrides()
shape = self.getshape()
#
dim = idim + 1
stride = strides[idim]
itemsize = self.getitemsize()
dimshape = shape[idim]
#
if dim >= self.getndim():
bytecount = (stride * dimshape)
values_w = [
self.value_from_bytes(space, self.getbytes(pos, itemsize))
for pos in range(start, start + bytecount, stride)]
return space.newlist(values_w)
items = [None] * dimshape
for i in range(dimshape):
item = self._tolist_rec(space, start, idim + 1)
items[i] = item
start += stride
return space.newlist(items)
def wrap(self, space):
return space.newmemoryview(self)
class SimpleView(BufferView):
_attrs_ = ['readonly', 'data']
_immutable_ = True
def __init__(self, data):
self.data = data
self.readonly = self.data.readonly
def getlength(self):
return self.data.getlength()
def as_str(self):
return self.data.as_str()
def getbytes(self, start, size):
return self.data[start:start + size]
def setbytes(self, offset, s):
self.data.setslice(offset, s)
def get_raw_address(self):
return self.data.get_raw_address()
def as_readbuf(self):
return self.data
def as_writebuf(self):
assert not self.data.readonly
return self.data
def getformat(self):
return 'B'
def getitemsize(self):
return 1
def getndim(self):
return 1
def getshape(self):
return [self.getlength()]
def getstrides(self):
return [1]
def get_offset(self, space, dim, index):
"Convert index at dimension `dim` into a byte offset"
assert dim == 0
nitems = self.getlength()
if index < 0:
index += nitems
if index < 0 or index >= nitems:
raise oefmt(space.w_IndexError,
"index out of bounds on dimension %d", dim + 1)
return index
def w_getitem(self, space, idx):
idx = self.get_offset(space, 0, idx)
ch = self.data[idx]
return space.newint(ord(ch))
def new_slice(self, start, step, slicelength):
if step == 1:
return SimpleView(SubBuffer(self.data, start, slicelength))
else:
return BufferSlice(self, start, step, slicelength)
def setitem_w(self, space, idx, w_obj):
idx = self.get_offset(space, 0, idx)
self.data[idx] = space.byte_w(w_obj)
class BufferSlice(BufferView):
_immutable_ = True
_attrs_ = ['parent', 'readonly', 'shape', 'strides', 'start', 'step']
def __init__(self, parent, start, step, length):
self.parent = parent
self.readonly = self.parent.readonly
self.strides = parent.getstrides()[:]
self.start = start
self.step = step
self.strides[0] *= step
self.shape = parent.getshape()[:]
self.shape[0] = length
def getlength(self):
return self.shape[0] * self.getitemsize()
def getbytes(self, start, size):
offset = self.start * self.parent.getstrides()[0]
return self.parent.getbytes(offset + start, size)
def setbytes(self, start, string):
if len(string) == 0:
return # otherwise, adding self.offset might make 'start'
# out of bounds
offset = self.start * self.parent.getstrides()[0]
self.parent.setbytes(offset + start, string)
def get_raw_address(self):
from rpython.rtyper.lltypesystem import rffi
offset = self.start * self.parent.getstrides()[0]
return rffi.ptradd(self.parent.get_raw_address(), offset)
def getformat(self):
return self.parent.getformat()
def getitemsize(self):
return self.parent.getitemsize()
def getndim(self):
return self.parent.getndim()
def getshape(self):
return self.shape
def getstrides(self):
return self.strides
def parent_index(self, idx):
return self.start + self.step * idx
def w_getitem(self, space, idx):
return self.parent.w_getitem(space, self.parent_index(idx))
def new_slice(self, start, step, slicelength):
real_start = start + self.start
real_step = self.step * step
return BufferSlice(self.parent, real_start, real_step, slicelength)
def setitem_w(self, space, idx, w_obj):
return self.parent.setitem_w(space, self.parent_index(idx), w_obj)
|