Skip to content
Snippets Groups Projects
Commit 455ec49d authored by Xin.Zh's avatar Xin.Zh Committed by GitHub
Browse files

Merge pull request #1034 from lin-jianjun/1.5

远程调用次数变量读取未使用原子操作
parents 52e4c97e e9616977
No related branches found
No related tags found
No related merge requests found
......@@ -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")
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment