smith-cruise / tinykv-white-paper Goto Github PK

if len(rd.CommittedEntries) > 0 { 
	Kvwb := new(engine_util.WriteBatch)
        // 处理所有日志，加入到writebatch中
	for _, ent := range rd.CommittedEntries {
		Kvwb = d.applyEntry(Kvwb, ent)
		if d.stopped {
		    return
		}
	}
        // 将committedIndex和writebatch内的entry一起写入kvDB
	d.peerStorage.applyState.AppliedIndex = rd.CommittedEntries[len(rd.CommittedEntries)-1].Index
	Kvwb.SetMeta(meta.ApplyStateKey(d.regionId), d.peerStorage.applyState)
	Kvwb.WriteToDB(d.peerStorage.Engines.Kv)
}