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

Merge branch 'errcode' of github.com:OpenIMSDK/Open-IM-Server into errcode

Browse Source
This commit is contained in:
wangchuxiao 2023-03-13 10:22:56 +08:00
commit 0b086e19a9
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -25,6 +25,7 @@ func rpcServerInterceptor(ctx context.Context, req interface{}, info *grpc.Unary
log.NewError(operationID, info.FullMethod, "type:", fmt.Sprintf("%T", r), "panic:", r, "stack:", string(debug.Stack())) log.NewError(operationID, info.FullMethod, "type:", fmt.Sprintf("%T", r), "panic:", r, "stack:", string(debug.Stack()))
} }
}() }()
log.Info("", "rpc come here,in rpc call")
funcName := info.FullMethod funcName := info.FullMethod
md, ok := metadata.FromIncomingContext(ctx) md, ok := metadata.FromIncomingContext(ctx)
if !ok { if !ok {
@ -63,7 +64,7 @@ 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("", "rpc come here") log.Info("", "rpc come here before")
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 {
return nil return nil