fix sync config problems

zouyx · Jan 18, 2020 · 953587c · 953587c
1 parent 8802f03
commit 953587c
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/component/notify/componet_notify.go b/component/notify/componet_notify.go
@@ -135,7 +135,7 @@ func SyncNamespaceConfig(namespace string) error {
 
 func syncConfigs(namespace string, isAsync bool) error {
 
-	remoteConfigs, err := notifyRemoteConfig(nil, utils.Empty, isAsync)
+	remoteConfigs, err := notifyRemoteConfig(nil, namespace, isAsync)
 
 	if err != nil {
 		return fmt.Errorf("notifySyncConfigServices: %s", err)

diff --git a/protocol/http/request.go b/protocol/http/request.go
@@ -44,10 +44,15 @@ func Request(requestURL string, connectionConfig *env.ConnectConfig, callBack *C
 	var responseBody []byte
 	var err error
 	var res *http.Response
+	var retries = maxRetries
+	if connectionConfig != nil && !connectionConfig.IsRetry {
+		retries = 1
+	}
 	for {
+
 		retry++
 
-		if retry > maxRetries {
+		if retry > retries {
 			break
 		}
 

diff --git a/repository.go b/repository.go
@@ -46,9 +46,6 @@ func GetConfigCache(namespace string) agcache.CacheInterface {
 	if config == nil {
 		return nil
 	}
-	if !config.GetIsInit() {
-		config.GetWaitInit().Wait()
-	}
 
 	return config.GetCache()
 }