From c3ae5e65fadafdc1e1f09364bf8e5a8f42bb2f28 Mon Sep 17 00:00:00 2001
From: benjamin <ben@elixxir.io>
Date: Thu, 20 Oct 2022 14:39:42 -0700
Subject: [PATCH] added a print denoting the number of registered nodes and
made node registeration time prints trace to make it less noisy
---
cmix/follow.go | 5 +++++
cmix/nodes/register.go | 5 ++++-
cmix/nodes/request.go | 4 ++--
3 files changed, 11 insertions(+), 3 deletions(-)
diff --git a/cmix/follow.go b/cmix/follow.go
index 7e75082ce..59e7cf7ed 100644
--- a/cmix/follow.go
+++ b/cmix/follow.go
@@ -27,6 +27,7 @@ import (
"encoding/binary"
"fmt"
"gitlab.com/elixxir/client/cmix/identity/receptionID"
+ "math/rand"
"sync"
"sync/atomic"
"time"
@@ -88,6 +89,10 @@ func (c *client) followNetwork(report ClientErrorReport,
return
case <-ticker.C:
+ if rand.Int()%6 == 0 {
+ jww.INFO.Printf("Registered with %d nodes", c.NumRegisteredNodes())
+ }
+
operator := func(toTrack []receptionID.IdentityUse) error {
// set up tracking tools
diff --git a/cmix/nodes/register.go b/cmix/nodes/register.go
index 5d2249ec6..8cada7d12 100644
--- a/cmix/nodes/register.go
+++ b/cmix/nodes/register.go
@@ -134,6 +134,8 @@ func registerWithNode(sender gateway.Sender, comms RegisterNodeCommsInterface,
var transmissionKey *cyclic.Int
var validUntil uint64
var keyId []byte
+
+ start := time.Now()
// TODO: should move this to a pre-canned user initialization
if s.IsPrecanned() {
userNum := int(s.GetTransmissionID().Bytes()[7])
@@ -156,7 +158,8 @@ func registerWithNode(sender gateway.Sender, comms RegisterNodeCommsInterface,
r.add(nodeID, transmissionKey, validUntil, keyId)
- jww.INFO.Printf("Completed registration with node %s", nodeID)
+ jww.INFO.Printf("Completed registration with node %s,"+
+ " took %d", nodeID, time.Since(start))
return nil
}
diff --git a/cmix/nodes/request.go b/cmix/nodes/request.go
index 010bf15a5..978cd01a3 100644
--- a/cmix/nodes/request.go
+++ b/cmix/nodes/request.go
@@ -81,11 +81,11 @@ func requestKey(sender gateway.Sender, comms RegisterNodeCommsInterface,
return nil, errors.WithMessage(err2,
"requestKey: clientKeyResponse error")
}
- jww.INFO.Printf("just comm reg request took %s", time.Since(startInternal))
+ jww.TRACE.Printf("just comm reg request took %s", time.Since(startInternal))
return keyResponse, nil
}, stop)
- jww.INFO.Printf("full reg request took %s", time.Since(start))
+ jww.TRACE.Printf("full reg request took %s", time.Since(start))
if err != nil {
return nil, nil, 0, err
--
GitLab