ServiceStack · mythz · Mar 22, 2014 · Mar 21, 2014
diff --git a/src/ServiceStack.Redis/RedisNativeClient_Utils.cs b/src/ServiceStack.Redis/RedisNativeClient_Utils.cs
@@ -199,22 +199,15 @@ protected bool SendCommand(params byte[][] cmdWithBinaryArgs)
         {
             if (!AssertConnectedSocket()) return false;
 
-            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)
-                    FlushSendBuffer();
-            }
-            catch (SocketException ex)
-            {
-                cmdBuffer.Clear();
-                return HandleSocketException(ex);
-            }
+            //pipeline will handle flush, if pipelining is turned on
+            if (Pipeline == null)
+                return FlushSendBuffer();
+
             return true;
         }
 
@@ -271,27 +264,35 @@ private void PushCurrentBuffer()
             currentBufferIndex = 0;
         }
 
-        public void FlushSendBuffer()
-        {
-            if (currentBufferIndex > 0)
-                PushCurrentBuffer();
-
-            if (!Env.IsMono)
-            {
-                socket.Send(cmdBuffer); //Optimized for Windows
-            }
-            else
-            {
-                //Sendling IList<ArraySegment> Throws 'Message to La
8000
rge' SocketException in Mono
-                foreach (var segment in cmdBuffer)
-                {
-                    var buffer = segment.Array;
-                    socket.Send(buffer, segment.Offset, segment.Count, SocketFlags.None);
-                }
-            }
-            ResetSendBuffer();
-        }
-
+        public bool FlushSendBuffer()
+ 	{
+ 		try
+ 		{
+ 			if (currentBufferIndex > 0)
+ 				PushCurrentBuffer();
+
+ 			if (!Env.IsMono)
+ 			{
+ 				socket.Send(cmdBuffer); //Optimized for Windows
+ 			}
+ 			else
+ 			{
+ 			//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();
+ 		}
+ 		catch (SocketException ex)
+ 		{
+ 			cmdBuffer.Clear();
+ 			return HandleSocketException(ex);
+ 		}
+ 		return true;
+ 	}
         /// <summary>
         /// reset buffer index in send buffer
         /// </summary>
@@ -911,4 +912,4 @@ public void ScriptKill()
 
     }
 
-}
+}