fix: incorrect expire time of client request (#164)

XiaoMi · Sep 28, 2021 · b3d80c9 · b3d80c9
1 parent 497f1b1
commit b3d80c9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/xiaomi/infra/pegasus/rpc/async/ClientRequestRound.java b/src/main/java/com/xiaomi/infra/pegasus/rpc/async/ClientRequestRound.java
@@ -22,6 +22,7 @@
 import com.xiaomi.infra.pegasus.operator.client_operator;
 import com.xiaomi.infra.pegasus.rpc.Table;
 import java.util.concurrent.ScheduledFuture;
+import java.util.concurrent.TimeUnit;
 import org.slf4j.Logger;
 
 /** Created by weijiesun on 16-11-25. */
@@ -56,7 +57,7 @@ public ClientRequestRound(
 
     this.enableCounter = enableCounter;
     this.createNanoTime = System.nanoTime();
-    this.expireNanoTime = createNanoTime + timeoutInMilliseconds;
+    this.expireNanoTime = createNanoTime + TimeUnit.MILLISECONDS.toNanos(timeoutInMilliseconds);
     this.isCompleted = false;
     this.tryId = 1;
     this.backupRequestTask = null;