Quick fix in client, commented console output in server...

Author: EvilLord666

TinyTcpServer/TinyTcpServer.Core.FunctionalTests/TestUtils/NetworkClient.cs

@@ -223,14 +223,14 @@ private Boolean WriteAsync(Byte[] data)
                 while (_bytesSend < data.Length)
                 {
                     _writeCompleted.Reset();
-                    Int32 offset = _bytesSend;
-                    Int32 size = Math.Min(MaximumPacketSize, data.Length - _bytesSend);
-                    lock (_synch)
+                    //Int32 offset = _bytesSend;
+                    //Int32 size = Math.Min(MaximumPacketSize, data.Length - _bytesSend);
+/*                    lock (_synch)
                     {
                         _clientSocket.BeginSend(data, offset, size, SocketFlags.Partial, WriteAsyncCallback,  _clientSocket);
-                    }
-                    //lock (_synch)
-                    //_clientSocket.BeginSend(data, 0, data.Length, SocketFlags.None, WriteAsyncCallback, _clientSocket);
+                    }*/
+                    lock (_synch)
+                        _clientSocket.BeginSend(data, 0, data.Length, SocketFlags.None, WriteAsyncCallback, _clientSocket);
                     _writeCompleted.Wait(_writeTimeout);
                 }
                 Console.WriteLine("[Client, WriteAsync] write done, bytes written: " + _bytesSend);

TinyTcpServer/TinyTcpServer.Core/Server/TcpServer.cs

@@ -167,7 +167,7 @@ private void StartClientProcessing()
                                 if (freeTaskIndex >= 0)
                                 {
                                     _tcpClients[clientCounter].IsProcessing = true;
-                                    Console.WriteLine("[Server, StartClientProcessing] Starting task 4 IO with client");
+                                    //Console.WriteLine("[Server, StartClientProcessing] Starting task 4 IO with client");
                                     _clientProcessingTasks[freeTaskIndex] = new Task(() => ProcessClientReceiveSend(client), new CancellationToken(_interruptRequested));
                                     _clientProcessingTasks[freeTaskIndex].Start();
                                 }
@@ -188,7 +188,7 @@ private void StartClientProcessing()
 
         private void ClientConnectProcessing()
         {
-            Console.WriteLine("[Server, ClientConnectProcessing]waiting 4 clients");
+            //Console.WriteLine("[Server, ClientConnectProcessing]waiting 4 clients");
             Int32 clientsNumber = _tcpClients.Count;
             for (Int32 attempt = 0; attempt < _clientConnectAttempts; attempt++)
             {
@@ -236,7 +236,7 @@ private Boolean CheckClientConnected(TcpClient client, Boolean formalCheck = fal
 
         private void ProcessClientReceiveSend(TcpClientContext client)
         {
-            Console.WriteLine("[Server ProcessClientReceiveSend] IO with client");
+            //Console.WriteLine("[Server ProcessClientReceiveSend] IO with client");
             Byte[] receivedData = ReceiveImpl(client);
             if (receivedData != null)
             {
@@ -246,7 +246,7 @@ private void ProcessClientReceiveSend(TcpClientContext client)
                     //todo: umv: add special selection for AnyPort and AnyIp
                     return TcpClientHandlerSelector.Select(item.Item1, client);
                 }).ToList();
-                Console.WriteLine("[Server ProcessClientReceiveSend] found {0} handlers", linkedHandlers.Count);
+                //Console.WriteLine("[Server ProcessClientReceiveSend] found {0} handlers", linkedHandlers.Count);
                 foreach (Tuple<TcpClientHandlerInfo, Func<Byte[], TcpClientHandlerInfo, Byte[]>> handler in linkedHandlers)
                 {
                     Byte[] dataForSend = handler.Item2(receivedData, handler.Item1);
@@ -264,7 +264,7 @@ private Byte[] ReceiveImpl(TcpClientContext client)
 
             try
             {
-                Console.WriteLine("[Server ReceiveImpl] waiting 4 data");
+                //Console.WriteLine("[Server ReceiveImpl] waiting 4 data");
 
                 for (Int32 attempt = 0; attempt < _clientReadAttempts; attempt++)
                 {
@@ -300,7 +300,7 @@ private Byte[] ReceiveImpl(TcpClientContext client)
                     }
                 }
                 Array.Resize(ref buffer, client.BytesRead);
-                Console.WriteLine("[SERVER, ReceiveImpl] Read bytes: " + client.BytesRead);
+                //Console.WriteLine("[SERVER, ReceiveImpl] Read bytes: " + client.BytesRead);
             }
             catch (Exception)
             {
@@ -325,13 +325,13 @@ private void SendImpl(TcpClientContext client, Byte[] data)
         {
             try
             {
-                Console.WriteLine("[Server, SendImpl] Write started");
+                //Console.WriteLine("[Server, SendImpl] Write started");
                 client.WriteDataEvent.Reset();
                 NetworkStream netStream = client.Client.GetStream();
                 lock (client.SynchObject)
                     netStream.BeginWrite(data, 0, data.Length, WriteAsyncCallback, client);
                 client.WriteDataEvent.Wait(_writeTimeout);
-                Console.WriteLine("[Server, SendImpl] Write done");
+                //Console.WriteLine("[Server, SendImpl] Write done");
             }
             catch (Exception)
             {
@@ -346,7 +346,7 @@ private void WriteAsyncCallback(IAsyncResult state)
             if (client == null)
                 throw new ApplicationException("state can't be null");
             client.Client.GetStream().EndWrite(state);
-            Console.WriteLine("[Server, WriteAsyncCallback] Write done!");
+            //Console.WriteLine("[Server, WriteAsyncCallback] Write done!");
             client.WriteDataEvent.Set();
         }