Add logging when clients are failed over

Author: mythz

src/ServiceStack.Redis/BasicRedisClientManager.cs

@@ -12,18 +12,22 @@
 
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
+using ServiceStack.Logging;
 using ServiceStack.Text;
 
 namespace ServiceStack.Redis
 {
     /// <summary>
-    /// Provides thread-safe retrievel of redis clients since each client is a new one.
+    /// Provides thread-safe retrieval of redis clients since each client is a new one.
     /// Allows the configuration of different ReadWrite and ReadOnly hosts
     /// </summary>
     public partial class BasicRedisClientManager
         : IRedisClientsManager, IRedisFailover, IHasRedisResolver
     {
+        public static ILog Log = LogManager.GetLogger(typeof(BasicRedisClientManager));
+        
         public int? ConnectTimeout { get; set; }
         public int? SocketSendTimeout { get; set; }
         public int? SocketReceiveTimeout { get; set; }
@@ -154,10 +158,15 @@ public void FailoverTo(IEnumerable<string> readWriteHosts, IEnumerable<string> r
         {
             Interlocked.Increment(ref RedisState.TotalFailovers);
 
+            var masters = readWriteHosts.ToList();
+            var replicas = readOnlyHosts.ToList();
+
+            Log.Info($"FailoverTo: {string.Join(",", masters)} : {string.Join(",", replicas)} Total: {RedisState.TotalFailovers}");
+            
             lock (this)
             {
-                RedisResolver.ResetMasters(readWriteHosts);
-                RedisResolver.ResetSlaves(readOnlyHosts);
+                RedisResolver.ResetMasters(masters);
+                RedisResolver.ResetSlaves(replicas);
             }
 
             Start();

src/ServiceStack.Redis/PooledRedisClientManager.cs

@@ -160,6 +160,11 @@ public void FailoverTo(IEnumerable<string> readWriteHosts, IEnumerable<string> r
         {
             Interlocked.Increment(ref RedisState.TotalFailovers);
 
+            var masters = readWriteHosts.ToList();
+            var replicas = readOnlyHosts.ToList();
+
+            Log.Info($"FailoverTo: {string.Join(",", masters)} : {string.Join(",", replicas)} Total: {RedisState.TotalFailovers}");
+
             lock (readClients)
             {
                 for (var i = 0; i < readClients.Length; i++)
@@ -170,7 +175,7 @@ public void FailoverTo(IEnumerable<string> readWriteHosts, IEnumerable<string> r
 
                     readClients[i] = null;
                 }
-                RedisResolver.ResetSlaves(readOnlyHosts);
+                RedisResolver.ResetSlaves(replicas);
             }
 
             lock (writeClients)
@@ -183,7 +188,7 @@ public void FailoverTo(IEnumerable<string> readWriteHosts, IEnumerable<string> r
 
                     writeClients[i] = null;
                 }
-                RedisResolver.ResetMasters(readWriteHosts);
+                RedisResolver.ResetMasters(masters);
             }
 
             if (this.OnFailover != null)

src/ServiceStack.Redis/RedisManagerPool.cs

@@ -94,6 +94,8 @@ public void FailoverTo(params string[] readWriteHosts)
         {
             Interlocked.Increment(ref RedisState.TotalFailovers);
 
+            Log.Info($"FailoverTo: {string.Join(",", readWriteHosts)} Total: {RedisState.TotalFailovers}");
+            
             lock (clients)
             {
                 for (var i = 0; i < clients.Length; i++)