X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=vss.c;h=24dfc6bb51af4edf67c645c0d3ccbda2ad8f1868;hp=5484db9d9479401fe90e481f842c37a9afed8e4f;hb=b6b571e6c6fb52207b11fc7833b272ec8cfa28bf;hpb=121015ff5cdbe6af7b84f6245ebe62fe2a52a859

diff --git a/vss.c b/vss.c
index 5484db9d..24dfc6bb 100644
--- a/vss.c
+++ b/vss.c
@@ -88,6 +88,8 @@ struct vss_task {
 	enum afs_socket_status afsss;
 	/** The memory mapped audio file. */
 	char *map;
+	/** The size of the memory mapping. */
+	size_t mapsize;
 	/** Used by the scheduler. */
 	struct task *task;
 	/** Pointer to the header of the mapped audio file. */
@@ -96,6 +98,8 @@ struct vss_task {
 	size_t header_len;
 	/** Time between audio file headers are sent. */
 	struct timeval header_interval;
+	/* Only used if afh supports dynamic chunks. */
+	void *afh_context;
 };
 
 /**
@@ -347,6 +351,8 @@ static int initialize_fec_client(struct fec_client *fc, struct vss_task *vsst)
 static void vss_get_chunk(int chunk_num, struct vss_task *vsst,
 		char **buf, size_t *sz)
 {
+	int ret;
+
 	/*
 	 * Chunk zero is special for header streams: It is the first portion of
 	 * the audio file which consists of the audio file header. It may be
@@ -360,8 +366,15 @@ static void vss_get_chunk(int chunk_num, struct vss_task *vsst,
 		*sz = vsst->header_len;
 		return;
 	}
-	afh_get_chunk(chunk_num, &mmd->afd.afhi, vsst->map, (const char **)buf,
-		sz);
+	ret = afh_get_chunk(chunk_num, &mmd->afd.afhi,
+		mmd->afd.audio_format_id, vsst->map, vsst->mapsize,
+		(const char **)buf, sz, &vsst->afh_context);
+	if (ret < 0) {
+		PARA_WARNING_LOG("could not get chunk %d: %s\n",
+			chunk_num, para_strerror(-ret));
+		*buf = NULL;
+		*sz = 0;
+	}
 }
 
 static void compute_group_size(struct vss_task *vsst, struct fec_group *g,
@@ -846,7 +859,7 @@ static void vss_eof(struct vss_task *vsst)
 	set_eof_barrier(vsst);
 	afh_free_header(vsst->header_buf, mmd->afd.audio_format_id);
 	vsst->header_buf = NULL;
-	para_munmap(vsst->map, mmd->size);
+	para_munmap(vsst->map, vsst->mapsize);
 	vsst->map = NULL;
 	mmd->chunks_sent = 0;
 	//mmd->offset = 0;
@@ -855,7 +868,9 @@ static void vss_eof(struct vss_task *vsst)
 	mmd->afd.afhi.chunk_tv.tv_usec = 0;
 	free(mmd->afd.afhi.chunk_table);
 	mmd->afd.afhi.chunk_table = NULL;
-	mmd->size = 0;
+	vsst->mapsize = 0;
+	afh_close(vsst->afh_context, mmd->afd.audio_format_id);
+	vsst->afh_context = NULL;
 	mmd->events++;
 }
 
@@ -973,11 +988,11 @@ static void recv_afs_result(struct vss_task *vsst, fd_set *rfds)
 		ret = -ERRNO_TO_PARA_ERROR(errno);
 		goto err;
 	}
-	mmd->size = statbuf.st_size;
-	ret = para_mmap(mmd->size, PROT_READ, MAP_PRIVATE | MAP_POPULATE,
+	ret = para_mmap(statbuf.st_size, PROT_READ, MAP_PRIVATE | MAP_POPULATE,
 		passed_fd, 0, &vsst->map);
 	if (ret < 0)
 		goto err;
+	vsst->mapsize = statbuf.st_size;
 	close(passed_fd);
 	mmd->chunks_sent = 0;
 	mmd->current_chunk = 0;
@@ -986,7 +1001,7 @@ static void recv_afs_result(struct vss_task *vsst, fd_set *rfds)
 	mmd->num_played++;
 	mmd->new_vss_status_flags &= (~VSS_NEXT);
 	afh_get_header(&mmd->afd.afhi, mmd->afd.audio_format_id,
-		vsst->map, mmd->size, &vsst->header_buf, &vsst->header_len);
+		vsst->map, vsst->mapsize, &vsst->header_buf, &vsst->header_len);
 	return;
 err:
 	free(mmd->afd.afhi.chunk_table);
@@ -1076,7 +1091,7 @@ static void vss_send(struct vss_task *vsst)
 		 */
 		if (mmd->current_chunk > 0) { /* chunk 0 might be on the heap */
 			buf += len;
-			for (i = 0; i < 5 && buf < vsst->map + mmd->size; i++) {
+			for (i = 0; i < 5 && buf < vsst->map + vsst->mapsize; i++) {
 				__a_unused volatile char x = *buf;
 				buf += 4096;
 			}
@@ -1113,7 +1128,7 @@ static int vss_post_select(struct sched *s, void *context)
 		set_eof_barrier(vsst);
 		mmd->chunks_sent = 0;
 		mmd->current_chunk = afh_get_start_chunk(mmd->repos_request,
-			&mmd->afd.afhi);
+			&mmd->afd.afhi, mmd->afd.audio_format_id);
 		mmd->new_vss_status_flags &= ~VSS_REPOS;
 		set_mmd_offset();
 	}