Commit 0c345a62 authored by liuyuhang's avatar liuyuhang Committed by vipwzw

modify linter

parent 51335caa
...@@ -129,7 +129,7 @@ func New(cfg *types.Store, sub []byte) queue.Module { ...@@ -129,7 +129,7 @@ func New(cfg *types.Store, sub []byte) queue.Module {
isDelMavlData = true isDelMavlData = true
} }
// 查询是Upgrade是否需保存mavl // 查询是Upgrade是否需保存mavl
isUpgradeCommitMavl = isCommitMavl(bs.GetDB()) isUpgradeCommitMavl = isCommitMavlDB(bs.GetDB())
bs.SetChild(kvms) bs.SetChild(kvms)
return kvms return kvms
...@@ -270,7 +270,7 @@ func (kvmMavls *KVmMavlStore) MemSetUpgrade(datas *types.StoreSet, sync bool) ([ ...@@ -270,7 +270,7 @@ func (kvmMavls *KVmMavlStore) MemSetUpgrade(datas *types.StoreSet, sync bool) ([
var err error var err error
if isUpgradeCommitMavl { if isUpgradeCommitMavl {
hash, err := kvmMavls.MavlStore.MemSet(datas, sync) hash, err = kvmMavls.MavlStore.MemSet(datas, sync)
if err != nil { if err != nil {
return hash, err return hash, err
} }
...@@ -381,7 +381,7 @@ func setDelMavl(state int32) { ...@@ -381,7 +381,7 @@ func setDelMavl(state int32) {
atomic.StoreInt32(&delMavlDataState, state) atomic.StoreInt32(&delMavlDataState, state)
} }
func isCommitMavl(db dbm.DB) bool { func isCommitMavlDB(db dbm.DB) bool {
prefix := []byte(leafNodePrefix) prefix := []byte(leafNodePrefix)
it := db.Iterator(prefix, nil, true) it := db.Iterator(prefix, nil, true)
defer it.Close() defer it.Close()
......
...@@ -720,12 +720,12 @@ func TestIsCommitMavl(t *testing.T) { ...@@ -720,12 +720,12 @@ func TestIsCommitMavl(t *testing.T) {
store := New(storeCfg, nil).(*KVmMavlStore) store := New(storeCfg, nil).(*KVmMavlStore)
assert.NotNil(t, store) assert.NotNil(t, store)
isComm := isCommitMavl(store.GetDB()) isComm := isCommitMavlDB(store.GetDB())
require.Equal(t, false, isComm) require.Equal(t, false, isComm)
store.GetDB().Set([]byte(fmt.Sprintln(leafNodePrefix, "123")), []byte("v1")) store.GetDB().Set([]byte(fmt.Sprintln(leafNodePrefix, "123")), []byte("v1"))
store.GetDB().Set([]byte(fmt.Sprintln(leafNodePrefix, "456")), []byte("v2")) store.GetDB().Set([]byte(fmt.Sprintln(leafNodePrefix, "456")), []byte("v2"))
isComm = isCommitMavl(store.GetDB()) isComm = isCommitMavlDB(store.GetDB())
require.Equal(t, true, isComm) require.Equal(t, true, isComm)
} }
......
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