cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject git commit: make sure stream bytes are skipped fully
Date Fri, 26 Jul 2013 03:31:56 GMT
Updated Branches:
  refs/heads/trunk b4bcdfc15 -> afe4d555b


make sure stream bytes are skipped fully


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/afe4d555
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/afe4d555
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/afe4d555

Branch: refs/heads/trunk
Commit: afe4d555bb070a7f2fe4b864727d27843f9b6482
Parents: b4bcdfc
Author: Dave Brosius <dbrosius@apache.org>
Authored: Thu Jul 25 23:30:36 2013 -0400
Committer: Dave Brosius <dbrosius@apache.org>
Committed: Thu Jul 25 23:30:36 2013 -0400

----------------------------------------------------------------------
 src/java/org/apache/cassandra/io/sstable/SSTableWriter.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/afe4d555/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java b/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
index 6add286..5b3abfc 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
@@ -22,9 +22,9 @@ import java.nio.ByteBuffer;
 import java.util.*;
 
 import com.google.common.collect.Sets;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
 import org.apache.cassandra.config.CFMetaData;
 import org.apache.cassandra.config.DatabaseDescriptor;
 import org.apache.cassandra.config.Schema;
@@ -228,7 +228,7 @@ public class SSTableWriter extends SSTable
         if (version.hasRowSizeAndColumnCount)
         {
             // skip row size
-            in.skipBytes(8);
+            FileUtils.skipBytesFully(in, 8);
             columnCount = in.readInt();
         }
         Iterator<OnDiskAtom> iter = metadata.getOnDiskIterator(in, columnCount, ColumnSerializer.Flag.PRESERVE_SIZE,
Integer.MIN_VALUE, version);


Mime
View raw message