Fixing integ test

hashicorp · Jul 17, 2014 · 35f5fa0 · 35f5fa0
1 parent 725e1d5
commit 35f5fa0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/raft.go b/raft.go
@@ -1079,7 +1079,7 @@ func (r *Raft) processLog(l *Log, future *logFuture, precommit bool) {
 		r.logger.Printf("[DEBUG] raft: Node %v updated peer set (%v): %v", r.localAddr, l.Type, peers)
 
 		// If the peer set does not include us, remove all other peers
-		removeSelf := !PeerContained(peers, r.localAddr)
+		removeSelf := !PeerContained(peers, r.localAddr) && l.Type == LogRemovePeer
 		if removeSelf {
 			r.peers = nil
 			r.peerStore.SetPeers([]net.Addr{r.localAddr})