diff --git a/pkg/cmd/roachtest/gossip.go b/pkg/cmd/roachtest/gossip.go index e097a6ce5593..aaca4c4f6d5c 100644 --- a/pkg/cmd/roachtest/gossip.go +++ b/pkg/cmd/roachtest/gossip.go @@ -32,8 +32,10 @@ import ( func registerGossip(r *testRegistry) { runGossipChaos := func(ctx context.Context, t *test, c *cluster) { + args := startArgs("--args=--vmodule=*=1") c.Put(ctx, cockroach, "./cockroach", c.All()) - c.Start(ctx, t, c.All()) + c.Start(ctx, t, c.All(), args) + waitForFullReplication(t, c.Conn(ctx, 1)) gossipNetwork := func(node int) string { const query = ` @@ -65,6 +67,7 @@ SELECT string_agg(source_id::TEXT || ':' || target_id::TEXT, ',') if i == deadNode { continue } + c.l.Printf("%d: checking gossip\n", i) s := gossipNetwork(i) if !initialized { deadNodeStr := fmt.Sprint(deadNode) @@ -88,7 +91,7 @@ SELECT string_agg(source_id::TEXT || ':' || target_id::TEXT, ',') return false } } - fmt.Printf("gossip ok: %s (%0.0fs)\n", expected, timeutil.Since(start).Seconds()) + c.l.Printf("gossip ok: %s (%0.0fs)\n", expected, timeutil.Since(start).Seconds()) return true } @@ -109,7 +112,7 @@ SELECT string_agg(source_id::TEXT || ':' || target_id::TEXT, ',') deadNode = nodes.randNode()[0] c.Stop(ctx, c.Node(deadNode)) waitForGossip() - c.Start(ctx, t, c.Node(deadNode)) + c.Start(ctx, t, c.Node(deadNode), args) } }