Author: jbellis
Date: Mon Apr 20 16:38:32 2009
New Revision: 766744
URL: http://svn.apache.org/viewvc?rev=766744&view=rev
Log:
fix row size "returned" via bufOut (currently ignored). patch by Jun Rao;
reviewed by jbellis for #33
Modified:
incubator/cassandra/trunk/src/org/apache/cassandra/io/SequenceFile.java
Modified:
incubator/cassandra/trunk/src/org/apache/cassandra/io/SequenceFile.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/io/SequenceFile.java?rev=766744&r1=766743&r2=766744&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/io/SequenceFile.java
(original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/io/SequenceFile.java Mon
Apr 20 16:38:32 2009
@@ -903,7 +903,7 @@
* 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 @@
* 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 */
