Browse Source

Wait for agent joins to finish in TestClient_RPC

pull/2440/head
Kyle Havlovitz 8 years ago
parent
commit
ae99f76763
  1. 17
      consul/client_test.go

17
consul/client_test.go

@ -343,17 +343,16 @@ func TestClient_RPC_TLS(t *testing.T) {
t.Fatalf("err: %v", err) t.Fatalf("err: %v", err)
} }
// Check the members // Wait for joins to finish/RPC to succeed
if len(s1.LANMembers()) != 2 { testutil.WaitForResult(func() (bool, error) {
t.Fatalf("bad len") if len(s1.LANMembers()) != 2 {
} return false, fmt.Errorf("bad len: %v", len(s1.LANMembers()))
}
if len(c1.LANMembers()) != 2 { if len(c1.LANMembers()) != 2 {
t.Fatalf("bad len") return false, fmt.Errorf("bad len: %v", len(c1.LANMembers()))
} }
// RPC should succeed
testutil.WaitForResult(func() (bool, error) {
err := c1.RPC("Status.Ping", struct{}{}, &out) err := c1.RPC("Status.Ping", struct{}{}, &out)
return err == nil, err return err == nil, err
}, func(err error) { }, func(err error) {

Loading…
Cancel
Save