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 2011/12/07 18:33:54 UTC
svn commit: r1211551 - in /cassandra/branches/cassandra-1.0: CHANGES.txt
src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java
Author: slebresne
Date: Wed Dec 7 17:33:54 2011
New Revision: 1211551
URL: http://svn.apache.org/viewvc?rev=1211551&view=rev
Log:
Fix missing response during range slice repair
patch by slebresne; reviewed by jbellis for CASSANDRA-3551
Modified:
cassandra/branches/cassandra-1.0/CHANGES.txt
cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java
Modified: cassandra/branches/cassandra-1.0/CHANGES.txt
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0/CHANGES.txt?rev=1211551&r1=1211550&r2=1211551&view=diff
==============================================================================
--- cassandra/branches/cassandra-1.0/CHANGES.txt (original)
+++ cassandra/branches/cassandra-1.0/CHANGES.txt Wed Dec 7 17:33:54 2011
@@ -15,6 +15,7 @@
* validate compression parameters on add/update of the ColumnFamily (CASSANDRA-3573)
* fix compression "chunk_length_kb" option to set correct kb value for thrift/avro
(CASSANDRA-3558)
+ * fix missing response during range slice repair (CASSANDRA-3551)
Merged from 0.8:
* use cannonical host for local node in nodetool info (CASSANDRA-3556)
* remove nonlocal DC write optimization since it only worked with
Modified: cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java?rev=1211551&r1=1211550&r2=1211551&view=diff
==============================================================================
--- cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java (original)
+++ cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java Wed Dec 7 17:33:54 2011
@@ -25,6 +25,7 @@ import java.io.IOException;
import org.apache.cassandra.io.util.FastByteArrayInputStream;
import org.apache.cassandra.net.IVerbHandler;
import org.apache.cassandra.net.Message;
+import org.apache.cassandra.net.MessagingService;
public class ReadRepairVerbHandler implements IVerbHandler
{
@@ -37,6 +38,10 @@ public class ReadRepairVerbHandler imple
{
RowMutation rm = RowMutation.serializer().deserialize(new DataInputStream(buffer), message.getVersion());
rm.apply();
+
+ WriteResponse response = new WriteResponse(rm.getTable(), rm.key(), true);
+ Message responseMessage = WriteResponse.makeWriteResponseMessage(message, response);
+ MessagingService.instance().sendReply(responseMessage, id, message.getFrom());
}
catch (IOException e)
{