From 535ade8eb2c1892055905185ee98de2acb54b58c Mon Sep 17 00:00:00 2001 From: Marek Siarkowicz Date: Thu, 26 Jan 2023 17:03:18 +0100 Subject: [PATCH] tests: Increase failpoint timeout and add more logs Signed-off-by: Marek Siarkowicz --- tests/linearizability/failpoints.go | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/tests/linearizability/failpoints.go b/tests/linearizability/failpoints.go index 46fd50800..e4f38e861 100644 --- a/tests/linearizability/failpoints.go +++ b/tests/linearizability/failpoints.go @@ -29,7 +29,7 @@ import ( ) const ( - triggerTimeout = time.Second + triggerTimeout = 2 * time.Second ) var ( @@ -136,20 +136,28 @@ func (f goPanicFailpoint) Trigger(t *testing.T, ctx context.Context, clus *e2e.E defer cancel() for member.IsRunning() { + t.Logf("setting up gofailpoint %q", f.Name()) err := member.Failpoints().Setup(triggerCtx, f.failpoint, "panic") if err != nil { t.Logf("gofailpoint setup failed: %v", err) } + if !member.IsRunning() { + // TODO: Check member logs that etcd not running is caused panic caused by proper gofailpoint. + break + } if f.trigger != nil { + t.Logf("triggering gofailpoint") err = f.trigger(triggerCtx, member) if err != nil { t.Logf("triggering gofailpoint failed: %v", err) } } + t.Logf("waiting for process to exist") err = member.Wait(triggerCtx) if err != nil && !strings.Contains(err.Error(), "unexpected exit code") { - return fmt.Errorf("failed to trigger a process panic within %s, err: %w", triggerTimeout, err) + return fmt.Errorf("failed to trigger a gofailpoint within %s, err: %w", triggerTimeout, err) } + t.Logf("process existed") } err := member.Start(ctx)