forked from Ivasoft/traefik
Fatalf for timeout cases.
This commit is contained in:
@@ -264,6 +264,7 @@ func TestKvWatchTree(t *testing.T) {
|
|||||||
<-configChan
|
<-configChan
|
||||||
close(c1) // WatchTree chans can close due to error
|
close(c1) // WatchTree chans can close due to error
|
||||||
case <-time.After(1 * time.Second):
|
case <-time.After(1 * time.Second):
|
||||||
|
t.Fatalf("Failed to create a new WatchTree chan")
|
||||||
}
|
}
|
||||||
|
|
||||||
select {
|
select {
|
||||||
@@ -271,6 +272,7 @@ func TestKvWatchTree(t *testing.T) {
|
|||||||
c2 <- []*store.KVPair{}
|
c2 <- []*store.KVPair{}
|
||||||
<-configChan
|
<-configChan
|
||||||
case <-time.After(1 * time.Second):
|
case <-time.After(1 * time.Second):
|
||||||
|
t.Fatalf("Failed to create a new WatchTree chan")
|
||||||
}
|
}
|
||||||
|
|
||||||
select {
|
select {
|
||||||
|
|||||||
Reference in New Issue
Block a user