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

simple specific master nodes test

This commit is contained in:
kimchy 2010-09-19 21:11:53 +02:00
parent 8def6f59b3
commit 95bb02b330
1 changed files with 27 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
modules/test/integration/src/test/java/org/elasticsearch/test/integration/masternode/SpecificMasterNodesTests.java
View File

@ -37,7 +37,7 @@ public class SpecificMasterNodesTests extends AbstractNodesTests {
closeAllNodes(); closeAllNodes();
} }
@Test public void simpleOnlyMasterNodesElection() { @Test public void simpleOnlyMasterNodeElection() {
logger.info("--> start data node / non master node"); logger.info("--> start data node / non master node");
startNode("data1", settingsBuilder().put("node.data", true).put("node.master", false).put("discovery.initial_state_timeout", "1s")); startNode("data1", settingsBuilder().put("node.data", true).put("node.master", false).put("discovery.initial_state_timeout", "1s"));
try { try {
@ -70,4 +70,30 @@ public class SpecificMasterNodesTests extends AbstractNodesTests {
closeNode("data1"); closeNode("data1");
closeNode("master1"); closeNode("master1");
} }
@Test public void electOnlyBetweenMasterNodes() {
logger.info("--> start data node / non master node");
startNode("data1", settingsBuilder().put("node.data", true).put("node.master", false).put("discovery.initial_state_timeout", "1s"));
try {
assertThat(client("data1").admin().cluster().prepareState().setMasterNodeTimeout("100ms").execute().actionGet().state().nodes().masterNodeId(), nullValue());
assert false : "should not be able to find master";
} catch (MasterNotDiscoveredException e) {
// all is well, no master elected
}
logger.info("--> start master node (1)");
startNode("master1", settingsBuilder().put("node.data", false).put("node.master", true));
assertThat(client("data1").admin().cluster().prepareState().execute().actionGet().state().nodes().masterNode().name(), equalTo("master1"));
assertThat(client("master1").admin().cluster().prepareState().execute().actionGet().state().nodes().masterNode().name(), equalTo("master1"));
logger.info("--> start master node (2)");
startNode("master2", settingsBuilder().put("node.data", false).put("node.master", true));
assertThat(client("data1").admin().cluster().prepareState().execute().actionGet().state().nodes().masterNode().name(), equalTo("master1"));
assertThat(client("master1").admin().cluster().prepareState().execute().actionGet().state().nodes().masterNode().name(), equalTo("master1"));
assertThat(client("master2").admin().cluster().prepareState().execute().actionGet().state().nodes().masterNode().name(), equalTo("master1"));
logger.info("--> closing master node (1)");
closeNode("master1");
assertThat(client("data1").admin().cluster().prepareState().execute().actionGet().state().nodes().masterNode().name(), equalTo("master2"));
assertThat(client("master2").admin().cluster().prepareState().execute().actionGet().state().nodes().masterNode().name(), equalTo("master2"));
}
} }