Commit 170bbca5 authored by Nick Craver's avatar Nick Craver

Tests: add DeslaveGoesToPrimary logging

parent 95271bbb
...@@ -71,13 +71,16 @@ public async Task DeslaveGoesToPrimary() ...@@ -71,13 +71,16 @@ public async Task DeslaveGoesToPrimary()
var ex = Assert.Throws<RedisConnectionException>(() => db.IdentifyEndpoint(key, CommandFlags.DemandSlave)); var ex = Assert.Throws<RedisConnectionException>(() => db.IdentifyEndpoint(key, CommandFlags.DemandSlave));
Assert.StartsWith("No connection is available to service this operation: EXISTS DeslaveGoesToPrimary", ex.Message); Assert.StartsWith("No connection is available to service this operation: EXISTS DeslaveGoesToPrimary", ex.Message);
Writer.WriteLine("Invoking MakeMaster()...");
primary.MakeMaster(ReplicationChangeOptions.Broadcast | ReplicationChangeOptions.EnslaveSubordinates | ReplicationChangeOptions.SetTiebreaker, Writer); primary.MakeMaster(ReplicationChangeOptions.Broadcast | ReplicationChangeOptions.EnslaveSubordinates | ReplicationChangeOptions.SetTiebreaker, Writer);
Writer.WriteLine("Finished MakeMaster() call.");
await Task.Delay(2000).ConfigureAwait(false); await Task.Delay(2000).ConfigureAwait(false);
Writer.WriteLine("Invoking Ping() (post-master)");
primary.Ping(); primary.Ping();
secondary.Ping(); secondary.Ping();
Writer.WriteLine("Finished Ping() (post-master)");
Assert.True(primary.IsConnected, $"{primary.EndPoint} is not connected."); Assert.True(primary.IsConnected, $"{primary.EndPoint} is not connected.");
Assert.True(secondary.IsConnected, $"{secondary.EndPoint} is not connected."); Assert.True(secondary.IsConnected, $"{secondary.EndPoint} is not connected.");
...@@ -87,6 +90,7 @@ public async Task DeslaveGoesToPrimary() ...@@ -87,6 +90,7 @@ public async Task DeslaveGoesToPrimary()
// Create a separate multiplexer with a valid view of the world to distinguish between failures of // Create a separate multiplexer with a valid view of the world to distinguish between failures of
// server topology changes from failures to recognize those changes // server topology changes from failures to recognize those changes
Writer.WriteLine("Connecting to secondary validation connection.");
using (var conn2 = ConnectionMultiplexer.Connect(config)) using (var conn2 = ConnectionMultiplexer.Connect(config))
{ {
var primary2 = conn.GetServer(TestConfig.Current.MasterServerAndPort); var primary2 = conn.GetServer(TestConfig.Current.MasterServerAndPort);
......
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