Merge pull request dragonflyoss#752 from wybzju/supernode_bugfix

bugfix: the dfget will always receive fail result when change supernode
starnop · Aug 1, 2019 · b7cca13 · b7cca13
2 parents dce28dd + 45c6b67
commit b7cca13
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)