From c4193014a4cd017a18ed842300d737f5e4c51cd1 Mon Sep 17 00:00:00 2001
From: alexfisher <1823748191@qq.com>
Date: Fri, 20 Dec 2024 10:06:42 +0800
Subject: [PATCH] fix recover bug

---
 db/version_set.cc | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/db/version_set.cc b/db/version_set.cc
index fd9357c..b362920 100644
--- a/db/version_set.cc
+++ b/db/version_set.cc
@@ -909,6 +909,7 @@ Status VersionSet::Recover(bool* save_manifest) {
   uint64_t last_sequence = 0;
   uint64_t log_number = 0;
   uint64_t prev_log_number = 0;
+  next_file_number_ = 0;
   Builder builder(this, current_);
   int read_records = 0;
 
@@ -977,12 +978,24 @@ Status VersionSet::Recover(bool* save_manifest) {
     MarkFileNumberUsed(log_number);
   }
 
+  assert(s.ok());
+  std::vector<std::string> filenames;
+  env_->GetChildren(dbname_, &filenames);
+  for (const auto& filename:filenames) {
+    if (IsValueLogFile(filename)){
+      uint64_t valuelog_number = GetValueLogID(filename);
+      std::cout<<valuelog_number<<std::endl;
+      MarkFileNumberUsed(valuelog_number);
+    }
+  }
+
   if (s.ok()) {
     Version* v = new Version(this);
     builder.SaveTo(v);
     // Install recovered version
     Finalize(v);
     AppendVersion(v);
+    if(next_file<next_file_number_)next_file=next_file_number_;
     manifest_file_number_ = next_file;
     next_file_number_ = next_file + 1;
     last_sequence_ = last_sequence;