openstack/deb-python-cassandra-driver
Code Issues Proposed changes

fixed vints_unpack

Browse Source
This commit is contained in:
Alan Boudreault
2017-01-13 14:23:55 -05:00
parent cfed17f357
commit aa11b5720b
1 changed files with 19 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
cassandra/marshal.py
View File

@@ -91,11 +91,23 @@ def decode_zig_zag(n):
def vints_unpack(term): # noqa def vints_unpack(term): # noqa
first_byte = ord(term[0]) values = []
if (first_byte & 128) == 0: n = 0
val = first_byte while n < len(term):
else: first_byte = ord(term[n])
extra_bytes = 8 - (~first_byte & 0xff).bit_length()
# takes (8-extra_bytes) bits + extra_bytes
return decode_zig_zag(val) if (first_byte & 128) == 0:
val = first_byte
else:
num_extra_bytes = 8 - (~first_byte & 0xff).bit_length()
val = first_byte & (0xff >> num_extra_bytes)
end = n + num_extra_bytes
while n < end:
n += 1
val <<= 8
val |= ord(term[n]) & 0xff
n += 1
values.append(decode_zig_zag(val))
return tuple(values)