add missing error check

This commit is contained in:
Seebs 2019-04-09 17:10:54 -05:00
parent 302830ed60
commit fc5fc4151b

View file

@ -360,7 +360,10 @@ func (b bcast) SendTo(to *Node, m Message) error {
// Apply the send message to the node.
for _, c := range b.t.Clusters {
if c.Node.ID == to.ID {
c.mergeClusterStatus(obj)
err := c.mergeClusterStatus(obj)
if err != nil {
return err
}
}
}
b.t.mu.RLock()