From 212628b2203d34fb25fd5f4bf7012ade4f0be2dc Mon Sep 17 00:00:00 2001 From: Travis Turner Date: Fri, 10 Nov 2017 11:38:16 -0600 Subject: [PATCH] adjust tests to include Cluster.ListenForJoins() --- cluster_test.go | 11 ----------- test/cluster.go | 7 +++++++ 2 files changed, 7 insertions(+), 11 deletions(-) diff --git a/cluster_test.go b/cluster_test.go index a51823993..1e5427df0 100644 --- a/cluster_test.go +++ b/cluster_test.go @@ -308,17 +308,6 @@ func TestCluster_Resize(t *testing.T) { // TestTestCluster ensures that general cluster functionality works as expected. func TestCluster_ResizeStates(t *testing.T) { - /* test conditions: - x- single node, no data, comes up in NORMAL with topology - x- single node, in topology, comes up NORMAL - x- single node, not in topology, raises error - x- two node, no data, comes up in NORMAL, with topology - x- two node, in topology, comes up NORMAL - x- two node, STARTING, not in topology, raises error - x- two node, NORMAL, not in topology, triggers resize - x- resize of nodes with data moves data appropriately - */ - t.Run("Single node, no data", func(t *testing.T) { tc := test.NewTestCluster(1) diff --git a/test/cluster.go b/test/cluster.go index e73289827..82c45aef6 100644 --- a/test/cluster.go +++ b/test/cluster.go @@ -255,6 +255,13 @@ func (t *TestCluster) Open() error { return err } } + + // Start the listener on the coordinator. + if len(t.Clusters) == 0 { + return nil + } + t.Clusters[0].ListenForJoins() + return nil }