2009-03-13 18:43:16 +01:00
|
|
|
/*
|
|
|
|
* Copyright (C) 2003-2009 The Music Player Daemon Project
|
|
|
|
* http://www.musicpd.org
|
2006-07-13 21:20:34 +02:00
|
|
|
*
|
|
|
|
* 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.
|
2009-03-13 18:43:16 +01:00
|
|
|
*
|
|
|
|
* 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.,
|
|
|
|
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
2006-07-13 21:20:34 +02:00
|
|
|
*/
|
|
|
|
|
2008-09-07 22:41:17 +02:00
|
|
|
#include "../output_api.h"
|
2009-03-14 11:36:59 +01:00
|
|
|
#include "mixer_list.h"
|
2006-07-19 18:48:24 +02:00
|
|
|
|
2008-10-29 20:37:36 +01:00
|
|
|
#include <glib.h>
|
2006-07-13 21:03:49 +02:00
|
|
|
#include <pulse/simple.h>
|
|
|
|
#include <pulse/error.h>
|
|
|
|
|
2006-07-19 18:48:24 +02:00
|
|
|
#define MPD_PULSE_NAME "mpd"
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data {
|
2009-02-25 17:32:58 +01:00
|
|
|
const char *name;
|
2008-09-24 07:20:55 +02:00
|
|
|
|
2006-07-20 18:02:40 +02:00
|
|
|
pa_simple *s;
|
|
|
|
char *server;
|
|
|
|
char *sink;
|
2008-10-29 20:37:15 +01:00
|
|
|
};
|
2006-07-13 21:03:49 +02:00
|
|
|
|
2009-02-26 22:04:59 +01:00
|
|
|
/**
|
|
|
|
* The quark used for GError.domain.
|
|
|
|
*/
|
|
|
|
static inline GQuark
|
|
|
|
pulse_output_quark(void)
|
|
|
|
{
|
|
|
|
return g_quark_from_static_string("pulse_output");
|
|
|
|
}
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
static struct pulse_data *pulse_new_data(void)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data *ret;
|
2006-07-20 18:02:40 +02:00
|
|
|
|
2008-10-29 20:37:36 +01:00
|
|
|
ret = g_new(struct pulse_data, 1);
|
2006-07-19 18:48:24 +02:00
|
|
|
|
2006-07-13 21:03:49 +02:00
|
|
|
ret->server = NULL;
|
|
|
|
ret->sink = NULL;
|
2006-07-19 18:48:24 +02:00
|
|
|
|
2006-07-13 21:03:49 +02:00
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
static void pulse_free_data(struct pulse_data *pd)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:36 +01:00
|
|
|
g_free(pd->server);
|
|
|
|
g_free(pd->sink);
|
|
|
|
g_free(pd);
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
static void *
|
2009-02-25 18:34:02 +01:00
|
|
|
pulse_init(G_GNUC_UNUSED const struct audio_format *audio_format,
|
2009-02-26 22:04:59 +01:00
|
|
|
const struct config_param *param, G_GNUC_UNUSED GError **error)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data *pd;
|
2006-07-13 21:03:49 +02:00
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
pd = pulse_new_data();
|
2009-02-25 17:32:58 +01:00
|
|
|
pd->name = config_get_block_string(param, "name", "mpd_pulse");
|
2009-01-18 19:37:27 +01:00
|
|
|
pd->server = param != NULL
|
|
|
|
? config_dup_block_string(param, "server", NULL) : NULL;
|
|
|
|
pd->sink = param != NULL
|
|
|
|
? config_dup_block_string(param, "sink", NULL) : NULL;
|
2006-07-13 21:03:49 +02:00
|
|
|
|
2008-09-24 07:20:55 +02:00
|
|
|
return pd;
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
static void pulse_finish(void *data)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data *pd = data;
|
2008-09-24 07:20:55 +02:00
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
pulse_free_data(pd);
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:40:27 +01:00
|
|
|
static bool pulse_test_default_device(void)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2006-07-20 18:02:40 +02:00
|
|
|
pa_simple *s;
|
2006-07-13 21:03:49 +02:00
|
|
|
pa_sample_spec ss;
|
|
|
|
int error;
|
|
|
|
|
|
|
|
ss.format = PA_SAMPLE_S16NE;
|
|
|
|
ss.rate = 44100;
|
|
|
|
ss.channels = 2;
|
|
|
|
|
|
|
|
s = pa_simple_new(NULL, MPD_PULSE_NAME, PA_STREAM_PLAYBACK, NULL,
|
2006-07-20 18:02:40 +02:00
|
|
|
MPD_PULSE_NAME, &ss, NULL, NULL, &error);
|
2006-07-13 21:03:49 +02:00
|
|
|
if (!s) {
|
2008-10-29 20:37:36 +01:00
|
|
|
g_message("Cannot connect to default PulseAudio server: %s\n",
|
|
|
|
pa_strerror(error));
|
2008-10-29 20:40:27 +01:00
|
|
|
return false;
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
pa_simple_free(s);
|
|
|
|
|
2008-10-29 20:40:27 +01:00
|
|
|
return true;
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:40:27 +01:00
|
|
|
static bool
|
2009-02-26 22:04:59 +01:00
|
|
|
pulse_open(void *data, struct audio_format *audio_format, GError **error_r)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data *pd = data;
|
2006-07-13 21:03:49 +02:00
|
|
|
pa_sample_spec ss;
|
|
|
|
int error;
|
|
|
|
|
2008-10-25 20:41:28 +02:00
|
|
|
/* MPD doesn't support the other pulseaudio sample formats, so
|
|
|
|
we just force MPD to send us everything as 16 bit */
|
2008-10-29 20:37:15 +01:00
|
|
|
audio_format->bits = 16;
|
2006-07-13 21:03:49 +02:00
|
|
|
|
|
|
|
ss.format = PA_SAMPLE_S16NE;
|
2008-10-29 20:37:15 +01:00
|
|
|
ss.rate = audio_format->sample_rate;
|
|
|
|
ss.channels = audio_format->channels;
|
2006-07-13 21:03:49 +02:00
|
|
|
|
2006-07-19 18:50:03 +02:00
|
|
|
pd->s = pa_simple_new(pd->server, MPD_PULSE_NAME, PA_STREAM_PLAYBACK,
|
2009-02-25 17:32:58 +01:00
|
|
|
pd->sink, pd->name,
|
2008-09-24 07:20:55 +02:00
|
|
|
&ss, NULL, NULL,
|
2006-07-20 18:02:40 +02:00
|
|
|
&error);
|
2006-07-19 18:50:03 +02:00
|
|
|
if (!pd->s) {
|
2009-02-26 22:04:59 +01:00
|
|
|
g_set_error(error_r, pulse_output_quark(), error,
|
|
|
|
"Cannot connect to PulseAudio server: %s",
|
|
|
|
pa_strerror(error));
|
2008-10-29 20:40:27 +01:00
|
|
|
return false;
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:40:27 +01:00
|
|
|
return true;
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
static void pulse_cancel(void *data)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data *pd = data;
|
2006-07-13 21:03:49 +02:00
|
|
|
int error;
|
|
|
|
|
2006-07-20 18:02:40 +02:00
|
|
|
if (pa_simple_flush(pd->s, &error) < 0)
|
2008-10-29 20:37:36 +01:00
|
|
|
g_warning("Flush failed in PulseAudio output \"%s\": %s\n",
|
2009-02-25 17:32:58 +01:00
|
|
|
pd->name, pa_strerror(error));
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
static void pulse_close(void *data)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data *pd = data;
|
2006-07-13 21:03:49 +02:00
|
|
|
|
2009-02-26 19:29:06 +01:00
|
|
|
pa_simple_drain(pd->s, NULL);
|
|
|
|
pa_simple_free(pd->s);
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2009-02-23 09:29:56 +01:00
|
|
|
static size_t
|
2009-02-26 22:04:59 +01:00
|
|
|
pulse_play(void *data, const void *chunk, size_t size, GError **error_r)
|
2006-07-13 21:03:49 +02:00
|
|
|
{
|
2008-10-29 20:37:15 +01:00
|
|
|
struct pulse_data *pd = data;
|
2006-07-13 21:03:49 +02:00
|
|
|
int error;
|
|
|
|
|
2009-02-23 09:34:26 +01:00
|
|
|
if (pa_simple_write(pd->s, chunk, size, &error) < 0) {
|
2009-02-26 22:04:59 +01:00
|
|
|
g_set_error(error_r, pulse_output_quark(), error,
|
|
|
|
"%s", pa_strerror(error));
|
2009-02-23 09:29:56 +01:00
|
|
|
return 0;
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2009-02-23 09:29:56 +01:00
|
|
|
return size;
|
2006-07-13 21:03:49 +02:00
|
|
|
}
|
|
|
|
|
2008-10-29 20:37:15 +01:00
|
|
|
const struct audio_output_plugin pulse_plugin = {
|
2008-09-29 15:55:17 +02:00
|
|
|
.name = "pulse",
|
2008-10-29 20:37:15 +01:00
|
|
|
.test_default_device = pulse_test_default_device,
|
|
|
|
.init = pulse_init,
|
|
|
|
.finish = pulse_finish,
|
|
|
|
.open = pulse_open,
|
|
|
|
.play = pulse_play,
|
|
|
|
.cancel = pulse_cancel,
|
|
|
|
.close = pulse_close,
|
2009-03-26 18:23:23 +01:00
|
|
|
.mixer_plugin = &pulse_mixer,
|
2006-07-13 21:03:49 +02:00
|
|
|
};
|