match v3 commit to recover from redis-server restarts

Author: mythz

src/ServiceStack.Redis/RedisNativeClient_Utils.cs

@@ -248,22 +248,15 @@ protected bool SendCommand(params byte[][] cmdWithBinaryArgs)
             if (__requestsPerHour % 20 == 0)
                 LicenseUtils.AssertValidUsage(LicenseFeature.Redis, QuotaType.RequestsPerHour, __requestsPerHour);
 
-            try
-            {
-                CmdLog(cmdWithBinaryArgs);
+            CmdLog(cmdWithBinaryArgs);
 
-                //Total command lines count
-                WriteAllToSendBuffer(cmdWithBinaryArgs);
+            //Total command lines count
+            WriteAllToSendBuffer(cmdWithBinaryArgs);
+
+            //pipeline will handle flush, if pipelining is turned on
+            if (Pipeline == null)
+                return FlushSendBuffer();
 
-                //pipeline will handle flush, if pipelining is turned on
-                if (Pipeline == null)
-                    FlushSendBuffer();
-            }
-            catch (SocketException ex)
-            {
-                cmdBuffer.Clear();
-                return HandleSocketException(ex);
-            }
             return true;
         }
 
@@ -320,25 +313,34 @@ private void PushCurrentBuffer()
             currentBufferIndex = 0;
         }
 
-        public void FlushSendBuffer()
+        public bool FlushSendBuffer()
         {
-            if (currentBufferIndex > 0)
-                PushCurrentBuffer();
-
-            if (!Env.IsMono)
-            {
-                socket.Send(cmdBuffer); //Optimized for Windows
-            }
-            else
+            try
             {
-                //Sendling IList<ArraySegment> Throws 'Message to Large' SocketException in Mono
-                foreach (var segment in cmdBuffer)
+                if (currentBufferIndex > 0)
+                    PushCurrentBuffer();
+
+                if (!Env.IsMono)
+                {
+                    socket.Send(cmdBuffer); //Optimized for Windows
+                }
+                else
                 {
-                    var buffer = segment.Array;
-                    socket.Send(buffer, segment.Offset, segment.Count, SocketFlags.None);
+                    //Sendling IList<ArraySegment> Throws 'Message to Large' SocketException in Mono
+                    foreach (var segment in cmdBuffer)
+                    {
+                        var buffer = segment.Array;
+                        socket.Send(buffer, segment.Offset, segment.Count, SocketFlags.None);
+                    }
                 }
+                ResetSendBuffer();
             }
-            ResetSendBuffer();
+            catch (SocketException ex)
+            {
+                cmdBuffer.Clear();
+                return HandleSocketException(ex);
+            }
+            return true;
         }
 
         /// <summary>