Skip to content

Commit

Permalink
Increase timeouts in UnicastZenPingTests
Browse files Browse the repository at this point in the history
Relates to #37268
  • Loading branch information
ywelsch committed Jan 11, 2019
1 parent dafb93b commit 1180687
Showing 1 changed file with 5 additions and 5 deletions.
Expand Up @@ -400,7 +400,7 @@ public BoundTransportAddress boundAddress() {
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) {
Expand Down Expand Up @@ -443,7 +443,7 @@ public BoundTransportAddress boundAddress() {
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) {
Expand Down Expand Up @@ -493,7 +493,7 @@ public TransportAddress[] addressesFromString(String address, int perAddressLimi
Arrays.asList(hostname),
1,
transportService,
TimeValue.timeValueSeconds(1)
TimeValue.timeValueSeconds(30)
);

assertThat(transportAddresses, empty());
Expand Down Expand Up @@ -543,7 +543,7 @@ public TransportAddress[] addressesFromString(String address, int perAddressLimi
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,
Expand Down Expand Up @@ -718,7 +718,7 @@ public BoundTransportAddress boundAddress() {
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));
Expand Down

0 comments on commit 1180687

Please sign in to comment.