Stop timer inside try to prevent double stop on timer

Signed-off-by: Suraj Singh <surajrider@gmail.com>
opensearch-project · Jul 10, 2023 · f0f7bb3 · f0f7bb3
1 parent 940fe8f
commit f0f7bb3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationSourceHandler.java b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationSourceHandler.java
@@ -170,9 +170,9 @@ public synchronized void sendFiles(GetSegmentFilesRequest request, ActionListene
                 try {
                     shard.updateVisibleCheckpointForShard(allocationId, copyState.getCheckpoint());
                     future.onResponse(new GetSegmentFilesResponse(List.of(storeFileMetadata)));
+                    timer.stop();
                 } finally {
                     IOUtils.close(resources);
-                    timer.stop();
                     logger.trace(
                         "[replication id {}] Source node completed sending files to target node [{}], timing: {}",
                         request.getReplicationId(),