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

Stream ID in header is a signed byte

Browse Source
This commit is contained in:
Tyler Hobbs
2014-04-04 12:58:04 -05:00
parent 74000bbbee
commit 80dd5fe1cb
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cassandra/marshal.py
View File

@@ -25,7 +25,7 @@ float_pack, float_unpack = _make_packer('>f')
double_pack, double_unpack = _make_packer('>d')
# Special case for cassandra header
header_struct = struct.Struct('>BBBB')
header_struct = struct.Struct('>BBbB')
header_pack = header_struct.pack
header_unpack = header_struct.unpack
@@ -37,7 +37,7 @@ if six.PY3:
val -= 1 << (len(term) * 8)
return val
else:
def varint_unpack(term):
def varint_unpack(term): # noqa
val = int(term.encode('hex'), 16)
if (ord(term[0]) & 128) != 0:
val = val - (1 << (len(term) * 8))