Test: extra debugging for refresh listeners stats
This test failed in CI but didn't give us enough information to
debug it:
This turns on more debugging and make the test fail more quickly
if something is obviously wrong.
@@ -23,6 +23,7 @@ import org.elasticsearch.action.ListenableActionFuture;
import org.elasticsearch.action.ShardOperationFailedException;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.support.WriteRequest.RefreshPolicy;
+import org.elasticsearch.common.Strings;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
@@ -30,8 +31,10 @@ import org.elasticsearch.index.engine.CommitStats;
import org.elasticsearch.index.engine.SegmentsStats;
import org.elasticsearch.index.translog.Translog;
import org.elasticsearch.test.ESSingleNodeTestCase;
+import org.elasticsearch.test.junit.annotations.TestLogging;
import java.util.List;
+import java.util.concurrent.TimeUnit;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked;
import static org.hamcrest.Matchers.greaterThan;
@@ -115,6 +118,7 @@ public class IndicesStatsTests extends ESSingleNodeTestCase {
}
}
+ @TestLogging("_root:debug")
public void testRefreshListeners() throws Exception {
// Create an index without automatic refreshes
createIndex("test", Settings.builder().put("refresh_interval", -1).build());
@@ -124,11 +128,19 @@ public class IndicesStatsTests extends ESSingleNodeTestCase {
.setRefreshPolicy(RefreshPolicy.WAIT_UNTIL).execute();
// Wait for the refresh listener to appear in the stats
- assertBusy(() -> {
- IndicesStatsResponse stats = client().admin().indices().prepareStats("test").clear().setRefresh(true).get();
+ long end = System.nanoTime() + TimeUnit.SECONDS.toNanos(10);
+ while (true) {
+ IndicesStatsResponse stats = client().admin().indices().prepareStats("test").clear().setRefresh(true).setDocs(true).get();
CommonStats common = stats.getIndices().get("test").getTotal();
- assertEquals(1, common.refresh.getListeners());
- });
+ // There shouldn't be a doc. If there is then we did *something* weird.
+ assertEquals(0, common.docs.getCount());
+ if (1 == common.refresh.getListeners()) {
+ break;
+ }
+ if (end - System.nanoTime() < 0) {
+ fail("didn't get a refresh listener in time: " + Strings.toString(common));
+ }
+ }
// Refresh the index and wait for the request to come back
client().admin().indices().prepareRefresh("test").get();
