Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

fix row size "returned" via bufOut (currently ignored). patch by Jun …

…Rao; reviewed by jbellis for #33
  • Loading branch information...
commit 550a5babda3d265e4d4e919fda5afe14097ed191 1 parent a8baa19
Jonathan Ellis authored
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/org/apache/cassandra/io/SequenceFile.java
View
4 src/org/apache/cassandra/io/SequenceFile.java
@@ -903,7 +903,7 @@ private void readTimeRange(String key, DataOutputBuffer bufOut, String columnFam
* 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 @@ private void readColumns(String key, DataOutputBuffer bufOut, String columnFamil
* 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 */
Please sign in to comment.
Something went wrong with that request. Please try again.