fix(ecstore): preserve successor fsync group registration

(cherry picked from commit c7dfaad90526052e56c57dafffa4813bdcde46ca)
2026-09-06 12:09:12 +00:00 · 2026-09-06 03:21:19 +08:00
parent ed100103d0
commit 5e33186cf6
1 changed files with 7 additions and 1 deletions
@@ -735,7 +735,13 @@ impl DstDirFsyncGroupCommit {
    fn remove_idle_group(&self, group: &Arc<DstDirFsyncGroup>) {
        let mut registry = self.inner.lock();
        let group_state = group.inner.lock();
-        if !group_state.worker_running && group_state.pending.is_empty() {
+        if !group_state.worker_running
+            && group_state.pending.is_empty()
+            && registry
+                .groups
+                .get(&group.key)
+                .is_some_and(|registered| Arc::ptr_eq(registered, group))
+        {
            registry.groups.remove(&group.key);
        }
    }