From 1642e11045fb24f20a288ff5dd78e531c3e5687c Mon Sep 17 00:00:00 2001
From: benjamin <ben@elixxir.io>
Date: Thu, 27 Oct 2022 13:13:44 -0700
Subject: [PATCH] added prints
---
cmix/nodes/registrar.go | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/cmix/nodes/registrar.go b/cmix/nodes/registrar.go
index 090d44093..53ab512f7 100644
--- a/cmix/nodes/registrar.go
+++ b/cmix/nodes/registrar.go
@@ -131,6 +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)
for i := int64(0); i < numRegistrations; i++ {
select {
case r.pauser <- struct{}{}:
@@ -148,7 +149,7 @@ 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