From a3a6eefcfe6f8b8129ac36a70243ca90e651a7fc Mon Sep 17 00:00:00 2001 From: Max Kellermann Date: Tue, 10 Feb 2009 18:51:49 +0100 Subject: audio: moved code to output_all.c Moved code which deals with all audio outputs at once into a separate library. --- src/output_all.c | 270 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 270 insertions(+) create mode 100644 src/output_all.c (limited to 'src/output_all.c') diff --git a/src/output_all.c b/src/output_all.c new file mode 100644 index 000000000..dff84e04a --- /dev/null +++ b/src/output_all.c @@ -0,0 +1,270 @@ +/* + * Copyright (C) 2003-2009 The Music Player Daemon Project + * http://www.musicpd.org + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include "output_all.h" +#include "output_internal.h" +#include "output_control.h" + +#include + +static struct audio_format input_audio_format; + +static struct audio_output *audioOutputArray; +static unsigned int audioOutputArraySize; + +unsigned int audio_output_count(void) +{ + return audioOutputArraySize; +} + +struct audio_output * +audio_output_get(unsigned i) +{ + assert(i < audioOutputArraySize); + + return &audioOutputArray[i]; +} + +struct audio_output * +audio_output_find(const char *name) +{ + for (unsigned i = 0; i < audioOutputArraySize; ++i) { + struct audio_output *ao = audio_output_get(i); + + if (strcmp(ao->name, name) == 0) + return ao; + } + + /* name not found */ + return NULL; +} + +static unsigned +audio_output_config_count(void) +{ + unsigned int nr = 0; + const struct config_param *param = NULL; + + while ((param = config_get_next_param(CONF_AUDIO_OUTPUT, param))) + nr++; + if (!nr) + nr = 1; /* we'll always have at least one device */ + return nr; +} + +/* make sure initPlayerData is called before this function!! */ +void initAudioDriver(void) +{ + const struct config_param *param = NULL; + unsigned int i; + + notify_init(&audio_output_client_notify); + + audioOutputArraySize = audio_output_config_count(); + audioOutputArray = g_new(struct audio_output, audioOutputArraySize); + + for (i = 0; i < audioOutputArraySize; i++) + { + struct audio_output *output = &audioOutputArray[i]; + unsigned int j; + + param = config_get_next_param(CONF_AUDIO_OUTPUT, param); + + /* only allow param to be NULL if there just one audioOutput */ + assert(param || (audioOutputArraySize == 1)); + + if (!audio_output_init(output, param)) { + if (param) + { + g_error("problems configuring output device " + "defined at line %i\n", param->line); + } + else + { + g_error("No audio_output specified and unable to " + "detect a default audio output device\n"); + } + } + + /* require output names to be unique: */ + for (j = 0; j < i; j++) { + if (!strcmp(output->name, audioOutputArray[j].name)) { + g_error("output devices with identical " + "names: %s\n", output->name); + } + } + } +} + +void finishAudioDriver(void) +{ + unsigned int i; + + for (i = 0; i < audioOutputArraySize; i++) { + audio_output_finish(&audioOutputArray[i]); + } + + g_free(audioOutputArray); + audioOutputArray = NULL; + audioOutputArraySize = 0; + + notify_deinit(&audio_output_client_notify); +} + +static void audio_output_wait_all(void) +{ + unsigned i; + + while (1) { + int finished = 1; + + for (i = 0; i < audioOutputArraySize; ++i) + if (audio_output_is_open(&audioOutputArray[i]) && + !audio_output_command_is_finished(&audioOutputArray[i])) + finished = 0; + + if (finished) + break; + + notify_wait(&audio_output_client_notify); + }; +} + +static void syncAudioDeviceStates(void) +{ + unsigned int i; + + if (!audio_format_defined(&input_audio_format)) + return; + + for (i = 0; i < audioOutputArraySize; ++i) + audio_output_update(&audioOutputArray[i], &input_audio_format); +} + +bool playAudio(const char *buffer, size_t length) +{ + bool ret = false; + unsigned int i; + + assert(length > 0); + /* no partial frames allowed */ + assert((length % audio_format_frame_size(&input_audio_format)) == 0); + + syncAudioDeviceStates(); + + for (i = 0; i < audioOutputArraySize; ++i) + if (audio_output_is_open(&audioOutputArray[i])) + audio_output_play(&audioOutputArray[i], + buffer, length); + + while (true) { + bool finished = true; + + for (i = 0; i < audioOutputArraySize; ++i) { + struct audio_output *ao = &audioOutputArray[i]; + + if (!audio_output_is_open(ao)) + continue; + + if (audio_output_command_is_finished(ao)) + ret = true; + else { + finished = false; + audio_output_signal(ao); + } + } + + if (finished) + break; + + notify_wait(&audio_output_client_notify); + }; + + return ret; +} + +bool openAudioDevice(const struct audio_format *audioFormat) +{ + bool ret = false; + unsigned int i; + + if (!audioOutputArray) + return false; + + if (audioFormat != NULL) + input_audio_format = *audioFormat; + + syncAudioDeviceStates(); + + for (i = 0; i < audioOutputArraySize; ++i) { + if (audioOutputArray[i].open) + ret = true; + } + + if (!ret) + /* close all devices if there was an error */ + closeAudioDevice(); + + return ret; +} + +void audio_output_pause_all(void) +{ + unsigned int i; + + syncAudioDeviceStates(); + + for (i = 0; i < audioOutputArraySize; ++i) + if (audio_output_is_open(&audioOutputArray[i])) + audio_output_pause(&audioOutputArray[i]); + + audio_output_wait_all(); +} + +void dropBufferedAudio(void) +{ + unsigned int i; + + syncAudioDeviceStates(); + + for (i = 0; i < audioOutputArraySize; ++i) { + if (audio_output_is_open(&audioOutputArray[i])) + audio_output_cancel(&audioOutputArray[i]); + } + + audio_output_wait_all(); +} + +void closeAudioDevice(void) +{ + unsigned int i; + + for (i = 0; i < audioOutputArraySize; ++i) + audio_output_close(&audioOutputArray[i]); +} + +void sendMetadataToAudioDevice(const struct tag *tag) +{ + unsigned int i; + + for (i = 0; i < audioOutputArraySize; ++i) + if (audio_output_is_open(&audioOutputArray[i])) + audio_output_send_tag(&audioOutputArray[i], tag); + + audio_output_wait_all(); +} -- cgit v1.2.3