|
@@ -41,6 +41,7 @@ import java.util.function.Consumer;
|
|
|
import java.util.function.Function;
|
|
|
|
|
|
import static org.hamcrest.Matchers.equalTo;
|
|
|
+import static org.hamcrest.Matchers.greaterThanOrEqualTo;
|
|
|
import static org.hamcrest.Matchers.startsWith;
|
|
|
import static org.mockito.Mockito.doAnswer;
|
|
|
import static org.mockito.Mockito.mock;
|
|
@@ -562,7 +563,6 @@ public class RollupIndexerStateTests extends ESTestCase {
|
|
|
assertThat(indexer.getState(), equalTo(IndexerState.INDEXING));
|
|
|
latch.countDown();
|
|
|
assertBusy(() -> assertThat(indexer.getState(), equalTo(IndexerState.STARTED)));
|
|
|
- assertThat(indexer.getStats().getNumInvocations(), equalTo((long) i + 1));
|
|
|
assertThat(indexer.getStats().getNumPages(), equalTo((long) i + 1));
|
|
|
}
|
|
|
final CountDownLatch latch = indexer.newLatch();
|
|
@@ -572,6 +572,7 @@ public class RollupIndexerStateTests extends ESTestCase {
|
|
|
latch.countDown();
|
|
|
assertBusy(() -> assertThat(indexer.getState(), equalTo(IndexerState.STOPPED)));
|
|
|
assertTrue(indexer.abort());
|
|
|
+ assertThat(indexer.getStats().getNumInvocations(), greaterThanOrEqualTo(6L));
|
|
|
} finally {
|
|
|
ThreadPool.terminate(threadPool, 30, TimeUnit.SECONDS);
|
|
|
}
|