From 693d8b38a972a6d1f45a706ca51b254f9d57e136 Mon Sep 17 00:00:00 2001
From: benjamin <ben@elixxir.io>
Date: Thu, 27 Oct 2022 13:16:11 -0700
Subject: [PATCH] added prints
---
cmix/nodes/registrar.go | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/cmix/nodes/registrar.go b/cmix/nodes/registrar.go
index 53ab512f7..03655c716 100644
--- a/cmix/nodes/registrar.go
+++ b/cmix/nodes/registrar.go
@@ -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")
--
GitLab