tests/robustness: Detect trigger timeout and exit

Signed-off-by: Marek Siarkowicz <siarkowicz@google.com>
This commit is contained in:
Marek Siarkowicz
2023-04-04 15:22:59 +02:00
parent f9d124974b
commit 5bae6b1e44

View File

@@ -109,6 +109,12 @@ func triggerFailpoints(ctx context.Context, t *testing.T, lg *zap.Logger, clus *
lg.Info("Triggering failpoint", zap.String("failpoint", config.failpoint.Name()))
err = config.failpoint.Trigger(ctx, t, lg, clus)
if err != nil {
select {
case <-ctx.Done():
t.Errorf("Triggering failpoints timed out, err: %v", ctx.Err())
return
default:
}
lg.Info("Failed to trigger failpoint", zap.String("failpoint", config.failpoint.Name()), zap.Error(err))
failures++
continue