Moving followerChecksFailureCounter outside of Transport call

Signed-off-by: Harsh Garg <gkharsh@amazon.com>
opensearch-project · May 23, 2024 · 13954dc · 13954dc
1 parent c295e40
commit 13954dc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/cluster/coordination/FollowersChecker.java b/server/src/main/java/org/opensearch/cluster/coordination/FollowersChecker.java
@@ -417,6 +417,7 @@ public String executor() {
  }
 
  void failNode(String reason) {
+ clusterManagerMetrics.incrementCounter(clusterManagerMetrics.followerChecksFailureCounter, 1.0);
  transportService.getThreadPool().generic().execute(new Runnable() {
  @Override
  public void run() {
@@ -430,7 +431,6 @@ public void run() {
  followerCheckers.remove(discoveryNode);
  }
  onNodeFailure.accept(discoveryNode, reason);
- clusterManagerMetrics.incrementCounter(clusterManagerMetrics.followerChecksFailureCounter, 1.0);
  }
 
  @Override