Explorar o código

raft: fix detected race in node.go

Xiang Li %!s(int64=10) %!d(string=hai) anos
pai
achega
59c5110b73
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      raft/node.go

+ 1 - 1
raft/node.go

@@ -325,7 +325,7 @@ func (n *node) run(r *raft) {
 				// block incoming proposal when local node is
 				// block incoming proposal when local node is
 				// removed
 				// removed
 				if cc.NodeID == r.id {
 				if cc.NodeID == r.id {
-					n.propc = nil
+					propc = nil
 				}
 				}
 				r.removeNode(cc.NodeID)
 				r.removeNode(cc.NodeID)
 			case pb.ConfChangeUpdateNode:
 			case pb.ConfChangeUpdateNode: