aboutsummaryrefslogtreecommitdiffstats
path: root/src/output_thread.c
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/output_thread.c72
1 files changed, 57 insertions, 15 deletions
diff --git a/src/output_thread.c b/src/output_thread.c
index 7f1e4935e..df9d7801b 100644
--- a/src/output_thread.c
+++ b/src/output_thread.c
@@ -94,12 +94,33 @@ ao_filter_open(struct audio_output *ao,
struct audio_format *audio_format,
GError **error_r)
{
- return filter_open(ao->filter, audio_format, error_r);
+ /* the replay_gain filter cannot fail here */
+ if (ao->replay_gain_filter != NULL)
+ filter_open(ao->replay_gain_filter, audio_format, error_r);
+ if (ao->other_replay_gain_filter != NULL)
+ filter_open(ao->other_replay_gain_filter, audio_format,
+ error_r);
+
+ const struct audio_format *af
+ = filter_open(ao->filter, audio_format, error_r);
+ if (af == NULL) {
+ if (ao->replay_gain_filter != NULL)
+ filter_close(ao->replay_gain_filter);
+ if (ao->other_replay_gain_filter != NULL)
+ filter_close(ao->other_replay_gain_filter);
+ }
+
+ return af;
}
static void
ao_filter_close(struct audio_output *ao)
{
+ if (ao->replay_gain_filter != NULL)
+ filter_close(ao->replay_gain_filter);
+ if (ao->other_replay_gain_filter != NULL)
+ filter_close(ao->other_replay_gain_filter);
+
filter_close(ao->filter);
}
@@ -258,6 +279,8 @@ ao_reopen(struct audio_output *ao)
static const char *
ao_chunk_data(struct audio_output *ao, const struct music_chunk *chunk,
+ struct filter *replay_gain_filter,
+ unsigned *replay_gain_serial_p,
size_t *length_r)
{
assert(chunk != NULL);
@@ -271,6 +294,26 @@ ao_chunk_data(struct audio_output *ao, const struct music_chunk *chunk,
assert(length % audio_format_frame_size(&ao->in_audio_format) == 0);
+ if (length > 0 && replay_gain_filter != NULL) {
+ if (chunk->replay_gain_serial != *replay_gain_serial_p) {
+ replay_gain_filter_set_info(replay_gain_filter,
+ chunk->replay_gain_serial != 0
+ ? &chunk->replay_gain_info
+ : NULL);
+ *replay_gain_serial_p = chunk->replay_gain_serial;
+ }
+
+ GError *error = NULL;
+ data = filter_filter(replay_gain_filter, data, length,
+ &length, &error);
+ if (data == NULL) {
+ g_warning("\"%s\" [%s] failed to filter: %s",
+ ao->name, ao->plugin->name, error->message);
+ g_error_free(error);
+ return NULL;
+ }
+ }
+
*length_r = length;
return data;
}
@@ -282,30 +325,29 @@ ao_filter_chunk(struct audio_output *ao, const struct music_chunk *chunk,
GError *error = NULL;
size_t length;
- const char *data = ao_chunk_data(ao, chunk, &length);
+ const char *data = ao_chunk_data(ao, chunk, ao->replay_gain_filter,
+ &ao->replay_gain_serial, &length);
+ if (data == NULL)
+ return NULL;
+
if (length == 0) {
/* empty chunk, nothing to do */
*length_r = 0;
return data;
}
- /* update replay gain */
-
- if (ao->replay_gain_filter != NULL &&
- chunk->replay_gain_serial != ao->replay_gain_serial) {
- replay_gain_filter_set_info(ao->replay_gain_filter,
- chunk->replay_gain_serial != 0
- ? &chunk->replay_gain_info
- : NULL);
- ao->replay_gain_serial = chunk->replay_gain_serial;
- }
-
/* cross-fade */
if (chunk->other != NULL) {
size_t other_length;
- const char *other_data = ao_chunk_data(ao, chunk->other,
- &other_length);
+ const char *other_data =
+ ao_chunk_data(ao, chunk->other,
+ ao->other_replay_gain_filter,
+ &ao->other_replay_gain_serial,
+ &other_length);
+ if (other_data == NULL)
+ return NULL;
+
if (other_length == 0) {
*length_r = 0;
return data;