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

diff --git a/oggdec_filter.c b/oggdec_filter.c
index 9fa80c55..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. */
 
@@ -92,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;
 }
 
@@ -125,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);
@@ -182,13 +178,13 @@ out:
 
 /**
   * Allocate chunks of this size and produce at most one chunk of output per
-  * ->post_select() invocation. If the buffer could only be filled partially
+  * ->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;
@@ -205,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;
@@ -215,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;
@@ -232,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);
@@ -266,7 +262,7 @@ out:
 const struct filter lsg_filter_cmd_com_oggdec_user_data = {
 	.open = ogg_open,
 	.close = ogg_close,
-	.pre_select = ogg_pre_select,
-	.post_select = ogg_post_select,
+	.pre_monitor = ogg_pre_monitor,
+	.post_monitor = ogg_post_monitor,
 	.execute = oggdec_execute
 };