Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

tests: Increase failpoint timeout and add more logs

Browse Source 
Signed-off-by: Marek Siarkowicz <siarkowicz@google.com>
This commit is contained in:
Marek Siarkowicz 2023-01-26 17:03:18 +01:00
parent 3b612ce345
commit 535ade8eb2
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/linearizability/failpoints.go
View File

@ -29,7 +29,7 @@ import (
) )
const ( const (
triggerTimeout = time.Second triggerTimeout = 2 * time.Second
) )
var ( var (
@ -136,20 +136,28 @@ func (f goPanicFailpoint) Trigger(t *testing.T, ctx context.Context, clus *e2e.E
defer cancel() defer cancel()
for member.IsRunning() { for member.IsRunning() {
t.Logf("setting up gofailpoint %q", f.Name())
err := member.Failpoints().Setup(triggerCtx, f.failpoint, "panic") err := member.Failpoints().Setup(triggerCtx, f.failpoint, "panic")
if err != nil { if err != nil {
t.Logf("gofailpoint setup failed: %v", err) 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 { if f.trigger != nil {
t.Logf("triggering gofailpoint")
err = f.trigger(triggerCtx, member) err = f.trigger(triggerCtx, member)
if err != nil { if err != nil {
t.Logf("triggering gofailpoint failed: %v", err) t.Logf("triggering gofailpoint failed: %v", err)
} }
} }
t.Logf("waiting for process to exist")
err = member.Wait(triggerCtx) err = member.Wait(triggerCtx)
if err != nil && !strings.Contains(err.Error(), "unexpected exit code") { 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) err := member.Start(ctx)