Method applyProposal

dgraph/cmd/zero/raft.go:399–488

(e raftpb.Entry)

}

func (n *node) applyProposal(e raftpb.Entry) (uint64, error) {
	x.AssertTrue(len(e.Data) > 0)

	var p pb.ZeroProposal
	key := binary.BigEndian.Uint64(e.Data[:8])
	if err := proto.Unmarshal(e.Data[8:], &p); err != nil {
		return key, err
	}
	span := trace.SpanFromContext(n.Proposals.Ctx(key))

	n.server.Lock()
	defer n.server.Unlock()

	state := n.server.state
	state.Counter = e.Index
	if len(p.Cid) > 0 {
		if len(state.Cid) > 0 {
			return key, errInvalidProposal
		}
		state.Cid = p.Cid
	}
	if p.MaxRaftId > 0 {
		if p.MaxRaftId <= state.MaxRaftId {
			return key, errInvalidProposal
		}
		state.MaxRaftId = p.MaxRaftId
		n.server.nextRaftId = x.Max(n.server.nextRaftId, p.MaxRaftId+1)
	}
	if p.SnapshotTs != nil {
		for gid, ts := range p.SnapshotTs {
			if group, ok := state.Groups[gid]; ok {
				group.SnapshotTs = x.Max(group.SnapshotTs, ts)
			}
		}
	}
	if p.Member != nil {
		if err := n.handleMemberProposal(p.Member); err != nil {
			span.AddEvent(fmt.Sprintf("While applying membership proposal: %+v", err))
			glog.Errorf("While applying membership proposal: %+v", err)
			return key, err
		}
	}
	if p.Tablet != nil {
		if err := n.handleTabletProposal(p.Tablet); err != nil {
			span.AddEvent(fmt.Sprintf("While applying tablet proposal: %v", err))
			glog.Errorf("While applying tablet proposal: %v", err)
			return key, err
		}
	}

	if len(p.Tablets) > 0 {
		if err := n.handleBulkTabletProposal(p.Tablets); err != nil {
			span.AddEvent(fmt.Sprintf("While applying bulk tablet proposal: %v", err))
			glog.Errorf("While applying bulk tablet proposal: %v", err)
			return key, err
		}
	}