From ed1747aba621152491037058588f475ac374678b Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Tue, 18 Jul 2023 14:32:45 +0800 Subject: [PATCH] debug: print stack --- internal/push/push_to_client.go | 3 +++ pkg/common/mw/rpc_client_interceptor.go | 2 -- pkg/common/mw/rpc_server_interceptor.go | 2 -- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/internal/push/push_to_client.go b/internal/push/push_to_client.go index 0583b453d..25fd7ff47 100644 --- a/internal/push/push_to_client.go +++ b/internal/push/push_to_client.go @@ -18,6 +18,8 @@ import ( "context" "encoding/json" "errors" + "fmt" + "runtime/debug" "github.com/OpenIMSDK/Open-IM-Server/internal/push/offlinepush" "github.com/OpenIMSDK/Open-IM-Server/internal/push/offlinepush/fcm" @@ -255,6 +257,7 @@ func (p *Pusher) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, if err != nil { return nil, err } + fmt.Println(string(debug.Stack())) // Online push message for _, v := range conns { msgClient := msggateway.NewMsgGatewayClient(v) diff --git a/pkg/common/mw/rpc_client_interceptor.go b/pkg/common/mw/rpc_client_interceptor.go index ff6396798..91a166c32 100644 --- a/pkg/common/mw/rpc_client_interceptor.go +++ b/pkg/common/mw/rpc_client_interceptor.go @@ -18,7 +18,6 @@ import ( "context" "errors" "fmt" - "runtime/debug" "strings" "google.golang.org/grpc" @@ -32,7 +31,6 @@ import ( ) func GrpcClient() grpc.DialOption { - fmt.Println("grpc client interceptor", "stack", string(debug.Stack())) return grpc.WithChainUnaryInterceptor(RpcClientInterceptor) } diff --git a/pkg/common/mw/rpc_server_interceptor.go b/pkg/common/mw/rpc_server_interceptor.go index 23eea4ee3..ec43069da 100644 --- a/pkg/common/mw/rpc_server_interceptor.go +++ b/pkg/common/mw/rpc_server_interceptor.go @@ -19,7 +19,6 @@ import ( "fmt" "math" "runtime" - "runtime/debug" "strings" "github.com/OpenIMSDK/Open-IM-Server/pkg/checker" @@ -178,6 +177,5 @@ func RpcServerInterceptor( } func GrpcServer() grpc.ServerOption { - fmt.Println("grpc server interceptor", "stack", string(debug.Stack())) return grpc.ChainUnaryInterceptor(RpcServerInterceptor) }