From 6ff5eac86c72f71a6eaef380e46b6a0c8e3c7614 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 22 Jan 2021 11:22:41 -0500 Subject: [PATCH] Increase timeouts for RedisLockLeaderInitTests * `setBusyWaitMillis(10000)` before yielding to let another candidate to lock * Add `Thread.sleep(100);` before yielding --- .../leader/RedisLockRegistryLeaderInitiatorTests.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/leader/RedisLockRegistryLeaderInitiatorTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/leader/RedisLockRegistryLeaderInitiatorTests.java index e82127ec9c..946bba4b4e 100644 --- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/leader/RedisLockRegistryLeaderInitiatorTests.java +++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/leader/RedisLockRegistryLeaderInitiatorTests.java @@ -102,7 +102,9 @@ public class RedisLockRegistryLeaderInitiatorTests extends RedisAvailableTests { initiator2.setLeaderEventPublisher(new CountingPublisher(granted2, revoked2, acquireLockFailed2)); // It's hard to see round-robin election, so let's make the yielding initiator to sleep long before restarting - initiator1.setBusyWaitMillis(1000); + initiator1.setBusyWaitMillis(10000); + + Thread.sleep(100); initiator1.getContext().yield(); @@ -113,7 +115,9 @@ public class RedisLockRegistryLeaderInitiatorTests extends RedisAvailableTests { assertThat(initiator1.getContext().isLeader()).isFalse(); initiator1.setBusyWaitMillis(LockRegistryLeaderInitiator.DEFAULT_BUSY_WAIT_TIME); - initiator2.setBusyWaitMillis(1000); + initiator2.setBusyWaitMillis(10000); + + Thread.sleep(100); initiator2.getContext().yield();