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

Make sure 2 writes happened, so we can check if 2 deletes happen that have been triggered by ttl

This commit is contained in:
Martijn van Groningen 2013-08-29 11:26:48 +02:00
parent 5b6be0c456
commit a1f2f44eef
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/test/java/org/elasticsearch/test/integration/percolator/TTLPercolatorTests.java
View File

@ -62,6 +62,11 @@ public class TTLPercolatorTests extends AbstractNodesTests {
.endObject() .endObject()
).setRefresh(true).setTTL(ttl).execute().actionGet(); ).setRefresh(true).setTTL(ttl).execute().actionGet();
IndicesStatsResponse response = client.admin().indices().prepareStats("test")
.clear().setIndexing(true)
.execute().actionGet();
assertThat(response.getIndices().get("test").getTotal().getIndexing().getTotal().getIndexCount(), equalTo(2l));
PercolateResponse percolateResponse = client.preparePercolate() PercolateResponse percolateResponse = client.preparePercolate()
.setIndices("test").setDocumentType("type1") .setIndices("test").setDocumentType("type1")
.setSource(jsonBuilder() .setSource(jsonBuilder()
@ -76,7 +81,7 @@ public class TTLPercolatorTests extends AbstractNodesTests {
// OK, ttl + purgeInterval has passed (slow machine or many other tests were running at the same time // OK, ttl + purgeInterval has passed (slow machine or many other tests were running at the same time
GetResponse getResponse = client.prepareGet("test", "_percolator", "kuku").execute().actionGet(); GetResponse getResponse = client.prepareGet("test", "_percolator", "kuku").execute().actionGet();
assertThat(getResponse.isExists(), equalTo(false)); assertThat(getResponse.isExists(), equalTo(false));
IndicesStatsResponse response = client.admin().indices().prepareStats("test") response = client.admin().indices().prepareStats("test")
.clear().setIndexing(true) .clear().setIndexing(true)
.execute().actionGet(); .execute().actionGet();
long currentDeleteCount = response.getIndices().get("test").getTotal().getIndexing().getTotal().getDeleteCount(); long currentDeleteCount = response.getIndices().get("test").getTotal().getIndexing().getTotal().getDeleteCount();
@ -95,7 +100,7 @@ public class TTLPercolatorTests extends AbstractNodesTests {
logger.info("Checking if the ttl purger has run"); logger.info("Checking if the ttl purger has run");
long currentDeleteCount; long currentDeleteCount;
do { do {
IndicesStatsResponse response = client.admin().indices().prepareStats("test") response = client.admin().indices().prepareStats("test")
.clear().setIndexing(true) .clear().setIndexing(true)
.execute().actionGet(); .execute().actionGet();
// This returns the number of delete operations stats (not Lucene delete count) // This returns the number of delete operations stats (not Lucene delete count)