diff --git a/index/store/cznicb/cznicb.go b/index/store/cznicb/cznicb.go index 9dce8e2d..479cde92 100644 --- a/index/store/cznicb/cznicb.go +++ b/index/store/cznicb/cznicb.go @@ -114,7 +114,7 @@ func (s *Store) Delete(k []byte) (err error) { func (s *Store) NewBatch() store.KVBatch { return &Batch{ s: s, - ops: make([]op, 0, 100), + ops: make([]op, 0, 1000), ms: map[string]store.AssociativeMergeChain{}, } } diff --git a/index/store/leveldb/batch.go b/index/store/leveldb/batch.go index ad815226..53bfe305 100644 --- a/index/store/leveldb/batch.go +++ b/index/store/leveldb/batch.go @@ -31,7 +31,7 @@ type Batch struct { func newBatch(store *Store) *Batch { rv := Batch{ store: store, - ops: make([]op, 0, 100), + ops: make([]op, 0, 1000), merges: make(map[string]indexStore.AssociativeMergeChain), } return &rv @@ -40,7 +40,7 @@ func newBatch(store *Store) *Batch { func newBatchAlreadyLocked(store *Store) *Batch { rv := Batch{ store: store, - ops: make([]op, 0, 100), + ops: make([]op, 0, 1000), alreadyLocked: true, merges: make(map[string]indexStore.AssociativeMergeChain), } diff --git a/index/upside_down/benchmark_cznicb_test.go b/index/upside_down/benchmark_cznicb_test.go index e4898df3..b56c87d2 100644 --- a/index/upside_down/benchmark_cznicb_test.go +++ b/index/upside_down/benchmark_cznicb_test.go @@ -106,3 +106,33 @@ func BenchmarkCznicBIndexing4Workers100Batch(b *testing.B) { CommonBenchmarkIndexBatch(b, s, 4, 100) } + +func BenchmarkCznicBIndexing1Workers1000Batch(b *testing.B) { + s, err := cznicb.StoreConstructor(nil) + if err != nil { + b.Fatal(err) + } + defer s.Close() + + CommonBenchmarkIndexBatch(b, s, 1, 1000) +} + +func BenchmarkCznicBIndexing2Workers1000Batch(b *testing.B) { + s, err := cznicb.StoreConstructor(nil) + if err != nil { + b.Fatal(err) + } + defer s.Close() + + CommonBenchmarkIndexBatch(b, s, 2, 1000) +} + +func BenchmarkCznicBIndexing4Workers1000Batch(b *testing.B) { + s, err := cznicb.StoreConstructor(nil) + if err != nil { + b.Fatal(err) + } + defer s.Close() + + CommonBenchmarkIndexBatch(b, s, 4, 1000) +} diff --git a/index/upside_down/benchmark_leveldb_test.go b/index/upside_down/benchmark_leveldb_test.go index 6b38ad4c..e3a640d9 100644 --- a/index/upside_down/benchmark_leveldb_test.go +++ b/index/upside_down/benchmark_leveldb_test.go @@ -122,3 +122,36 @@ func BenchmarkLevelDBIndexing4Workers100Batch(b *testing.B) { CommonBenchmarkIndexBatch(b, s, 4, 100) } + +func BenchmarkLevelDBIndexing1Workers1000Batch(b *testing.B) { + s, err := leveldb.Open("test", leveldbTestOptions) + if err != nil { + b.Fatal(err) + } + defer os.RemoveAll("test") + defer s.Close() + + CommonBenchmarkIndexBatch(b, s, 1, 1000) +} + +func BenchmarkLevelDBIndexing2Workers1000Batch(b *testing.B) { + s, err := leveldb.Open("test", leveldbTestOptions) + if err != nil { + b.Fatal(err) + } + defer os.RemoveAll("test") + defer s.Close() + + CommonBenchmarkIndexBatch(b, s, 2, 1000) +} + +func BenchmarkLevelDBIndexing4Workers1000Batch(b *testing.B) { + s, err := leveldb.Open("test", leveldbTestOptions) + if err != nil { + b.Fatal(err) + } + defer os.RemoveAll("test") + defer s.Close() + + CommonBenchmarkIndexBatch(b, s, 4, 1000) +}