@@ -67,9 +67,9 @@ func TestBucket_Take(t *testing.T) {
67
67
68
68
func TestBucket_Merge (t * testing.T ) {
69
69
rng := rand .New (rand .NewSource (time .Now ().UnixNano ()))
70
- buckets := make ([]* Bucket , 100 )
70
+ buckets := make ([]Bucket , 100 )
71
71
for i := range buckets {
72
- buckets [i ] = & Bucket {
72
+ buckets [i ] = Bucket {
73
73
added : rng .Float64 (), // The P of the PN counter "tokens".
74
74
taken : rng .Float64 (), // The N of the PN counter "tokens".
75
75
elapsed : time .Duration (rng .Int63 ()), // A separate "elapsed" duration G-Counter.
@@ -79,7 +79,7 @@ func TestBucket_Merge(t *testing.T) {
79
79
// Compute the result of a merged bucket with sequential operations.
80
80
var sequential Bucket
81
81
for _ , bucket := range buckets {
82
- sequential .Merge (& sequential , bucket )
82
+ sequential .Merge (& sequential , & bucket )
83
83
}
84
84
85
85
// Compute multiple random sequences of merge operations and compare with
@@ -96,13 +96,13 @@ func TestBucket_Merge(t *testing.T) {
96
96
buckets [i ], buckets [j ] = buckets [j ], buckets [i ]
97
97
})
98
98
99
- random := buckets [ rng . Int () % len ( buckets )]
99
+ var random Bucket
100
100
for _ , bucket := range buckets {
101
101
// Explicitly test idempotence by merging the same bucket twice.
102
- random .Merge (bucket , bucket )
102
+ random .Merge (& bucket , & bucket )
103
103
}
104
104
105
- if * random != sequential {
105
+ if random != sequential {
106
106
t .Fatalf (
107
107
"Buckets merged in random order diverged from sequential result:\n have: %v\n want: %v\n buckets: %v" ,
108
108
random ,
0 commit comments