fix:[动态配置]修复config_flow递归加读锁导致的死锁问题 (#212)

Signed-off-by: ArmstrongCN <[email protected]>

pkg/flow/configuration/config_flow.go

@@ -338,7 +338,7 @@ func (c *ConfigFileFlow) mainLoop(ctx context.Context) {
 				changedConfigFile.GetFileName())
 
 			newNotifiedVersion := changedConfigFile.GetVersion()
-			oldNotifiedVersion := c.getConfigFileNotifiedVersion(cacheKey)
+			oldNotifiedVersion := c.getConfigFileNotifiedVersion(cacheKey, true)
 
 			maxVersion := oldNotifiedVersion
 			if newNotifiedVersion > oldNotifiedVersion {
@@ -384,7 +384,7 @@ func (c *ConfigFileFlow) assembleWatchConfigFiles() []*configconnector.ConfigFil
 			Namespace: configFileMetadata.GetNamespace(),
 			FileGroup: configFileMetadata.GetFileGroup(),
 			FileName:  configFileMetadata.GetFileName(),
-			Version:   c.getConfigFileNotifiedVersion(cacheKey),
+			Version:   c.getConfigFileNotifiedVersion(cacheKey, false),
 		})
 	}
 
@@ -397,9 +397,11 @@ func (c *ConfigFileFlow) updateNotifiedVersion(cacheKey string, version uint64)
 	c.notifiedVersion[cacheKey] = version
 }
 
-func (c *ConfigFileFlow) getConfigFileNotifiedVersion(cacheKey string) uint64 {
-	c.fclock.RLock()
-	defer c.fclock.RUnlock()
+func (c *ConfigFileFlow) getConfigFileNotifiedVersion(cacheKey string, locking bool) uint64 {
+	if locking {
+		c.fclock.RLock()
+		defer c.fclock.RUnlock()
+	}
 	version, ok := c.notifiedVersion[cacheKey]
 	if !ok {
 		version = initVersion