From 9acb4cf2b0d0b4eefe84cc40e0156a79c7f8e1c3 Mon Sep 17 00:00:00 2001 From: Blake Mizerany Date: Sat, 23 Aug 2014 17:56:06 -0700 Subject: [PATCH] raft: move raft.nextEnts to tests --- raft2/raft.go | 7 ------- raft2/raft_test.go | 7 +++++++ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/raft2/raft.go b/raft2/raft.go index f6e466b78..170ca6cda 100644 --- a/raft2/raft.go +++ b/raft2/raft.go @@ -252,13 +252,6 @@ func (r *raft) maybeCommit() bool { return r.raftLog.maybeCommit(mci, r.Term) } -// nextEnts returns the appliable entries and updates the applied index -func (r *raft) nextEnts() (ents []Entry) { - ents = r.raftLog.nextEnts() - r.raftLog.resetNextEnts() - return ents -} - func (r *raft) reset(term int64) { r.Term = term r.lead = none diff --git a/raft2/raft_test.go b/raft2/raft_test.go index cb8071d59..511cf930f 100644 --- a/raft2/raft_test.go +++ b/raft2/raft_test.go @@ -8,6 +8,13 @@ import ( "testing" ) +// nextEnts returns the appliable entries and updates the applied index +func (r *raft) nextEnts() (ents []Entry) { + ents = r.raftLog.nextEnts() + r.raftLog.resetNextEnts() + return ents +} + type Interface interface { Step(m Message) error ReadMessages() []Message