luxolus/open-nomad
2
0
Fork 0
Code Issues 1 Pull requests Packages Releases Wiki Activity

Disable half the workers, freeing half the CPUs

Browse source
This commit is contained in:
Alex Dadgar 2016-02-17 13:50:06 -08:00
parent 9301581bb4
commit 75d7fce90c
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
nomad/leader.go
View file

@ -98,10 +98,13 @@ WAIT:
// previously inflight transactions have been commited and that our // previously inflight transactions have been commited and that our
// state is up-to-date. // state is up-to-date.
func (s *Server) establishLeadership(stopCh chan struct{}) error { func (s *Server) establishLeadership(stopCh chan struct{}) error {
// If we have multiple workers, disable one to free processing // Disable workers to free half the cores for use in the plan queue and
// for the plan queue and evaluation broker // evaluation broker
if len(s.workers) > 1 { if numWorkers := len(s.workers); numWorkers > 1 {
s.workers[0].SetPause(true) // Disabling half the workers frees half the CPUs.
for i := 0; i < numWorkers / 2; i++ {
s.workers[i].SetPause(true)
}
} }
// Enable the plan queue, since we are now the leader // Enable the plan queue, since we are now the leader
@ -363,7 +366,9 @@ func (s *Server) revokeLeadership() error {
// Unpause our worker if we paused previously // Unpause our worker if we paused previously
if len(s.workers) > 1 { if len(s.workers) > 1 {
s.workers[0].SetPause(false) for i := 0; i < len(s.workers) / 2; i++ {
s.workers[i].SetPause(false)
}
} }
return nil return nil
} }