X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=oggdec_filter.c;h=708a27e52b68c1c2add01a3b3fe39f721485e39f;hp=11552cbb33a4d7fe48bc958edbaa6dc01e2025ae;hb=HEAD;hpb=f167629b3191c57a6b691cd2a6af04a45a74ccb0

diff --git a/oggdec_filter.c b/oggdec_filter.c
index 11552cbb..b1aec4bc 100644
--- a/oggdec_filter.c
+++ b/oggdec_filter.c
@@ -1,8 +1,4 @@
-/*
- * Copyright (C) 2005 Andre Noll <maan@tuebingen.mpg.de>
- *
- * Licensed under the GPL v2. For licencing details see COPYING.
- */
+/* Copyright (C) 2005 Andre Noll <maan@tuebingen.mpg.de>, see file COPYING. */
 
 /** \file oggdec_filter.c Paraslash's ogg vorbis decoder. */
 
@@ -12,7 +8,6 @@
 #include "para.h"
 #include "list.h"
 #include "sched.h"
-#include "ggo.h"
 #include "buffer_tree.h"
 #include "filter.h"
 #include "error.h"
@@ -93,7 +88,7 @@ static const ov_callbacks ovc = {
 
 static void ogg_open(struct filter_node *fn)
 {
-	fn->private_data = para_calloc(sizeof(struct private_oggdec_data));
+	fn->private_data = zalloc(sizeof(struct private_oggdec_data));
 	fn->min_iqs = 8000;
 }
 
@@ -126,7 +121,7 @@ static int ogg_init(struct filter_node *fn)
 	struct btr_node *btrn = fn->btrn;
 	int ret, oret;
 	size_t iqs;
-	struct OggVorbis_File *vf = para_malloc(sizeof(*vf));
+	struct OggVorbis_File *vf = alloc(sizeof(*vf));
 
 	PARA_NOTICE_LOG("iqs: %zu, min_iqs: %zu, opening ov callbacks\n",
 		btr_get_input_queue_size(btrn), fn->min_iqs);
@@ -162,7 +157,7 @@ open:
 		goto out;
 	pod->channels = ov_info(vf, 0)->channels;
 	pod->sample_rate = ov_info(vf, 0)->rate;
-	PARA_NOTICE_LOG("%d channels, %d Hz\n", pod->channels,
+	PARA_NOTICE_LOG("%u channels, %u Hz\n", pod->channels,
 		pod->sample_rate);
 	ret = 1;
 out:
@@ -178,10 +173,18 @@ out:
 	return ret;
 }
 
+/** Suspend decoding if output queue size is larger than that. */
 #define OGGDEC_MAX_OUTPUT_SIZE (96 * 1024)
+
+/**
+  * Allocate chunks of this size and produce at most one chunk of output per
+  * ->post_monitor() invocation. If the buffer could only be filled partially
+  * due to insufficient input being available, it is shrunk to the real output
+  * size and the resized buffer is fed into the output queue.
+  */
 #define OGGDEC_OUTPUT_CHUNK_SIZE (32 * 1024)
 
-static void ogg_pre_select(struct sched *s, void *context)
+static void ogg_pre_monitor(struct sched *s, void *context)
 {
 	struct filter_node *fn = context;
 	struct private_oggdec_data *pod = fn->private_data;
@@ -198,7 +201,7 @@ static void ogg_pre_select(struct sched *s, void *context)
 	sched_min_delay(s);
 }
 
-static int ogg_post_select(__a_unused struct sched *s, void *context)
+static int ogg_post_monitor(__a_unused struct sched *s, void *context)
 {
 	struct filter_node *fn = context;
 	struct private_oggdec_data *pod = fn->private_data;
@@ -208,7 +211,7 @@ static int ogg_post_select(__a_unused struct sched *s, void *context)
 
 	ret = btr_node_status(btrn, fn->min_iqs, BTR_NT_INTERNAL);
 	if (ret < 0) {
-		if (ret != -E_BTR_EOF) /* fatal error */
+		if (ret != -E_EOF) /* fatal error */
 			goto out;
 		if (fn->min_iqs == 0 && !pod->have_more) /* EOF */
 			goto out;
@@ -225,7 +228,7 @@ static int ogg_post_select(__a_unused struct sched *s, void *context)
 		goto out;
 	}
 	have = 0;
-	buf = para_malloc(OGGDEC_OUTPUT_CHUNK_SIZE);
+	buf = alloc(OGGDEC_OUTPUT_CHUNK_SIZE);
 	for (;;) {
 		ret = ov_read(pod->vf, buf + have, OGGDEC_OUTPUT_CHUNK_SIZE - have,
 			ENDIAN, 2 /* 16 bit */, 1 /* signed */, NULL);
@@ -256,16 +259,10 @@ out:
 	return ret;
 }
 
-/**
- * The init function of the ogg vorbis decoder.
- *
- * \param f Its fields are filled in by the function.
- */
-void oggdec_filter_init(struct filter *f)
-{
-	f->open = ogg_open;
-	f->close = ogg_close;
-	f->pre_select = ogg_pre_select;
-	f->post_select = ogg_post_select;
-	f->execute = oggdec_execute;
-}
+const struct filter lsg_filter_cmd_com_oggdec_user_data = {
+	.open = ogg_open,
+	.close = ogg_close,
+	.pre_monitor = ogg_pre_monitor,
+	.post_monitor = ogg_post_monitor,
+	.execute = oggdec_execute
+};