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

wip

This commit is contained in:
voidlizard 2024-11-13 20:19:24 +03:00
parent e61f762913
commit b838637cd3
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbs2-peer/app/BlockDownloadNew.hs
View File

@ -496,8 +496,9 @@ downloadFromPeer t bu cache env h peer = liftIO $ withPeerM env do
t1 <- getTimeCoarse t1 <- getTimeCoarse
atomically do atomically do
when (isRight r) do
-- wx0 <- readTVar _wx -- wx0 <- readTVar _wx
let wx1 = 100 * realToFrac (t1 - t0) / 1e6 -- millis let wx1 = 20000 -- min 10000 (2.5 * 100 * realToFrac (t1 - t0) / 1e6) -- millis
writeTVar _wx wx1 writeTVar _wx wx1
case r of case r of
@ -662,11 +663,12 @@ downloadDispatcher brains env = flip runContT pure do
_errors <- newTVarIO 0 _errors <- newTVarIO 0
_avg <- newTVarIO 600 _avg <- newTVarIO 600
sto <- withPeerM env getStorage
_sizeCache <- newTVarIO ( mempty :: HashMap HashRef (Maybe Integer) ) _sizeCache <- newTVarIO ( mempty :: HashMap HashRef (Maybe Integer) )
bm <- liftIO $ newBurstMachine 0.5 256 (Just 50) 0.05 0.15 bm <- liftIO do
case _sockType p of
TCP -> newBurstMachine 10 256 (Just 256) 0.25 0.45
UDP -> newBurstMachine 10 256 (Just 50) 0.10 0.25
void $ ContT $ bracket none $ const do void $ ContT $ bracket none $ const do
debug $ "Cancelling thread for" <+> pretty p debug $ "Cancelling thread for" <+> pretty p
@ -798,7 +800,7 @@ downloadDispatcher brains env = flip runContT pure do
avg <- readTVarIO _avg avg <- readTVarIO _avg
when (dtsec > avg * 1.5) do when (dtsec > avg) do
burstMachineAddErrors bm 1 burstMachineAddErrors bm 1
atomically do atomically do