Skip to content

P
plugin
Commit 76c68c8a authored by liuyuhang's avatar liuyuhang Committed by vipwzw
Browse files
Options

modify strict true

parent 0fa36c1e
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 5 deletions
plugin/store/kvmvccmavl/kvmvccdb.go
View file @ 76c68c8a
......@@ -252,12 +252,12 @@ func (mvccs *KVMVCCStore) Del(req *types.StoreDel) ([]byte, error) {
for i := maxVersion; i >= req.Height; i-- {
hash, err := mvccs.mvcc.GetVersionHash(i)
if err != nil {
kmlog.Debug("store kvmvcc Del GetVersionHash failed", "height", i, "maxVersion", maxVersion)
kmlog.Warn("store kvmvcc Del GetVersionHash failed", "height", i, "maxVersion", maxVersion)
continue
}
kvlist, err := mvccs.mvcc.DelMVCC(hash, i, false)
kvlist, err := mvccs.mvcc.DelMVCC(hash, i, true)
if err != nil {
kmlog.Debug("store kvmvcc Del DelMVCC failed", "height", i, "err", err)
kmlog.Warn("store kvmvcc Del DelMVCC failed", "height", i, "err", err)
continue
}
kvset = append(kvset, kvlist...)
......@@ -315,12 +315,12 @@ func (mvccs *KVMVCCStore) checkVersion(height int64) ([]*types.KeyValue, error)
for i := maxVersion; i >= height; i-- {
hash, err := mvccs.mvcc.GetVersionHash(i)
if err != nil {
kmlog.Debug("store kvmvcc checkVersion GetVersionHash failed", "height", i, "maxVersion", maxVersion)
kmlog.Warn("store kvmvcc checkVersion GetVersionHash failed", "height", i, "maxVersion", maxVersion)
continue
}
kvlist, err := mvccs.mvcc.DelMVCC(hash, i, false)
if err != nil {
kmlog.Debug("store kvmvcc checkVersion DelMVCC failed", "height", i, "err", err)
kmlog.Warn("store kvmvcc checkVersion DelMVCC failed", "height", i, "err", err)
continue
}
kvset = append(kvset, kvlist...)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment