fix: neg version in beansdb.write_record

douban · Sep 28, 2017 · 6b17eb7 · 6b17eb7
1 parent 1dd33c7
commit 6b17eb7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dpark/beansdb.py b/dpark/beansdb.py
@@ -126,7 +126,7 @@ def read_record(f, check_crc=False):
 
 
 def write_record(f, key, flag, value, version, ts):
-    header = struct.pack('IIIII', ts, flag, version, len(key), len(value))
+    header = struct.pack('IIiII', ts, flag, version, len(key), len(value))
     crc32 = binascii.crc32(header)
     crc32 = binascii.crc32(key, crc32)
     crc32 = binascii.crc32(value, crc32) & 0xffffffff