You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2009/04/20 18:38:33 UTC
svn commit: r766744 -
/incubator/cassandra/trunk/src/org/apache/cassandra/io/SequenceFile.java
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 */