1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
package datastore
import (
"strconv"
"testing"
"github.com/stretchr/testify/require"
"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper"
)
// The test setup takes a lot of time, so it is better to run each sub-benchmark separately with limit on number of repeats.
func BenchmarkPostgresRepositoryStore_GetConsistentStorages(b *testing.B) {
// go test -tags=postgres -test.bench=BenchmarkPostgresRepositoryStore_GetConsistentStorages/extra-small -benchtime=5000x gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore
b.Run("extra-small", func(b *testing.B) {
benchmarkGetConsistentStorages(b, 3, 1000)
})
// go test -tags=postgres -test.bench=BenchmarkPostgresRepositoryStore_GetConsistentStorages/small -benchtime=1000x gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore
b.Run("small", func(b *testing.B) {
benchmarkGetConsistentStorages(b, 3, 10_000)
})
// go test -tags=postgres -test.bench=BenchmarkPostgresRepositoryStore_GetConsistentStorages/medium -benchtime=50x gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore
b.Run("medium", func(b *testing.B) {
benchmarkGetConsistentStorages(b, 3, 100_000)
})
// go test -tags=postgres -test.bench=BenchmarkPostgresRepositoryStore_GetConsistentStorages/large -benchtime=10x gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore
b.Run("large", func(b *testing.B) {
benchmarkGetConsistentStorages(b, 3, 1_000_000)
})
// go test -tags=postgres -test.bench=BenchmarkPostgresRepositoryStore_GetConsistentStorages/huge -benchtime=1x gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore
b.Run("huge", func(b *testing.B) {
benchmarkGetConsistentStorages(b, 6, 1_000_000)
})
}
func benchmarkGetConsistentStorages(b *testing.B, nstorages, nrepositories int) {
db := getDB(b)
ctx, cancel := testhelper.Context()
defer cancel()
for n := 0; n < b.N; n++ {
b.StopTimer()
db.Truncate(b, "storage_repositories")
var storages []string
for i := 0; i < nstorages; i++ {
storages = append(storages, "gitaly-"+strconv.Itoa(i))
}
repoStore := NewPostgresRepositoryStore(db, map[string][]string{"vs": storages})
_, err := db.DB.ExecContext(
ctx,
`INSERT INTO storage_repositories(virtual_storage, relative_path, storage, generation)
SELECT 'vs', '/path/repo/' || R.I, 'gitaly-' || S.I, 1
FROM GENERATE_SERIES(1, $1) R(I)
CROSS JOIN GENERATE_SERIES(1, $2) S(I)`,
nrepositories, nstorages,
)
require.NoError(b, err)
b.StartTimer()
_, err = repoStore.GetConsistentStorages(ctx, "vs", "/path/repo/"+strconv.Itoa(nrepositories/2))
b.StopTimer()
require.NoError(b, err)
}
}
|
