From 234d0895ad470c5adef3f071a01ce26efb6580b7 Mon Sep 17 00:00:00 2001 From: Jonathan Ellis Date: Mon, 20 Apr 2009 16:38:32 +0000 Subject: [PATCH] fix row size "returned" via bufOut (currently ignored). patch by Jun Rao; reviewed by jbellis for #33 git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@766744 13f79535-47bb-0310-9956-ffa450edef68 --- src/org/apache/cassandra/io/SequenceFile.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/org/apache/cassandra/io/SequenceFile.java b/src/org/apache/cassandra/io/SequenceFile.java index 0b96f003f2..2c4edd9907 100644 --- a/src/org/apache/cassandra/io/SequenceFile.java +++ b/src/org/apache/cassandra/io/SequenceFile.java @@ -903,7 +903,7 @@ public class SequenceFile * one booleanfor deleted or not + * one int for number of columns */ - bufOut.writeInt(dataSize + utfPrefix_ + cfName.length() + 4 + 1); + bufOut.writeInt(dataSize + utfPrefix_ + cfName.length() + 4 + 8 + 4); /* write the column family name */ bufOut.writeUTF(cfName); /* write local deletion time */ @@ -991,7 +991,7 @@ public class SequenceFile * one booleanfor deleted or not + * one int for number of columns */ - bufOut.writeInt(dataSizeReturned + utfPrefix_ + cfName.length() + 4 + 1); + bufOut.writeInt(dataSizeReturned + utfPrefix_ + cfName.length() + 4 + 8 + 4); /* write the column family name */ bufOut.writeUTF(cfName); /* write local deletion time */