distributed/talent-plan-tinykv
1
0
Fork 0
mirror of https://github.com/talent-plan/tinykv.git synced 2025-03-28 21:10:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix #225 (#227)

Browse Source 
Co-authored-by: NingLin-P <linningde25@gmail.com>
This commit is contained in:
何卓然 2020-12-30 13:24:03 +08:00 committed by GitHub
parent d70b4d2560
commit 5e493b7bb9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
kv/raftstore/peer_storage_test.go
View File

@ -15,7 +15,8 @@ import (
"github.com/stretchr/testify/require"
)
func newTestPeerStorage(t *testing.T) *PeerStorage {
// NewPeerStorageFromZero generates a PeerStorage whose Term & index starts at zero, instead of 5
func NewPeerStorageFromZero(t *testing.T) *PeerStorage {
engines := util.NewTestEngines()
err := BootstrapStore(engines, 1, 1)
require.Nil(t, err)
@ -23,11 +24,17 @@ func newTestPeerStorage(t *testing.T) *PeerStorage {
require.Nil(t, err)
peerStore, err := NewPeerStorage(engines, region, nil, "")
require.Nil(t, err)
peerStore.raftState = &rspb.RaftLocalState{}
peerStore.raftState.HardState = &eraftpb.HardState{}
peerStore.applyState = &rspb.RaftApplyState{}
peerStore.applyState.TruncatedState = &rspb.RaftTruncatedState{}
return peerStore
}
func newTestPeerStorageFromEnts(t *testing.T, ents []eraftpb.Entry) *PeerStorage {
peerStore := newTestPeerStorage(t)
peerStore := NewPeerStorageFromZero(t)
kvWB := new(engine_util.WriteBatch)
raftWB := new(engine_util.WriteBatch)
require.Nil(t, peerStore.Append(ents[1:], raftWB))