X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=server.c;h=b5063e2dfc2a7bd66c9b25836438e6c4677167c7;hp=88ee2425615a543394a88e7941b5b6d5dd3d6a5f;hb=feb3f00938a717061e0b41e76f4c68cdac9a17f7;hpb=823a4ff87a03ff9e1d2bfe8bc501f55ee4213649

diff --git a/server.c b/server.c
index 88ee2425..b5063e2d 100644
--- a/server.c
+++ b/server.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 1997-2014 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 1997-2014 Andre Noll <maan@tuebingen.mpg.de>
  *
  * Licensed under the GPL v2. For licencing details see COPYING.
  */
@@ -110,7 +110,7 @@ struct server_command_task {
 	/** Argument vector passed to para_server's main function. */
 	char **argv;
 	/** The command task structure for scheduling. */
-	struct task task;
+	struct task *task;
 };
 
 static int want_colors(void)
@@ -235,9 +235,9 @@ out:
 	exit(EXIT_FAILURE);
 }
 
-static void signal_pre_select(struct sched *s, struct task *t)
+static void signal_pre_select(struct sched *s, void *context)
 {
-	struct signal_task *st = container_of(t, struct signal_task, task);
+	struct signal_task *st = context;
 	para_fd_set(st->fd, &s->rfds, &s->max_fileno);
 }
 
@@ -253,7 +253,7 @@ static void handle_sighup(void)
 		kill(mmd->afs_pid, SIGHUP);
 }
 
-static int signal_post_select(struct sched *s, __a_unused struct task *t)
+static int signal_post_select(struct sched *s, __a_unused void *context)
 {
 	int signum = para_next_signal(&s->rfds);
 
@@ -312,10 +312,6 @@ static void init_signal_task(void)
 	static struct signal_task signal_task_struct,
 		*st = &signal_task_struct;
 
-	st->task.pre_select = signal_pre_select;
-	st->task.post_select = signal_post_select;
-	sprintf(st->task.status, "signal task");
-
 	PARA_NOTICE_LOG("setting up signal handling\n");
 	st->fd = para_signal_init(); /* always successful */
 	para_install_sighandler(SIGINT);
@@ -324,18 +320,24 @@ static void init_signal_task(void)
 	para_install_sighandler(SIGCHLD);
 	para_sigaction(SIGPIPE, SIG_IGN);
 	add_close_on_fork_list(st->fd);
-	register_task(&sched, &st->task);
+	st->task = task_register(&(struct task_info) {
+		.name = "signal",
+		.pre_select = signal_pre_select,
+		.post_select = signal_post_select,
+		.context = st,
+
+	}, &sched);
 }
 
-static void command_pre_select(struct sched *s, struct task *t)
+static void command_pre_select(struct sched *s, void *context)
 {
-	struct server_command_task *sct = container_of(t, struct server_command_task, task);
+	struct server_command_task *sct = context;
 	para_fd_set(sct->listen_fd, &s->rfds, &s->max_fileno);
 }
 
-static int command_post_select(struct sched *s, struct task *t)
+static int command_post_select(struct sched *s, void *context)
 {
-	struct server_command_task *sct = container_of(t, struct server_command_task, task);
+	struct server_command_task *sct = context;
 
 	int new_fd, ret, i;
 	char *peer_name;
@@ -399,8 +401,6 @@ static void init_server_command_task(int argc, char **argv)
 		*sct = &server_command_task_struct;
 
 	PARA_NOTICE_LOG("initializing tcp command socket\n");
-	sct->task.pre_select = command_pre_select;
-	sct->task.post_select = command_post_select;
 	sct->argc = argc;
 	sct->argv = argv;
 	ret = para_listen_simple(IPPROTO_TCP, conf.port_arg);
@@ -411,8 +411,12 @@ static void init_server_command_task(int argc, char **argv)
 	if (ret < 0)
 		goto err;
 	add_close_on_fork_list(sct->listen_fd); /* child doesn't need the listener */
-	sprintf(sct->task.status, "server command task");
-	register_task(&sched, &sct->task);
+	sct->task = task_register(&(struct task_info) {
+		.name = "server command",
+		.pre_select = command_pre_select,
+		.post_select = command_post_select,
+		.context = sct,
+	}, &sched);
 	return;
 err:
 	PARA_EMERG_LOG("%s\n", para_strerror(-ret));
@@ -571,6 +575,7 @@ int main(int argc, char *argv[])
 	server_init(argc, argv);
 	mutex_lock(mmd_mutex);
 	ret = schedule(&sched);
+	sched_shutdown(&sched);
 	if (ret < 0) {
 		PARA_EMERG_LOG("%s\n", para_strerror(-ret));
 		exit(EXIT_FAILURE);