Merge pull request #553 from ahfa92/main

caffeinated92 · web-flow · commit 7cb382fc7e2e · 2024-04-08T17:36:01.000+07:00
Remove lock from initiation
diff --git a/cluster/cluster.go b/cluster/cluster.go
@@ -487,11 +487,6 @@ func (cluster *Cluster) initOrchetratorNodes() {
 		return
 	}
 	cluster.inInitNodes = true
-	cluster.Lock()
-	defer func() {
-		cluster.inInitNodes = false
-		cluster.Unlock()
-	}()
 
 	//defer cluster.insideInitNodes = false
 	//cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModGeneral,LvlInfo, "Loading nodes from orchestrator %s", cluster.Conf.ProvOrchestrator)
@@ -511,6 +506,7 @@ func (cluster *Cluster) initOrchetratorNodes() {
 	}
 
 	cluster.SetAgentsCpuCoreMem()
+	cluster.inInitNodes = false
 
 }
 

Original file line number	Diff line number	Diff line change
`@@ -487,11 +487,6 @@ func (cluster *Cluster) initOrchetratorNodes() {`
`487`	`487`	`return`
`488`	`488`	`}`
`489`	`489`	`cluster.inInitNodes = true`
`490`		`- cluster.Lock()`
`491`		`- defer func() {`
`492`		`- cluster.inInitNodes = false`
`493`		`- cluster.Unlock()`
`494`		`- }()`
`495`	`490`
`496`	`491`	`//defer cluster.insideInitNodes = false`
`497`	`492`	`//cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModGeneral,LvlInfo, "Loading nodes from orchestrator %s", cluster.Conf.ProvOrchestrator)`
`@@ -511,6 +506,7 @@ func (cluster *Cluster) initOrchetratorNodes() {`
`511`	`506`	`}`
`512`	`507`
`513`	`508`	`cluster.SetAgentsCpuCoreMem()`
	`509`	`+ cluster.inInitNodes = false`
`514`	`510`
`515`	`511`	`}`
`516`	`512`