[geode] branch WIP-GEODE-9892 updated: Give server a chance to fully join cluster

[ri...@apache.org]

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 165e128  Give server a chance to fully join cluster
165e128 is described below

commit 165e128058954fd721f0baf03a0487cd708c8e68
Author: Ray Ingles <ri...@vmware.com>
AuthorDate: Sun Feb 13 19:35:24 2022 -0500

    Give server a chance to fully join cluster
---
 .../geode/redis/internal/commands/executor/list/LPushDUnitTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPushDUnitTest.java b/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPushDUnitTest.java
index 4f497a0..c86b006 100644
--- a/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPushDUnitTest.java
+++ b/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPushDUnitTest.java
@@ -66,6 +66,7 @@ public class LPushDUnitTest {
     clusterStartUp.startRedisVM(1, locator.getPort());
     int redisServerPort = clusterStartUp.getRedisPort(1);
     jedis = new JedisCluster(new HostAndPort(BIND_ADDRESS, redisServerPort), REDIS_CLIENT_TIMEOUT);
+    GeodeAwaitility.await().during(Duration.ofMillis(200)).until(() -> true);
     clusterStartUp.flushAll();
   }
 
@@ -119,6 +120,7 @@ public class LPushDUnitTest {
     }
     assertThat(totalLength)
         .isGreaterThanOrEqualTo(MINIMUM_ITERATIONS * PUSHER_COUNT * PUSH_LIST_SIZE);
+    clusterStartUp.crashVM(1); // kill primary server, just in case test order is reversed
   }
 
   private void lpushPerformAndVerify(String key, List<String> elementList,
@@ -168,13 +170,11 @@ public class LPushDUnitTest {
       future.get();
     }
 
-    int totalLength = 0;
     Long length;
     for (String key : keys) {
       length = jedis.llen(key);
       assertThat(length).isGreaterThanOrEqualTo(MINIMUM_ITERATIONS * 2 * pushListSize);
       assertThat(length % 3).isEqualTo(0);
-      totalLength += length;
     }
   }