investigate #922

tests/StackExchange.Redis.Tests/ConnectingFailDetection.cs

@@ -111,5 +111,37 @@ public void ConnectsWhenBeginConnectCompletesSynchronously()
                 ClearAmbientFailures();
             }
         }
+
+        [Fact]
+        public void Issue922_ReconnectRaised()
+        {
+            var config = ConfigurationOptions.Parse(TestConfig.Current.MasterServerAndPort);
+            config.AbortOnConnectFail = true;
+            config.KeepAlive = 10;
+            config.SyncTimeout = 1000;
+            config.ReconnectRetryPolicy = new ExponentialRetry(5000);
+            config.AllowAdmin = true;
+
+            int failCount = 0, restoreCount = 0;
+
+            using (var muxer = ConnectionMultiplexer.Connect(config))
+            {
+                muxer.ConnectionFailed += delegate { Interlocked.Increment(ref failCount); };
+                muxer.ConnectionRestored += delegate { Interlocked.Increment(ref restoreCount); };
+
+                var db = muxer.GetDatabase();
+                db.Ping();
+                Assert.Equal(0, Volatile.Read(ref failCount));
+                Assert.Equal(0, Volatile.Read(ref restoreCount));
+
+                var server = muxer.GetServer(TestConfig.Current.MasterServerAndPort);
+                server.SimulateConnectionFailure();
+                Thread.Sleep(1000);
+
+                db.Ping(); // interactive+subscriber = 2
+                Assert.Equal(2, Volatile.Read(ref failCount));
+                Assert.Equal(2, Volatile.Read(ref restoreCount));
+            }
+        }
     }
 }