TrueCloudLab/frostfs-node
20
1
Fork 27
Code Issues 95 Pull requests 5 Projects Releases 1 Activity Actions 1

Small fixes for local blobstor benchmarks #236

Merged
fyrchik merged 1 commit from fyrchik/frostfs-node:perf-test-fix into master 2023-07-26 21:07:57 +00:00
Conversation 0 Commits 1 Files changed 1 +14 -8
1 changed files with 14 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
pkg/local_object_storage/blobstor/perf_test.go
View file

@ -11,6 +11,7 @@ import (
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/blobstor/memstore" "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/blobstor/memstore"
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/internal/testutil" "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/internal/testutil"
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
"golang.org/x/sync/errgroup"
) )
type storage struct { type storage struct {
@ -103,18 +104,23 @@ func BenchmarkSubstorageReadPerf(b *testing.B) {
st := stEntry.open(b) st := stEntry.open(b)
// Fill database // Fill database
var errG errgroup.Group
for i := 0; i < tt.size; i++ { for i := 0; i < tt.size; i++ {
obj := objGen.Next() obj := objGen.Next()
addr := testutil.AddressFromObject(b, obj) addr := testutil.AddressFromObject(b, obj)
raw, err := obj.Marshal() errG.Go(func() error {
require.NoError(b, err) raw, err := obj.Marshal()
if _, err := st.Put(common.PutPrm{ if err != nil {
Address: addr, return fmt.Errorf("marshal: %v", err)
RawData: raw, }
}); err != nil { _, err = st.Put(common.PutPrm{
b.Fatalf("writing entry: %v", err) Address: addr,
} RawData: raw,
})
return err
})
} }
require.NoError(b, errG.Wait())
// Benchmark reading // Benchmark reading
addrGen := tt.addrGen() addrGen := tt.addrGen()