Skip to content

Commit b3c2095

Browse files
committed
rename getShardCancellationAction
Signed-off-by: Shivansh Arora <hishiv@amazon.com>
1 parent 6411b2e commit b3c2095

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/opensearch/gateway/ReplicaShardAllocator.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ protected boolean shouldSkipFetchForRecovery(ShardRouting shard) {
8888
return false;
8989
}
9090

91-
protected Runnable getShardCancellationAction(
91+
protected Runnable cancelExistingRecoveryForBetterMatch(
9292
ShardRouting shard,
9393
RoutingAllocation allocation,
9494
Map<DiscoveryNode, StoreFilesMetadata> nodeShardStores
@@ -174,7 +174,7 @@ public void processExistingRecoveries(RoutingAllocation allocation) {
174174
AsyncShardFetch.FetchResult<NodeStoreFilesMetadata> shardStores = fetchData(shard, allocation);
175175
Map<DiscoveryNode, StoreFilesMetadata> nodeShardStores = convertToNodeStoreFilesMetadataMap(shardStores);
176176

177-
Runnable cancellationAction = getShardCancellationAction(shard, allocation, nodeShardStores);
177+
Runnable cancellationAction = cancelExistingRecoveryForBetterMatch(shard, allocation, nodeShardStores);
178178
if (cancellationAction != null) {
179179
shardCancellationActions.add(cancellationAction);
180180
}

0 commit comments

Comments
 (0)