diff --git a/kv/raftstore/peer_storage.go b/kv/raftstore/peer_storage.go index cd8c9594..aa79b3a2 100644 --- a/kv/raftstore/peer_storage.go +++ b/kv/raftstore/peer_storage.go @@ -34,9 +34,9 @@ type PeerStorage struct { // current region information of the peer region *metapb.Region // current raft state of the peer - raftState rspb.RaftLocalState + raftState *rspb.RaftLocalState // current apply state of the peer - applyState rspb.RaftApplyState + applyState *rspb.RaftApplyState // current snapshot state snapState snap.SnapState @@ -69,8 +69,8 @@ func NewPeerStorage(engines *engine_util.Engines, region *metapb.Region, regionS Engines: engines, region: region, Tag: tag, - raftState: *raftState, - applyState: *applyState, + raftState: raftState, + applyState: applyState, regionSched: regionSched, }, nil } diff --git a/kv/raftstore/peer_storage_test.go b/kv/raftstore/peer_storage_test.go index f892ae55..790db157 100644 --- a/kv/raftstore/peer_storage_test.go +++ b/kv/raftstore/peer_storage_test.go @@ -37,7 +37,7 @@ func newTestPeerStorageFromEnts(t *testing.T, ents []eraftpb.Entry) *PeerStorage Term: ents[0].Term, } applyState.AppliedIndex = ents[len(ents)-1].Index - kvWB.SetMeta(meta.ApplyStateKey(peerStore.region.GetId()), &applyState) + kvWB.SetMeta(meta.ApplyStateKey(peerStore.region.GetId()), applyState) require.Nil(t, peerStore.Engines.WriteRaft(raftWB)) peerStore.Engines.WriteKV(kvWB) return peerStore @@ -86,7 +86,7 @@ func TestPeerStorageTerm(t *testing.T) { func appendEnts(t *testing.T, peerStore *PeerStorage, ents []eraftpb.Entry) { raftWB := new(engine_util.WriteBatch) require.Nil(t, peerStore.Append(ents, raftWB)) - raftWB.SetMeta(meta.RaftStateKey(peerStore.region.GetId()), &peerStore.raftState) + raftWB.SetMeta(meta.RaftStateKey(peerStore.region.GetId()), peerStore.raftState) require.Nil(t, peerStore.Engines.WriteRaft(raftWB)) }