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

q only

This commit is contained in:
Dmitry Zuikov 2023-02-20 10:46:42 +03:00
parent 78bdd5da29
commit f22410ba81
2 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
hbs2-core/lib/HBS2/Net/Messaging/UDP.hs
View File

@ -140,10 +140,10 @@ udpWorker env tso = do
rcvLoop <- async $ forever $ do
-- so <- readTVarIO tso
pause ( 10 :: Timeout 'Seconds )
-- (msg, from) <- recvFrom so defMaxDatagram
-- pause ( 10 :: Timeout 'Seconds )
(msg, from) <- recvFrom so defMaxDatagram
-- liftIO $ print $ "recv:" <+> pretty (BS.length msg)
-- atomically $ Q.writeTBQueue (sink env) (From (PeerUDP from), LBS.fromStrict msg)
liftIO $ atomically $ Q.writeTBQueue (sink env) (From (PeerUDP from), LBS.fromStrict msg)
sndLoop <- async $ forever $ do
pause ( 10 :: Timeout 'Seconds )
@ -178,10 +178,9 @@ instance Messaging MessagingUDP UDP ByteString where
sendAllTo so (LBS.toStrict msg) (view sockAddr whom)
receive bus _ = liftIO do
so <- readTVarIO (sock bus)
(msg, from) <- recvFrom so defMaxDatagram
pure [(From (PeerUDP from), LBS.fromStrict msg)]
-- so <- readTVarIO (sock bus)
-- (msg, from) <- recvFrom so defMaxDatagram
-- pure [(From (PeerUDP from), LBS.fromStrict msg)]
-- liftIO $ atomically
-- $ Q.readTBQueue (sink bus) <&> L.singleton
liftIO $ atomically $ Q.readTBQueue (sink bus) <&> L.singleton

2
hbs2-peer/app/BlockDownload.hs
View File

@ -382,7 +382,7 @@ updatePeerInfo onError pinfo = do
let buM = headMay $ drop 2 $ IntSet.toDescList buSet
writeTVar (view peerBurstMax pinfo) buM
-- let s = IntSet.size buSet
let buN = headDef defBurst $ drop 10 $ IntSet.toDescList buSet
let buN = headDef defBurst $ drop 4 $ IntSet.toDescList buSet
pure (buN, trimDown 50 $ IntSet.insert buN buSet)