Fix a bug in TryCatchupWithLeader

anand1976 · Apr 18, 2024 · f345b98 · f345b98
1 parent 44745c2
commit f345b98
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/db/db_impl/db_impl_follower.cc b/db/db_impl/db_impl_follower.cc
@@ -135,14 +135,14 @@ Status DBImplFollower::TryCatchUpWithLeader() {
           cfd->imm()->Add(cfd->mem(), &job_context.memtables_to_free);
           new_mem->Ref();
           cfd->SetMemtable(new_mem);
-
-          // This will check if the old memtable is still referenced
-          cfd->imm()->RemoveOldMemTables(cfd->GetLogNumber(),
-                                         &job_context.memtables_to_free);
-          auto& sv_context = job_context.superversion_contexts.back();
-          cfd->InstallSuperVersion(&sv_context, &mutex_);
-          sv_context.NewSuperVersion();
         }
+
+        // This will check if the old memtable is still referenced
+        cfd->imm()->RemoveOldMemTables(cfd->GetLogNumber(),
+                                       &job_context.memtables_to_free);
+        auto& sv_context = job_context.superversion_contexts.back();
+        cfd->InstallSuperVersion(&sv_context, &mutex_);
+        sv_context.NewSuperVersion();
       }
     }
   }