From 88dabade14e8b3b6ca8092974e69c4f8691e2cfe Mon Sep 17 00:00:00 2001
From: Benjamin Wenger <ben@elixxir.ioo>
Date: Thu, 23 Jun 2022 12:33:06 -0700
Subject: [PATCH] fixed a bug in e2e crititcal messages
---
cmix/client.go | 6 +++---
e2e/critical.go | 1 +
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/cmix/client.go b/cmix/client.go
index 59640e2b0..a06e21f4d 100644
--- a/cmix/client.go
+++ b/cmix/client.go
@@ -117,14 +117,14 @@ func NewClient(params Params, comms *commClient.Comms, session storage.Session,
c.Handler = message.NewHandler(c.param.Message, c.session.GetKV(),
c.events, c.session.GetReceptionID())
- err := c.connect(session.GetNDF())
+ err := c.initialize(session.GetNDF())
return c, err
}
-// connect turns on network handlers, initializing a host pool and
+// initialize turns on network handlers, initializing a host pool and
// network health monitors. This should be called before
// network Follow command is called.
-func (c *client) connect(ndf *ndf.NetworkDefinition) error {
+func (c *client) initialize(ndf *ndf.NetworkDefinition) error {
// Start network instance
instance, err := commNetwork.NewInstance(
c.comms.ProtoComms, ndf, nil, nil, commNetwork.None,
diff --git a/e2e/critical.go b/e2e/critical.go
index a60577541..9a803886f 100644
--- a/e2e/critical.go
+++ b/e2e/critical.go
@@ -53,6 +53,7 @@ func newCritical(kv *versioned.KV, hm func(f func(bool)) uint64,
E2eMessageBuffer: cm,
trigger: make(chan bool, 100),
send: send,
+ healthcb: hm,
}
return c
--
GitLab