Skip to content

Commit df9cc0f

Browse files
committed
test: do InsertOnInstances in parallel
1 parent f443836 commit df9cc0f

File tree

1 file changed

+13
-8
lines changed

1 file changed

+13
-8
lines changed

test_helpers/pool_helper.go

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -181,16 +181,21 @@ func InsertOnInstances(
181181
return fmt.Errorf("fail to set roles for cluster: %s", err.Error())
182182
}
183183

184-
for _, dialer := range dialers {
185-
ctx, cancel := GetConnectContext()
186-
err := InsertOnInstance(ctx, dialer, connOpts, space, tuple)
187-
cancel()
188-
if err != nil {
189-
return err
190-
}
184+
ctx, cancel := GetConnectContext()
185+
defer cancel()
186+
187+
errs := make([]error, len(dialers))
188+
var wg sync.WaitGroup
189+
wg.Add(len(dialers))
190+
for i, dialer := range dialers {
191+
go func(i int, dialer tarantool.Dialer) {
192+
defer wg.Done()
193+
errs[i] = InsertOnInstance(ctx, dialer, connOpts, space, tuple)
194+
}(i, dialer)
191195
}
196+
wg.Wait()
192197

193-
return nil
198+
return errors.Join(errs...)
194199
}
195200

196201
func SetInstanceRO(ctx context.Context, dialer tarantool.Dialer, connOpts tarantool.Opts,

0 commit comments

Comments
 (0)