nitpick

Signed-off-by: Bukhtawar Khan <[email protected]>
opensearch-project · Jul 22, 2024 · 1c5c211 · 1c5c211
1 parent d3d78cf
commit 1c5c211
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/server/src/main/java/org/opensearch/common/util/BatchRunnableExecutor.java b/server/src/main/java/org/opensearch/common/util/BatchRunnableExecutor.java
@@ -44,7 +44,7 @@ public void run() {
             return;
         }
         for (TimeoutAwareRunnable workQueue : timeoutAwareRunnables) {
-            if (System.nanoTime() - startTime > timeoutSupplier.get().nanos()) {
+            if (System.nanoTime() - startTime < timeoutSupplier.get().nanos()) {
                 workQueue.run();
             } else {
                 logger.debug("Executing timeout for runnable of size [{}]", timeoutAwareRunnables.size());

diff --git a/server/src/main/java/org/opensearch/gateway/PrimaryShardBatchAllocator.java b/server/src/main/java/org/opensearch/gateway/PrimaryShardBatchAllocator.java
@@ -122,7 +122,7 @@ public void allocateUnassignedBatch(List<ShardRouting> shardRoutings, RoutingAll
         logger.trace("Finished shard allocation execution for unassigned primary shards: {}", shardRoutings.size());
     }
 
-    public void allocateUnassignedBatchOnTimeout(List<ShardRouting> shardRoutings, RoutingAllocation allocation) {
+    protected void allocateUnassignedBatchOnTimeout(List<ShardRouting> shardRoutings, RoutingAllocation allocation) {
         Set<ShardRouting> batchShardRoutingSet = new HashSet<>(shardRoutings);
         RoutingNodes.UnassignedShards.UnassignedIterator iterator = allocation.routingNodes().unassigned().iterator();
         while (iterator.hasNext()) {

diff --git a/server/src/main/java/org/opensearch/gateway/ReplicaShardBatchAllocator.java b/server/src/main/java/org/opensearch/gateway/ReplicaShardBatchAllocator.java
@@ -168,7 +168,7 @@ public void allocateUnassignedBatch(List<ShardRouting> shardRoutings, RoutingAll
         logger.trace("Finished shard allocation execution for unassigned replica shards: {}", shardRoutings.size());
     }
 
-    public void allocateUnassignedBatchOnTimeout(List<ShardRouting> shardRoutings, RoutingAllocation allocation) {
+    protected void allocateUnassignedBatchOnTimeout(List<ShardRouting> shardRoutings, RoutingAllocation allocation) {
         Set<ShardId> shardIdsFromBatch = new HashSet<>();
         for (ShardRouting shardRouting : shardRoutings) {
             ShardId shardId = shardRouting.shardId();