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 2011/09/08 21:26:35 UTC
svn commit: r1166865 -
/cassandra/trunk/src/java/org/apache/cassandra/db/ReadVerbHandler.java
Author: jbellis
Date: Thu Sep 8 19:26:34 2011
New Revision: 1166865
URL: http://svn.apache.org/viewvc?rev=1166865&view=rev
Log:
reset ReadVerbHandler buffer between uses
patch by jbellis; reviewed by brandonwilliams for CASSANDRA-3156
Modified:
cassandra/trunk/src/java/org/apache/cassandra/db/ReadVerbHandler.java
Modified: cassandra/trunk/src/java/org/apache/cassandra/db/ReadVerbHandler.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/db/ReadVerbHandler.java?rev=1166865&r1=1166864&r2=1166865&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/db/ReadVerbHandler.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/db/ReadVerbHandler.java Thu Sep 8 19:26:34 2011
@@ -62,6 +62,7 @@ public class ReadVerbHandler implements
Row row = command.getRow(table);
DataOutputBuffer out = threadLocalOut.get();
+ out.reset();
ReadResponse.serializer().serialize(getResponse(command, row), out, message.getVersion());
byte[] bytes = new byte[out.getLength()];
System.arraycopy(out.getData(), 0, bytes, 0, bytes.length);