Skip to content

Commit

Permalink
[Segment Replication] Cancellation check before send files to prevent…
Browse files Browse the repository at this point in the history
… segrep round (#7053)

Signed-off-by: Suraj Singh <[email protected]>
  • Loading branch information
dreamer-89 authored Apr 11, 2023
1 parent a15475a commit df5def4
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit df5def4

Please sign in to comment.