Skip to content

Commit e85c5e3

Browse files
committed
Rev3327, Add compatbility with new msgpack version
1 parent 194d57c commit e85c5e3

File tree

2 files changed

+12
-4
lines changed

2 files changed

+12
-4
lines changed

src/Config.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ class Config(object):
1010

1111
def __init__(self, argv):
1212
self.version = "0.6.2"
13-
self.rev = 3326
13+
self.rev = 3327
1414
self.argv = argv
1515
self.action = None
1616
self.config_file = "zeronet.conf"

src/Connection/Connection.py

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -215,11 +215,19 @@ def handleStream(self, message):
215215

216216
read_bytes = message["stream_bytes"] # Bytes left we have to read from socket
217217
# Check if the unpacker has something left in buffer
218-
extradata_len = min(self.unpacker._fb_buf_n - self.unpacker._fb_buf_o, read_bytes)
218+
if hasattr(self.unpacker, "_buffer"): # New version of msgpack
219+
bytes_buffer_left = len(self.unpacker._buffer) - self.unpacker.tell()
220+
else:
221+
bytes_buffer_left = self.unpacker._fb_buf_n - self.unpacker._fb_buf_o
222+
223+
extradata_len = min(bytes_buffer_left, read_bytes)
219224
if extradata_len:
220225
buff = self.unpacker.read_bytes(extradata_len)
221-
self.unpacker._fb_consume()
222-
self.log("Recovered: %r" % buff)
226+
# Get rid of extra data from buffer
227+
if hasattr(self.unpacker, "_consume"):
228+
self.unpacker._consume()
229+
else:
230+
self.unpacker._fb_consume()
223231
else:
224232
buff = ""
225233

0 commit comments

Comments
 (0)