@@ -2,11 +2,10 @@ package e2e
2
2
3
3
import (
4
4
"context"
5
- "math/rand"
6
5
"os"
7
- "sync"
8
6
"testing"
9
- "time"
7
+
8
+ "k8s.io/apimachinery/pkg/util/rand"
10
9
)
11
10
12
11
func BenchmarkCreateClusterCatalog (b * testing.B ) {
@@ -16,70 +15,26 @@ func BenchmarkCreateClusterCatalog(b *testing.B) {
16
15
}
17
16
ctx := context .Background ()
18
17
b .ResetTimer ()
19
- // b.RunParallel(func(pb *testing.PB) {
20
- // for pb.Next() {
21
- // catalogObj, err := createTestCatalog(ctx, getRandomStringParallel(6), catalogImageRef)
22
- // if err != nil {
23
- // b.Logf("failed to create ClusterCatalog: %v", err)
24
- // }
25
-
26
- // if err := deleteTestCatalog(ctx, catalogObj); err != nil {
27
- // b.Logf("failed to remove ClusterCatalog: %v", err)
28
- // }
29
- // }
30
- // })
31
- for i := 0 ; i < b .N ; i ++ {
32
- catalogObj , err := createTestCatalog (ctx , getRandomString (8 ), catalogImageRef )
33
- if err != nil {
34
- b .Logf ("failed to create ClusterCatalog: %v" , err )
18
+ b .RunParallel (func (pb * testing.PB ) {
19
+ for pb .Next () {
20
+ catalogObj , err := createTestCatalog (ctx , rand .String (6 ), catalogImageRef )
21
+ if err != nil {
22
+ b .Logf ("failed to create ClusterCatalog: %v" , err )
23
+ }
24
+
25
+ if err := deleteTestCatalog (ctx , catalogObj ); err != nil {
26
+ b .Logf ("failed to remove ClusterCatalog: %v" , err )
27
+ }
35
28
}
29
+ })
30
+ // for i := 0; i < b.N; i++ {
31
+ // catalogObj, err := createTestCatalog(ctx, rand.String(8), catalogImageRef)
32
+ // if err != nil {
33
+ // b.Logf("failed to create ClusterCatalog: %v", err)
34
+ // }
36
35
37
- if err := deleteTestCatalog (ctx , catalogObj ); err != nil {
38
- b .Logf ("failed to remove ClusterCatalog: %v" , err )
39
- }
40
- }
41
- }
42
-
43
- var (
44
- mu sync.Mutex
45
- usedChars = make (map [string ]struct {})
46
- alphabet = "abcdefghijklmnopqrstuvwxyz"
47
- )
48
-
49
- func getRandomStringParallel (length int ) string {
50
- // Ensure we seed the random number generator only once
51
- rand .Seed (time .Now ().UnixNano ())
52
-
53
- // Lock to ensure no concurrent access to shared resources (e.g., usedChars)
54
- mu .Lock ()
55
- defer mu .Unlock ()
56
-
57
- // Try generating a random string and ensure it's unique
58
- for {
59
- var result []rune
60
- for i := 0 ; i < length ; i ++ {
61
- result = append (result , rune (alphabet [rand .Intn (len (alphabet ))]))
62
- }
63
- // Convert result to string
64
- randomStr := string (result )
65
-
66
- // Check if the generated string is unique
67
- if _ , exists := usedChars [randomStr ]; ! exists {
68
- // If it's unique, add it to the map and return it
69
- usedChars [randomStr ] = struct {}{}
70
- return randomStr
71
- }
72
- }
73
- }
74
-
75
- // GetRandomString generates a random string of the given length
76
- func getRandomString (length int ) string {
77
- const charset = "abcdefghijklmnopqrstuvwxyz"
78
- seededRand := rand .New (rand .NewSource (time .Now ().UnixNano ()))
79
-
80
- b := make ([]byte , length )
81
- for i := range b {
82
- b [i ] = charset [seededRand .Intn (len (charset ))]
83
- }
84
- return string (b )
36
+ // if err := deleteTestCatalog(ctx, catalogObj); err != nil {
37
+ // b.Logf("failed to remove ClusterCatalog: %v", err)
38
+ // }
39
+ // }
85
40
}
0 commit comments