Merge pull request #15642 from serathius/robustness-detect-trigger-timeout
tests/robustness: Detect trigger timeout and exit
This commit is contained in:
@ -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()))
|
lg.Info("Triggering failpoint", zap.String("failpoint", config.failpoint.Name()))
|
||||||
err = config.failpoint.Trigger(ctx, t, lg, clus)
|
err = config.failpoint.Trigger(ctx, t, lg, clus)
|
||||||
if err != nil {
|
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))
|
lg.Info("Failed to trigger failpoint", zap.String("failpoint", config.failpoint.Name()), zap.Error(err))
|
||||||
failures++
|
failures++
|
||||||
continue
|
continue
|
||||||
|
Reference in New Issue
Block a user