summaryrefslogtreecommitdiff
path: root/msgpack/fallback.py
diff options
context:
space:
mode:
authorjfolz <theriddling@gmail.com>2020-06-08 05:14:50 +0200
committerGitHub <noreply@github.com>2020-06-08 12:14:50 +0900
commitc1b1a23f62d5e0ec39a1910d2e9580ce1c13a1cf (patch)
tree9726bba0edf80ba9515495c315d7966f7b7aa37e /msgpack/fallback.py
parentb04690012d5d77cfe5074893686c4d55ec780300 (diff)
downloadmsgpack-python-c1b1a23f62d5e0ec39a1910d2e9580ce1c13a1cf.tar.gz
Fix Unpacker.tell() (#427)
Fixes #426. Co-authored-by: folz <joachim.folz@dfki.de>
Diffstat (limited to 'msgpack/fallback.py')
-rw-r--r--msgpack/fallback.py15
1 files changed, 8 insertions, 7 deletions
diff --git a/msgpack/fallback.py b/msgpack/fallback.py
index 9f6665b..1e0bbe9 100644
--- a/msgpack/fallback.py
+++ b/msgpack/fallback.py
@@ -365,18 +365,19 @@ class Unpacker(object):
return self._buffer[self._buff_i :]
def read_bytes(self, n):
- ret = self._read(n)
+ ret = self._read(n, raise_outofdata=False)
self._consume()
return ret
- def _read(self, n):
+ def _read(self, n, raise_outofdata=True):
# (int) -> bytearray
- self._reserve(n)
+ self._reserve(n, raise_outofdata=raise_outofdata)
i = self._buff_i
- self._buff_i = i + n
- return self._buffer[i : i + n]
+ ret = self._buffer[i : i + n]
+ self._buff_i = i + len(ret)
+ return ret
- def _reserve(self, n):
+ def _reserve(self, n, raise_outofdata=True):
remain_bytes = len(self._buffer) - self._buff_i - n
# Fast path: buffer has n bytes already
@@ -404,7 +405,7 @@ class Unpacker(object):
self._buffer += read_data
remain_bytes -= len(read_data)
- if len(self._buffer) < n + self._buff_i:
+ if len(self._buffer) < n + self._buff_i and raise_outofdata:
self._buff_i = 0 # rollback
raise OutOfData