distributed/talent-plan-tinykv
1
0
Fork 0
mirror of https://github.com/talent-plan/tinykv.git synced 2025-02-27 12:20:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix build

Browse Source 
Signed-off-by: Connor1996 <zbk602423539@gmail.com>
This commit is contained in:
Connor1996 2020-03-21 16:57:05 +08:00 committed by Connor
parent 14cf2d23bf
commit a779cddddc
1 changed files with 10 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
kv/raftstore/peer_storage.go
View File

@ -35,6 +35,9 @@ type PeerStorage struct {
region *metapb.Region region *metapb.Region
// current raft state of the peer // current raft state of the peer
raftState rspb.RaftLocalState raftState rspb.RaftLocalState
// current apply state of the peer
applyState rspb.RaftApplyState
// current snapshot state // current snapshot state
snapState snap.SnapState snapState snap.SnapState
// regionSched used to schedule task to region worker // regionSched used to schedule task to region worker
@ -244,12 +247,6 @@ func (ps *PeerStorage) validateSnap(snap *eraftpb.Snapshot) bool {
return true return true
} }
// Append the given entries to the raft log and update ps.raftState also delete log entries that will
// never be committed
func (ps *PeerStorage) Append(entries []eraftpb.Entry, raftWB *engine_util.WriteBatch) error {
// Your Code Here (2B).
}
func (ps *PeerStorage) clearMeta(kvWB, raftWB *engine_util.WriteBatch) error { func (ps *PeerStorage) clearMeta(kvWB, raftWB *engine_util.WriteBatch) error {
return ClearMeta(ps.Engines, kvWB, raftWB, ps.region.Id, ps.raftState.LastIndex) return ClearMeta(ps.Engines, kvWB, raftWB, ps.region.Id, ps.raftState.LastIndex)
} }
@ -304,18 +301,15 @@ func ClearMeta(engines *engine_util.Engines, kvWB, raftWB *engine_util.WriteBatc
return nil return nil
} }
// Apply the peer with given snapshot // Save memory states to disk.
func (ps *PeerStorage) ApplySnapshot(snapshot *eraftpb.Snapshot, kvWB *engine_util.WriteBatch, raftWB *engine_util.WriteBatch) (*ApplySnapResult, error) { // Do not modify ready in this function, this is a requirement to advance the ready object properly later.
// Hint: things need to do here including: update peer storage state like raftState and applyState, etc,
// and send RegionTaskApply task to region worker through ps.regionSched, also remenber call ps.clearMeta
// and ps.clearExtraData to delete stale data
// Your Code Here (2B).
}
/// Save memory states to disk.
/// Do not modify ready in this function, this is a requirement to advance the ready object properly later.
func (ps *PeerStorage) SaveReadyState(ready *raft.Ready) (*ApplySnapResult, error) { func (ps *PeerStorage) SaveReadyState(ready *raft.Ready) (*ApplySnapResult, error) {
// Hint: things need to do here including: update peer storage state like raftState and applyState, etc,
// When applying snapshot, send RegionTaskApply task to region worker through ps.regionSched, also remember call ps.clearMeta
// and ps.clearExtraData to delete stale data
// Your Code Here (2B). // Your Code Here (2B).
return nil, nil
} }
func (ps *PeerStorage) ClearData() { func (ps *PeerStorage) ClearData() {