Skip to content
Snippets Groups Projects
Unverified Commit c2256e66 authored by Manish R Jain's avatar Manish R Jain
Browse files

Return error if raft isn't initialized yet. But, save a panic.

parent eb3f8991
No related branches found
No related tags found
No related merge requests found
......@@ -176,6 +176,10 @@ func (h *header) Decode(in []byte) {
}
func (n *node) ProposeAndWait(ctx context.Context, proposal *task.Proposal) error {
if n.raft == nil {
return x.Errorf("RAFT isn't initialized yet")
}
proposal.Id = rand.Uint32()
proposalData, err := proposal.Marshal()
if err != nil {
......
......@@ -267,8 +267,9 @@ func (g *groupi) syncMemberships() {
}
zero := g.Node(0)
x.AssertTruef(zero != nil, "Expected node 0")
x.Check(zero.ProposeAndWait(zero.ctx, &task.Proposal{Membership: mm}))
if err := zero.ProposeAndWait(zero.ctx, &task.Proposal{Membership: mm}); err != nil {
x.TraceError(g.ctx, err)
}
}(rc, n.AmLeader())
}
return
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment