try to fix double initialization of namespaces

Author: d-biehl

robotcode/language_server/robotframework/diagnostics/namespace.py

@@ -600,6 +600,8 @@ def __init__(
         self.imports_manager.resources_changed.add(self.resources_changed)
         self.imports_manager.variables_changed.add(self.variables_changed)
 
+        self._in_initialize = False
+
     @async_event
     async def has_invalidated(sender) -> None:  # NOSONAR
         ...
@@ -678,6 +680,7 @@ async def invalidate(self) -> None:
             self._variable_references = {}
 
             self._finder = None
+            self._in_initialize = False
 
             await self._reset_global_variables()
 
@@ -767,6 +770,12 @@ async def ensure_initialized(self) -> bool:
             imports_changed = False
             async with self._initialize_lock:
                 if not self._initialized:
+
+                    if self._in_initialize:
+                        self._logger.critical(f"already initialized {self.document}")
+
+                    self._in_initialize = True
+
                     try:
                         self._logger.debug(f"ensure_initialized -> initialize {self.document}")
 
@@ -834,6 +843,8 @@ async def ensure_initialized(self) -> bool:
 
                         await self.invalidate()
                         raise
+                    finally:
+                        self._in_initialize = False
 
             if self._initialized:
                 await self.has_initialized(self)

robotcode/utils/async_tools.py

@@ -583,7 +583,7 @@ async def release(self) -> None:
         await super().release()
 
 
-class NewLock:
+class Lock:
     def __init__(self) -> None:
         self._block = BoundedSemaphore(value=1)
 
@@ -609,7 +609,7 @@ async def __aexit__(
         await self.release()
 
 
-class Lock:
+class OldLock:
     """Threadsafe version of an async Lock."""
 
     def __init__(self) -> None:
@@ -638,7 +638,6 @@ async def __inner_lock(self) -> AsyncGenerator[Any, None]:
         while not b:
             await asyncio.sleep(0)
             b = self._lock.acquire(blocking=False)
-
         try:
             yield None
         finally: