Commit efdef273 authored by liuyuhang's avatar liuyuhang Committed by 33cn

add Independent enable kvmvcc prune

parent b8fa1f7b
...@@ -171,6 +171,7 @@ enableMVCCIter=true ...@@ -171,6 +171,7 @@ enableMVCCIter=true
enableMavlPrefix=false enableMavlPrefix=false
enableMVCC=false enableMVCC=false
enableMavlPrune=false enableMavlPrune=false
enableMVCCPrune=false
pruneHeight=10000 pruneHeight=10000
# 是否使能mavl数据载入内存 # 是否使能mavl数据载入内存
enableMemTree=true enableMemTree=true
......
...@@ -74,7 +74,7 @@ type KVmMavlStore struct { ...@@ -74,7 +74,7 @@ type KVmMavlStore struct {
type subKVMVCCConfig struct { type subKVMVCCConfig struct {
EnableMVCCIter bool `json:"enableMVCCIter"` EnableMVCCIter bool `json:"enableMVCCIter"`
EnableMavlPrune bool `json:"enableMavlPrune"` EnableMVCCPrune bool `json:"enableMVCCPrune"`
PruneHeight int32 `json:"pruneHeight"` PruneHeight int32 `json:"pruneHeight"`
} }
...@@ -96,6 +96,7 @@ type subConfig struct { ...@@ -96,6 +96,7 @@ type subConfig struct {
EnableMavlPrefix bool `json:"enableMavlPrefix"` EnableMavlPrefix bool `json:"enableMavlPrefix"`
EnableMVCC bool `json:"enableMVCC"` EnableMVCC bool `json:"enableMVCC"`
EnableMavlPrune bool `json:"enableMavlPrune"` EnableMavlPrune bool `json:"enableMavlPrune"`
EnableMVCCPrune bool `json:"enableMVCCPrune"`
PruneHeight int32 `json:"pruneHeight"` PruneHeight int32 `json:"pruneHeight"`
// 是否使能内存树 // 是否使能内存树
EnableMemTree bool `json:"enableMemTree"` EnableMemTree bool `json:"enableMemTree"`
...@@ -114,7 +115,7 @@ func New(cfg *types.Store, sub []byte) queue.Module { ...@@ -114,7 +115,7 @@ func New(cfg *types.Store, sub []byte) queue.Module {
if sub != nil { if sub != nil {
types.MustDecode(sub, &subcfg) types.MustDecode(sub, &subcfg)
subKVMVCCcfg.EnableMVCCIter = subcfg.EnableMVCCIter subKVMVCCcfg.EnableMVCCIter = subcfg.EnableMVCCIter
subKVMVCCcfg.EnableMavlPrune = subcfg.EnableMavlPrune subKVMVCCcfg.EnableMVCCPrune = subcfg.EnableMVCCPrune
subKVMVCCcfg.PruneHeight = subcfg.PruneHeight subKVMVCCcfg.PruneHeight = subcfg.PruneHeight
subMavlcfg.EnableMavlPrefix = subcfg.EnableMavlPrefix subMavlcfg.EnableMavlPrefix = subcfg.EnableMavlPrefix
......
...@@ -52,7 +52,7 @@ type KVMVCCStore struct { ...@@ -52,7 +52,7 @@ type KVMVCCStore struct {
mvcc dbm.MVCC mvcc dbm.MVCC
kvsetmap map[string][]*types.KeyValue kvsetmap map[string][]*types.KeyValue
enableMVCCIter bool enableMVCCIter bool
enableMavlPrune bool enableMVCCPrune bool
pruneHeight int32 pruneHeight int32
sync bool sync bool
} }
...@@ -66,12 +66,12 @@ func NewKVMVCC(sub *subKVMVCCConfig, db dbm.DB) *KVMVCCStore { ...@@ -66,12 +66,12 @@ func NewKVMVCC(sub *subKVMVCCConfig, db dbm.DB) *KVMVCCStore {
} }
if enable { if enable {
kvs = &KVMVCCStore{db, dbm.NewMVCCIter(db), make(map[string][]*types.KeyValue), kvs = &KVMVCCStore{db, dbm.NewMVCCIter(db), make(map[string][]*types.KeyValue),
true, sub.EnableMavlPrune, sub.PruneHeight, false} true, sub.EnableMVCCPrune, sub.PruneHeight, false}
} else { } else {
kvs = &KVMVCCStore{db, dbm.NewMVCC(db), make(map[string][]*types.KeyValue), kvs = &KVMVCCStore{db, dbm.NewMVCC(db), make(map[string][]*types.KeyValue),
false, sub.EnableMavlPrune, sub.PruneHeight, false} false, sub.EnableMVCCPrune, sub.PruneHeight, false}
} }
EnablePrune(sub.EnableMavlPrune) EnablePrune(sub.EnableMVCCPrune)
SetPruneHeight(int(sub.PruneHeight)) SetPruneHeight(int(sub.PruneHeight))
return kvs return kvs
} }
......
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