From 5b7a73a39dfaf10b8f49ae611a7387870810352c Mon Sep 17 00:00:00 2001
From: Thomas Schoebel-Theuer <mars@box>
Date: Thu, 10 May 2018 09:56:54 +0200
Subject: [PATCH] server: make tcp params dynamic

---
 kernel/mars_server.c | 34 +++++++++++++++++++++++++++-------
 kernel/mars_server.h |  1 +
 2 files changed, 28 insertions(+), 7 deletions(-)

diff --git a/kernel/mars_server.c b/kernel/mars_server.c
index c9afcf43..ebc12dfc 100644
--- a/kernel/mars_server.c
+++ b/kernel/mars_server.c
@@ -42,9 +42,25 @@
 
 #include "mars_server.h"
 
+struct server_cookie {
+	struct mars_socket server_socket;
+	struct mars_tcp_params *server_params;
+};
+
 #define NR_SOCKETS 3
 
-static struct mars_socket server_socket[NR_SOCKETS] = {};
+static struct server_cookie server_cookie[NR_SOCKETS] = {
+	[0] = {
+		.server_params = &default_tcp_params,
+	},
+	[1] = {
+		.server_params = &default_tcp_params,
+	},
+	[2] = {
+		.server_params = &default_tcp_params,
+	},
+};
+
 static struct task_struct *server_thread[NR_SOCKETS] = {};
 
 atomic_t server_handler_count = ATOMIC_INIT(0);
@@ -820,7 +836,9 @@ static int _server_thread(void *data)
 		},
 		.main_event = __WAIT_QUEUE_HEAD_INITIALIZER(server_global.main_event),
 	};
-	struct mars_socket *my_socket = data;
+	struct server_cookie *cookie = data;
+	struct mars_socket *my_socket = &cookie->server_socket;
+	struct mars_tcp_params *my_params = cookie->server_params;
 	char *id = my_id();
 	int status = 0;
 
@@ -860,7 +878,7 @@ static int _server_thread(void *data)
 
 		status = mars_accept_socket(&handler_socket,
 					    my_socket,
-					    &default_tcp_params);
+					    my_params);
 		if (unlikely(status < 0 || !mars_socket_is_alive(&handler_socket))) {
 			brick_msleep(500);
 			if (status == -EAGAIN)
@@ -949,7 +967,7 @@ void exit_mars_server(void)
 			brick_thread_stop(server_thread[i]);
 		}
 		MARS_INF("closing server socket %d...\n", i);
-		mars_put_socket(&server_socket[i]);
+		mars_put_socket(&server_cookie[i].server_socket);
 	}
 }
 
@@ -971,9 +989,9 @@ int __init init_mars_server(void)
 			return status;
 		}
 
-		status = mars_create_socket(&server_socket[i],
+		status = mars_create_socket(&server_cookie[i].server_socket,
 					    &sockaddr,
-					    &default_tcp_params,
+					    server_cookie[i].server_params,
 					    true);
 		if (unlikely(status < 0)) {
 			MARS_ERR("could not create server socket %d, status = %d\n", i, status);
@@ -981,7 +999,9 @@ int __init init_mars_server(void)
 			return status;
 		}
 
-		server_thread[i] = brick_thread_create(_server_thread, &server_socket[i], "mars_server_%d", i);
+		server_thread[i] = brick_thread_create(_server_thread,
+						       &server_cookie[i],
+						       "mars_server_%d", i);
 		if (unlikely(!server_thread[i] || IS_ERR(server_thread[i]))) {
 			MARS_ERR("could not create server thread %d\n", i);
 			exit_mars_server();
diff --git a/kernel/mars_server.h b/kernel/mars_server.h
index d8ee406d..e1a17b41 100644
--- a/kernel/mars_server.h
+++ b/kernel/mars_server.h
@@ -55,6 +55,7 @@ struct server_brick {
 	MARS_BRICK(server);
 	struct semaphore socket_sem;
 	struct mars_socket handler_socket;
+	struct mars_tcp_params *handler_params;
 	struct mars_brick *conn_brick;
 	struct task_struct *handler_thread;
 	struct task_struct *cb_thread;