blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-24 02:16:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

zap

Browse Source
This commit is contained in:
wangchuxiao 2023-03-14 17:51:11 +08:00
parent 5c6141d0e6
commit 5310f60422
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/common/log/zap.go
View File

@ -86,7 +86,7 @@ func (l *ZapLogger) cores() (zap.Option, error) {
c.EncodeTime = zapcore.ISO8601TimeEncoder c.EncodeTime = zapcore.ISO8601TimeEncoder
c.EncodeDuration = zapcore.SecondsDurationEncoder c.EncodeDuration = zapcore.SecondsDurationEncoder
c.EncodeLevel = zapcore.LowercaseColorLevelEncoder c.EncodeLevel = zapcore.LowercaseColorLevelEncoder
fileEncoder := zapcore.NewConsoleEncoder(c) fileEncoder := zapcore.NewJSONEncoder(c)
fileEncoder.AddInt("PID", os.Getpid()) fileEncoder.AddInt("PID", os.Getpid())
writer, err := l.getWriter() writer, err := l.getWriter()
if err != nil { if err != nil {

7
pkg/common/mw/rpc.go
View File

@ -35,7 +35,6 @@ func rpcServerInterceptor(ctx context.Context, req interface{}, info *grpc.Unary
log.ZError(ctx, "rpc panic", nil, "FullMethod", info.FullMethod, "type:", fmt.Sprintf("%T", r), "panic:", r, string(debug.Stack())) log.ZError(ctx, "rpc panic", nil, "FullMethod", info.FullMethod, "type:", fmt.Sprintf("%T", r), "panic:", r, string(debug.Stack()))
} }
}() }()
log.Info("", "rpc come here,in rpc call")
funcName := info.FullMethod funcName := info.FullMethod
log.ZInfo(ctx, "rpc req", "funcName", funcName, "req", rpcString(req)) log.ZInfo(ctx, "rpc req", "funcName", funcName, "req", rpcString(req))
md, ok := metadata.FromIncomingContext(ctx) md, ok := metadata.FromIncomingContext(ctx)
@ -89,6 +88,7 @@ func rpcClientInterceptor(ctx context.Context, method string, req, reply interfa
if ctx == nil { if ctx == nil {
return errs.ErrInternalServer.Wrap("call rpc request context is nil") return errs.ErrInternalServer.Wrap("call rpc request context is nil")
} }
log.ZInfo(ctx, "rpc input", "req", req)
operationID, ok := ctx.Value(constant.OperationID).(string) operationID, ok := ctx.Value(constant.OperationID).(string)
if !ok { if !ok {
log.ZError(ctx, "ctx missing operationID", errors.New("ctx missing operationID")) log.ZError(ctx, "ctx missing operationID", errors.New("ctx missing operationID"))
@ -99,13 +99,12 @@ func rpcClientInterceptor(ctx context.Context, method string, req, reply interfa
if ok { if ok {
md.Append(constant.OpUserID, opUserID) md.Append(constant.OpUserID, opUserID)
} }
log.Info(operationID, "OpUserID", "RPC", method, "Req", rpcString(req))
err = invoker(metadata.NewOutgoingContext(ctx, md), method, req, reply, cc, opts...) err = invoker(metadata.NewOutgoingContext(ctx, md), method, req, reply, cc, opts...)
if err == nil { if err == nil {
log.Info(operationID, "Resp", rpcString(reply)) log.ZInfo(ctx, "rpc return", "resp", rpcString(reply))
return nil return nil
} }
log.Info(operationID, "rpc error:", err.Error()) log.ZError(ctx, "rpc result error:", err)
rpcErr, ok := err.(interface{ GRPCStatus() *status.Status }) rpcErr, ok := err.(interface{ GRPCStatus() *status.Status })
if !ok { if !ok {
return errs.ErrInternalServer.Wrap(err.Error()) return errs.ErrInternalServer.Wrap(err.Error())