Skip to content

Commit 18cff92

Browse files
author
lamai93
committed
Don't updated the agency if not required. This may overwrites changes made by the user.
1 parent 93a8661 commit 18cff92

File tree

1 file changed

+12
-4
lines changed

1 file changed

+12
-4
lines changed

pkg/deployment/cluster_scaling_integration.go

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -192,11 +192,19 @@ func (ci *clusterScalingIntegration) updateClusterServerCount(ctx context.Contex
192192
}
193193
coordinatorCount := spec.Coordinators.GetCount()
194194
dbserverCount := spec.DBServers.GetCount()
195-
if err := arangod.SetNumberOfServers(ctx, c.Connection(), coordinatorCount, dbserverCount); err != nil {
196-
if expectSuccess {
197-
log.Debug().Err(err).Msg("Failed to set number of servers")
195+
196+
ci.lastNumberOfServers.mutex.Lock()
197+
lastNumberOfServers := ci.lastNumberOfServers.NumberOfServers
198+
ci.lastNumberOfServers.mutex.Unlock()
199+
200+
// This is to prevent unneseccary updates that may override some values written by the WebUI (in the case of a update loop)
201+
if coordinatorCount != lastNumberOfServers.GetCoordinators() && dbserverCount != lastNumberOfServers.GetDBServers() {
202+
if err := arangod.SetNumberOfServers(ctx, c.Connection(), coordinatorCount, dbserverCount); err != nil {
203+
if expectSuccess {
204+
log.Debug().Err(err).Msg("Failed to set number of servers")
205+
}
206+
return false, maskAny(err)
198207
}
199-
return false, maskAny(err)
200208
}
201209

202210
// Success, now update internal state

0 commit comments

Comments
 (0)