From 7797ffd7dbd621746e88fae0beb677af429d818c Mon Sep 17 00:00:00 2001 From: Sydonian <794346190@qq.com> Date: Thu, 20 Jun 2024 17:13:34 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- common/pkgs/downloader/iterator.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/common/pkgs/downloader/iterator.go b/common/pkgs/downloader/iterator.go index bfa1a36..7662aa1 100644 --- a/common/pkgs/downloader/iterator.go +++ b/common/pkgs/downloader/iterator.go @@ -255,8 +255,6 @@ func (iter *DownloadObjectIterator) downloadECObject(req downloadReqeust2, ecRed StripPosition: curStripPos, } - logger.Debugf("begin read ec strip %v of object %v", curStripPos, req.Detail.Object.ObjectID) - var stripData []byte cache, ok := iter.downloader.strips.Get(cacheKey) @@ -277,6 +275,7 @@ func (iter *DownloadObjectIterator) downloadECObject(req downloadReqeust2, ecRed go iter.downloadECStrip(curStripPos, &req.Detail.Object, ecRed, rs, fileStrs, blocks, downloadStripCb) } + logger.Debugf("waitting for ec strip %v of object %v", curStripPos, req.Detail.Object.ObjectID) stripData, err = downloadStripCb.WaitValue(context.Background()) if err != nil { pw.CloseWithError(err) @@ -326,8 +325,6 @@ func (iter *DownloadObjectIterator) downloadECObject(req downloadReqeust2, ecRed } func (i *DownloadObjectIterator) downloadECStrip(stripPos int64, obj *cdssdk.Object, ecRed *cdssdk.ECRedundancy, rs *ec.Rs, blockStrs []*IPFSReader, blocks []downloadBlock, cb *future.SetValueFuture[[]byte]) { - logger.Debugf("download ec strip %v of object %v", stripPos, obj.ObjectID) - for _, str := range blockStrs { _, err := str.Seek(stripPos*int64(ecRed.ChunkSize), io.SeekStart) if err != nil {