Add fallback for missing INFO command for Twemproxy

Author: mythz

src/ServiceStack.Redis/RedisNativeClient_Utils.cs

@@ -26,6 +26,7 @@ public partial class RedisNativeClient
     {
         private static Timer UsageTimer;
         private static int __requestsPerHour = 0;
+        private const int Unknown = -1;
         public int ServerVersionNumber { get; set; }
 
         public static void DisposeTimers()
@@ -91,7 +92,7 @@ private void Connect()
                     if (ServerVersionNumber == 0)
                     {
                         var parts = ServerVersion.Split('.');
-                        var version = int.Parse(parts[0]) * 1000;
+                        var version = int.Parse(parts[0])*1000;
                         if (parts.Length > 1)
                             version += int.Parse(parts[1])*100;
                         if (parts.Length > 2)
@@ -100,7 +101,14 @@ private void Connect()
                         ServerVersionNumber = version;
                     }
                 }
-                catch {}
+                catch (Exception)
+                {
+                    //Twemproxy doesn't support the INFO command so automatically closes the socket
+                    //Fallback to ServerVersionNumber=Unknown then try re-connecting
+                    ServerVersionNumber = Unknown;
+                    Connect();
+                    return;
+                }
 
                 var ipEndpoint = socket.LocalEndPoint as IPEndPoint;
                 clientPort = ipEndpoint != null ? ipEndpoint.Port : -1;

tests/ServiceStack.Redis.Tests/ServiceStack.Redis.Tests.csproj

@@ -274,6 +274,7 @@
     <Compile Include="RedisPersistenceProviderTests.cs" />
     <Compile Include="ShippersExample.cs" />
     <Compile Include="TestData\PopulateTestData.cs" />
+    <Compile Include="TwemproxyTests.cs" />
     <Compile Include="UserSessionRedisClientTests.cs" />
     <Compile Include="ValueTypeExamples.cs" />
     <Compile Include="QueueTests.cs" />

tests/ServiceStack.Redis.Tests/TwemproxyTests.cs

@@ -0,0 +1,22 @@
+using NUnit.Framework;
+using ServiceStack.Text;
+
+namespace ServiceStack.Redis.Tests
+{
+    [TestFixture, Explicit]
+    public class TwemproxyTests
+    {
+        [Test]
+        public void Can_connect_to_twemproxy()
+        {
+            var redis = new RedisClient("10.0.0.14", 22121) {
+                //ServerVersionNumber = 2611
+            };
+            //var redis = new RedisClient("10.0.0.14");
+            redis.SetEntry("foo", "bar");
+            var foo = redis.GetEntry("foo");
+
+            Assert.That(foo, Is.EqualTo("bar"));
+        }
+    }
+}