|
@@ -155,7 +155,7 @@ func (rc *raftNode) publishEntries(ents []raftpb.Entry) bool {
|
|
|
case raftpb.EntryConfChange:
|
|
case raftpb.EntryConfChange:
|
|
|
var cc raftpb.ConfChange
|
|
var cc raftpb.ConfChange
|
|
|
cc.Unmarshal(ents[i].Data)
|
|
cc.Unmarshal(ents[i].Data)
|
|
|
- rc.node.ApplyConfChange(cc)
|
|
|
|
|
|
|
+ rc.confState = *rc.node.ApplyConfChange(cc)
|
|
|
switch cc.Type {
|
|
switch cc.Type {
|
|
|
case raftpb.ConfChangeAddNode:
|
|
case raftpb.ConfChangeAddNode:
|
|
|
if len(cc.Context) > 0 {
|
|
if len(cc.Context) > 0 {
|
Xiang Li