Add lock to internal socket fetch function

2026-07-11 06:32:04 +00:00 · 2024-07-07 20:33:45 +02:00
1 changed files with 6 additions and 4 deletions
@@ -19,6 +19,7 @@ class UnixSocket:
        self.reader = None
        self.writer = None
        self.server_writer = None
+        self.open_lock = asyncio.Lock()

    async def setup_server(self):
        try:
@@ -42,6 +43,7 @@ class UnixSocket:
            return True

    async def get_socket_connection(self):
+        async with self.open_lock:
            if not await self._open_socket_if_not_exists():
                return None, None