Skip to content
This repository was archived by the owner on Dec 24, 2022. It is now read-only.

Commit 1d9acf5

Browse files
committed
skip if there's nothing to write
1 parent 8dc69c6 commit 1d9acf5

File tree

1 file changed

+17
-14
lines changed

1 file changed

+17
-14
lines changed

src/ServiceStack.Redis/RedisNativeClient_Utils.cs

Lines changed: 17 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -392,23 +392,26 @@ public bool FlushSendBuffer()
392392
if (currentBufferIndex > 0)
393393
PushCurrentBuffer();
394394

395-
if (!Env.IsMono && sslStream == null)
395+
if (cmdBuffer.Count > 0)
396396
{
397-
socket.Send(cmdBuffer); //Optimized for Windows
398-
}
399-
else
400-
{
401-
//Sendling IList<ArraySegment> Throws 'Message to Large' SocketException in Mono
402-
foreach (var segment in cmdBuffer)
397+
if (!Env.IsMono && sslStream == null)
403398
{
404-
var buffer = segment.Array;
405-
if (sslStream == null)
406-
{
407-
socket.Send(buffer, segment.Offset, segment.Count, SocketFlags.None);
408-
}
409-
else
399+
socket.Send(cmdBuffer); //Optimized for Windows
400+
}
401+
else
402+
{
403+
//Sendling IList<ArraySegment> Throws 'Message to Large' SocketException in Mono
404+
foreach (var segment in cmdBuffer)
410405
{
411-
sslStream.Write(buffer, segment.Offset, segment.Count);
406+
var buffer = segment.Array;
407+
if (sslStream == null)
408+
{
409+
socket.Send(buffer, segment.Offset, segment.Count, SocketFlags.None);
410+
}
411+
else
412+
{
413+
sslStream.Write(buffer, segment.Offset, segment.Count);
414+
}
412415
}
413416
}
414417
}

0 commit comments

Comments
 (0)