Fix commit log index update.

2013-05-10 21:54:25 -06:00 · 2013-05-10 21:54:25 -06:00 · 49f3a13fbc
parent 2efa6b4107
commit 49f3a13fbc
2 changed files with 4 additions and 4 deletions
--- a/append_entries.go
+++ b/append_entries.go
@ -48,6 +48,6 @@ func NewAppendEntriesResponse(term uint64, success bool, commitIndex uint64) *Ap
 	return &AppendEntriesResponse{
 		Term:           term,
 		Success:        success,
-		CommitIndex: commitIndex,
+		CommitIndex:    commitIndex,
 	}
 }
--- a/peer.go
+++ b/peer.go
@ -146,9 +146,9 @@ func (p *Peer) sendFlushRequest(req *AppendEntriesRequest, handler func(*Server,
 		// problem.
 		if p.prevLogIndex > 0 {
 			p.prevLogIndex--
-			if resp.CommitIndex > p.prevLogIndex {
-				p.prevLogIndex = resp.CommitIndex
-			}
+		}
+		if resp.CommitIndex > p.prevLogIndex {
+			p.prevLogIndex = resp.CommitIndex
 		}
 	}