rename getShardCancellationAction

Signed-off-by: Shivansh Arora <[email protected]>
shiv0408 · Feb 5, 2024 · b3c2095 · b3c2095
1 parent 6411b2e
commit b3c2095
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/ReplicaShardAllocator.java b/server/src/main/java/org/opensearch/gateway/ReplicaShardAllocator.java
@@ -88,7 +88,7 @@ protected boolean shouldSkipFetchForRecovery(ShardRouting shard) {
         return false;
     }
 
-    protected Runnable getShardCancellationAction(
+    protected Runnable cancelExistingRecoveryForBetterMatch(
         ShardRouting shard,
         RoutingAllocation allocation,
         Map<DiscoveryNode, StoreFilesMetadata> nodeShardStores
@@ -174,7 +174,7 @@ public void processExistingRecoveries(RoutingAllocation allocation) {
                 AsyncShardFetch.FetchResult<NodeStoreFilesMetadata> shardStores = fetchData(shard, allocation);
                 Map<DiscoveryNode, StoreFilesMetadata> nodeShardStores = convertToNodeStoreFilesMetadataMap(shardStores);
 
-                Runnable cancellationAction = getShardCancellationAction(shard, allocation, nodeShardStores);
+                Runnable cancellationAction = cancelExistingRecoveryForBetterMatch(shard, allocation, nodeShardStores);
                 if (cancellationAction != null) {
                     shardCancellationActions.add(cancellationAction);
                 }