From be9c70203fef6df45a6c954192b510520567883e Mon Sep 17 00:00:00 2001
From: Arsenii Kulikov <klkvrr@gmail.com>
Date: Fri, 29 May 2026 14:26:46 +0400
Subject: [PATCH] fix: properly clear cache

---
 src/lib.rs | 20 +++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/src/lib.rs b/src/lib.rs
index 55715e1..57efe25 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -256,7 +256,8 @@ where
         const EPOCH_MAX: usize = (1 << EPOCH_BITS) - 1;
         const { assert!(C::EPOCHS, "can only .clear() when C::EPOCHS is true") }
         let prev = self.epoch.fetch_add(1, Ordering::Release);
-        if prev == EPOCH_MAX {
+        // Tags store only the low EPOCH_BITS of the epoch, clear the cache on every low-bit wrap.
+        if (prev & EPOCH_MAX) == EPOCH_MAX {
             self.clear_slow();
         }
     }
@@ -1206,6 +1207,23 @@ mod tests {
         }
     }
 
+    #[test]
+    fn epoch_repeated_wraparound_stays_cleared() {
+        let cache: EpochCache<u64, u64> = EpochCache::new(4096, Default::default());
+
+        for _ in 0..1024 {
+            cache.clear();
+        }
+
+        cache.insert(42, 123);
+        assert_eq!(cache.get(&42), Some(123));
+
+        for i in 0..1024 {
+            cache.clear();
+            assert_eq!(cache.get(&42), None, "failed at clear #{i}");
+        }
+    }
+
     #[test]
     fn remove_copy_type() {
         let cache = new_cache::<u64, u64>(64);