X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=audiod.c;h=295787262ae66589ceb6dc2d56da258e77943ef8;hp=7085ef0f4da3e303df923c4ea6dd1b705911968d;hb=8aa0f575bcca12ab63ab53141c2144448c457478;hpb=09a69f08d83ad23e806f0412fbc3f98b1410b115

diff --git a/audiod.c b/audiod.c
index 7085ef0f..29578726 100644
--- a/audiod.c
+++ b/audiod.c
@@ -78,6 +78,8 @@ enum vss_status_flags {
 	VSS_STATUS_FLAG_PLAYING = 2,
 };
 
+struct sched sched = {.max_fileno = 0};
+
 /**
  * The task for obtaining para_server's status (para_client stat).
  *
@@ -505,7 +507,7 @@ static void open_filters(struct slot_info *s)
 				.handler = f->execute, .context = fn));
 
 		f->open(fn);
-		register_task(&fn->task);
+		register_task(&sched, &fn->task);
 		parent = fn->btrn;
 		PARA_NOTICE_LOG("%s filter %d/%d (%s) started in slot %d\n",
 			audio_formats[s->format], i,  nf, f->name, (int)(s - slot));
@@ -528,7 +530,7 @@ static void open_writers(struct slot_info *s)
 		wn = s->wns + i;
 		wn->conf = a->writer_conf[i];
 		wn->writer_num = a->writer_nums[i];
-		register_writer_node(wn, parent);
+		register_writer_node(wn, parent, &sched);
 	}
 }
 
@@ -565,7 +567,7 @@ static int open_receiver(int format)
 	rn->task.pre_select = r->pre_select;
 	rn->task.post_select = r->post_select;
 	sprintf(rn->task.status, "%s receiver node", r->name);
-	register_task(&rn->task);
+	register_task(&sched, &rn->task);
 	return slot_num;
 }
 
@@ -1147,7 +1149,7 @@ static void start_stop_decoders(void)
 	if (a->num_filters)
 		open_filters(sl);
 	open_writers(sl);
-	activate_grab_clients();
+	activate_grab_clients(&sched);
 	btr_log_tree(sl->receiver_node->btrn, LL_NOTICE);
 }
 
@@ -1180,7 +1182,7 @@ min_delay:
 }
 
 /* restart the client task if necessary */
-static void status_post_select(__a_unused struct sched *s, struct task *t)
+static void status_post_select(struct sched *s, struct task *t)
 {
 	struct status_task *st = container_of(t, struct status_task, task);
 
@@ -1242,13 +1244,13 @@ static void status_post_select(__a_unused struct sched *s, struct task *t)
 		int argc = 5;
 		PARA_INFO_LOG("clock diff count: %d\n", st->clock_diff_count);
 		st->clock_diff_count--;
-		client_open(argc, argv, &st->ct, NULL, NULL, st->btrn);
+		client_open(argc, argv, &st->ct, NULL, NULL, st->btrn, s);
 		set_stat_task_restart_barrier(2);
 
 	} else {
 		char *argv[] = {"audiod", "--", "stat", "-p", NULL};
 		int argc = 4;
-		client_open(argc, argv, &st->ct, NULL, NULL, st->btrn);
+		client_open(argc, argv, &st->ct, NULL, NULL, st->btrn, s);
 		set_stat_task_restart_barrier(5);
 	}
 	free(stat_item_values[SI_BASENAME]);
@@ -1332,7 +1334,6 @@ static void init_colors_or_die(void)
 int main(int argc, char *argv[])
 {
 	int ret, i;
-	static struct sched s;
 	struct command_task command_task_struct, *cmd_task = &command_task_struct;
 	struct audiod_cmdline_parser_params params = {
 		.override = 0,
@@ -1384,12 +1385,12 @@ int main(int argc, char *argv[])
 	if (conf.daemon_given)
 		daemonize(false /* parent exits immediately */);
 
-	register_task(&sig_task->task);
-	register_task(&cmd_task->task);
-	register_task(&stat_task->task);
-	s.default_timeout.tv_sec = 2;
-	s.default_timeout.tv_usec = 999 * 1000;
-	ret = schedule(&s);
+	register_task(&sched, &sig_task->task);
+	register_task(&sched, &cmd_task->task);
+	register_task(&sched, &stat_task->task);
+	sched.default_timeout.tv_sec = 2;
+	sched.default_timeout.tv_usec = 999 * 1000;
+	ret = schedule(&sched);
 
 	PARA_EMERG_LOG("%s\n", para_strerror(-ret));
 	return EXIT_FAILURE;