You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/04/26 04:13:04 UTC
[iotdb] 01/01: use logical clock
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch fix_client_manager_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b66d34d5a7bfb7ce9d46eb61a57401df7d3fd1f0
Author: LebronAl <TX...@gmail.com>
AuthorDate: Tue Apr 26 12:12:43 2022 +0800
use logical clock
---
.../test/java/org/apache/iotdb/commons/ClientManagerTest.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/node-commons/src/test/java/org/apache/iotdb/commons/ClientManagerTest.java b/node-commons/src/test/java/org/apache/iotdb/commons/ClientManagerTest.java
index 497eb910ec..131dee451c 100644
--- a/node-commons/src/test/java/org/apache/iotdb/commons/ClientManagerTest.java
+++ b/node-commons/src/test/java/org/apache/iotdb/commons/ClientManagerTest.java
@@ -236,7 +236,10 @@ public class ClientManagerTest {
Assert.assertEquals(0, syncClusterManager.getPool().getNumIdle(endPoint));
// get another sync client, should throw error and return null
+ long start = System.nanoTime();
SyncDataNodeInternalServiceClient syncClient2 = syncClusterManager.borrowClient(endPoint);
+ long end = System.nanoTime();
+ Assert.assertTrue(end - start >= DefaultProperty.WAIT_CLIENT_TIMEOUT_MS * 1000);
Assert.assertNull(syncClient2);
// return one sync client
@@ -300,10 +303,10 @@ public class ClientManagerTest {
Assert.assertEquals(0, syncClusterManager.getPool().getNumIdle(endPoint));
// get another sync client, should wait waitClientTimeoutMS ms, throw error and return null
- long start = System.currentTimeMillis();
+ long start = System.nanoTime();
SyncDataNodeInternalServiceClient syncClient2 = syncClusterManager.borrowClient(endPoint);
- long end = System.currentTimeMillis();
- Assert.assertTrue(end - start >= waitClientTimeoutMS);
+ long end = System.nanoTime();
+ Assert.assertTrue(end - start >= waitClientTimeoutMS * 1000);
Assert.assertNull(syncClient2);
// return one sync client