Add constant for min timeout

Signed-off-by: Rishab Nahata <[email protected]>
imRishN · Jul 26, 2024 · 01e8ef8 · 01e8ef8
1 parent c2b75cb
commit 01e8ef8
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/ShardsBatchGatewayAllocator.java b/server/src/main/java/org/opensearch/gateway/ShardsBatchGatewayAllocator.java
@@ -80,6 +80,7 @@ public class ShardsBatchGatewayAllocator implements ExistingShardsAllocator {
 
     private TimeValue primaryShardsBatchGatewayAllocatorTimeout;
     private TimeValue replicaShardsBatchGatewayAllocatorTimeout;
+    public static final TimeValue MIN_ALLOCATOR_TIMEOUT = TimeValue.timeValueSeconds(20);
 
     /**
      * Number of shards we send in one batch to data nodes for fetching metadata
@@ -103,7 +104,7 @@ public class ShardsBatchGatewayAllocator implements ExistingShardsAllocator {
         new Setting.Validator<>() {
             @Override
             public void validate(TimeValue timeValue) {
-                if (timeValue.compareTo(TimeValue.timeValueSeconds(20)) < 0 && timeValue.compareTo(TimeValue.MINUS_ONE) != 0) {
+                if (timeValue.compareTo(MIN_ALLOCATOR_TIMEOUT) < 0 && timeValue.compareTo(TimeValue.MINUS_ONE) != 0) {
                     throw new IllegalArgumentException(
                         "Setting ["
                             + PRIMARY_BATCH_ALLOCATOR_TIMEOUT_SETTING.getKey()
@@ -127,7 +128,7 @@ public void validate(TimeValue timeValue) {
         new Setting.Validator<>() {
             @Override
             public void validate(TimeValue timeValue) {
-                if (timeValue.compareTo(TimeValue.timeValueSeconds(20)) < 0 && timeValue.compareTo(TimeValue.MINUS_ONE) != 0) {
+                if (timeValue.compareTo(MIN_ALLOCATOR_TIMEOUT) < 0 && timeValue.compareTo(TimeValue.MINUS_ONE) != 0) {
                     throw new IllegalArgumentException(
                         "Setting ["
                             + REPLICA_BATCH_ALLOCATOR_TIMEOUT_SETTING.getKey()