cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [3/5] git commit: generify AsyncRepairCallback
Date Fri, 22 Mar 2013 15:58:16 GMT
generify AsyncRepairCallback


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

Branch: refs/heads/trunk
Commit: b60bc58e6d259a5ec69a354eb7a096525e5a8763
Parents: f13f257
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Fri Mar 22 10:42:10 2013 -0500
Committer: Jonathan Ellis <jbellis@apache.org>
Committed: Fri Mar 22 10:42:10 2013 -0500

----------------------------------------------------------------------
 .../cassandra/service/AsyncRepairCallback.java     |    5 +++--
 .../org/apache/cassandra/service/ReadCallback.java |    2 +-
 2 files changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/b60bc58e/src/java/org/apache/cassandra/service/AsyncRepairCallback.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/AsyncRepairCallback.java b/src/java/org/apache/cassandra/service/AsyncRepairCallback.java
index 63b7df3..6ac765b 100644
--- a/src/java/org/apache/cassandra/service/AsyncRepairCallback.java
+++ b/src/java/org/apache/cassandra/service/AsyncRepairCallback.java
@@ -22,11 +22,12 @@ import java.util.concurrent.atomic.AtomicInteger;
 
 import org.apache.cassandra.concurrent.Stage;
 import org.apache.cassandra.concurrent.StageManager;
+import org.apache.cassandra.db.ReadResponse;
 import org.apache.cassandra.net.IAsyncCallback;
 import org.apache.cassandra.net.MessageIn;
 import org.apache.cassandra.utils.WrappedRunnable;
 
-public class AsyncRepairCallback implements IAsyncCallback
+public class AsyncRepairCallback implements IAsyncCallback<ReadResponse>
 {
     private final RowDataResolver repairResolver;
     private final int blockfor;
@@ -38,7 +39,7 @@ public class AsyncRepairCallback implements IAsyncCallback
         this.blockfor = blockfor;
     }
 
-    public void response(MessageIn message)
+    public void response(MessageIn<ReadResponse> message)
     {
         repairResolver.preprocess(message);
         if (received.incrementAndGet() == blockfor)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/b60bc58e/src/java/org/apache/cassandra/service/ReadCallback.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/ReadCallback.java b/src/java/org/apache/cassandra/service/ReadCallback.java
index 92c8a85..2ebaedd 100644
--- a/src/java/org/apache/cassandra/service/ReadCallback.java
+++ b/src/java/org/apache/cassandra/service/ReadCallback.java
@@ -186,7 +186,7 @@ public class ReadCallback<TMessage, TResolved> implements IAsyncCallback<TMessag
 
                 ReadCommand readCommand = (ReadCommand) command;
                 final RowDataResolver repairResolver = new RowDataResolver(readCommand.table,
readCommand.key, readCommand.filter());
-                IAsyncCallback repairHandler = new AsyncRepairCallback(repairResolver, endpoints.size());
+                AsyncRepairCallback repairHandler = new AsyncRepairCallback(repairResolver,
endpoints.size());
 
                 MessageOut<ReadCommand> message = ((ReadCommand) command).createMessage();
                 for (InetAddress endpoint : endpoints)


Mime
View raw message