From 2c31f35ce23e5f253f6ee2dbeb081c38dbb4f3e8 Mon Sep 17 00:00:00 2001 From: sunwp <244372610@qq.com> Date: Mon, 24 Jan 2022 17:38:42 +0800 Subject: [PATCH] add cdn get piece tasks result logs (#1019) Signed-off-by: sunwp <244372610@qq.com> --- cdn/rpcserver/rpcserver.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/cdn/rpcserver/rpcserver.go b/cdn/rpcserver/rpcserver.go index f7a571c91..1c71fcb78 100644 --- a/cdn/rpcserver/rpcserver.go +++ b/cdn/rpcserver/rpcserver.go @@ -170,9 +170,14 @@ func (css *Server) GetPieceTasks(ctx context.Context, req *base.PieceTaskRequest if r := recover(); r != nil { err = dferrors.Newf(base.Code_UnknownError, "get task(%s) piece tasks encounter an panic: %v", req.TaskId, r) 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) seedTask, err := css.service.GetSeedTask(req.TaskId)