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

same shit

This commit is contained in:
voidlizard 2024-11-13 17:42:43 +03:00
parent 14ed31dc38
commit 1ad5be6b10
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -644,7 +644,9 @@ downloadDispatcher brains env = flip runContT pure do
atomically do atomically do
dcb <- newDcbSTM now dcb <- newDcbSTM now
let w = realToFrac now let w = realToFrac now
modifyTVar wip (HPSQ.insert hi 1.0 dcb) already <- readTVar wip <&> HPSQ.member hi
unless already do
modifyTVar wip (HPSQ.insert hi 1.0 dcb)
forever $ (>> pause @'Seconds 10) do forever $ (>> pause @'Seconds 10) do
sw0 <- readTVarIO wip <&> HPSQ.size sw0 <- readTVarIO wip <&> HPSQ.size
@ -703,8 +705,6 @@ downloadDispatcher brains env = flip runContT pure do
unless here do unless here do
modifyTVar _sizeCache (HM.delete h) modifyTVar _sizeCache (HM.delete h)
parseQ <- newTQueueIO
bmt <- ContT $ withAsync $ runBurstMachine bm bmt <- ContT $ withAsync $ runBurstMachine bm
tstat <- ContT $ withAsync $ forever $ (>> pause @'Seconds 5) do tstat <- ContT $ withAsync $ forever $ (>> pause @'Seconds 5) do
@ -797,6 +797,7 @@ downloadDispatcher brains env = flip runContT pure do
case r of case r of
Right bs -> do Right bs -> do
let dtsec = realToFrac (toNanoSeconds (TimeoutTS (t1 - t0))) / 1e9 let dtsec = realToFrac (toNanoSeconds (TimeoutTS (t1 - t0))) / 1e9
avg <- readTVarIO _avg avg <- readTVarIO _avg
@ -804,8 +805,10 @@ downloadDispatcher brains env = flip runContT pure do
when (dtsec > avg * 1.10) do when (dtsec > avg * 1.10) do
burstMachineAddErrors bm 1 burstMachineAddErrors bm 1
atomically $ modifyTVar btimes ( take 100 . (dtsec :) ) atomically do
atomically $ writeTVar (dcbDownloaded dcb) True modifyTVar btimes ( take 100 . (dtsec :) )
writeTVar (dcbDownloaded dcb) True
onBlock hx
go (PReleaseBlock hx dcb True) go (PReleaseBlock hx dcb True)
@ -823,7 +826,6 @@ downloadDispatcher brains env = flip runContT pure do
else do else do
-- modifyTVar (dcbBusy dcb) pred -- modifyTVar (dcbBusy dcb) pred
modifyTVar wip (HPSQ.delete hx) modifyTVar wip (HPSQ.delete hx)
onBlock hx
bs <- ContT $ withAsync $ forever do bs <- ContT $ withAsync $ forever do
pause @'Seconds 10 pause @'Seconds 10