voidlizard
/
hbs2
mirror of https://github.com/voidlizard/hbs2
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

wip, fix tcp

This commit is contained in:
voidlizard 2025-03-18 08:11:24 +03:00
parent 0d90b4df05
commit 21f60b6ce9
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbs2-core/lib/HBS2/Net/Messaging/TCP.hs
View File

@ -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