Add debug log in network transfer.

Author: 10people

.gitignore

@@ -1,3 +1,4 @@
+/.vs/
 Backup/
 bin/
 obj/

nuget.config

@@ -1,3 +1,4 @@
+<?xml version="1.0" encoding="utf-8"?>
 <configuration>
     <config>
         <add key="repositoryPath" value="shadowsocks-csharp\3rd" />

shadowsocks-csharp/Controller/Service/TCPRelay.cs

@@ -215,6 +215,7 @@ private void HandshakeReceive()
                         response = new byte[] { 0, 91 };
                         Console.WriteLine("socks 5 protocol error");
                     }
+                    Logging.Debug($"======Send Local Port, size:" + response.Length);
                     connection.BeginSend(response, 0, response.Length, 0, new AsyncCallback(HandshakeSendCallback), null);
                 }
                 else
@@ -246,6 +247,7 @@ private void HandshakeSendCallback(IAsyncResult ar)
                 // +----+-----+-------+------+----------+----------+
                 // Skip first 3 bytes
                 // TODO validate
+                Logging.Debug($"======Receive Local Port, size:" + 3);
                 connection.BeginReceive(connetionRecvBuffer, 0, 3, 0,
                     new AsyncCallback(handshakeReceive2Callback), null);
             }
@@ -272,6 +274,7 @@ private void handshakeReceive2Callback(IAsyncResult ar)
                     if (command == 1)
                     {
                         byte[] response = { 5, 0, 0, 1, 0, 0, 0, 0, 0, 0 };
+                        Logging.Debug($"======Send Local Port, size:" + response.Length);
                         connection.BeginSend(response, 0, response.Length, 0, new AsyncCallback(ResponseCallback), null);
                     }
                     else if (command == 3)
@@ -310,6 +313,7 @@ private void HandleUDPAssociate()
             address.CopyTo(response, 4);
             response[response.Length - 1] = (byte)(port & 0xFF);
             response[response.Length - 2] = (byte)((port >> 8) & 0xFF);
+            Logging.Debug($"======Send Local Port, size:" + response.Length);
             connection.BeginSend(response, 0, response.Length, 0, new AsyncCallback(ReadAll), true);
         }
 
@@ -324,6 +328,7 @@ private void ReadAll(IAsyncResult ar)
                 if (ar.AsyncState != null)
                 {
                     connection.EndSend(ar);
+                    Logging.Debug($"======Receive Local Port, size:" + RecvSize);
                     connection.BeginReceive(connetionRecvBuffer, 0, RecvSize, 0,
                         new AsyncCallback(ReadAll), null);
                 }
@@ -332,6 +337,7 @@ private void ReadAll(IAsyncResult ar)
                     int bytesRead = connection.EndReceive(ar);
                     if (bytesRead > 0)
                     {
+                        Logging.Debug($"======Receive Local Port, size:" + RecvSize);
                         connection.BeginReceive(connetionRecvBuffer, 0, RecvSize, 0,
                             new AsyncCallback(ReadAll), null);
                     }
@@ -402,6 +408,7 @@ private void StartConnect()
 
                 connected = false;
                 // Connect to the remote endpoint.
+                Logging.Debug($"++++++Connect Server Port");
                 remote.BeginConnect(remoteEP,
                     new AsyncCallback(ConnectCallback), connectTimer);
             }
@@ -501,8 +508,10 @@ private void StartPipe()
             }
             try
             {
+                Logging.Debug($"++++++Receive Server Port, size:" + RecvSize);
                 remote.BeginReceive(remoteRecvBuffer, 0, RecvSize, 0,
                     new AsyncCallback(PipeRemoteReceiveCallback), null);
+                Logging.Debug($"======Receive Local Port, size:"+ RecvSize);
                 connection.BeginReceive(connetionRecvBuffer, 0, RecvSize, 0,
                     new AsyncCallback(PipeConnectionReceiveCallback), null);
             }
@@ -536,6 +545,7 @@ private void PipeRemoteReceiveCallback(IAsyncResult ar)
                         }
                         encryptor.Decrypt(remoteRecvBuffer, bytesRead, remoteSendBuffer, out bytesToSend);
                     }
+                    Logging.Debug($"======Send Local Port, size:" + bytesToSend);
                     connection.BeginSend(remoteSendBuffer, 0, bytesToSend, 0, new AsyncCallback(PipeConnectionSendCallback), null);
 
                     IStrategy strategy = controller.GetCurrentStrategy();
@@ -588,6 +598,7 @@ private void PipeConnectionReceiveCallback(IAsyncResult ar)
                         }
                         encryptor.Encrypt(connetionRecvBuffer, bytesRead, connetionSendBuffer, out bytesToSend);
                     }
+                    Logging.Debug($"++++++Send Server Port, size:" + bytesToSend);
                     remote.BeginSend(connetionSendBuffer, 0, bytesToSend, 0, new AsyncCallback(PipeRemoteSendCallback), null);
 
                     IStrategy strategy = controller.GetCurrentStrategy();
@@ -619,6 +630,7 @@ private void PipeRemoteSendCallback(IAsyncResult ar)
             try
             {
                 remote.EndSend(ar);
+                Logging.Debug($"======Receive Local Port, size:" + RecvSize);
                 connection.BeginReceive(this.connetionRecvBuffer, 0, RecvSize, 0,
                     new AsyncCallback(PipeConnectionReceiveCallback), null);
             }
@@ -638,6 +650,7 @@ private void PipeConnectionSendCallback(IAsyncResult ar)
             try
             {
                 connection.EndSend(ar);
+                Logging.Debug($"++++++Receive Server Port, size:" + RecvSize);
                 remote.BeginReceive(this.remoteRecvBuffer, 0, RecvSize, 0,
                     new AsyncCallback(PipeRemoteReceiveCallback), null);
             }

shadowsocks-csharp/Controller/Service/UDPRelay.cs

@@ -80,11 +80,13 @@ public void Send(byte[] data, int length)
                 byte[] dataOut = new byte[length - 3 + 16 + IVEncryptor.ONETIMEAUTH_BYTES];
                 int outlen;
                 encryptor.Encrypt(dataIn, length - 3, dataOut, out outlen);
+                Logging.Debug($"++++++Send Server Port, size:" + outlen);
                 _remote.SendTo(dataOut, outlen, SocketFlags.None, _remoteEndPoint);
             }
             public void Receive()
             {
                 EndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0);
+                Logging.Debug($"++++++Receive Server Port, size:" + _buffer.Length);
                 _remote.BeginReceiveFrom(_buffer, 0, _buffer.Length, 0, ref remoteEndPoint, new AsyncCallback(RecvFromCallback), null);
             }
             public void RecvFromCallback(IAsyncResult ar)
@@ -103,6 +105,7 @@ public void RecvFromCallback(IAsyncResult ar)
                     byte[] sendBuf = new byte[outlen + 3];
                     Array.Copy(dataOut, 0, sendBuf, 3, outlen);
 
+                    Logging.Debug($"======Send Local Port, size:" + (outlen + 3));
                     _local.SendTo(sendBuf, outlen + 3, 0, _localEndPoint);
                     Receive();
                 }