Repository: hadoop
Updated Branches:
  refs/heads/trunk 281c192e7 -> ee051ef9f


HADOOP-15742. Log if ipc backoff is enabled in CallQueueManager. Contributed by 
Ryan Wu.


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

Branch: refs/heads/trunk
Commit: ee051ef9fec1fddb612aa1feae9fd3df7091354f
Parents: 281c192
Author: Yiqun Lin <yq...@apache.org>
Authored: Tue Sep 18 11:10:33 2018 +0800
Committer: Yiqun Lin <yq...@apache.org>
Committed: Tue Sep 18 11:10:33 2018 +0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/ipc/CallQueueManager.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/ee051ef9/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/CallQueueManager.java
----------------------------------------------------------------------
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/CallQueueManager.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/CallQueueManager.java
index d1bd180..29649a6 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/CallQueueManager.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/CallQueueManager.java
@@ -81,8 +81,9 @@ public class CallQueueManager<E extends Schedulable>
     this.clientBackOffEnabled = clientBackOffEnabled;
     this.putRef = new AtomicReference<BlockingQueue<E>>(bq);
     this.takeRef = new AtomicReference<BlockingQueue<E>>(bq);
-    LOG.info("Using callQueue: " + backingClass + " queueCapacity: " +
-        maxQueueSize + " scheduler: " + schedulerClass);
+    LOG.info("Using callQueue: {}, queueCapacity: {}, " +
+        "scheduler: {}, ipcBackoff: {}.",
+        backingClass, maxQueueSize, schedulerClass, clientBackOffEnabled);
   }
 
   @VisibleForTesting // only!


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

Reply via email to