wip, fix tcp

This commit is contained in:
voidlizard 2025-03-18 08:06:13 +03:00
parent 4757465fc3
commit 0d90b4df05
1 changed files with 1 additions and 1 deletions

View File

@ -260,7 +260,7 @@ runMessagingTCP env@MessagingTCP{..} = liftIO do
now <- getTimeCoarse now <- getTimeCoarse
atomically do atomically do
w <- readTVar _tcpSent <&> HPSQ.toList w <- readTVar _tcpSent <&> HPSQ.toList
let live = [ x | x@(_,t,_) <- w, realToFrac (now - t) / 1e9 < 1200 ] let live = [ x | x@(_,t,_) <- w, realToFrac (now - t) / 1e9 < 300 ]
writeTVar _tcpSent (HPSQ.fromList live) writeTVar _tcpSent (HPSQ.fromList live)
-- atomically do -- atomically do
-- pips <- readTVar _tcpPeerConn -- pips <- readTVar _tcpPeerConn