tests: Sleep between failpoint failure

Signed-off-by: Marek Siarkowicz <siarkowicz@google.com>
This commit is contained in:
Marek Siarkowicz 2022-12-02 00:41:47 +01:00
parent 11711fc007
commit df2d075e1a

View File

@ -119,8 +119,8 @@ func triggerFailpoints(ctx context.Context, t *testing.T, clus *e2e.EtcdProcessC
var err error var err error
successes := 0 successes := 0
failures := 0 failures := 0
time.Sleep(config.waitBetweenTriggers)
for successes < config.count && failures < config.count { for successes < config.count && failures < config.count {
time.Sleep(config.waitBetweenTriggers)
err = config.failpoint.Trigger(t, ctx, clus) err = config.failpoint.Trigger(t, ctx, clus)
if err != nil { if err != nil {
t.Logf("Failed to trigger failpoint %q, err: %v\n", config.failpoint.Name(), err) t.Logf("Failed to trigger failpoint %q, err: %v\n", config.failpoint.Name(), err)
@ -128,8 +128,8 @@ func triggerFailpoints(ctx context.Context, t *testing.T, clus *e2e.EtcdProcessC
continue continue
} }
successes++ successes++
time.Sleep(config.waitBetweenTriggers)
} }
time.Sleep(config.waitBetweenTriggers)
if successes < config.count || failures >= config.count { if successes < config.count || failures >= config.count {
return fmt.Errorf("failed to trigger failpoints enough times, err: %v", err) return fmt.Errorf("failed to trigger failpoints enough times, err: %v", err)
} }