2008-09-09 10:02:34 +02:00
|
|
|
/* the Music Player Daemon (MPD)
|
|
|
|
* Copyright (C) 2003-2007 by Warren Dukes (warren.dukes@gmail.com)
|
|
|
|
* This project's homepage is: 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_control.h"
|
|
|
|
#include "output_api.h"
|
2008-09-24 07:20:55 +02:00
|
|
|
#include "output_internal.h"
|
2008-09-24 07:20:26 +02:00
|
|
|
#include "output_thread.h"
|
|
|
|
|
2008-10-08 10:49:29 +02:00
|
|
|
#include <assert.h>
|
|
|
|
#include <stdlib.h>
|
2008-09-24 07:20:26 +02:00
|
|
|
|
2008-12-27 20:53:52 +01:00
|
|
|
struct notify audio_output_client_notify;
|
2008-09-24 07:20:26 +02:00
|
|
|
|
|
|
|
static void ao_command_wait(struct audio_output *ao)
|
|
|
|
{
|
|
|
|
while (ao->command != AO_COMMAND_NONE) {
|
|
|
|
notify_signal(&ao->notify);
|
|
|
|
notify_wait(&audio_output_client_notify);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void ao_command(struct audio_output *ao, enum audio_output_command cmd)
|
|
|
|
{
|
|
|
|
assert(ao->command == AO_COMMAND_NONE);
|
|
|
|
ao->command = cmd;
|
|
|
|
ao_command_wait(ao);
|
|
|
|
}
|
2008-09-09 10:02:34 +02:00
|
|
|
|
2008-09-24 07:23:19 +02:00
|
|
|
static void ao_command_async(struct audio_output *ao,
|
|
|
|
enum audio_output_command cmd)
|
|
|
|
{
|
|
|
|
assert(ao->command == AO_COMMAND_NONE);
|
|
|
|
ao->command = cmd;
|
|
|
|
notify_signal(&ao->notify);
|
|
|
|
}
|
|
|
|
|
2008-10-29 20:40:27 +01:00
|
|
|
bool
|
|
|
|
audio_output_open(struct audio_output *audioOutput,
|
|
|
|
const struct audio_format *audioFormat)
|
2008-09-09 10:02:34 +02:00
|
|
|
{
|
2008-10-29 22:32:50 +01:00
|
|
|
audioOutput->reopen_after = 0;
|
|
|
|
|
2008-09-09 10:02:34 +02:00
|
|
|
if (audioOutput->open &&
|
2008-09-09 10:05:15 +02:00
|
|
|
audio_format_equals(audioFormat, &audioOutput->inAudioFormat)) {
|
2008-10-29 20:40:27 +01:00
|
|
|
return true;
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|
|
|
|
|
2008-09-09 10:04:42 +02:00
|
|
|
audioOutput->inAudioFormat = *audioFormat;
|
2008-09-09 10:02:34 +02:00
|
|
|
|
2008-09-11 07:47:28 +02:00
|
|
|
if (audio_format_defined(&audioOutput->reqAudioFormat)) {
|
2008-09-11 07:50:20 +02:00
|
|
|
/* copy reqAudioFormat to outAudioFormat only if the
|
|
|
|
device is not yet open; if it is already open,
|
|
|
|
plugin->open() may have modified outAudioFormat,
|
|
|
|
and the value is already ok */
|
|
|
|
if (!audioOutput->open)
|
|
|
|
audioOutput->outAudioFormat =
|
|
|
|
audioOutput->reqAudioFormat;
|
2008-09-09 10:02:34 +02:00
|
|
|
} else {
|
2008-09-09 10:04:42 +02:00
|
|
|
audioOutput->outAudioFormat = audioOutput->inAudioFormat;
|
2008-09-09 10:02:34 +02:00
|
|
|
if (audioOutput->open)
|
2008-09-09 10:03:24 +02:00
|
|
|
audio_output_close(audioOutput);
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|
|
|
|
|
2008-12-28 22:09:42 +01:00
|
|
|
if (audioOutput->thread == NULL)
|
2008-09-24 07:20:26 +02:00
|
|
|
audio_output_thread_start(audioOutput);
|
2008-09-09 10:02:34 +02:00
|
|
|
|
2008-10-29 22:34:37 +01:00
|
|
|
if (!audioOutput->open)
|
2008-09-24 07:20:26 +02:00
|
|
|
ao_command(audioOutput, AO_COMMAND_OPEN);
|
2008-09-09 10:02:34 +02:00
|
|
|
|
2008-10-29 22:34:37 +01:00
|
|
|
return audioOutput->open;
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 22:17:44 +01:00
|
|
|
void
|
|
|
|
audio_output_update(struct audio_output *ao,
|
|
|
|
const struct audio_format *audio_format)
|
|
|
|
{
|
2008-10-29 22:32:50 +01:00
|
|
|
if (ao->enabled) {
|
|
|
|
if (ao->reopen_after == 0 || time(NULL) > ao->reopen_after)
|
|
|
|
audio_output_open(ao, audio_format);
|
|
|
|
} else if (audio_output_is_open(ao))
|
2008-10-29 22:17:44 +01:00
|
|
|
audio_output_close(ao);
|
|
|
|
}
|
|
|
|
|
2008-09-26 07:12:29 +02:00
|
|
|
void
|
|
|
|
audio_output_signal(struct audio_output *ao)
|
|
|
|
{
|
|
|
|
notify_signal(&ao->notify);
|
|
|
|
}
|
|
|
|
|
2008-09-24 07:23:19 +02:00
|
|
|
void audio_output_play(struct audio_output *audioOutput,
|
|
|
|
const char *playChunk, size_t size)
|
2008-09-09 10:02:34 +02:00
|
|
|
{
|
2008-11-02 20:16:56 +01:00
|
|
|
assert(size > 0);
|
|
|
|
|
2008-09-09 10:02:34 +02:00
|
|
|
if (!audioOutput->open)
|
2008-09-24 07:23:19 +02:00
|
|
|
return;
|
2008-09-09 10:02:34 +02:00
|
|
|
|
2008-09-24 07:20:26 +02:00
|
|
|
audioOutput->args.play.data = playChunk;
|
|
|
|
audioOutput->args.play.size = size;
|
2008-09-24 07:23:19 +02:00
|
|
|
ao_command_async(audioOutput, AO_COMMAND_PLAY);
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|
|
|
|
|
2008-09-29 16:43:55 +02:00
|
|
|
void audio_output_pause(struct audio_output *audioOutput)
|
|
|
|
{
|
|
|
|
ao_command_async(audioOutput, AO_COMMAND_PAUSE);
|
|
|
|
}
|
|
|
|
|
2008-09-09 10:03:24 +02:00
|
|
|
void audio_output_cancel(struct audio_output *audioOutput)
|
2008-09-09 10:02:34 +02:00
|
|
|
{
|
2008-09-24 07:23:19 +02:00
|
|
|
ao_command_async(audioOutput, AO_COMMAND_CANCEL);
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|
|
|
|
|
2008-09-09 10:03:24 +02:00
|
|
|
void audio_output_close(struct audio_output *audioOutput)
|
2008-09-09 10:02:34 +02:00
|
|
|
{
|
|
|
|
if (audioOutput->open)
|
2008-09-24 07:20:26 +02:00
|
|
|
ao_command(audioOutput, AO_COMMAND_CLOSE);
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|
|
|
|
|
2008-09-09 10:03:24 +02:00
|
|
|
void audio_output_finish(struct audio_output *audioOutput)
|
2008-09-09 10:02:34 +02:00
|
|
|
{
|
2008-09-09 10:03:24 +02:00
|
|
|
audio_output_close(audioOutput);
|
2009-01-07 23:55:13 +01:00
|
|
|
|
|
|
|
if (audioOutput->thread != NULL) {
|
2008-09-24 07:20:26 +02:00
|
|
|
ao_command(audioOutput, AO_COMMAND_KILL);
|
2009-01-07 23:55:13 +01:00
|
|
|
g_thread_join(audioOutput->thread);
|
|
|
|
}
|
|
|
|
|
2008-09-09 10:02:34 +02:00
|
|
|
if (audioOutput->plugin->finish)
|
2008-09-24 07:20:55 +02:00
|
|
|
audioOutput->plugin->finish(audioOutput->data);
|
2008-09-09 10:02:34 +02:00
|
|
|
if (audioOutput->convBuffer)
|
|
|
|
free(audioOutput->convBuffer);
|
2009-01-07 23:53:28 +01:00
|
|
|
|
|
|
|
notify_deinit(&audioOutput->notify);
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|
|
|
|
|
2008-09-09 10:03:24 +02:00
|
|
|
void audio_output_send_tag(struct audio_output *audioOutput,
|
|
|
|
const struct tag *tag)
|
2008-09-09 10:02:34 +02:00
|
|
|
{
|
2008-09-24 07:20:26 +02:00
|
|
|
if (audioOutput->plugin->send_tag == NULL)
|
|
|
|
return;
|
|
|
|
|
|
|
|
audioOutput->args.tag = tag;
|
2008-09-24 07:23:19 +02:00
|
|
|
ao_command_async(audioOutput, AO_COMMAND_SEND_TAG);
|
2008-09-09 10:02:34 +02:00
|
|
|
}
|