From b5a4ccb4c247a98d6f2650ce56bd73ed9ae449f8 Mon Sep 17 00:00:00 2001 From: Nate Maninger Date: Tue, 12 Mar 2024 22:22:23 -0700 Subject: [PATCH] increase lookahead --- renterd/downloader/downloader.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/renterd/downloader/downloader.go b/renterd/downloader/downloader.go index 9a935db..d3f6d00 100644 --- a/renterd/downloader/downloader.go +++ b/renterd/downloader/downloader.go @@ -151,15 +151,15 @@ func (bd *BlockDownloader) downloadBlockData(ctx context.Context, c cid.Cid, buc func (bd *BlockDownloader) queueRelated(c cid.Cid) { log := bd.log.Named("queueRelated").With(zap.Stringer("cid", c)) - siblings, err := bd.store.BlockSiblings(c, 10) + siblings, err := bd.store.BlockSiblings(c, 64) if err != nil { log.Error("failed to get block siblings", zap.Error(err)) return } - children, err := bd.store.BlockChildren(c, 10) + children, err := bd.store.BlockChildren(c, 64) if err != nil { - log.Error("failed to get block siblings", zap.Error(err)) + log.Error("failed to get block children", zap.Error(err)) return } @@ -174,7 +174,7 @@ func (bd *BlockDownloader) queueRelated(c cid.Cid) { } if !bd.dataCache.Contains(cidKey(sibling)) { - if _, ok := bd.queueBlock(sibling, bucket, key, downloadPriorityLow); ok { + if _, ok := bd.queueBlock(sibling, bucket, key, downloadPriorityMedium); ok { log.Debug("queued sibling", zap.Stringer("sibling", sibling)) } }