Updated Branches: refs/heads/trunk 292312380 -> aebe612db
r/m redundant branching Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/aebe612d Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/aebe612d Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/aebe612d Branch: refs/heads/trunk Commit: aebe612db3abe8a22b27cd4619dece10a536cc96 Parents: 2923123 Author: Jonathan Ellis <[email protected]> Authored: Fri Mar 22 11:00:41 2013 -0500 Committer: Jonathan Ellis <[email protected]> Committed: Fri Mar 22 11:00:41 2013 -0500 ---------------------------------------------------------------------- .../apache/cassandra/net/ResponseVerbHandler.java | 13 ++----------- 1 files changed, 2 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/aebe612d/src/java/org/apache/cassandra/net/ResponseVerbHandler.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/net/ResponseVerbHandler.java b/src/java/org/apache/cassandra/net/ResponseVerbHandler.java index 8e38218..0245005 100644 --- a/src/java/org/apache/cassandra/net/ResponseVerbHandler.java +++ b/src/java/org/apache/cassandra/net/ResponseVerbHandler.java @@ -38,18 +38,9 @@ public class ResponseVerbHandler implements IVerbHandler return; } + Tracing.trace("Processing response from {}", message.from); IAsyncCallback cb = callbackInfo.callback; MessagingService.instance().maybeAddLatency(cb, message.from, latency); - - if (cb instanceof IAsyncCallback) - { - Tracing.trace("Processing response from {}", message.from); - ((IAsyncCallback) cb).response(message); - } - else - { - Tracing.trace("Processing result from {}", message.from); - ((AsyncOneResponse) cb).response(message); - } + cb.response(message); } }
