honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increase timeouts in UnicastZenPingTests 

Relates to #37268
This commit is contained in:
Yannick Welsch 2019-01-11 11:25:20 +01:00
parent ed2b5e80eb
commit 4d3928d444
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/src/test/java/org/elasticsearch/discovery/zen/UnicastZenPingTests.java
View File

@ -401,7 +401,7 @@ public class UnicastZenPingTests extends ESTestCase {
Collections.singletonList("127.0.0.1"),
limitPortCounts,
transportService,
TimeValue.timeValueSeconds(1));
TimeValue.timeValueSeconds(30));
assertThat(transportAddresses, hasSize(limitPortCounts));
final Set<Integer> ports = new HashSet<>();
for (final TransportAddress address : transportAddresses) {
@ -445,7 +445,7 @@ public class UnicastZenPingTests extends ESTestCase {
Collections.singletonList(NetworkAddress.format(loopbackAddress)),
10,
transportService,
TimeValue.timeValueSeconds(1));
TimeValue.timeValueSeconds(30));
assertThat(transportAddresses, hasSize(7));
final Set<Integer> ports = new HashSet<>();
for (final TransportAddress address : transportAddresses) {
@ -496,7 +496,7 @@ public class UnicastZenPingTests extends ESTestCase {
Arrays.asList(hostname),
1,
transportService,
TimeValue.timeValueSeconds(1)
TimeValue.timeValueSeconds(30)
);
assertThat(transportAddresses, empty());
@ -547,7 +547,7 @@ public class UnicastZenPingTests extends ESTestCase {
new TransportService(Settings.EMPTY, transport, threadPool, TransportService.NOOP_TRANSPORT_INTERCEPTOR, x -> null, null,
Collections.emptySet());
closeables.push(transportService);
final TimeValue resolveTimeout = TimeValue.timeValueSeconds(randomIntBetween(1, 3));
final TimeValue resolveTimeout = TimeValue.timeValueSeconds(randomIntBetween(3, 5));
try {
final List<TransportAddress> transportAddresses = UnicastZenPing.resolveHostsLists(
executorService,
@ -722,7 +722,7 @@ public class UnicastZenPingTests extends ESTestCase {
Arrays.asList("127.0.0.1:9300:9300", "127.0.0.1:9301"),
1,
transportService,
TimeValue.timeValueSeconds(1));
TimeValue.timeValueSeconds(30));
assertThat(transportAddresses, hasSize(1)); // only one of the two is valid and will be used
assertThat(transportAddresses.get(0).getAddress(), equalTo("127.0.0.1"));
assertThat(transportAddresses.get(0).getPort(), equalTo(9301));