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 <[email protected]> Authored: Fri Mar 22 10:42:10 2013 -0500 Committer: Jonathan Ellis <[email protected]> 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)
