From 21f60b6ce9f0b5bf4e4023b90eb2cb9116971285 Mon Sep 17 00:00:00 2001 From: voidlizard Date: Tue, 18 Mar 2025 08:11:24 +0300 Subject: [PATCH] wip, fix tcp --- 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 45faca0d..3499eb03 100644 --- a/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs +++ b/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs @@ -249,11 +249,11 @@ runMessagingTCP env@MessagingTCP{..} = liftIO do sweepCookies <- ContT $ withAsync $ forever do pause @'Seconds 300 - -- atomically do - -- pips <- readTVar _tcpPeerConn - -- modifyTVar _tcpPeerToCookie (HM.filterWithKey (\k _ -> HM.member k pips)) - -- alive <- readTVar _tcpPeerToCookie <&> HS.fromList . HM.elems - -- modifyTVar _tcpPeerCookie (HM.filterWithKey (\k _ -> HS.member k alive)) + atomically do + pips <- readTVar _tcpPeerConn + modifyTVar _tcpPeerToCookie (HM.filterWithKey (\k _ -> HM.member k pips)) + alive <- readTVar _tcpPeerToCookie <&> HS.fromList . HM.elems + modifyTVar _tcpPeerCookie (HM.filterWithKey (\k _ -> HS.member k alive)) sweep <- ContT $ withAsync $ forever do pause @'Seconds 300