cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From slebre...@apache.org
Subject svn commit: r1211551 - in /cassandra/branches/cassandra-1.0: CHANGES.txt src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java
Date Wed, 07 Dec 2011 17:33:54 GMT
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)
         {



Mime
View raw message