bugfix: the dfget will always receive fail result when change supernode

Signed-off-by: wybzju <[email protected]>
dragonflyoss · Jul 31, 2019 · 4847085 · 4847085
1 parent 7bfa08f
commit 4847085
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/supernode/server/0.3_bridge.go b/supernode/server/0.3_bridge.go
@@ -121,9 +121,11 @@ func (s *Server) pullPieceTask(ctx context.Context, rw http.ResponseWriter, req
 	if !cutil.IsEmptyStr(dstCID) {
 		dstDfgetTask, err := s.DfgetTaskMgr.Get(ctx, dstCID, taskID)
 		if err != nil {
-			return err
+			logrus.Warnf("failed to get dfget task by dstCID(%s) and taskID(%s), and the srcCID is %s, err: %v",
+				dstCID, taskID, srcCID, err)
+		} else {
+			request.DstPID = dstDfgetTask.PeerID
 		}
-		request.DstPID = dstDfgetTask.PeerID
 	}
 
 	isFinished, data, err := s.TaskMgr.GetPieces(ctx, taskID, srcCID, request)