repos: (Re-)write a repository only once at a time

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>

diff --git a/src/buildservice/repository.py b/src/buildservice/repository.py
index 3ab217d75c9e365635ec18ec6ce0056aa12aee84..de7b4cac6e8c41c2cf08383a10db8883ba371468 100644 (file)
--- a/src/buildservice/repository.py
+++ b/src/buildservice/repository.py
@@ -863,11 +863,23 @@ class Repository(base.DataObject):
 
        # Write repository
 
-       async def write(self, *args, **kwargs):
+       __locks = {}
+
+       @property
+       def __lock(self):
+               try:
+                       lock = self.__locks[self.id]
+               except KeyError:
+                       lock = self.__locks[self.id] = asyncio.Lock()
+
+               return lock
+
+       async def write(self):
                """
                        Called to write/rewrite/update the repository metadata
                """
-               return await asyncio.to_thread(self._write, *args, **kwargs)
+               with self.__lock:
+                       return await asyncio.to_thread(self._write)
 
        def _write(self):
                log.info("Writing repository %s..." % self)