Add test

Author: ankikuma

.idea/eclipseCodeFormatter.xml

@@ -29,6 +29,7 @@
 import java.util.Optional;
 
 import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertNoFailures;
+import static org.hamcrest.Matchers.greaterThan;
 import static org.hamcrest.Matchers.lessThanOrEqualTo;
 
 public class IndexingMemoryControllerIT extends ESSingleNodeTestCase {
@@ -37,7 +38,9 @@ public class IndexingMemoryControllerIT extends ESSingleNodeTestCase {
     protected Settings nodeSettings() {
         return Settings.builder()
             .put(super.nodeSettings())
-            // small indexing buffer so that we can trigger refresh after buffering 100 deletes
+            // small indexing buffer so that
+            // 1. We can trigger refresh after buffering 100 deletes
+            // 2. Indexing memory Controller writes indexing buffers in sync with indexing on the indexing thread
             .put("indices.memory.index_buffer_size", "1kb")
             .build();
     }
@@ -111,4 +114,21 @@ public void testDeletesAloneCanTriggerRefresh() throws Exception {
         }
         assertThat(shard.getEngineOrNull().getIndexBufferRAMBytesUsed(), lessThanOrEqualTo(ByteSizeUnit.KB.toBytes(1)));
     }
+
+    /* When there is memory pressure, we write indexing buffers to disk on the same thread as the indexing thread,
+     * @see org.elasticsearch.indices.IndexingMemoryController.
+     * This test verifies that we update the stats that capture the combined time for indexing + writing the
+     * indexing buffers.
+     */
+    public void testIndexingUpdatesRelevantStats() throws Exception {
+        IndexService indexService = createIndex("index", indexSettings(1, 0).put("index.refresh_interval", -1).build());
+        IndexShard shard = indexService.getShard(0);
+        for (int i = 0; i < 100; i++) {
+            prepareIndex("index").setId(Integer.toString(i)).setSource("field", "value").get();
+        }
+        assertThat(
+            shard.indexingStats().getTotal().getTotalIndexExecutionTimeInMillis(),
+            greaterThan(shard.indexingStats().getTotal().getIndexTime().getMillis())
+        );
+    }
 }