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

[Test] Use no failures, shard might not have been initialize yet

This commit is contained in:
Shay Banon 2014-06-21 12:43:00 +02:00
parent 08ca51d7b6
commit 0e83615496
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/test/java/org/elasticsearch/threadpool/SimpleThreadPoolTests.java
View File

@ -50,6 +50,7 @@ import static org.elasticsearch.common.settings.ImmutableSettings.settingsBuilde
import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder; import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;
import static org.elasticsearch.test.ElasticsearchIntegrationTest.Scope; import static org.elasticsearch.test.ElasticsearchIntegrationTest.Scope;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAllSuccessful; import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAllSuccessful;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertNoFailures;
import static org.hamcrest.Matchers.*; import static org.hamcrest.Matchers.*;
/** /**
@ -91,8 +92,8 @@ public class SimpleThreadPoolTests extends ElasticsearchIntegrationTest {
indexRandom(true, builders); indexRandom(true, builders);
int numSearches = randomIntBetween(2, 100); int numSearches = randomIntBetween(2, 100);
for (int i = 0; i < numSearches; i++) { for (int i = 0; i < numSearches; i++) {
assertAllSuccessful(client().prepareSearch("idx").setQuery(QueryBuilders.termQuery("str_value", "s" + i)).get()); assertNoFailures(client().prepareSearch("idx").setQuery(QueryBuilders.termQuery("str_value", "s" + i)).get());
assertAllSuccessful(client().prepareSearch("idx").setQuery(QueryBuilders.termQuery("l_value", i)).get()); assertNoFailures(client().prepareSearch("idx").setQuery(QueryBuilders.termQuery("l_value", i)).get());
} }
Set<String> threadNames = Sets.newHashSet(); Set<String> threadNames = Sets.newHashSet();
for (long l : threadBean.getAllThreadIds()) { for (long l : threadBean.getAllThreadIds()) {