You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2013/03/22 17:01:06 UTC
git commit: r/m redundant branching
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 <jb...@apache.org>
Authored: Fri Mar 22 11:00:41 2013 -0500
Committer: Jonathan Ellis <jb...@apache.org>
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);
}
}