hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ndimi...@apache.org
Subject hbase git commit: HBASE-12825 CallRunner exception messages should include destination host:port
Date Fri, 09 Jan 2015 02:45:10 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.0 5041e7eb7 -> 4ba2cb625


HBASE-12825 CallRunner exception messages should include destination host:port


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

Branch: refs/heads/branch-1.0
Commit: 4ba2cb625d8749bb7e391049eefaae80659e4085
Parents: 5041e7e
Author: Nick Dimiduk <ndimiduk@apache.org>
Authored: Thu Jan 8 18:38:24 2015 -0800
Committer: Nick Dimiduk <ndimiduk@apache.org>
Committed: Thu Jan 8 18:41:33 2015 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/4ba2cb62/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java
index 56bd96b..d4364ab 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java
@@ -48,8 +48,6 @@ public class CallRunner {
    * On construction, adds the size of this call to the running count of outstanding call
sizes.
    * Presumption is that we are put on a queue while we wait on an executor to run us.  During
this
    * time we occupy heap.
-   * @param call The call to run.
-   * @param rpcServer
    */
   // The constructor is shutdown so only RpcServer in this class can make one of these.
   CallRunner(final RpcServerInterface rpcServer, final Call call, UserProvider userProvider)
{
@@ -97,7 +95,8 @@ public class CallRunner {
       TraceScope traceScope = null;
       try {
         if (!this.rpcServer.isStarted()) {
-          throw new ServerNotRunningYetException("Server is not running yet");
+          throw new ServerNotRunningYetException("Server " + rpcServer.getListenerAddress()
+              + " is not running yet");
         }
         if (call.tinfo != null) {
           traceScope = Trace.startSpan(call.toTraceString(), call.tinfo);
@@ -145,7 +144,7 @@ public class CallRunner {
       }
     } catch (ClosedChannelException cce) {
       RpcServer.LOG.warn(Thread.currentThread().getName() + ": caught a ClosedChannelException,
" +
-          "this means that the server was processing a " +
+          "this means that the server " + rpcServer.getListenerAddress() + " was processing
a " +
           "request but the client went away. The error message was: " +
           cce.getMessage());
     } catch (Exception e) {


Mime
View raw message