From 025b2695620b596b819da4707d6e5b7077a4a3c0 Mon Sep 17 00:00:00 2001 From: voidlizard Date: Sat, 15 Mar 2025 07:44:43 +0300 Subject: [PATCH] wip. fixing TCP busyloop --- hbs2-core/lib/HBS2/Net/Messaging/TCP.hs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs b/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs index 50e6de87..f2dd3de2 100644 --- a/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs +++ b/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs @@ -391,11 +391,11 @@ runMessagingTCP env@MessagingTCP{..} = liftIO do forever $ void $ runMaybeT do -- client sockets - -- смотрим к кому надо - who <- atomically $ fix \next -> do - who <- readTQueue _tcpConnDemand - already <- readTVar _tcpPeerConn <&> HM.member who - if not already then pure who else next + who <- atomically $ readTQueue _tcpConnDemand + + already <- readTVarIO _tcpPeerConn <&> HM.member who + + when already mzero debug $ "DEMAND:" <+> pretty who