Skip to content
Snippets Groups Projects
Commit 693d8b38 authored by benjamin's avatar benjamin
Browse files

added prints

parent 1642e110
No related branches found
No related tags found
2 merge requests!510Release,!432Control node reg
......@@ -131,7 +131,7 @@ func (r *registrar) PauseNodeRegistrations(timeout time.Duration) error {
timer := time.NewTimer(timeout)
defer timer.Stop()
numRegistrations := atomic.LoadInt64(r.numberRunning)
jww.INFO.Printf("Stopping %d registration", numRegistrations)
jww.INFO.Printf("PauseNodeRegistrations() - Pausing %d registrations", numRegistrations)
for i := int64(0); i < numRegistrations; i++ {
select {
case r.pauser <- struct{}{}:
......@@ -149,7 +149,6 @@ func (r *registrar) ChangeNumberOfNodeRegistrations(toRun int,
r.runnerLock.Lock()
defer r.runnerLock.Unlock()
numRunning := int(atomic.LoadInt64(r.numberRunning))
jww.INFO.Printf("Stopping %d registration", numRunning)
if toRun+numRunning > r.maxRunning {
return errors.Errorf("Cannot change number of " +
"running node registration to number greater than the max")
......
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