mirror of https://github.com/voidlizard/hbs2
wip, fix tcp
This commit is contained in:
parent
8b06b53f00
commit
4757465fc3
|
@ -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 < 1200 ]
|
||||||
writeTVar _tcpSent (HPSQ.fromList live)
|
writeTVar _tcpSent (HPSQ.fromList live)
|
||||||
-- atomically do
|
-- atomically do
|
||||||
-- pips <- readTVar _tcpPeerConn
|
-- pips <- readTVar _tcpPeerConn
|
||||||
|
|
Loading…
Reference in New Issue