[geode] branch WIP-GEODE-9892 updated: Slow the roll on the bucket moves

[ringles]

This is an automated email from the ASF dual-hosted git repository.

ringles pushed a commit to branch WIP-GEODE-9892
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/WIP-GEODE-9892 by this push:
     new 9f1baa3  Slow the roll on the bucket moves
9f1baa3 is described below

commit 9f1baa39d51126b4ade71633ed829b4725eacf63
Author: Ray Ingles <ring...@vmware.com>
AuthorDate: Fri Feb 11 17:04:05 2022 -0500

    Slow the roll on the bucket moves
---
 .../redis/internal/commands/executor/list/LPopDUnitTest.java   | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java
 
b/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java
index 4de22e2..388e415 100644
--- 
a/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java
+++ 
b/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java
@@ -20,6 +20,7 @@ import static 
org.apache.geode.test.dunit.rules.RedisClusterStartupRule.REDIS_CL
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.fail;
 
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.Future;
@@ -36,6 +37,7 @@ import redis.clients.jedis.HostAndPort;
 import redis.clients.jedis.JedisCluster;
 
 import org.apache.geode.logging.internal.log4j.api.LogService;
+import org.apache.geode.test.awaitility.GeodeAwaitility;
 import org.apache.geode.test.dunit.rules.MemberVM;
 import org.apache.geode.test.dunit.rules.RedisClusterStartupRule;
 import org.apache.geode.test.junit.rules.ExecutorServiceRule;
@@ -114,10 +116,10 @@ public class LPopDUnitTest {
     Future<Void> future2 = executor.runAsync(task2);
     Future<Void> future3 = executor.runAsync(task3);
 
-    // for (int i = 0; i < 100 && runningCount.get() > 0; i++) {
-    // clusterStartUp.moveBucketForKey(listHashtags.get(i % 
listHashtags.size()));
-    // GeodeAwaitility.await().during(Duration.ofMillis(200)).until(() -> 
true);
-    // }
+    for (int i = 0; i < 50 && runningCount.get() > 0; i++) {
+      clusterStartUp.moveBucketForKey(listHashtags.get(i % 
listHashtags.size()));
+      GeodeAwaitility.await().during(Duration.ofMillis(500)).until(() -> true);
+    }
 
     runningCount.set(0);