add lock (apache#1304)

chans-open-source · Jul 29, 2021 · 55d711f · 55d711f
1 parent 2f47462
commit 55d711f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/config/config_loader.go b/config/config_loader.go
@@ -441,6 +441,8 @@ func GetApplicationConfig() *ApplicationConfig {
 // if not found, create new one
 func GetProviderConfig() ProviderConfig {
 	if providerConfig == nil {
+		configAccessMutex.Lock()
+		defer configAccessMutex.Unlock()
 		if providerConfig == nil {
 			return ProviderConfig{}
 		}
@@ -455,6 +457,8 @@ func GetProviderConfig() ProviderConfig {
 // So you don't need to worry about the race condition
 func GetConsumerConfig() ConsumerConfig {
 	if consumerConfig == nil {
+		configAccessMutex.Lock()
+		defer configAccessMutex.Unlock()
 		if consumerConfig == nil {
 			return ConsumerConfig{}
 		}