[Segment Replication] Cancellation check before send files to prevent…

… segrep round (#7053) Signed-off-by: Suraj Singh <[email protected]> (cherry picked from commit df5def4) Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
opensearch-project · Apr 11, 2023 · c21d7ad · c21d7ad
1 parent b59c826
commit c21d7ad
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
@@ -136,7 +136,7 @@ public synchronized void sendFiles(GetSegmentFilesRequest request, ActionListene
                     timer.time()
                 );
             };
-
+            cancellableThreads.checkForCancel();
             final IndexShardRoutingTable routingTable = shard.getReplicationGroup().getRoutingTable();
             ShardRouting targetShardRouting = routingTable.getByAllocationId(request.getTargetAllocationId());
             if (targetShardRouting == null) {