avoid session deadlock
This commit is contained in:
@ -123,9 +123,10 @@ class MultiplayerSessionManager(object):
|
|||||||
logger.info("Removed %d idle sessions", len(idle_session_ids))
|
logger.info("Removed %d idle sessions", len(idle_session_ids))
|
||||||
|
|
||||||
async def create_session(self, lang: str | Languages, grid_w: int, grid_h: int) -> MultiplayerSession:
|
async def create_session(self, lang: str | Languages, grid_w: int, grid_h: int) -> MultiplayerSession:
|
||||||
async with self._sessions_lock:
|
|
||||||
# Remove idle sessions before creating a new one
|
# Remove idle sessions before creating a new one
|
||||||
await self.remove_idle_sessions()
|
await self.remove_idle_sessions()
|
||||||
|
async with self._sessions_lock:
|
||||||
|
|
||||||
|
|
||||||
if isinstance(lang, str):
|
if isinstance(lang, str):
|
||||||
lang = Languages(lang)
|
lang = Languages(lang)
|
||||||
|
|||||||
Reference in New Issue
Block a user