[Remote Translog] Fix translog inconsistent generation assertion fail…

…ure in ITs Signed-off-by: Ashish Singh <ssashish@amazon.com>
opensearch-project · Oct 30, 2023 · 502e3f2 · 502e3f2
1 parent 73bbeb5
commit 502e3f2
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/index/translog/RemoteFsTranslog.java b/server/src/main/java/org/opensearch/index/translog/RemoteFsTranslog.java
@@ -266,13 +266,14 @@ public void rollGeneration() throws IOException {
     }
 
     private boolean prepareAndUpload(Long primaryTerm, Long generation) throws IOException {
+        boolean translogOpen = closed.get() == false;
         try (Releasable ignored = writeLock.acquire()) {
             if (generation == null || generation == current.getGeneration()) {
                 try {
                     final TranslogReader reader = current.closeIntoReader();
                     readers.add(reader);
                     copyCheckpointTo(location.resolve(getCommitCheckpointFileName(current.getGeneration())));
-                    if (closed.get() == false) {
+                    if (translogOpen) {
                         logger.trace("Creating new writer for gen: [{}]", current.getGeneration() + 1);
                         current = createWriter(current.getGeneration() + 1);
                     }
@@ -299,7 +300,7 @@ private boolean prepareAndUpload(Long primaryTerm, Long generation) throws IOExc
             // Writing remote in sync fashion doesn't hurt as global ckp update
             // is not updated in remote translog except in primary to primary recovery.
             if (generation == null) {
-                if (closed.get() == false) {
+                if (translogOpen) {
                     return upload(primaryTerm, current.getGeneration() - 1);
                 } else {
                     return upload(primaryTerm, current.getGeneration());