adjust parm for timeout

ctripcorp · Dec 30, 2024 · 2009075 · 2009075
1 parent fae3b9e
commit 2009075
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/core/src/test/java/com/ctrip/xpipe/AbstractTest.java b/core/src/test/java/com/ctrip/xpipe/AbstractTest.java
@@ -194,7 +194,7 @@ protected boolean assertSuccess(Runnable assertion) {
 
     protected void waitConditionUntilTimeOut(BooleanSupplier booleanSupplier) throws TimeoutException {
 
-        waitConditionUntilTimeOut(booleanSupplier, 5000, 2);
+        waitConditionUntilTimeOut(booleanSupplier, 15000, 2);
     }
 
     protected void waitConditionUntilTimeOut(BooleanSupplier booleanSupplier, int waitTimeMilli) throws TimeoutException {

diff --git a/...er/src/test/java/com/ctrip/xpipe/redis/keeper/impl/DefaultRedisMasterReplicationTest.java b/...er/src/test/java/com/ctrip/xpipe/redis/keeper/impl/DefaultRedisMasterReplicationTest.java
@@ -13,6 +13,7 @@
 import com.ctrip.xpipe.redis.keeper.config.DefaultKeeperConfig;
 import com.ctrip.xpipe.redis.keeper.config.DefaultKeeperResourceManager;
 import com.ctrip.xpipe.redis.keeper.config.KeeperResourceManager;
+import com.ctrip.xpipe.redis.keeper.config.TestKeeperConfig;
 import com.ctrip.xpipe.redis.keeper.monitor.KeeperMonitor;
 import com.ctrip.xpipe.simpleserver.Server;
 import com.ctrip.xpipe.utils.DefaultLeakyBucket;
@@ -81,7 +82,7 @@ public void beforeDefaultRedisMasterReplicationTest() throws Exception {
 		defaultRedisMasterReplication = new DefaultRedisMasterReplication(redisMaster, redisKeeperServer, nioEventLoopGroup,
 				scheduled, proxyResourceManager);
 		when(redisKeeperServer.getRedisKeeperServerState()).thenReturn(new RedisKeeperServerStateActive(redisKeeperServer));
-		when(redisKeeperServer.getKeeperConfig()).thenReturn(new DefaultKeeperConfig());
+		when(redisKeeperServer.getKeeperConfig()).thenReturn(new TestKeeperConfig());
 
 		when(redisMaster.getCurrentReplicationStore()).thenReturn(replicationStore);
 		when(replicationStore.getMetaStore()).thenReturn(metaStore);

diff --git a/...src/test/java/com/ctrip/xpipe/redis/keeper/impl/fakeredis/FakeRedisHalfRdbServerFail.java b/...src/test/java/com/ctrip/xpipe/redis/keeper/impl/fakeredis/FakeRedisHalfRdbServerFail.java
@@ -67,7 +67,7 @@ public void redisFailKeeperRestartDumpNewRdb() throws Exception {
 		SimplePsyncObserver simplePsyncObserver = new SimplePsyncObserver();
 		InMemoryPsync inMemoryPsync = sendInmemoryPsync("localhost", redisKeeperServer.getListeningPort(), simplePsyncObserver);
 		//wait
-		simplePsyncObserver.getOnline().get(5000, TimeUnit.MILLISECONDS);
+		simplePsyncObserver.getOnline().get(6000, TimeUnit.MILLISECONDS);
 		//wait for commands
 		sleep(1000);