fix add beat info (#557)

nacos-group · Jan 12, 2023 · 475201a · 475201a
1 parent ea56886
commit 475201a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 7 deletions.
diff --git a/clients/naming_client/beat_reactor.go b/clients/naming_client/beat_reactor.go
@@ -70,8 +70,8 @@ func (br *BeatReactor) AddBeatInfo(serviceName string, beatInfo *model.BeatInfo)
 	defer br.mux.Unlock()
 	br.mux.Lock()
 	if data, ok := br.beatMap.Get(k); ok {
-		beatInfo = data.(*model.BeatInfo)
-		atomic.StoreInt32(&beatInfo.State, int32(model.StateShutdown))
+		oldBeatInfo := data.(*model.BeatInfo)
+		atomic.StoreInt32(&oldBeatInfo.State, int32(model.StateShutdown))
 		br.beatMap.Remove(k)
 	}
 	br.beatMap.Set(k, beatInfo)
@@ -111,8 +111,7 @@ func (br *BeatReactor) sendInstanceBeat(k string, beatInfo *model.BeatInfo) {
 		if err != nil {
 			logger.Errorf("beat to server return error:%+v", err)
 			br.beatThreadSemaphore.Release(1)
-			t := time.NewTimer(beatInfo.Period)
-			<-t.C
+			time.Sleep(beatInfo.Period)
 			continue
 		}
 		if beatInterval > 0 {
@@ -122,7 +121,6 @@ func (br *BeatReactor) sendInstanceBeat(k string, beatInfo *model.BeatInfo) {
 		br.beatRecordMap.Set(k, util.CurrentMillis())
 		br.beatThreadSemaphore.Release(1)
 
-		t := time.NewTimer(beatInfo.Period)
-		<-t.C
+		time.Sleep(beatInfo.Period)
 	}
 }
diff --git a/common/constant/const.go b/common/constant/const.go
@@ -66,7 +66,7 @@ const (
 	KEY_BEAT                    = "beat"
 	KEY_DOM                     = "dom"
 	DEFAULT_CONTEXT_PATH        = "/nacos"
-	CLIENT_VERSION              = "Nacos-Go-Client:v1.0.1"
+	CLIENT_VERSION              = "Nacos-Go-Client:v1.1.4"
 	REQUEST_DOMAIN_RETRY_TIME   = 3
 	SERVICE_INFO_SPLITER        = "@@"
 	CONFIG_INFO_SPLITER         = "@@"