@@ -296,40 +296,40 @@ func TestNoRetriesManyFilesBenchmark(t *testing.T) {
296
296
}
297
297
298
298
func TestBatching1500 (t * testing.T ) {
299
- myWriter , myFiles := setupWriter (1500 )
300
-
301
- err := myWriter .SetRetries (0 )
302
- if err != nil {
303
- t .Errorf ("Error setting retries: %v" , err )
304
- }
305
- err = myWriter .SetMaxPool (150 )
306
- if err != nil {
307
- t .Errorf ("Error setting max pool: %v" , err )
308
- }
309
-
310
- //Start Timer
311
- start := time .Now ()
312
- results , err := myWriter .Write (4 )
313
- if err != nil {
314
- t .Errorf ("Write failed: %v" , err )
315
- }
316
- elapsed := time .Since (start )
317
-
318
- // Close connections first, before any cleanup
319
- err = myWriter .CloseAllConns ()
320
- if err != nil {
321
- t .Errorf ("Error closing connections: %v" , err )
322
- }
323
- cleanupFiles (myFiles )
324
-
325
- if err != nil {
326
- t .Errorf ("Write failed: %v" , err )
327
- }
328
- if results .Success != 1500 {
329
- t .Errorf ("Expected 1500 successes, got %d" , results .Success )
330
- }
331
-
332
- t .Logf ("Elapsed time: %.3fs" , elapsed .Seconds ())
299
+ myWriter , myFiles := setupWriter (1500 )
300
+
301
+ err := myWriter .SetRetries (0 )
302
+ if err != nil {
303
+ t .Errorf ("Error setting retries: %v" , err )
304
+ }
305
+ err = myWriter .SetMaxPool (1500 )
306
+ if err != nil {
307
+ t .Errorf ("Error setting max pool: %v" , err )
308
+ }
309
+
310
+ //Start Timer
311
+ start := time .Now ()
312
+ results , err := myWriter .Write (1500 )
313
+ if err != nil {
314
+ t .Errorf ("Write failed: %v" , err )
315
+ }
316
+ elapsed := time .Since (start )
317
+
318
+ // Close connections first, before any cleanup
319
+ err = myWriter .CloseAllConns ()
320
+ if err != nil {
321
+ t .Errorf ("Error closing connections: %v" , err )
322
+ }
323
+ cleanupFiles (myFiles )
324
+
325
+ if err != nil {
326
+ t .Errorf ("Write failed: %v" , err )
327
+ }
328
+ if results .Success != 1500 {
329
+ t .Errorf ("Expected 1500 successes, got %d" , results .Success )
330
+ }
331
+
332
+ t .Logf ("Elapsed time: %.3fs" , elapsed .Seconds ())
333
333
}
334
334
335
335
func TestBatching3000 (t * testing.T ) {
0 commit comments