You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ri...@apache.org on 2022/02/11 22:05:31 UTC
[geode] branch WIP-GEODE-9892 updated: Slow the roll on the bucket moves
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 <ri...@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);