diff --git a/cmix/client.go b/cmix/client.go index 59640e2b0614b19d17afab771e69a50e0b0bfd43..a06e21f4d3a1c94e492a81ddd7bed6679a1547f9 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 a605775419c8e2181e3d22eb3f984fed7a05bf3e..9a803886ff81faeded4e546a8462af9e78c73dc9 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