Merge pull request #2834 from EventStore/fix-tcp-regression

Fix regression in TCP connection

Author: YoEight

src/EventStore.Transport.Tcp/TcpConnection.cs

@@ -11,7 +11,7 @@
 
 namespace EventStore.Transport.Tcp {
 	public class TcpConnection : TcpConnectionBase, ITcpConnection {
-		internal const int MaxSendPacketSize = 64 * 1024;
+		internal const int MaxSendPacketSize = 65535 /*Max IP packet size*/ - 20 /*IP packet header size*/ - 32 /*TCP min header size*/;
 
 		internal static readonly BufferManager BufferManager =
 			new BufferManager(TcpConfiguration.BufferChunksCount, TcpConfiguration.SocketBufferSize);
@@ -151,7 +151,7 @@ private void TrySend() {
 			try {
 				do {
 					lock (_sendLock) {
-						if (_isSending || _sendQueue.IsEmpty || _sendSocketArgs == null) return;
+						if (_isSending || (_sendQueue.IsEmpty && _memoryStreamOffset >= _memoryStream.Length) || _sendSocketArgs == null) return;
 						if (TcpConnectionMonitor.Default.IsSendBlocked()) return;
 						_isSending = true;
 					}

src/EventStore.Transport.Tcp/TcpConnectionSsl.cs

@@ -345,7 +345,7 @@ private void TrySend() {
 			try {
 				do {
 					lock (_streamLock) {
-						if (_isSending || _sendQueue.IsEmpty || _sslStream == null || !_isAuthenticated) return;
+						if (_isSending || (_sendQueue.IsEmpty && _memoryStreamOffset >= _memoryStream.Length) || _sslStream == null || !_isAuthenticated) return;
 						if (TcpConnectionMonitor.Default.IsSendBlocked()) return;
 						_isSending = true;
 					}