make start run timestamp as call's field.

Author: hfutatzhanghb

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine2.java

@@ -426,13 +426,11 @@ static class ProtobufRpcEngineCallbackImpl
       private final RPC.Server server;
       private final Call call;
       private final String methodName;
-      private final long callStartNanos;
 
       ProtobufRpcEngineCallbackImpl() {
         this.server = CURRENT_CALL_INFO.get().getServer();
         this.call = Server.getCurCall().get();
         this.methodName = CURRENT_CALL_INFO.get().getMethodName();
-        this.callStartNanos = Server.getCurCallStartnanos().get();
       }
 
       private void updateProcessingDetails(Call rpcCall, long deltaNanos) {
@@ -446,15 +444,15 @@ private void updateProcessingDetails(Call rpcCall, long deltaNanos) {
 
       @Override
       public void setResponse(Message message) {
-        long deltaNanos = Time.monotonicNowNanos() - callStartNanos;
+        long deltaNanos = Time.monotonicNowNanos() - call.getStartHandleTimestampNanos();
         updateProcessingDetails(call, deltaNanos);
         call.setDeferredResponse(RpcWritable.wrap(message));
         server.updateDeferredMetrics(call, methodName, deltaNanos);
       }
 
       @Override
       public void error(Throwable t) {
-        long deltaNanos = Time.monotonicNowNanos() - callStartNanos;
+        long deltaNanos = Time.monotonicNowNanos() - call.getStartHandleTimestampNanos();
         updateProcessingDetails(call, deltaNanos);
         call.setDeferredError(t);
         String detailedMetricsName = t.getClass().getSimpleName();

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java

@@ -1002,6 +1002,7 @@ public static class Call implements Schedulable,
     final int callId;            // the client's call id
     final int retryCount;        // the retry count of the call
     private final long timestampNanos; // time the call was received
+    protected long startHandleTimestampNanos; // time the call was run
     long responseTimestampNanos; // time the call was served
     private AtomicInteger responseWaitCount = new AtomicInteger(1);
     final RPC.RpcKind rpcKind;
@@ -1206,6 +1207,15 @@ public void setDeferredError(Throwable t) {
     public long getTimestampNanos() {
       return timestampNanos;
     }
+
+
+    public long getStartHandleTimestampNanos() {
+      return startHandleTimestampNanos;
+    }
+
+    public void setStartHandleTimestampNanos(long startHandleTimestampNanos) {
+      this.startHandleTimestampNanos = startHandleTimestampNanos;
+    }
   }
 
   /** A RPC extended call queued for handling. */
@@ -1282,7 +1292,7 @@ public Void run() throws Exception {
       }
 
       long startNanos = Time.monotonicNowNanos();
-      CUR_CALL_STARTNANOS.set(startNanos);
+      this.setStartHandleTimestampNanos(startNanos);
       Writable value = null;
       ResponseParams responseParams = new ResponseParams();
 

hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestProtoBufRpcServerHandoff.java

@@ -76,7 +76,7 @@ public void setUp() throws IOException {
     long serverStartTime = System.currentTimeMillis();
     LOG.info("Server started at: " + address + " at time: " + serverStartTime);
   }
-  
+
   @Test(timeout = 20000)
   public void test() throws Exception {
     final TestProtoBufRpcServerHandoffProtocol client = RPC.getProxy(