Skip to content

Commit 4c86052

Browse files
lyh169lyh169
committed
modify store config
1 parent 54e45a7 commit 4c86052

File tree

6 files changed

+26
-26
lines changed

6 files changed

+26
-26
lines changed

‎store/store.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,5 +23,5 @@ func New(cfg *types.Chain33Config) queue.Module {
2323
if !ok {
2424
subcfg = nil
2525
}
26-
return s(mcfg, subcfg)
26+
return s(mcfg, subcfg, cfg)
2727
}

‎system/dapp/coins/types/types.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ func InitFork(cfg *types.Chain33Config) {
4646
}
4747

4848
func InitExecutor(cfg *types.Chain33Config) {
49-
types.RegistorExecutor("coins", NewType(cfg))
49+
types.RegistorExecutor(CoinsX, NewType(cfg))
5050
}
5151

5252
// CoinsType defines exec type

‎system/store/base_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,7 @@ func TestSubStore(t *testing.T) {
187187
}
188188

189189
func TestRegAndLoad(t *testing.T) {
190-
Reg("test", func(cfg *types.Store, sub []byte) queue.Module {
190+
Reg("test", func(cfg *types.Store, sub []byte, chain33cfg *types.Chain33Config) queue.Module {
191191
return nil
192192
})
193193

‎system/store/mavl/mavl.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ type subConfig struct {
6363
}
6464

6565
// New new mavl store module
66-
func New(cfg *types.Store, sub []byte) queue.Module {
66+
func New(cfg *types.Store, sub []byte, chain33cfg *types.Chain33Config) queue.Module {
6767
bs := drivers.NewBaseStore(cfg)
6868
var subcfg subConfig
6969
if sub != nil {

‎system/store/mavl/mavl_test.go

+21-21
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ func TestKvdbNewClose(t *testing.T) {
3333
defer os.RemoveAll(dir) // clean up
3434
os.RemoveAll(dir) //删除已存在目录
3535
var storeCfg = newStoreCfg(dir)
36-
store := New(storeCfg, nil).(*Store)
36+
store := New(storeCfg, nil, nil).(*Store)
3737
assert.NotNil(t, store)
3838

3939
store.Close()
@@ -45,7 +45,7 @@ func TestKvddbSetGet(t *testing.T) {
4545
defer os.RemoveAll(dir) // clean up
4646
os.RemoveAll(dir) //删除已存在目录
4747
var storeCfg = newStoreCfg(dir)
48-
store := New(storeCfg, nil).(*Store)
48+
store := New(storeCfg, nil, nil).(*Store)
4949
assert.NotNil(t, store)
5050

5151
keys0 := [][]byte{[]byte("mk1"), []byte("mk2")}
@@ -92,7 +92,7 @@ func TestKvdbMemSet(t *testing.T) {
9292
defer os.RemoveAll(dir) // clean up
9393
os.RemoveAll(dir) //删除已存在目录
9494
var storeCfg = newStoreCfg(dir)
95-
store := New(storeCfg, nil).(*Store)
95+
store := New(storeCfg, nil, nil).(*Store)
9696
assert.NotNil(t, store)
9797

9898
var kv []*types.KeyValue
@@ -123,7 +123,7 @@ func TestKvdbMemSetUpgrade(t *testing.T) {
123123
defer os.RemoveAll(dir) // clean up
124124
os.RemoveAll(dir) //删除已存在目录
125125
var storeCfg = newStoreCfg(dir)
126-
store := New(storeCfg, nil).(*Store)
126+
store := New(storeCfg, nil, nil).(*Store)
127127
assert.NotNil(t, store)
128128

129129
var kv []*types.KeyValue
@@ -152,7 +152,7 @@ func TestKvdbRollback(t *testing.T) {
152152
defer os.RemoveAll(dir) // clean up
153153
os.RemoveAll(dir) //删除已存在目录
154154
var storeCfg = newStoreCfg(dir)
155-
store := New(storeCfg, nil).(*Store)
155+
store := New(storeCfg, nil, nil).(*Store)
156156
assert.NotNil(t, store)
157157

158158
var kv []*types.KeyValue
@@ -182,7 +182,7 @@ func TestProcEvent(t *testing.T) {
182182
defer os.RemoveAll(dir) // clean up
183183
os.RemoveAll(dir) //删除已存在目录
184184
var storeCfg = newStoreCfg(dir)
185-
store := New(storeCfg, nil).(*Store)
185+
store := New(storeCfg, nil, nil).(*Store)
186186
assert.NotNil(t, store)
187187

188188
store.ProcEvent(nil)
@@ -195,7 +195,7 @@ func TestDel(t *testing.T) {
195195
defer os.RemoveAll(dir) // clean up
196196
os.RemoveAll(dir) //删除已存在目录
197197
var storeCfg = newStoreCfg(dir)
198-
store := New(storeCfg, nil).(*Store)
198+
store := New(storeCfg, nil, nil).(*Store)
199199
assert.NotNil(t, store)
200200

201201
store.Del(nil)
@@ -215,7 +215,7 @@ func TestKvdbIterate(t *testing.T) {
215215
defer os.RemoveAll(dir) // clean up
216216
os.RemoveAll(dir) //删除已存在目录
217217
var storeCfg = newStoreCfg(dir)
218-
store := New(storeCfg, nil).(*Store)
218+
store := New(storeCfg, nil, nil).(*Store)
219219
assert.NotNil(t, store)
220220

221221
var kv []*types.KeyValue
@@ -284,7 +284,7 @@ func TestIterateCallBack_Mode1(t *testing.T) {
284284
defer os.RemoveAll(dir) // clean up
285285
os.RemoveAll(dir) //删除已存在目录
286286
var store_cfg = newStoreCfg(dir)
287-
store := New(store_cfg, nil).(*Store)
287+
store := New(store_cfg, nil, nil).(*Store)
288288
assert.NotNil(t, store)
289289
//mavldb.EnableMavlPrefix(true)
290290
//defer mavldb.EnableMavlPrefix(false)
@@ -429,7 +429,7 @@ func TestIterateCallBack_Mode2(t *testing.T) {
429429
defer os.RemoveAll(dir) // clean up
430430
os.RemoveAll(dir) //删除已存在目录
431431
var store_cfg = newStoreCfg(dir)
432-
store := New(store_cfg, nil).(*Store)
432+
store := New(store_cfg, nil, nil).(*Store)
433433
assert.NotNil(t, store)
434434
//mavldb.EnableMavlPrefix(true)
435435
//defer mavldb.EnableMavlPrefix(false)
@@ -602,7 +602,7 @@ func TestKvdbIterateTimes(t *testing.T) {
602602
defer os.RemoveAll(dir) // clean up
603603
os.RemoveAll(dir) //删除已存在目录
604604
var storeCfg = newStoreCfg(dir)
605-
store := New(storeCfg, nil).(*Store)
605+
store := New(storeCfg, nil, nil).(*Store)
606606
assert.NotNil(t, store)
607607

608608
var kv []*types.KeyValue
@@ -633,7 +633,7 @@ func BenchmarkGet(b *testing.B) {
633633
defer os.RemoveAll(dir) // clean up
634634
os.RemoveAll(dir) //删除已存在目录
635635
var storeCfg = newStoreCfg(dir)
636-
store := New(storeCfg, nil).(*Store)
636+
store := New(storeCfg, nil, nil).(*Store)
637637
assert.NotNil(b, store)
638638
mavldb.EnableMavlPrefix(true)
639639
defer mavldb.EnableMavlPrefix(false)
@@ -680,7 +680,7 @@ func BenchmarkStoreGetKvs4N(b *testing.B) {
680680
defer os.RemoveAll(dir) // clean up
681681
os.RemoveAll(dir) //删除已存在目录
682682
var storeCfg = newStoreCfg(dir)
683-
store := New(storeCfg, nil).(*Store)
683+
store := New(storeCfg, nil, nil).(*Store)
684684
assert.NotNil(b, store)
685685

686686
var kv []*types.KeyValue
@@ -725,7 +725,7 @@ func BenchmarkStoreGetKvsForNN(b *testing.B) {
725725
defer os.RemoveAll(dir) // clean up
726726
os.RemoveAll(dir) //删除已存在目录
727727
var storeCfg = newStoreCfg(dir)
728-
store := New(storeCfg, nil).(*Store)
728+
store := New(storeCfg, nil, nil).(*Store)
729729
assert.NotNil(b, store)
730730

731731
var kv []*types.KeyValue
@@ -786,7 +786,7 @@ func BenchmarkStoreGetKvsFor10000(b *testing.B) {
786786
defer os.RemoveAll(dir) // clean up
787787
os.RemoveAll(dir) //删除已存在目录
788788
var storeCfg = newStoreCfg(dir)
789-
store := New(storeCfg, nil).(*Store)
789+
store := New(storeCfg, nil, nil).(*Store)
790790
assert.NotNil(b, store)
791791

792792
var kv []*types.KeyValue
@@ -851,7 +851,7 @@ func BenchmarkSet(b *testing.B) {
851851
defer os.RemoveAll(dir) // clean up
852852
os.RemoveAll(dir) //删除已存在目录
853853
var storeCfg = newStoreCfg(dir)
854-
store := New(storeCfg, nil).(*Store)
854+
store := New(storeCfg, nil, nil).(*Store)
855855
assert.NotNil(b, store)
856856
mavldb.EnableMavlPrefix(true)
857857
defer mavldb.EnableMavlPrefix(false)
@@ -887,7 +887,7 @@ func BenchmarkStoreSetKvs(b *testing.B) {
887887
defer os.RemoveAll(dir) // clean up
888888
os.RemoveAll(dir) //删除已存在目录
889889
var storeCfg = newStoreCfg(dir)
890-
store := New(storeCfg, nil).(*Store)
890+
store := New(storeCfg, nil, nil).(*Store)
891891
assert.NotNil(b, store)
892892

893893
var kv []*types.KeyValue
@@ -922,7 +922,7 @@ func BenchmarkMemSet(b *testing.B) {
922922
defer os.RemoveAll(dir) // clean up
923923
os.RemoveAll(dir) //删除已存在目录
924924
var storeCfg = newStoreCfg(dir)
925-
store := New(storeCfg, nil).(*Store)
925+
store := New(storeCfg, nil, nil).(*Store)
926926
assert.NotNil(b, store)
927927
var kv []*types.KeyValue
928928
var key string
@@ -955,7 +955,7 @@ func BenchmarkStoreMemSet(b *testing.B) {
955955
defer os.RemoveAll(dir) // clean up
956956
os.RemoveAll(dir) //删除已存在目录
957957
var storeCfg = newStoreCfg(dir)
958-
store := New(storeCfg, nil).(*Store)
958+
store := New(storeCfg, nil, nil).(*Store)
959959
assert.NotNil(b, store)
960960

961961
var kv []*types.KeyValue
@@ -990,7 +990,7 @@ func BenchmarkCommit(b *testing.B) {
990990
defer os.RemoveAll(dir) // clean up
991991
os.RemoveAll(dir) //删除已存在目录
992992
var storeCfg = newStoreCfg(dir)
993-
store := New(storeCfg, nil).(*Store)
993+
store := New(storeCfg, nil, nil).(*Store)
994994
assert.NotNil(b, store)
995995

996996
var kv []*types.KeyValue
@@ -1030,7 +1030,7 @@ func BenchmarkStoreCommit(b *testing.B) {
10301030
defer os.RemoveAll(dir) // clean up
10311031
os.RemoveAll(dir) //删除已存在目录
10321032
var storeCfg = newStoreCfg(dir)
1033-
store := New(storeCfg, nil).(*Store)
1033+
store := New(storeCfg, nil, nil).(*Store)
10341034
assert.NotNil(b, store)
10351035

10361036
var kv []*types.KeyValue

‎system/store/store.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
)
1212

1313
// Storecreate store queue module
14-
type Storecreate func(cfg *types.Store, sub []byte) queue.Module
14+
type Storecreate func(cfg *types.Store, sub []byte, chain33cfg *types.Chain33Config) queue.Module
1515

1616
var regStore = make(map[string]Storecreate)
1717

0 commit comments

Comments
 (0)