| commit | cad1eb55f6de613a62efc2a3daf2935b2b7aebda | [log] [tgz] |
|---|---|---|
| author | Jens Deppe <jdeppe@pivotal.io> | Mon Jan 11 07:40:01 2021 -0800 |
| committer | GitHub <noreply@github.com> | Mon Jan 11 07:40:01 2021 -0800 |
| tree | c73df25f5e257c1fc909a89073583e4050034842 | |
| parent | 84f43e1ed75e670de4fe8663e4da7dfa952ffa87 [diff] |
GEODE-8577: Increase time to get Redis native connection (#5874) - It's possible that the test is exhausting the number of available sockets. Closed connections sit in TIME_WAIT for 60 seconds on Linux. This change increases the time to get a connection beyond that to allow for connections to be fully closed and ports to be released.
diff --git a/geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/PubSubNativeRedisAcceptanceTest.java b/geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/PubSubNativeRedisAcceptanceTest.java index 772ebb1..ce7778f 100644 --- a/geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/PubSubNativeRedisAcceptanceTest.java +++ b/geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/PubSubNativeRedisAcceptanceTest.java
@@ -16,11 +16,9 @@ package org.apache.geode.redis.internal.executor.pubsub; import org.junit.ClassRule; -import org.junit.Ignore; import org.apache.geode.NativeRedisTestRule; -@Ignore("GEODE-8577") public class PubSubNativeRedisAcceptanceTest extends AbstractPubSubIntegrationTest { @ClassRule public static NativeRedisTestRule redis = new NativeRedisTestRule();
diff --git a/geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java b/geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java index 9e3f323..832441a 100644 --- a/geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java +++ b/geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java
@@ -715,7 +715,7 @@ private Jedis getConnection() { Exception lastException = null; - for (int i = 0; i < 10; i++) { + for (int i = 0; i < 20; i++) { Jedis client = null; try { client = new Jedis("localhost", getPort(), JEDIS_TIMEOUT); @@ -731,7 +731,7 @@ } } try { - Thread.sleep(1000); + Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); }