fix #59, require lock before generate a mq store

qinxuye · Jul 29, 2016 · db3b424 · db3b424
1 parent 8ec66dd
commit db3b424
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/cola/core/mq/store.py b/cola/core/mq/store.py
@@ -254,7 +254,8 @@ def put_one(self, obj, force=False, commit=True):
             if self.deduper.exist(prop):
                 return
         if len(self.legal_files) == 0:
-            self._generate_file()
+            with self.lock:
+                self._generate_file()
 
         obj_str = self._stringfy(obj)
         # If no file has enough space