Merge pull request #1519 from namewxt1220/master

修复bug或优化，对已经下载完成的片，客户端再次获得supernode调度后，上报当前片成功的状态。
dragonflyoss · Jan 5, 2021 · 73b11eb · 73b11eb
2 parents 011e011 + d342b03
commit 73b11eb
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/dfget/core/downloader/p2p_downloader/p2p_downloader.go b/dfget/core/downloader/p2p_downloader/p2p_downloader.go
@@ -459,13 +459,9 @@ func (p2p *P2PDownloader) processPiece(response *types.PullPieceTaskResponse,
 		v, ok := p2p.pieceSet[pieceRange]
 		if ok && v {
 			alreadyDownload = append(alreadyDownload, pieceRange)
-			p2p.queue.Put(NewPiece(p2p.taskID,
-				p2p.node,
-				pieceTask.Cid,
-				pieceRange,
-				constants.ResultSemiSuc,
-				constants.TaskStatusRunning,
-				p2p.RegisterResult.CDNSource))
+			alreadyDownloadedPiece := NewPiece(p2p.taskID, p2p.node, pieceTask.Cid, pieceRange, constants.ResultSemiSuc, constants.TaskStatusRunning, p2p.RegisterResult.CDNSource)
+			p2p.queue.Put(alreadyDownloadedPiece)
+			go sendSuccessPiece(p2p.API, p2p.cfg.RV.Cid, alreadyDownloadedPiece, 0, p2p.notifyQueue)
 			continue
 		}
 		if !ok {