Merge pull request #1026 from lin-jianjun/patch-2

Update dubbo_invoker.go
apache · Feb 22, 2021 · 24e0d8c · 24e0d8c
2 parents 5c76040 + befd3e5
commit 24e0d8c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/protocol/dubbo/dubbo_invoker.go b/protocol/dubbo/dubbo_invoker.go
@@ -87,7 +87,7 @@ func (di *DubboInvoker) Invoke(ctx context.Context, invocation protocol.Invocati
 		err    error
 		result protocol.RPCResult
 	)
-	if di.reqNum < 0 {
+	if atomic.LoadInt64(di.reqNum) < 0 {
 		// Generally, the case will not happen, because the invoker has been removed
 		// from the invoker list before destroy,so no new request will enter the destroyed invoker
 		logger.Warnf("this dubboInvoker is destroyed")