Revert "faster-download-start"

This reverts commit 351ac97d44.
This commit is contained in:
Dmitry Zuikov 2023-10-20 21:28:18 +03:00
parent 1623b5b1a4
commit 66ce6a659d
4 changed files with 8 additions and 8 deletions

View File

@ -55,7 +55,7 @@ defBlockSizeCacheTime :: TimeSpec
defBlockSizeCacheTime = toTimeSpec ( 30 :: Timeout 'Seconds )
defRequestLimitSec :: Timeout 'Seconds
defRequestLimitSec = 10 -- 300
defRequestLimitSec = 300
defBlockBanTime :: TimeSpec
defBlockBanTime = toTimeSpec defBlockBanTimeSec
@ -70,7 +70,7 @@ defBlockWipTimeout :: TimeSpec
defBlockWipTimeout = defCookieTimeout
defBlockInfoTimeout :: Timeout 'Seconds
defBlockInfoTimeout = 1
defBlockInfoTimeout = 20
defBlockInfoTimeoutSpec :: TimeSpec
defBlockInfoTimeoutSpec = toTimeSpec defBlockInfoTimeout

View File

@ -72,7 +72,7 @@ instance HasProtocol L4Proto (BlockInfo L4Proto) where
-- FIXME: requestMinPeriod-breaks-fast-block-download
--
requestPeriodLim = ReqLimPerMessage 0.5
requestPeriodLim = ReqLimPerMessage 1
instance HasProtocol L4Proto (BlockChunks L4Proto) where
type instance ProtocolId (BlockChunks L4Proto) = 2
@ -116,7 +116,7 @@ instance HasProtocol L4Proto (RefLogUpdate L4Proto) where
encode = serialise
-- TODO: find-out-optimal-max-safe-frequency
requestPeriodLim = ReqLimPerMessage 60
requestPeriodLim = ReqLimPerMessage 600
instance HasProtocol L4Proto (RefLogRequest L4Proto) where
type instance ProtocolId (RefLogRequest L4Proto) = 8
@ -148,7 +148,7 @@ instance HasProtocol L4Proto (EncryptionHandshake L4Proto) where
decode = deserialiseCustom
encode = serialise
requestPeriodLim = ReqLimPerProto 0.1
requestPeriodLim = ReqLimPerProto 0.5
instance HasProtocol L4Proto (RefChanUpdate L4Proto) where

View File

@ -514,7 +514,6 @@ blockDownloadLoop env0 = do
wipNum <- asks (view blockInQ) >>= liftIO . readTVarIO <&> HashMap.size
when (wipNum == 0) do
trace "NOTHING TO DOWNLOAD"
pause @'Seconds 1
next
@ -528,7 +527,7 @@ blockDownloadLoop env0 = do
pure $ not busy
when (List.null pips) do
void $ liftIO $ race (pause @'Seconds 1) $ do
void $ liftIO $ race (pause @'Seconds 5) $ do
trace "ALL PEERS BUSY"
void $ liftIO $ atomically $ do
p <- readTQueue released
@ -570,7 +569,7 @@ blockDownloadLoop env0 = do
liftIO $ atomically $ modifyTVar downMiss succ
Right (Just size) -> do
trace $ "BLOCK SIZE" <+> pretty p <+> pretty h <+> pretty size
-- trace $ "BLOCK SIZE" <+> pretty p <+> pretty h <+> pretty size
let downFail = view peerDownloadFail pinfo
let downBlk = view peerDownloadedBlk pinfo

View File

@ -112,6 +112,7 @@ instance ( Hashable (Peer e)
updateOP br (deleteDownload br what)
onKnownPeers br ps = do
trace $ "BRAINS: onKnownPeers" <+> pretty ps
let tv = view brainsPeers br
liftIO $ atomically $ writeTVar tv ps
updateOP br $ do