distributed/talent-plan-tinykv
1
0
Fork 0
mirror of https://github.com/talent-plan/tinykv.git synced 2024-12-26 12:50:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

add a new interface allEntries to RaftLog (#418)

Browse Source
This commit is contained in:
niebayes 2022-08-29 11:31:40 +08:00 committed by GitHub
parent 6df022c85d
commit cfbc05df7e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
raft/log.go
View File

@ -66,6 +66,14 @@ func (l *RaftLog) maybeCompact() {
// Your Code Here (2C). // Your Code Here (2C).
} }
// allEntries return all the entries not compacted.
// note, exclude any dummy entries from the return value.
// note, this is one of the test stub functions you need to implement.
func (l *RaftLog) allEntries() []pb.Entry {
// Your Code Here (2A).
return nil
}
// unstableEntries return all the unstable entries // unstableEntries return all the unstable entries
func (l *RaftLog) unstableEntries() []pb.Entry { func (l *RaftLog) unstableEntries() []pb.Entry {
// Your Code Here (2A). // Your Code Here (2A).

2
raft/raft_paper_test.go
View File

@ -659,7 +659,7 @@ func TestFollowerAppendEntries2AB(t *testing.T) {
for _, ent := range tt.wents { for _, ent := range tt.wents {
wents = append(wents, *ent) wents = append(wents, *ent)
} }
if g := r.RaftLog.entries; !reflect.DeepEqual(g, wents) { if g := r.RaftLog.allEntries(); !reflect.DeepEqual(g, wents) {
t.Errorf("#%d: ents = %+v, want %+v", i, g, wents) t.Errorf("#%d: ents = %+v, want %+v", i, g, wents)
} }
var wunstable []pb.Entry var wunstable []pb.Entry