From e84f96051680bde1c33f3045fa26e0c097a6174f Mon Sep 17 00:00:00 2001
From: Pere Diaz Bou <pere-altea@hotmail.com>
Date: Wed, 1 Oct 2025 15:46:53 +0200
Subject: [PATCH] core/wal: check index header on begin_write_tx

---
 core/storage/wal.rs | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/core/storage/wal.rs b/core/storage/wal.rs
index 899da558a..c8f7fcf00 100644
--- a/core/storage/wal.rs
+++ b/core/storage/wal.rs
@@ -983,12 +983,17 @@ impl Wal for WalFile {
         if !shared.write_lock.write() {
             return Err(LimboError::Busy);
         }
-        let (shared_max, nbackfills, last_checksum) = (
-            shared.max_frame.load(Ordering::Acquire),
-            shared.nbackfills.load(Ordering::Acquire),
-            shared.last_checksum,
-        );
-        if self.max_frame.load(Ordering::Acquire) == shared_max {
+        let (shared_max, nbackfills, last_checksum, checkpoint_seq) = {
+            let mx = shared.max_frame.load(Ordering::Acquire);
+            let nb = shared.nbackfills.load(Ordering::Acquire);
+            let ck = shared.last_checksum;
+            let checkpoint_seq = shared.wal_header.lock().checkpoint_seq;
+            (mx, nb, ck, checkpoint_seq)
+        };
+        let db_changed = shared_max != self.max_frame.load(Ordering::Acquire)
+            || last_checksum != self.last_checksum
+            || checkpoint_seq != self.checkpoint_seq.load(Ordering::Acquire);
+        if !db_changed {
             // Snapshot still valid; adopt counters
             drop(shared);
             self.last_checksum = last_checksum;