mirror of
https://github.com/restic/restic.git
synced 2025-03-30 00:00:14 +01:00
backend/test: partially parallelize delayedRemove
This commit is contained in:
parent
4640b3c41a
commit
17b585f7c7
1 changed files with 11 additions and 6 deletions
|
@ -725,14 +725,19 @@ func (s *Suite[C]) delayedRemove(t testing.TB, be backend.Backend, handles ...ba
|
||||||
// Some backend (swift, I'm looking at you) may implement delayed
|
// Some backend (swift, I'm looking at you) may implement delayed
|
||||||
// removal of data. Let's wait a bit if this happens.
|
// removal of data. Let's wait a bit if this happens.
|
||||||
|
|
||||||
|
wg, ctx := errgroup.WithContext(context.TODO())
|
||||||
for _, h := range handles {
|
for _, h := range handles {
|
||||||
err := be.Remove(context.TODO(), h)
|
wg.Go(func() error {
|
||||||
if s.ErrorHandler != nil {
|
err := be.Remove(ctx, h)
|
||||||
err = s.ErrorHandler(t, be, err)
|
if s.ErrorHandler != nil {
|
||||||
}
|
err = s.ErrorHandler(t, be, err)
|
||||||
if err != nil {
|
}
|
||||||
return err
|
return err
|
||||||
}
|
})
|
||||||
|
}
|
||||||
|
err := wg.Wait()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, h := range handles {
|
for _, h := range handles {
|
||||||
|
|
Loading…
Add table
Reference in a new issue