From 4b5d366e107a463979f7ddc92702a12e0109d05b Mon Sep 17 00:00:00 2001
From: yedf2 <120050102@qq.com>
Date: Fri, 24 Dec 2021 20:20:12 +0800
Subject: [PATCH] grpc request log ok

---
 dtmgrpc/dtmgimp/types.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/dtmgrpc/dtmgimp/types.go b/dtmgrpc/dtmgimp/types.go
index 31f0bf9..594c6c9 100644
--- a/dtmgrpc/dtmgimp/types.go
+++ b/dtmgrpc/dtmgimp/types.go
@@ -9,6 +9,7 @@ package dtmgimp
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"github.com/yedf/dtm/dtmcli"
 	"github.com/yedf/dtm/dtmcli/dtmimp"
@@ -20,14 +21,16 @@ import (
 
 // GrpcServerLog 打印grpc服务端的日志
 func GrpcServerLog(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
-	logger.Debugf("grpc server handling: %s %v", info.FullMethod, req)
+	began := time.Now()
+	logger.Debugf("grpc server handling: %s %s", info.FullMethod, dtmimp.MustMarshalString(req))
 	LogDtmCtx(ctx)
 	m, err := handler(ctx, req)
-	res := fmt.Sprintf("grpc server handled: %s %v result: %v err: %v", info.FullMethod, req, m, err)
+	res := fmt.Sprintf("%2dms %v %s %s %s",
+		time.Since(began).Milliseconds(), err, info.FullMethod, dtmimp.MustMarshalString(m), dtmimp.MustMarshalString(req))
 	if err != nil {
 		logger.Errorf("%s", res)
 	} else {
-		logger.Debugf("%s", res)
+		logger.Infof("%s", res)
 	}
 	return m, err
 }