vitalif
/
etcd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #15191 from serathius/linearizability-failpoints-timeout 

tests: Increase failpoint timeout and add more logs
dependabot/go_modules/go.uber.org/atomic-1.10.0
Marek Siarkowicz 2023-01-30 14:05:23 +01:00 committed by GitHub
parent b9b7c9328e 535ade8eb2
commit a8b6b05564
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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 (
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)