summaryrefslogtreecommitdiff
path: root/msgpack/_unpacker.pyx
diff options
context:
space:
mode:
authorINADA Naoki <songofacandy@gmail.com>2018-11-09 22:13:11 +0900
committerINADA Naoki <songofacandy@gmail.com>2018-11-09 22:13:11 +0900
commit33e6aef1715722fe13370baf45e2fd6dae2a11de (patch)
tree632502320e7016fbf1c605f34f5963cf287c119c /msgpack/_unpacker.pyx
parent1bf62ba6f8f94ab8a7dd135e0039ee3b10e0e96c (diff)
downloadmsgpack-python-33e6aef1715722fe13370baf45e2fd6dae2a11de.tar.gz
Remove deprecated exception classes
Diffstat (limited to 'msgpack/_unpacker.pyx')
-rw-r--r--msgpack/_unpacker.pyx42
1 files changed, 19 insertions, 23 deletions
diff --git a/msgpack/_unpacker.pyx b/msgpack/_unpacker.pyx
index 85c404a..2f99019 100644
--- a/msgpack/_unpacker.pyx
+++ b/msgpack/_unpacker.pyx
@@ -35,7 +35,6 @@ ctypedef unsigned long long uint64_t
from msgpack.exceptions import (
BufferFull,
OutOfData,
- UnpackValueError,
ExtraData,
)
from msgpack import ExtType
@@ -208,7 +207,7 @@ def unpackb(object packed, object object_hook=None, object list_hook=None,
raise ExtraData(obj, PyBytes_FromStringAndSize(buf+off, buf_len-off))
return obj
unpack_clear(&ctx)
- raise UnpackValueError("Unpack failed: error = %d" % (ret,))
+ raise ValueError("Unpack failed: error = %d" % (ret,))
def unpack(object stream, **kwargs):
@@ -460,28 +459,25 @@ cdef class Unpacker(object):
else:
raise OutOfData("No more data to unpack.")
- try:
- ret = execute(&self.ctx, self.buf, self.buf_tail, &self.buf_head)
- self.stream_offset += self.buf_head - prev_head
- if write_bytes is not None:
- write_bytes(PyBytes_FromStringAndSize(self.buf + prev_head, self.buf_head - prev_head))
-
- if ret == 1:
- obj = unpack_data(&self.ctx)
- unpack_init(&self.ctx)
- return obj
- elif ret == 0:
- if self.file_like is not None:
- self.read_from_file()
- continue
- if iter:
- raise StopIteration("No more data to unpack.")
- else:
- raise OutOfData("No more data to unpack.")
+ ret = execute(&self.ctx, self.buf, self.buf_tail, &self.buf_head)
+ self.stream_offset += self.buf_head - prev_head
+ if write_bytes is not None:
+ write_bytes(PyBytes_FromStringAndSize(self.buf + prev_head, self.buf_head - prev_head))
+
+ if ret == 1:
+ obj = unpack_data(&self.ctx)
+ unpack_init(&self.ctx)
+ return obj
+ elif ret == 0:
+ if self.file_like is not None:
+ self.read_from_file()
+ continue
+ if iter:
+ raise StopIteration("No more data to unpack.")
else:
- raise UnpackValueError("Unpack failed: error = %d" % (ret,))
- except ValueError as e:
- raise UnpackValueError(e)
+ raise OutOfData("No more data to unpack.")
+ else:
+ raise ValueError("Unpack failed: error = %d" % (ret,))
def read_bytes(self, Py_ssize_t nbytes):
"""Read a specified number of raw bytes from the stream"""