@@ -81,6 +81,7 @@ func BenchmarkClientSerial(b *testing.B) {
81
81
b .Errorf ("No connection available" )
82
82
}
83
83
84
+ b .ResetTimer ()
84
85
for i := 0 ; i < b .N ; i ++ {
85
86
_ , err = conn .Select (spaceNo , indexNo , 0 , 1 , IterEq , []interface {}{uint (1111 )})
86
87
if err != nil {
@@ -105,6 +106,7 @@ func BenchmarkClientSerialTyped(b *testing.B) {
105
106
}
106
107
107
108
var r []Tuple
109
+ b .ResetTimer ()
108
110
for i := 0 ; i < b .N ; i ++ {
109
111
err = conn .SelectTyped (spaceNo , indexNo , 0 , 1 , IterEq , IntKey {1111 }, & r )
110
112
if err != nil {
@@ -128,6 +130,7 @@ func BenchmarkClientFuture(b *testing.B) {
128
130
b .Error (err )
129
131
}
130
132
133
+ b .ResetTimer ()
131
134
for i := 0 ; i < b .N ; i += N {
132
135
var fs [N ]* Future
133
136
for j := 0 ; j < N ; j ++ {
@@ -158,6 +161,7 @@ func BenchmarkClientFutureTyped(b *testing.B) {
158
161
b .Errorf ("No connection available" )
159
162
}
160
163
164
+ b .ResetTimer ()
161
165
for i := 0 ; i < b .N ; i += N {
162
166
var fs [N ]* Future
163
167
for j := 0 ; j < N ; j ++ {
@@ -191,6 +195,7 @@ func BenchmarkClientFutureParallel(b *testing.B) {
191
195
b .Errorf ("No connection available" )
192
196
}
193
197
198
+ b .ResetTimer ()
194
199
b .RunParallel (func (pb * testing.PB ) {
195
200
exit := false
196
201
for ! exit {
@@ -227,6 +232,7 @@ func BenchmarkClientFutureParallelTyped(b *testing.B) {
227
232
b .Fatal ("No connection available" )
228
233
}
229
234
235
+ b .ResetTimer ()
230
236
b .RunParallel (func (pb * testing.PB ) {
231
237
exit := false
232
238
for ! exit {
@@ -266,6 +272,7 @@ func BenchmarkClientParallel(b *testing.B) {
266
272
b .Fatal ("No connection available" )
267
273
}
268
274
275
+ b .ResetTimer ()
269
276
b .RunParallel (func (pb * testing.PB ) {
270
277
for pb .Next () {
271
278
_ , err := conn .Select (spaceNo , indexNo , 0 , 1 , IterEq , []interface {}{uint (1111 )})
@@ -307,6 +314,7 @@ func BenchmarkClientParallelMassive(b *testing.B) {
307
314
}
308
315
}()
309
316
}
317
+ b .ResetTimer ()
310
318
for i := 0 ; i < b .N ; i ++ {
311
319
wg .Add (1 )
312
320
limit <- struct {}{}
@@ -344,6 +352,8 @@ func BenchmarkClientParallelMassiveUntyped(b *testing.B) {
344
352
}
345
353
}()
346
354
}
355
+
356
+ b .ResetTimer ()
347
357
for i := 0 ; i < b .N ; i ++ {
348
358
wg .Add (1 )
349
359
limit <- struct {}{}
0 commit comments