Merge pull request #1454 from 0chain/hotfix/init-queue

init queue after meta result
0chain · Apr 5, 2024 · bf55293 · bf55293
2 parents d57a542 + 3dfcba7
commit bf55293
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/zboxcore/sdk/blockdownloadworker.go b/zboxcore/sdk/blockdownloadworker.go
@@ -267,6 +267,8 @@ func AddBlockDownloadReq(ctx context.Context, req *BlockDownloadRequest, rb zbox
 		if len(req.respBuf) == 0 {
 			req.respBuf = make([]byte, int(req.numBlocks)*effectiveBlockSize)
 		}
+	} else {
+		req.respBuf = make([]byte, int(req.numBlocks)*effectiveBlockSize)
 	}
 	downloadBlockChan[req.blobber.ID] <- req
 }
diff --git a/zboxcore/sdk/downloadworker.go b/zboxcore/sdk/downloadworker.go
@@ -1244,6 +1244,7 @@ func (req *DownloadRequest) getFileMetaConsensus(fMetaResp []*fileMetaResponse)
 		return nil, fmt.Errorf("consensus_not_met")
 	}
 	req.downloadMask = foundMask
+	heap.Init(&req.downloadQueue)
 	return selected.fileref, nil
 }