From b51ef90f2e7e01f3f4303b972e2ef88bfdc963a7 Mon Sep 17 00:00:00 2001
From: wangwx <wangwx@tuya.com>
Date: Sun, 28 Feb 2021 12:24:24 +0800
Subject: [PATCH] fix comments
---
protocol/dubbo/dubbo_invoker.go | 4 ++--
remoting/exchange_client.go | 8 ++++----
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/protocol/dubbo/dubbo_invoker.go b/protocol/dubbo/dubbo_invoker.go
index aed33a633..bc85d7303 100644
--- a/protocol/dubbo/dubbo_invoker.go
+++ b/protocol/dubbo/dubbo_invoker.go
@@ -196,9 +196,9 @@ func (di *DubboInvoker) Destroy() {
di.BaseInvoker.Destroy()
client := di.getClient()
if client != nil {
- client.DecreaseActiveNumber()
+ activeNumber := client.DecreaseActiveNumber()
di.setClient(nil)
- if client.GetActiveNumber() == 0 {
+ if activeNumber == 0 {
exchangeClientMap.Delete(di.GetUrl().Location)
client.Close()
}
diff --git a/remoting/exchange_client.go b/remoting/exchange_client.go
index e611586ef..6d57a1471 100644
--- a/remoting/exchange_client.go
+++ b/remoting/exchange_client.go
@@ -92,13 +92,13 @@ func (cl *ExchangeClient) doInit(url *common.URL) error {
}
// increase number of service using client
-func (client *ExchangeClient) IncreaseActiveNumber() {
- atomic.AddUint32(&client.activeNum, 1)
+func (client *ExchangeClient) IncreaseActiveNumber() uint32 {
+ return atomic.AddUint32(&client.activeNum, 1)
}
// decrease number of service using client
-func (client *ExchangeClient) DecreaseActiveNumber() {
- atomic.AddUint32(&client.activeNum, ^uint32(0))
+func (client *ExchangeClient) DecreaseActiveNumber() uint32 {
+ return atomic.AddUint32(&client.activeNum, ^uint32(0))
}
// get number of service using client
--
GitLab