[tests] Update peer bootstrapper new cluster integration test (#3282)

src/dbnode/integration/integration.go

@@ -256,7 +256,7 @@ func NewDefaultBootstrappableTestSetups( // nolint:gocyclo
 		case bootstrapper.NoOpNoneBootstrapperName:
 			finalBootstrapper = bootstrapper.NewNoOpNoneBootstrapperProvider()
 		case uninitialized.UninitializedTopologyBootstrapperName:
-			uninitialized.NewUninitializedTopologyBootstrapperProvider(
+			finalBootstrapper = uninitialized.NewUninitializedTopologyBootstrapperProvider(
 				uninitialized.NewOptions().
 					SetInstrumentOptions(instrumentOpts), nil)
 		default:

src/dbnode/integration/peers_bootstrap_none_available_test.go

@@ -23,18 +23,18 @@
 package integration
 
 import (
-	"sync"
 	"testing"
 	"time"
 
+	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
 	"github.com/m3db/m3/src/cluster/services"
 	"github.com/m3db/m3/src/cluster/shard"
 	"github.com/m3db/m3/src/dbnode/namespace"
 	"github.com/m3db/m3/src/dbnode/retention"
 	"github.com/m3db/m3/src/dbnode/sharding"
-	"github.com/m3db/m3/src/dbnode/storage/bootstrap/bootstrapper"
+	"github.com/m3db/m3/src/dbnode/storage/bootstrap/bootstrapper/uninitialized"
 	"github.com/m3db/m3/src/dbnode/topology"
 	"github.com/m3db/m3/src/dbnode/topology/testutil"
 	xtest "github.com/m3db/m3/src/x/test"
@@ -94,37 +94,26 @@ func TestPeersBootstrapNoneAvailable(t *testing.T) {
 		{
 			DisablePeersBootstrapper: false,
 			TopologyInitializer:      topoInit,
-			FinalBootstrapper:        bootstrapper.NoOpAllBootstrapperName,
+			FinalBootstrapper:        uninitialized.UninitializedTopologyBootstrapperName,
 		},
 		{
 			DisablePeersBootstrapper: false,
 			TopologyInitializer:      topoInit,
-			FinalBootstrapper:        bootstrapper.NoOpAllBootstrapperName,
+			FinalBootstrapper:        uninitialized.UninitializedTopologyBootstrapperName,
 		},
 	}
 	setups, closeFn := NewDefaultBootstrappableTestSetups(t, opts, setupOpts)
 	defer closeFn()
 
-	serversAreUp := &sync.WaitGroup{}
-	serversAreUp.Add(2)
-
-	// Start both servers "simultaneously"
-	go func() {
-		if err := setups[0].StartServer(); err != nil {
-			panic(err)
-		}
-		serversAreUp.Done()
-	}()
-	go func() {
-		if err := setups[1].StartServer(); err != nil {
-			panic(err)
-		}
-		serversAreUp.Done()
-	}()
-
-	serversAreUp.Wait()
+	setups.parallel(func(s TestSetup) {
+		s.StartServer()
+	})
 	log.Debug("servers are now up")
 
+	for i, s := range setups {
+		assert.True(t, s.ServerIsBootstrapped(), "setups[%v] should be bootstrapped", i)
+	}
+
 	// Stop the servers
 	defer func() {
 		setups.parallel(func(s TestSetup) {