AssertServerVersionNumber is called for ops requiring version detection

Author: mythz

src/ServiceStack.Redis/RedisClient.ICacheClient.cs

@@ -121,7 +121,7 @@ public bool Set<T>(string key, T value, TimeSpan expiresIn)
             var bytesValue = value as byte[];
             if (bytesValue != null)
             {
-                if (ServerVersionNumber >= 2600)
+                if (AssertServerVersionNumber() >= 2600)
                 {
                     Exec(r => r.PSetEx(key, (long)expiresIn.TotalMilliseconds, bytesValue));
                 }

src/ServiceStack.Redis/RedisClient.cs

@@ -136,7 +136,7 @@ public void SetEntry(string key, string value, TimeSpan expireIn)
                 ? value.ToUtf8Bytes()
                 : null;
 
-            if (ServerVersionNumber >= 2610)
+            if (AssertServerVersionNumber() >= 2610)
             {
                 if (expireIn.Milliseconds > 0)
                     base.Set(key, bytesValue, 0, (long)expireIn.TotalMilliseconds);
@@ -331,7 +331,7 @@ public string GetRandomKey()
 
         public bool ExpireEntryIn(string key, TimeSpan expireIn)
         {
-            if (ServerVersionNumber >= 2600)
+            if (AssertServerVersionNumber() >= 2600)
             {
                 if (expireIn.Milliseconds > 0)
                 {
@@ -344,7 +344,7 @@ public bool ExpireEntryIn(string key, TimeSpan expireIn)
 
         public bool ExpireEntryAt(string key, DateTime expireAt)
         {
-            if (ServerVersionNumber >= 2600)
+            if (AssertServerVersionNumber() >= 2600)
             {
                 return PExpireAt(key, ConvertToServerDate(expireAt).ToUnixTimeMs());
             }
@@ -416,6 +416,7 @@ public IDisposable AcquireLock(string key, TimeSpan timeOut)
 
         public IRedisTransaction CreateTransaction()
         {
+            AssertServerVersionNumber(); // pre-fetch call to INFO before transaction if needed
             return new RedisTransaction(this);
         }
 

src/ServiceStack.Redis/RedisNativeClient_Utils.cs

@@ -29,6 +29,14 @@ public partial class RedisNativeClient
         private const int Unknown = -1;
         public int ServerVersionNumber { get; set; }
 
+        public int AssertServerVersionNumber()
+        {
+            if (ServerVersionNumber == 0)
+                AssertConnectedSocket();
+
+            return ServerVersionNumber;
+        }
+
         public static void DisposeTimers()
         {
             if (UsageTimer == null) return;
@@ -163,7 +171,7 @@ public bool IsSocketConnected()
             return !(part1 & part2);
         }
 
-        private bool AssertConnectedSocket()
+        internal bool AssertConnectedSocket()
         {
             if (LastConnectedAtTimestamp > 0)
             {