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 16:53:14 +03:00
parent a109e9acb7
commit 23118aaea3
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -665,7 +665,7 @@ downloadDispatcher brains env = flip runContT pure do
_sizeCache <- newTVarIO ( mempty :: HashMap HashRef (Maybe Integer) ) _sizeCache <- newTVarIO ( mempty :: HashMap HashRef (Maybe Integer) )
bm <- liftIO $ newBurstMachine 2.5 256 (Just 50) 0.10 0.25 bm <- liftIO $ 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
@ -691,8 +691,8 @@ downloadDispatcher brains env = flip runContT pure do
what <- atomically $ readTQueue parseQ what <- atomically $ readTQueue parseQ
missed <- findMissedBlocks sto what missed <- findMissedBlocks sto what
now <- getTimeCoarse now <- getTimeCoarse
atomically do
for_ missed $ \hi -> do for_ missed $ \hi -> do
atomically do
dcb <- newDcbSTM now dcb <- newDcbSTM now
modifyTVar wip (HPSQ.insert hi 1.0 dcb) modifyTVar wip (HPSQ.insert hi 1.0 dcb)
@ -740,7 +740,7 @@ downloadDispatcher brains env = flip runContT pure do
if erno > 50 then do if erno > 50 then do
pause @'Seconds 60 pause @'Seconds 60
else do else do
pause @'Seconds 1.0 pause @'Seconds 1
go PChoose go PChoose
PInit hx dcb -> do PInit hx dcb -> do