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

use lambdas

This commit is contained in:
Britta Weber 2015-10-14 11:36:02 +02:00
parent 4f536945de
commit f07853b56c
1 changed files with 13 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
core/src/test/java/org/elasticsearch/gateway/MetaDataWriteDataNodesIT.java
View File

@ -152,29 +152,23 @@ public class MetaDataWriteDataNodesIT extends ESIntegTestCase {
} }
protected void assertIndexDirectoryDeleted(final String nodeName, final String indexName) throws Exception { protected void assertIndexDirectoryDeleted(final String nodeName, final String indexName) throws Exception {
assertBusy(new Runnable() { assertBusy(() -> {
@Override logger.info("checking if index directory exists...");
public void run() { assertFalse("Expecting index directory of " + indexName + " to be deleted from node " + nodeName, indexDirectoryExists(nodeName, indexName));
logger.info("checking if index directory exists..."); }
assertFalse("Expecting index directory of " + indexName + " to be deleted from node " + nodeName, indexDirectoryExists(nodeName, indexName));
}
}
); );
} }
protected void assertIndexInMetaState(final String nodeName, final String indexName) throws Exception { protected void assertIndexInMetaState(final String nodeName, final String indexName) throws Exception {
assertBusy(new Runnable() { assertBusy(() -> {
@Override logger.info("checking if meta state exists...");
public void run() { try {
logger.info("checking if meta state exists..."); assertTrue("Expecting meta state of index " + indexName + " to be on node " + nodeName, getIndicesMetaDataOnNode(nodeName).containsKey(indexName));
try { } catch (Throwable t) {
assertTrue("Expecting meta state of index " + indexName + " to be on node " + nodeName, getIndicesMetaDataOnNode(nodeName).containsKey(indexName)); logger.info("failed to load meta state", t);
} catch (Throwable t) { fail("could not load meta state");
logger.info("failed to load meta state", t); }
fail("could not load meta state"); }
}
}
}
); );
} }