From 3859297225752fc5bef4024a0471df262c50719c Mon Sep 17 00:00:00 2001 From: Yicheng Qin Date: Fri, 3 Oct 2014 15:21:10 -0700 Subject: [PATCH] etcdserver: check id match --- etcdserver/server.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/etcdserver/server.go b/etcdserver/server.go index bb0e533fd..aed6cf6c7 100644 --- a/etcdserver/server.go +++ b/etcdserver/server.go @@ -530,6 +530,9 @@ func (s *EtcdServer) applyConfChange(cc raftpb.ConfChange) { if err := json.Unmarshal(cc.Context, &m); err != nil { panic("unexpected unmarshal error") } + if cc.NodeID != m.ID { + panic("unmatch node id") + } s.ClusterStore.Create(m) case raftpb.ConfChangeRemoveNode: s.ClusterStore.Delete(cc.NodeID)