Add assertions

Signed-off-by: Sachin Kale <[email protected]>
opensearch-project · Oct 29, 2023 · c8720eb · c8720eb
1 parent 62e396a
commit c8720eb
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/.../src/main/java/org/opensearch/index/store/lockmanager/RemoteStoreMetadataLockManager.java b/.../src/main/java/org/opensearch/index/store/lockmanager/RemoteStoreMetadataLockManager.java
@@ -14,6 +14,7 @@
 import org.apache.lucene.store.IndexOutput;
 import org.opensearch.index.store.RemoteBufferedOutputDirectory;
 
+import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.nio.file.NoSuchFileException;
 import java.util.Collection;
@@ -78,6 +79,10 @@ public String fetchLock(String filenamePrefix, String acquirerId) throws IOExcep
             .filter(lockFile -> acquirerId.equals(FileLockInfo.LockFileUtils.getAcquirerIdFromLock(lockFile)))
             .map(FileLockInfo.LockFileUtils::getFileToLockNameFromLock)
             .collect(Collectors.toList());
+        if (lockFilesForAcquirer.size() == 0) {
+            throw new FileNotFoundException("No lock file found for prefix: " + filenamePrefix + " and acquirerId: " + acquirerId);
+        }
+        assert lockFilesForAcquirer.size() == 1;
         return lockFilesForAcquirer.get(0);
     }