diff --git a/protocol/dubbo/dubbo_invoker.go b/protocol/dubbo/dubbo_invoker.go index 62335c10fe3ce75d491e8425533b87d3a5c53ca0..a7ae577809d33b0c420a7ca15d33c46d63d33d3d 100644 --- a/protocol/dubbo/dubbo_invoker.go +++ b/protocol/dubbo/dubbo_invoker.go @@ -77,6 +77,7 @@ func (di *DubboInvoker) Invoke(ctx context.Context, invocation protocol.Invocati // from the invoker list before destroy,so no new request will enter the destroyed invoker logger.Warnf("this dubboInvoker is destroyed") result.Err = ErrDestroyedInvoker + return &result } atomic.AddInt64(&(di.reqNum), 1) defer atomic.AddInt64(&(di.reqNum), -1)