Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

rafthttp: Panic informatively when removing unknown peer ID

Browse Source
This commit is contained in:
Amit Gupta 2015-02-11 18:37:02 -08:00
parent a71184424a
commit 317e57a8a8
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rafthttp/transport.go
View File

@ -132,7 +132,11 @@ func (t *transport) AddPeer(id types.ID, urls []string) {
func (t *transport) RemovePeer(id types.ID) { func (t *transport) RemovePeer(id types.ID) {
t.mu.Lock() t.mu.Lock()
defer t.mu.Unlock() defer t.mu.Unlock()
t.peers[id].Stop() if peer, ok := t.peers[id]; ok {
peer.Stop()
} else {
log.Panicf("rafthttp: unexpected removal of unknown peer '%d'", id)
}
delete(t.peers, id) delete(t.peers, id)
delete(t.leaderStats.Followers, id.String()) delete(t.leaderStats.Followers, id.String())
} }