HADOOP-14893. WritableRpcEngine should use Time.monotonicNow. Contributed by Chetna Chaudhari.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d08b8c80 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d08b8c80 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d08b8c80 Branch: refs/heads/YARN-5734 Commit: d08b8c801a908b4242e7b21a54f3b1e4072f1eae Parents: a2b31e3 Author: Akira Ajisaka <[email protected]> Authored: Tue Sep 26 16:45:39 2017 +0900 Committer: Akira Ajisaka <[email protected]> Committed: Tue Sep 26 16:46:03 2017 +0900 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/ipc/WritableRpcEngine.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d08b8c80/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/WritableRpcEngine.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/WritableRpcEngine.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/WritableRpcEngine.java index fa0726d..f2b5862 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/WritableRpcEngine.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/WritableRpcEngine.java @@ -231,7 +231,7 @@ public class WritableRpcEngine implements RpcEngine { throws Throwable { long startTime = 0; if (LOG.isDebugEnabled()) { - startTime = Time.now(); + startTime = Time.monotonicNow(); } // if Tracing is on then start a new span for this rpc. @@ -251,7 +251,7 @@ public class WritableRpcEngine implements RpcEngine { if (traceScope != null) traceScope.close(); } if (LOG.isDebugEnabled()) { - long callTime = Time.now() - startTime; + long callTime = Time.monotonicNow() - startTime; LOG.debug("Call: " + method.getName() + " " + callTime); } return value.get(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
