You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sl...@apache.org on 2012/11/13 19:02:35 UTC

[2/3] git commit: Fix bad serialization of binary protocol message

Fix bad serialization of binary protocol message


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

Branch: refs/heads/cassandra-1.2
Commit: 9c5e5dc0db64fd311ff90d9061a40bd3c8a6c7c4
Parents: 5ecb91f
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Tue Nov 13 18:58:47 2012 +0100
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Tue Nov 13 18:58:47 2012 +0100

----------------------------------------------------------------------
 .../cassandra/transport/messages/ErrorMessage.java |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/9c5e5dc0/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java b/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
index c8ff879..56d002a 100644
--- a/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
+++ b/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
@@ -147,7 +147,7 @@ public class ErrorMessage extends Message.Response
                                          : null;
 
                     int extraSize = isWrite  ? 2 + writeType.remaining() : 1;
-                    acb = ChannelBuffers.buffer(rteCl.writableBytes() + 8 + extraSize);
+                    acb = ChannelBuffers.buffer(rteCl.readableBytes() + 8 + extraSize);
 
                     acb.writeBytes(rteCl);
                     acb.writeInt(rte.received);