Skip to content
Snippets Groups Projects
Commit 88dabade authored by Benjamin Wenger's avatar Benjamin Wenger
Browse files

fixed a bug in e2e crititcal messages

parent 9b7c24df
No related branches found
No related tags found
2 merge requests!510Release,!250Hotfix/refactor connect
...@@ -117,14 +117,14 @@ func NewClient(params Params, comms *commClient.Comms, session storage.Session, ...@@ -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.Handler = message.NewHandler(c.param.Message, c.session.GetKV(),
c.events, c.session.GetReceptionID()) c.events, c.session.GetReceptionID())
err := c.connect(session.GetNDF()) err := c.initialize(session.GetNDF())
return c, err 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 health monitors. This should be called before
// network Follow command is called. // network Follow command is called.
func (c *client) connect(ndf *ndf.NetworkDefinition) error { func (c *client) initialize(ndf *ndf.NetworkDefinition) error {
// Start network instance // Start network instance
instance, err := commNetwork.NewInstance( instance, err := commNetwork.NewInstance(
c.comms.ProtoComms, ndf, nil, nil, commNetwork.None, c.comms.ProtoComms, ndf, nil, nil, commNetwork.None,
......
...@@ -53,6 +53,7 @@ func newCritical(kv *versioned.KV, hm func(f func(bool)) uint64, ...@@ -53,6 +53,7 @@ func newCritical(kv *versioned.KV, hm func(f func(bool)) uint64,
E2eMessageBuffer: cm, E2eMessageBuffer: cm,
trigger: make(chan bool, 100), trigger: make(chan bool, 100),
send: send, send: send,
healthcb: hm,
} }
return c return c
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment