DatagramServer: Eliminate a possible race condition error

francis-clairicia · Jun 23, 2024 · b756126 · b756126
1 parent df84bc1
commit b756126
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/src/easynetwork/lowlevel/api_async/servers/datagram.py b/src/easynetwork/lowlevel/api_async/servers/datagram.py
@@ -185,13 +185,10 @@ async def handler(datagram: bytes, address: _T_Address, /) -> None:
                         client = client_cache[address]
                     except KeyError:
                         client_cache[address] = client = _ClientToken(DatagramClientContext(address, self), _ClientData(backend))
-                        new_client_task = True
-                    else:
-                        new_client_task = client.data.state is None
 
                     await client.data.push_datagram(datagram)
 
-                    if new_client_task:
+                    if client.data.state is None:
                         del datagram
                         client.data.mark_pending()
                         await self.__client_coroutine(datagram_received_cb, client, task_group, default_context)