Take the lock before unlinking the mmap'ed shared memory to ensure

all writes are finished and visible.

diff --git a/collect/shared_dict.py b/collect/shared_dict.py
index ac390bc600e769a94c2205440883257a665917bb..ec76138b393955d47f3850bf2a91d425ada563b1 100644 (file)
--- a/collect/shared_dict.py
+++ b/collect/shared_dict.py
@@ -108,7 +108,8 @@ class SharedDict(object):
     def cleanup(self) -> None:
         if not hasattr(self, 'shared_memory'):
             return
-        self.shared_memory.unlink()
+        with SharedDict.MPLOCK:
+            self.shared_memory.unlink()
 
     def clear(self) -> None:
         self._save_memory({})