|
|
|
@ -3,11 +3,12 @@ package mw
|
|
|
|
|
import (
|
|
|
|
|
"context"
|
|
|
|
|
"fmt"
|
|
|
|
|
"github.com/OpenIMSDK/Open-IM-Server/pkg/checker"
|
|
|
|
|
"math"
|
|
|
|
|
"runtime"
|
|
|
|
|
"strings"
|
|
|
|
|
|
|
|
|
|
"github.com/OpenIMSDK/Open-IM-Server/pkg/checker"
|
|
|
|
|
|
|
|
|
|
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/constant"
|
|
|
|
|
|
|
|
|
|
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/config"
|
|
|
|
@ -31,7 +32,6 @@ func rpcString(v interface{}) string {
|
|
|
|
|
|
|
|
|
|
func RpcServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error) {
|
|
|
|
|
log.ZDebug(ctx, "rpc server req", "req", rpcString(req))
|
|
|
|
|
|
|
|
|
|
//defer func() {
|
|
|
|
|
// if r := recover(); r != nil {
|
|
|
|
|
// log.ZError(ctx, "rpc panic", nil, "FullMethod", info.FullMethod, "type:", fmt.Sprintf("%T", r), "panic:", r)
|
|
|
|
@ -145,7 +145,8 @@ func RpcServerInterceptor(ctx context.Context, req interface{}, info *grpc.Unary
|
|
|
|
|
}
|
|
|
|
|
details, err := grpcStatus.WithDetails(errInfo)
|
|
|
|
|
if err != nil {
|
|
|
|
|
panic(err)
|
|
|
|
|
log.ZWarn(ctx, "rpc server resp", err, "funcName", funcName)
|
|
|
|
|
return nil, errs.Wrap(err)
|
|
|
|
|
}
|
|
|
|
|
log.ZWarn(ctx, "rpc server resp", err, "funcName", funcName)
|
|
|
|
|
return nil, details.Err()
|
|
|
|
|