Update RedisStats to include Retry Counts and Resets

Author: mythz

src/ServiceStack.Redis/RedisConfig.cs

@@ -44,5 +44,29 @@ public class RedisConfig
         //Example at: http://msdn.microsoft.com/en-us/library/office/dd633677(v=exchg.80).aspx 
         public static LocalCertificateSelectionCallback CertificateSelectionCallback { get; set; }
         public static RemoteCertificateValidationCallback CertificateValidationCallback { get; set; }
+
+        /// <summary>
+        /// Resets Redis Config and Redis Stats back to default values
+        /// </summary>
+        public static void Reset()
+        {
+            RedisStats.Reset();
+
+            DefaultConnectTimeout = 0;
+            DefaultSendTimeout = -1;
+            DefaultReceiveTimeout = -1;
+            DefaultRetryTimeout = 3 * 1000;
+            DefaultIdleTimeOutSecs = 240;
+            BackOffMultiplier = 10;
+            BufferLength = 1450;
+            BufferPoolMaxSize = 500000;
+            VerifyMasterConnections = true;
+            HostLookupTimeoutMs = 200;
+            AssumeServerVersion = null;
+            DeactivatedClientsExpiry = TimeSpan.FromMinutes(1);
+            DisableVerboseLogging = false;
+            CertificateSelectionCallback = null;
+            CertificateValidationCallback = null;
+        }
     }
 }

src/ServiceStack.Redis/RedisState.cs

@@ -24,6 +24,9 @@ internal static class RedisState
         internal static long TotalClientsCreatedOutsidePool = 0;
         internal static long TotalSubjectiveServersDown = 0;
         internal static long TotalObjectiveServersDown = 0;
+        internal static long TotalRetryCount = 0;
+        internal static long TotalRetrySuccess = 0;
+        internal static long TotalRetryTimedout = 0;
 
         internal static readonly ConcurrentDictionary<RedisClient, DateTime> DeactivatedClients = new ConcurrentDictionary<RedisClient, DateTime>();
 

src/ServiceStack.Redis/RedisStats.cs

@@ -7,52 +7,84 @@ public static class RedisStats
     {
         public static long TotalFailovers
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalFailovers, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalFailovers); }
         }
 
         public static long TotalDeactivatedClients
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalDeactivatedClients, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalDeactivatedClients); }
         }
 
         public static long TotalFailedSentinelWorkers
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalFailedSentinelWorkers, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalFailedSentinelWorkers); }
         }
 
         public static long TotalForcedMasterFailovers
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalForcedMasterFailovers, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalForcedMasterFailovers); }
         }
 
         public static long TotalInvalidMasters
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalInvalidMasters, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalInvalidMasters); }
         }
 
         public static long TotalNoMastersFound
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalNoMastersFound, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalNoMastersFound); }
         }
 
         public static long TotalClientsCreated
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalClientsCreated, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalClientsCreated); }
         }
 
         public static long TotalClientsCreatedOutsidePool
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalClientsCreatedOutsidePool, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalClientsCreatedOutsidePool); }
         }
 
         public static long TotalSubjectiveServersDown
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalSubjectiveServersDown, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalSubjectiveServersDown); }
         }
 
         public static long TotalObjectiveServersDown
         {
-            get { return Interlocked.CompareExchange(ref RedisState.TotalObjectiveServersDown, 0, 0); }
+            get { return Interlocked.Read(ref RedisState.TotalObjectiveServersDown); }
+        }
+
+        public static long TotalRetryCount
+        {
+            get { return Interlocked.Read(ref RedisState.TotalRetryCount); }
+        }
+
+        public static long TotalRetrySuccess
+        {
+            get { return Interlocked.Read(ref RedisState.TotalRetrySuccess); }
+        }
+
+        public static long TotalRetryTimedout
+        {
+            get { return Interlocked.Read(ref RedisState.TotalRetryTimedout); }
+        }
+
+        public static void Reset()
+        {
+            Interlocked.Exchange(ref RedisState.TotalFailovers, 0);
+            Interlocked.Exchange(ref RedisState.TotalDeactivatedClients, 0);
+            Interlocked.Exchange(ref RedisState.TotalFailedSentinelWorkers, 0);
+            Interlocked.Exchange(ref RedisState.TotalForcedMasterFailovers, 0);
+            Interlocked.Exchange(ref RedisState.TotalInvalidMasters, 0);
+            Interlocked.Exchange(ref RedisState.TotalNoMastersFound, 0);
+            Interlocked.Exchange(ref RedisState.TotalClientsCreated, 0);
+            Interlocked.Exchange(ref RedisState.TotalClientsCreatedOutsidePool, 0);
+            Interlocked.Exchange(ref RedisState.TotalSubjectiveServersDown, 0);
+            Interlocked.Exchange(ref RedisState.TotalObjectiveServersDown, 0);
+            Interlocked.Exchange(ref RedisState.TotalRetryCount, 0);
+            Interlocked.Exchange(ref RedisState.TotalRetrySuccess, 0);
+            Interlocked.Exchange(ref RedisState.TotalRetryTimedout, 0);
         }
 
         public static Dictionary<string, long> ToDictionary()
@@ -70,6 +102,9 @@ public static Dictionary<string, long> ToDictionary()
                 {"TotalSubjectiveServersDown", TotalSubjectiveServersDown},
                 {"TotalObjectiveServersDown", TotalObjectiveServersDown},
                 {"TotalPendingDeactivatedClients", RedisState.DeactivatedClients.Count },
+                {"TotalRetryCount", TotalRetryCount },
+                {"TotalRetrySuccess", TotalRetrySuccess },
+                {"TotalRetryTimedout", TotalRetryTimedout },
             };
         }
     }