Merge branch 'loopback-fast-path'

Author: cincuranet

Provider/src/FirebirdSql.Data.FirebirdClient/Client/Managed/GdsConnection.cs

@@ -124,7 +124,8 @@ public virtual void Connect()
 				_socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveBuffer, _packetSize);
 				_socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.SendBuffer, _packetSize);
 				_socket.SetSocketOption(SocketOptionLevel.Tcp, SocketOptionName.NoDelay, 1);
-				_socket.SetKeepAlive(KeepAliveTime, KeepAliveInterval);
+				_socket.TrySetKeepAlive(KeepAliveTime, KeepAliveInterval);
+				_socket.TryEnableLoopbackFastPath();
 
 				_socket.Connect(endPoint);
 				_networkStream = new NetworkStream(_socket, false);

Provider/src/FirebirdSql.Data.FirebirdClient/Common/Extensions.cs

@@ -27,19 +27,34 @@ namespace FirebirdSql.Data.Common
 {
 	internal static class Extensions
 	{
-		public static bool SetKeepAlive(this Socket socket, ulong time, ulong interval)
+		static bool TrySocketAction(Action action)
+		{
+			try
+			{
+				action();
+				return true;
+			}
+			catch (SocketException)
+			{
+				return false;
+			}
+			catch (PlatformNotSupportedException)
+			{
+				return false;
+			}
+		}
+
+		public static bool TrySetKeepAlive(this Socket socket, ulong time, ulong interval)
 		{
 			const int BytesPerLong = 4;
 			const int BitsPerByte = 8;
-
 			bool turnOn = time != 0 && interval != 0;
 			ulong[] input = new[]
 				{
 					turnOn ? (ulong)1 : (ulong)0,
 					time,
 					interval
 				};
-
 			// tcp_keepalive struct
 			byte[] inValue = new byte[3 * BytesPerLong];
 			for (int i = 0; i < input.Length; i++)
@@ -49,19 +64,23 @@ public static bool SetKeepAlive(this Socket socket, ulong time, ulong interval)
 				inValue[i * BytesPerLong + 1] = (byte)(input[i] >> ((BytesPerLong - 3) * BitsPerByte) & 0xFF);
 				inValue[i * BytesPerLong + 0] = (byte)(input[i] >> ((BytesPerLong - 4) * BitsPerByte) & 0xFF);
 			}
-
 			byte[] outValue = BitConverter.GetBytes(0);
 
-			try
+			return TrySocketAction(() =>
 			{
 				socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, turnOn ? 1 : 0);
 				socket.IOControl(IOControlCode.KeepAliveValues, inValue, outValue);
-			}
-			catch (SocketException)
+			});
+		}
+
+		public static bool TryEnableLoopbackFastPath(this Socket socket)
+		{
+			const int SIOLoopbackFastPath = -1744830448; //0x98000010;
+			byte[] inValue = BitConverter.GetBytes(1);
+			return TrySocketAction(() =>
 			{
-				return false;
-			}
-			return true;
+				socket.IOControl(SIOLoopbackFastPath, inValue, null);
+			});
 		}
 
 		public static int AsInt(this IntPtr ptr)