Skip to content
Snippets Groups Projects
Commit c2fb2b8e authored by Jono Wenger's avatar Jono Wenger
Browse files

Merge remote-tracking branch 'origin/controlNodeReg' into controlNodeReg

parents cb44c7b2 035668cb
No related branches found
No related tags found
2 merge requests!510Release,!432Control node reg
...@@ -148,7 +148,7 @@ func (r *registrar) ChangeNumberOfNodeRegistrations(toRun int, ...@@ -148,7 +148,7 @@ func (r *registrar) ChangeNumberOfNodeRegistrations(toRun int,
defer timer.Stop() defer timer.Stop()
if numRunning < toRun { if numRunning < toRun {
jww.INFO.Printf("ChangeNumberOfNodeRegistrations(%d) Reducing number "+ jww.INFO.Printf("ChangeNumberOfNodeRegistrations(%d) Reducing number "+
"of node registrations from %d to %d", numRunning, toRun) "of node registrations from %d to %d", toRun, numRunning, toRun)
for i := 0; i < toRun-numRunning; i++ { for i := 0; i < toRun-numRunning; i++ {
select { select {
case r.pauser <- struct{}{}: case r.pauser <- struct{}{}:
...@@ -158,7 +158,7 @@ func (r *registrar) ChangeNumberOfNodeRegistrations(toRun int, ...@@ -158,7 +158,7 @@ func (r *registrar) ChangeNumberOfNodeRegistrations(toRun int,
} }
} else if numRunning > toRun { } else if numRunning > toRun {
jww.INFO.Printf("ChangeNumberOfNodeRegistrations(%d) Increasing number "+ jww.INFO.Printf("ChangeNumberOfNodeRegistrations(%d) Increasing number "+
"of node registrations from %d to %d", numRunning, toRun) "of node registrations from %d to %d", toRun, numRunning, toRun)
for i := 0; i < toRun-numRunning; i++ { for i := 0; i < toRun-numRunning; i++ {
select { select {
case r.resumer <- struct{}{}: case r.resumer <- struct{}{}:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment