mirror of
https://github.com/status-im/consul.git
synced 2025-02-03 01:14:23 +00:00
Fix race condition in TestCatalogListNodes
This commit is contained in:
parent
76d9fa255b
commit
048b780d61
@ -212,13 +212,12 @@ func TestCatalogListNodes(t *testing.T) {
|
|||||||
// Just add a node
|
// Just add a node
|
||||||
s1.fsm.State().EnsureNode(1, structs.Node{"foo", "127.0.0.1"})
|
s1.fsm.State().EnsureNode(1, structs.Node{"foo", "127.0.0.1"})
|
||||||
|
|
||||||
if err := client.Call("Catalog.ListNodes", &args, &out); err != nil {
|
testutil.WaitForResult(func() (bool, error) {
|
||||||
|
client.Call("Catalog.ListNodes", &args, &out)
|
||||||
|
return len(out.Nodes) == 2, nil
|
||||||
|
}, func(err error) {
|
||||||
t.Fatalf("err: %v", err)
|
t.Fatalf("err: %v", err)
|
||||||
}
|
})
|
||||||
|
|
||||||
if len(out.Nodes) != 2 {
|
|
||||||
t.Fatalf("bad: %v", out)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Server node is auto added from Serf
|
// Server node is auto added from Serf
|
||||||
if out.Nodes[0].Node != s1.config.NodeName {
|
if out.Nodes[0].Node != s1.config.NodeName {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user