Updated Branches: refs/heads/trunk 4357676f3 -> 033486158
DataInput.skipBytes isn't guaranteed to actually skip the number of bytes requested, use FileUtils.skipBytesFully instead patch by dbrosius; reviewed by jbellis for CASSANDRA-4226 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/03348615 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/03348615 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/03348615 Branch: refs/heads/trunk Commit: 033486158a8ee2ed3af870bd17e2734632a796ff Parents: 4357676 Author: Jonathan Ellis <jbel...@apache.org> Authored: Wed May 9 11:15:07 2012 -0500 Committer: Jonathan Ellis <jbel...@apache.org> Committed: Wed May 9 11:15:07 2012 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/net/MessageIn.java | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/03348615/src/java/org/apache/cassandra/net/MessageIn.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/net/MessageIn.java b/src/java/org/apache/cassandra/net/MessageIn.java index 531e0dd..f3b712e 100644 --- a/src/java/org/apache/cassandra/net/MessageIn.java +++ b/src/java/org/apache/cassandra/net/MessageIn.java @@ -27,6 +27,7 @@ import com.google.common.collect.ImmutableMap; import org.apache.cassandra.concurrent.Stage; import org.apache.cassandra.io.IVersionedSerializer; +import org.apache.cassandra.io.util.FileUtils; public class MessageIn<T> { @@ -82,7 +83,7 @@ public class MessageIn<T> if (callback == null) { // reply for expired callback. we'll have to skip it. - in.skipBytes(payloadSize); + FileUtils.skipBytesFully(in, payloadSize); return null; } serializer = (IVersionedSerializer<T2>) callback.serializer;