aarifullin/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#2061] meta: Add parallel bench for Get

Browse source 
Signed-off-by: Pavel Karpy <carpawell@nspcc.ru>
This commit is contained in:
Pavel Karpy 2022-11-15 19:17:53 +03:00 committed by fyrchik
parent 761e82fecd
commit bc905f169d
1 changed files with 24 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
pkg/local_object_storage/metabase/get_test.go
View file

@ -172,7 +172,7 @@ func BenchmarkGet(b *testing.B) {
} }
for _, num := range numOfObjects { for _, num := range numOfObjects {
b.Run(fmt.Sprintf("%d objects", num), func(b *testing.B) { b.Run(fmt.Sprintf("%d_objects", num), func(b *testing.B) {
benchmarkGet(b, num) benchmarkGet(b, num)
}) })
} }
@ -196,23 +196,36 @@ func benchmarkGet(b *testing.B, numOfObj int) {
_ = db.Close() _ = db.Close()
_ = os.RemoveAll(b.Name()) _ = os.RemoveAll(b.Name())
}) })
b.ReportAllocs()
b.ResetTimer()
var err error
var getPrm meta.GetPrm var getPrm meta.GetPrm
getPrm.SetAddress(addrs[len(addrs)/2]) getPrm.SetAddress(addrs[len(addrs)/2])
for i := 0; i < b.N; i++ { b.Run("parallel", func(b *testing.B) {
for _, addr := range addrs { b.ReportAllocs()
getPrm.SetAddress(addr) b.RunParallel(func(pb *testing.PB) {
for pb.Next() {
_, err = db.Get(getPrm)
if err != nil {
b.Fatal(err)
}
}
})
})
res, err := db.Get(getPrm) b.Run("serial", func(b *testing.B) {
require.NoError(b, err) b.ReportAllocs()
for i := 0; i < b.N; i++ {
for _, addr := range addrs {
getPrm.SetAddress(addr)
obj = res.Header() _, err := db.Get(getPrm)
if err != nil {
b.Fatal(err)
}
}
} }
})
}
} }
func metaGet(db *meta.DB, addr oid.Address, raw bool) (*objectSDK.Object, error) { func metaGet(db *meta.DB, addr oid.Address, raw bool) (*objectSDK.Object, error) {