diff --git a/pkg/server/manager.go b/pkg/server/manager.go index 34f6a4aa1bc6e3b4eaeacdd0e191802b94ed843a..97debe88790307d7e347273be6133707d0f1e7fe 100644 --- a/pkg/server/manager.go +++ b/pkg/server/manager.go @@ -41,6 +41,7 @@ import ( ) var lastStatus = common.NewAtomicBool(false) +var resourceVersion = "" // HwDevManager manages huawei device devices. type HwDevManager struct { @@ -1027,7 +1028,6 @@ func (hdm *HwDevManager) isSupportGraceTolerance() { } func (hdm *HwDevManager) pollFaultCodeCM(ctx context.Context) { - var resourceVersion = "" var interval = common.PollFaultCodeCMInterval for { select { @@ -1044,17 +1044,17 @@ func (hdm *HwDevManager) pollFaultCodeCM(ctx context.Context) { if err != nil { hwlog.RunLog.Debugf("cannot find '%s' configmap, reason: %v", common.FaultCodeCMName, err) initFaultInfoFromFile() - time.Sleep(time.Duration(common.PollFaultCodeCMInterval) * time.Second) + time.Sleep(time.Duration(interval) * time.Second) continue } interval = getFaultCodeCMPollInterval(configMap) - updateFaultConfigFromCm(resourceVersion, configMap) + updateFaultConfigFromCm(configMap) time.Sleep(time.Duration(interval) * time.Second) } } } -func updateFaultConfigFromCm(resourceVersion string, configMap *v1.ConfigMap) { +func updateFaultConfigFromCm(configMap *v1.ConfigMap) { if resourceVersion == configMap.ResourceVersion { return }