Add synchronized block

Signed-off-by: Aman Khare <[email protected]>
amkhar · Feb 23, 2024 · a6921f0 · a6921f0
1 parent 608c8ae
commit a6921f0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/gateway/AsyncShardFetch.java b/server/src/main/java/org/opensearch/gateway/AsyncShardFetch.java
@@ -234,7 +234,7 @@ protected synchronized void processAsyncFetch(List<T> responses, List<FailedNode
         reroute(reroutingKey, "post_response");
     }
 
-    public int getNumberOfInFlightFetches() {
+    public synchronized int getNumberOfInFlightFetches() {
         return cache.getInflightFetches();
     }