We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 79e136a commit ef95d68Copy full SHA for ef95d68
pkg/kv/kvclient/kvcoord/dist_sender_test.go
@@ -2072,6 +2072,11 @@ func TestGetFirstRangeDescriptor(t *testing.T) {
2072
node.Gossip.EnableSimulationCycler(false)
2073
}
2074
n.Start()
2075
+ // Make sure the first two nodes are connected via gossip.
2076
+ n.SimulateNetwork(func(_ int, _ *simulation.Network) bool { return false })
2077
+ <-n.Nodes[0].Gossip.Connected
2078
+ <-n.Nodes[1].Gossip.Connected
2079
+
2080
ds := NewDistSender(DistSenderConfig{
2081
AmbientCtx: log.MakeTestingAmbientContext(stopper.Tracer()),
2082
NodeDescs: n.Nodes[0].Gossip,
0 commit comments