diff --git a/zrpc/internal/serverinterceptors/statinterceptor.go b/zrpc/internal/serverinterceptors/statinterceptor.go index a921897e..52700d3a 100644 --- a/zrpc/internal/serverinterceptors/statinterceptor.go +++ b/zrpc/internal/serverinterceptors/statinterceptor.go @@ -26,10 +26,7 @@ func SetSlowThreshold(threshold time.Duration) { func UnaryStatInterceptor(metrics *stat.Metrics) grpc.UnaryServerInterceptor { return func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error) { - defer handleCrash(func(r interface{}) { - err = toPanicError(r) - }) - + startTime := timex.Now() defer func() { duration := timex.Since(startTime) diff --git a/zrpc/internal/serverinterceptors/statinterceptor_test.go b/zrpc/internal/serverinterceptors/statinterceptor_test.go index e3e3f424..b9a4706c 100644 --- a/zrpc/internal/serverinterceptors/statinterceptor_test.go +++ b/zrpc/internal/serverinterceptors/statinterceptor_test.go @@ -30,17 +30,6 @@ func TestUnaryStatInterceptor(t *testing.T) { assert.Nil(t, err) } -func TestUnaryStatInterceptor_crash(t *testing.T) { - metrics := stat.NewMetrics("mock") - interceptor := UnaryStatInterceptor(metrics) - _, err := interceptor(context.Background(), nil, &grpc.UnaryServerInfo{ - FullMethod: "/", - }, func(ctx context.Context, req interface{}) (interface{}, error) { - panic("error") - }) - assert.NotNil(t, err) -} - func TestLogDuration(t *testing.T) { addrs, err := net.InterfaceAddrs() assert.Nil(t, err)