X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=vss.c;h=1b66a6e5d01cbecb5b08d0e4f17d5808ae8c5d7f;hp=aec357ab7e5bdd936e438412a3c94216c72bbff2;hb=62c2dc7f15d4875ec86b9de7bb9a5f82413f7ac9;hpb=d46a0767b58654f15f16406cf99296287bd0d534

diff --git a/vss.c b/vss.c
index aec357ab..1b66a6e5 100644
--- a/vss.c
+++ b/vss.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 1997-2013 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 1997-2014 Andre Noll <maan@systemlinux.org>
  *
  * Licensed under the GPL v2. For licencing details see COPYING.
  */
@@ -11,8 +11,14 @@
  * senders.
  */
 
+#include <sys/socket.h>
+#include <netinet/in.h>
 #include <regex.h>
 #include <osl.h>
+#include <sys/types.h>
+#include <arpa/inet.h>
+#include <sys/un.h>
+#include <netdb.h>
 
 #include "para.h"
 #include "error.h"
@@ -83,7 +89,7 @@ struct vss_task {
 	/** The memory mapped audio file. */
 	char *map;
 	/** Used by the scheduler. */
-	struct task task;
+	struct task *task;
 	/** Pointer to the header of the mapped audio file. */
 	char *header_buf;
 	/** Length of the audio file header. */
@@ -565,8 +571,14 @@ static int setup_next_fec_group(struct fec_client *fc, struct vss_task *vsst)
 		if (payload_size < g->slice_bytes)
 			memset(fc->extra_header_buf + payload_size, 0,
 				g->slice_bytes - payload_size);
-		fc->src_data[i] = fc->extra_header_buf;
-		assert(i == g->num_header_slices - 1);
+		/*
+		 * There might be more than one header slice to fill although
+		 * only the first one will be used. Set all header slices to
+		 * our extra buffer.
+		 */
+		while (i < g->num_header_slices)
+			fc->src_data[i++] = fc->extra_header_buf;
+		break; /* we don't want i to be increased. */
 	}
 
 	/*
@@ -890,7 +902,7 @@ static void set_mmd_offset(void)
 static void vss_pre_select(struct sched *s, struct task *t)
 {
 	int i;
-	struct vss_task *vsst = container_of(t, struct vss_task, task);
+	struct vss_task *vsst = task_context(t);
 
 	if (!vsst->map || vss_next() || vss_paused() || vss_repos()) {
 		struct fec_client *fc, *tmp;
@@ -1117,7 +1129,7 @@ static void vss_send(struct vss_task *vsst)
 static int vss_post_select(struct sched *s, struct task *t)
 {
 	int ret, i;
-	struct vss_task *vsst = container_of(t, struct vss_task, task);
+	struct vss_task *vsst = task_context(t);
 
 	if (mmd->sender_cmd_data.cmd_num >= 0) {
 		int num = mmd->sender_cmd_data.cmd_num,
@@ -1173,8 +1185,6 @@ void init_vss_task(int afs_socket, struct sched *s)
 			conf.autoplay_delay_arg : 0;
 	vsst->header_interval.tv_sec = 5; /* should this be configurable? */
 	vsst->afs_socket = afs_socket;
-	vsst->task.pre_select = vss_pre_select;
-	vsst->task.post_select = vss_post_select;
 	ms2tv(announce_time, &vsst->announce_tv);
 	PARA_INFO_LOG("announce timeval: %lums\n", tv2ms(&vsst->announce_tv));
 	INIT_LIST_HEAD(&fec_client_list);
@@ -1194,6 +1204,10 @@ void init_vss_task(int afs_socket, struct sched *s)
 		tv_add(&vsst->autoplay_barrier, &vsst->announce_tv,
 			&vsst->data_send_barrier);
 	}
-	sprintf(vsst->task.status, "vss task");
-	register_task(s, &vsst->task);
+	vsst->task = task_register(&(struct task_info) {
+		.name = "vss task",
+		.pre_select = vss_pre_select,
+		.post_select = vss_post_select,
+		.context = vsst,
+	}, s);
 }