Commit f5f9b140 authored by Nick Craver's avatar Nick Craver

Tests: Better logging on cluster, so we can figure out what's happening on Appveyor

parent 09b6613f
......@@ -65,15 +65,34 @@ public void CanGetTotalStats()
}
}
private void PrintEndpoints(EndPoint[] endpoints)
{
Output.WriteLine($"Endpoints Expected: {TestConfig.Current.ClusterStartPort}+{TestConfig.Current.ClusterServerCount}");
Output.WriteLine("Endpoints Found:");
foreach (var endpoint in endpoints)
{
Output.WriteLine(" Endpoint: " + endpoint);
}
}
[Fact]
public void Connect()
{
using (var muxer = Create())
var expectedPorts = new HashSet<int>(Enumerable.Range(TestConfig.Current.ClusterStartPort, TestConfig.Current.ClusterServerCount));
using (var sw = new StringWriter())
using (var muxer = Create(log: sw))
{
var endpoints = muxer.GetEndPoints();
if (TestConfig.Current.ClusterServerCount != endpoints.Length)
{
PrintEndpoints(endpoints);
}
else
{
Output.WriteLine(sw.ToString());
}
Assert.Equal(TestConfig.Current.ClusterServerCount, endpoints.Length);
var expectedPorts = new HashSet<int>(Enumerable.Range(TestConfig.Current.ClusterStartPort, TestConfig.Current.ClusterServerCount));
int masters = 0, slaves = 0;
var failed = new List<EndPoint>();
foreach (var endpoint in endpoints)
......@@ -428,7 +447,8 @@ public void SScan()
[Fact]
public void GetConfig()
{
using (var muxer = Create(allowAdmin: true))
using (var sw = new StringWriter())
using (var muxer = Create(allowAdmin: true, log: sw))
{
var endpoints = muxer.GetEndPoints();
var server = muxer.GetServer(endpoints[0]);
......@@ -444,6 +464,8 @@ public void GetConfig()
{
Output.WriteLine(node.ToString());
}
Output.WriteLine(sw.ToString());
Assert.Equal(TestConfig.Current.ClusterServerCount, endpoints.Length);
Assert.Equal(TestConfig.Current.ClusterServerCount, nodes.Nodes.Count);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment