Minor comment incorporated

Signed-off-by: Dhwanil Patel <dhwanip@amazon.com>
opensearch-project · Sep 2, 2022 · 018912b · 018912b
1 parent 53b6614
commit 018912b
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/server/src/main/java/org/opensearch/cluster/service/ClusterManagerTaskThrottler.java b/server/src/main/java/org/opensearch/cluster/service/ClusterManagerTaskThrottler.java
@@ -147,7 +147,7 @@ public void onSubmitFailure(List<? extends TaskBatcher.BatchedTask> tasks) {
      * @param tasks list of tasks which will be executed.
      */
     @Override
-    public void onBeginProcess(List<? extends TaskBatcher.BatchedTask> tasks) {
+    public void onBeginProcessing(List<? extends TaskBatcher.BatchedTask> tasks) {
         reduceTaskCount(tasks);
     }
 

diff --git a/server/src/main/java/org/opensearch/cluster/service/TaskBatcher.java b/server/src/main/java/org/opensearch/cluster/service/TaskBatcher.java
@@ -186,7 +186,7 @@ void runIfNotProcessed(BatchedTask updateTask) {
                     return tasks.isEmpty() ? entry.getKey() : entry.getKey() + "[" + tasks + "]";
                 }).reduce((s1, s2) -> s1 + ", " + s2).orElse("");
 
-                taskBatcherListener.onBeginProcess(toExecute);
+                taskBatcherListener.onBeginProcessing(toExecute);
                 run(updateTask.batchingKey, toExecute, tasksSummary);
             }
         }

diff --git a/server/src/main/java/org/opensearch/cluster/service/TaskBatcherListener.java b/server/src/main/java/org/opensearch/cluster/service/TaskBatcherListener.java
@@ -31,7 +31,7 @@ public interface TaskBatcherListener {
      * Callback called before processing any tasks.
      * @param tasks list of tasks which will be executed.
      */
-    void onBeginProcess(List<? extends TaskBatcher.BatchedTask> tasks);
+    void onBeginProcessing(List<? extends TaskBatcher.BatchedTask> tasks);
 
     /**
      * Callback called when tasks are timed out.

diff --git a/server/src/test/java/org/opensearch/cluster/service/ClusterManagerTaskThrottlerTests.java b/server/src/test/java/org/opensearch/cluster/service/ClusterManagerTaskThrottlerTests.java
@@ -236,7 +236,7 @@ public void testThrottling() {
         assertEquals(3L, throttlingStats.getThrottlingCount(taskKey));
 
         // remove one task
-        throttler.onBeginProcess(getMockUpdateTaskList(taskKey, 1));
+        throttler.onBeginProcessing(getMockUpdateTaskList(taskKey, 1));
 
         // add 3 tasks should pass now.
         // taskCount in Queue: 2 Threshold: 5

diff --git a/server/src/test/java/org/opensearch/cluster/service/TaskBatcherTests.java b/server/src/test/java/org/opensearch/cluster/service/TaskBatcherTests.java
@@ -357,7 +357,7 @@ public void onSubmitFailure(List<? extends TaskBatcher.BatchedTask> tasks) {
             }
 
             @Override
-            public void onBeginProcess(List<? extends TaskBatcher.BatchedTask> tasks) {
+            public void onBeginProcessing(List<? extends TaskBatcher.BatchedTask> tasks) {
                 // No Op
             }