summaryrefslogtreecommitdiff
path: root/core/src/test/java/org/elasticsearch
diff options
context:
space:
mode:
authorSimon Willnauer <simonw@apache.org>2017-07-02 22:12:35 +0200
committerSimon Willnauer <simonw@apache.org>2017-07-02 22:12:35 +0200
commit12056100233fef70b20c498fa8c9d7917dca2ffa (patch)
tree29d2c20176c7bb873d329a730cc395ac8dc96427 /core/src/test/java/org/elasticsearch
parenta4fae1540ea14331467199309d4eb7551a91f700 (diff)
[TEST] Expect nodes getting disconnected quickly
If all nodes get disconnected before we can send the request we might try to reconnect and that will fail with an ISE instead of the a transport exception. Closes #25301
Diffstat (limited to 'core/src/test/java/org/elasticsearch')
-rw-r--r--core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java14
1 files changed, 9 insertions, 5 deletions
diff --git a/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java b/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java
index 646efa9428..1dbd935229 100644
--- a/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java
+++ b/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java
@@ -410,12 +410,16 @@ public class RemoteClusterServiceTests extends ESTestCase {
});
failLatch.await();
assertNotNull(ex.get());
- if (ex.get() instanceof TransportException == false) {
- // we have an issue for this see #25301
- logger.error("expected TransportException but got a different one see #25301", ex.get());
+ if (ex.get() instanceof IllegalStateException) {
+ assertEquals(ex.get().getMessage(), "no seed node left");
+ } else {
+ if (ex.get() instanceof TransportException == false) {
+ // we have an issue for this see #25301
+ logger.error("expected TransportException but got a different one see #25301", ex.get());
+ }
+ assertTrue("expected TransportException but got a different one [" + ex.get().getClass().toString() + "]",
+ ex.get() instanceof TransportException);
}
- assertTrue("expected TransportException but got a different one [" + ex.get().getClass().toString() + "]",
- ex.get() instanceof TransportException);
}
}
}