From d7acfc422ca5487d8ad5ebd85b869e3b3fb2cc9e Mon Sep 17 00:00:00 2001
From: matst80 <mats.tornberg@gmail.com>
Date: Mon, 29 Jun 2026 20:10:09 +0200
Subject: [PATCH] better lock handling

---
 pkg/actor/disk_storage.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/pkg/actor/disk_storage.go b/pkg/actor/disk_storage.go
index 8d89020..62ec531 100644
--- a/pkg/actor/disk_storage.go
+++ b/pkg/actor/disk_storage.go
@@ -176,11 +176,12 @@ func (s *DiskStorage[V]) closeWriters() {
 	defer s.writersMu.Unlock()
 	for id, w := range s.writers {
 		w.mu.Lock()
+		w.purged = true
 		if err := w.file.Close(); err != nil {
 			log.Printf("failed to close event log %d: %v", id, err)
 		}
-		w.mu.Unlock()
 		delete(s.writers, id)
+		w.mu.Unlock()
 	}
 }