Reputation: 3630
I'm currently working on a server that uses keepalive using Socket.IOControl But it is not working in dotnet core Linux When I try to run it I get a PlatformNotSupportedException
Is there a cross-platform alternative for implementing keepalive in dotnet core?
private static void Main(string[] args)
{
Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
socket.Bind((EndPoint)new IPEndPoint(IPAddress.Loopback, 3178));
socket.Listen(10);
Console.WriteLine("Server: Begin Listening");
socket.BeginAccept(new AsyncCallback(Program.AcceptCallback), (object)socket);
Console.WriteLine("Client: Begin Connecting");
TcpClient tcpClient = new TcpClient();
tcpClient.Connect(new IPEndPoint(IPAddress.Loopback, 3178));
Console.WriteLine("Client: Connected");
Console.WriteLine("Client: Client keepAlive");
Program.SetSocketKeepAliveValues(tcpClient.Client, 1000, 1);
Thread.Sleep(50);
Console.WriteLine("Done");
Console.ReadLine();
}
private static void AcceptCallback(IAsyncResult ar)
{
Socket asyncState = ar.AsyncState as Socket;
try
{
Socket socket = asyncState.EndAccept(ar);
Console.WriteLine("Server: Connection made");
Console.WriteLine("Server: Set keepAlive");
Program.SetSocketKeepAliveValues(socket, 1000, 1);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
public static void SetSocketKeepAliveValues(Socket socket, int KeepAliveTime, int KeepAliveInterval)
{
uint structure = 0;
byte[] optionInValue = new byte[Marshal.SizeOf<uint>(structure) * 3];
BitConverter.GetBytes(true ? 1U : 0U).CopyTo((Array)optionInValue, 0);
BitConverter.GetBytes((uint)KeepAliveTime).CopyTo((Array)optionInValue, Marshal.SizeOf<uint>(structure));
BitConverter.GetBytes((uint)KeepAliveInterval).CopyTo((Array)optionInValue, Marshal.SizeOf<uint>(structure) * 2);
socket.IOControl(IOControlCode.KeepAliveValues, optionInValue, (byte[])null);
}
Thanks in advance
Upvotes: 3
Views: 2681
Reputation: 3630
c code
#include <netinet/in.h>
#include <netinet/tcp.h>
#define check(expr) if (!(expr)) { return 0; }
int enable_keepalive(int sock, int enable_keepalive,int time, int interval,int maxpkt) {
check(setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, &enable_keepalive, sizeof(int)) != -1);
check(setsockopt(sock, IPPROTO_TCP, TCP_KEEPIDLE, &time, sizeof(int)) != -1);
check(setsockopt(sock, IPPROTO_TCP, TCP_KEEPINTVL, &interval, sizeof(int)) != -1);
check(setsockopt(sock, IPPROTO_TCP, TCP_KEEPCNT, &maxpkt, sizeof(int)) != -1);
return 1;
}
usage
[DllImport("libname.so")]
public static extern int enable_keepalive(int sock, int enable_keepalive,int time, int interval,int maxpkt);
private static void Main(string[] args)
{
TcpClient tcpClient = new TcpClient();
tcpClient.Connect(new IPEndPoint(IPAddress.Loopback, 3178));
Console.WriteLine("Client: Connected");
Console.WriteLine("Client: Client keepAlive");
Console.WriteLine(enable_keepalive((int)tcpClient.Client.Handle,1,10,5, 2));
}
tested in ubuntu 16.04
Upvotes: 3
Reputation: 899
Based on this https://github.com/kburtram/corefx/commit/10791b0f6040e206887906a748fd119a16c6c2b9
You can set the KeepAlive using the SetSocketOption
this.socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
this.socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);
this.socket.SetSocketOption(SocketOptionLevel.Tcp, SocketOptionName.TcpKeepAliveInterval, 5);
this.socket.SetSocketOption(SocketOptionLevel.Tcp, SocketOptionName.TcpKeepAliveRetryCount, 16);
Upvotes: 5