From cbdffb714cf24eacfe08586f56109e46df234806 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Roman=20Smr=C5=BE?= Date: Thu, 14 Sep 2023 21:05:07 +0200 Subject: Protocol: check if control flow is free before processing incoming packet --- src/Network/Protocol.hs | 1 + 1 file changed, 1 insertion(+) diff --git a/src/Network/Protocol.hs b/src/Network/Protocol.hs index e286a67..0f099e0 100644 --- a/src/Network/Protocol.hs +++ b/src/Network/Protocol.hs @@ -267,6 +267,7 @@ passUpIncoming GlobalState {..} = do processIncoming :: GlobalState addr -> STM (IO ()) processIncoming gs@GlobalState {..} = do guard =<< isEmptyTMVar gNextUp + guard =<< canWriteFlow gControlFlow (addr, msg) <- readFlow gDataFlow mbconn <- findConnection gs addr -- cgit v1.2.3