Avoid calling t.Fatalf from goroutine
This commit is contained in:
parent
647b036ed1
commit
8a655b8566
|
@ -11,6 +11,7 @@ package sequencer
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"fmt"
|
||||||
"testing"
|
"testing"
|
||||||
mathrand "math/rand/v2"
|
mathrand "math/rand/v2"
|
||||||
"time"
|
"time"
|
||||||
|
@ -23,7 +24,7 @@ func TestSequencerBasic(t *testing.T) {
|
||||||
for i := range uint64(10_000) {
|
for i := range uint64(10_000) {
|
||||||
err := seq.Add(ctx, i, &i)
|
err := seq.Add(ctx, i, &i)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("%d: seq.Add returned unexpected error %v", i, err)
|
panic(fmt.Sprintf("%d: seq.Add returned unexpected error %v", i, err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
@ -46,7 +47,7 @@ func TestSequencerNonZeroStart(t *testing.T) {
|
||||||
for i := range uint64(10_000) {
|
for i := range uint64(10_000) {
|
||||||
err := seq.Add(ctx, i+10, &i)
|
err := seq.Add(ctx, i+10, &i)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("%d: seq.Add returned unexpected error %v", i, err)
|
panic(fmt.Sprintf("%d: seq.Add returned unexpected error %v", i, err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
@ -69,7 +70,7 @@ func TestSequencerCapacity1(t *testing.T) {
|
||||||
for i := range uint64(10_000) {
|
for i := range uint64(10_000) {
|
||||||
err := seq.Add(ctx, i, &i)
|
err := seq.Add(ctx, i, &i)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("%d: seq.Add returned unexpected error %v", i, err)
|
panic(fmt.Sprintf("%d: seq.Add returned unexpected error %v", i, err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
@ -130,7 +131,7 @@ func TestSequencerOutOfOrder(t *testing.T) {
|
||||||
//t.Logf("seq.Add %d", i)
|
//t.Logf("seq.Add %d", i)
|
||||||
err := seq.Add(ctx, i, &i)
|
err := seq.Add(ctx, i, &i)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("%d: seq.Add returned unexpected error %v", i, err)
|
panic(fmt.Sprintf("%d: seq.Add returned unexpected error %v", i, err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
Loading…
Reference in New Issue