dragonflyoss
/
dragonfly
mirror of https://github.com/dragonflyoss/dragonfly.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add cdn get piece tasks result logs (#1019) 

Signed-off-by: sunwp <244372610@qq.com>
This commit is contained in:
sunwp 2022-01-24 17:38:42 +08:00 committed by Gaius
parent 23021dea4b
commit 2c31f35ce2
No known key found for this signature in database
GPG Key ID: 8B4E5D1290FA2FFB
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cdn/rpcserver/rpcserver.go
View File

@ -170,9 +170,14 @@ func (css *Server) GetPieceTasks(ctx context.Context, req *base.PieceTaskRequest
if r := recover(); r != nil { if r := recover(); r != nil {
err = dferrors.Newf(base.Code_UnknownError, "get task(%s) piece tasks encounter an panic: %v", req.TaskId, r) err = dferrors.Newf(base.Code_UnknownError, "get task(%s) piece tasks encounter an panic: %v", req.TaskId, r)
span.RecordError(err) span.RecordError(err)
logger.WithTaskID(req.TaskId).Errorf("get piece tasks failed: %v", err)
} }
logger.WithTaskID(req.TaskId).Infof("get piece tasks result success: %t", err == nil) if err != nil {
logger.WithTaskID(req.TaskId).Errorf("get piece tasks failed: %v", err)
} else {
logger.WithTaskID(req.TaskId).Infof("get piece tasks success, availablePieceCount(%d), totalPieceCount(%d), pieceMd5Sign(%s), "+
"contentLength(%d)", len(piecePacket.PieceInfos), piecePacket.TotalPiece, piecePacket.PieceMd5Sign, piecePacket.ContentLength)
}
}() }()
logger.Infof("get piece tasks: %#v", req) logger.Infof("get piece tasks: %#v", req)
seedTask, err := css.service.GetSeedTask(req.TaskId) seedTask, err := css.service.GetSeedTask(req.TaskId)