aboutsummaryrefslogtreecommitdiffstats
path: root/src/mixer/pulse_mixer_plugin.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mixer/pulse_mixer_plugin.c')
-rw-r--r--src/mixer/pulse_mixer_plugin.c382
1 files changed, 382 insertions, 0 deletions
diff --git a/src/mixer/pulse_mixer_plugin.c b/src/mixer/pulse_mixer_plugin.c
new file mode 100644
index 000000000..54b082819
--- /dev/null
+++ b/src/mixer/pulse_mixer_plugin.c
@@ -0,0 +1,382 @@
+/*
+ * 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.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
+
+#include "mixer_api.h"
+#include "conf.h"
+
+#include <glib.h>
+#include <pulse/volume.h>
+#include <pulse/pulseaudio.h>
+
+#include <string.h>
+
+#undef G_LOG_DOMAIN
+#define G_LOG_DOMAIN "pulse_mixer"
+
+struct pulse_mixer {
+ struct mixer base;
+
+ const char *server;
+ const char *sink;
+ const char *output_name;
+
+ uint32_t index;
+ bool online;
+
+ struct pa_context *context;
+ struct pa_threaded_mainloop *mainloop;
+ struct pa_cvolume volume;
+
+};
+
+/**
+ * \brief waits for a pulseaudio operation to finish, frees it and
+ * unlocks the mainloop
+ * \param operation the operation to wait for
+ * \return true if operation has finished normally (DONE state),
+ * false otherwise
+ */
+static bool
+pulse_wait_for_operation(struct pa_threaded_mainloop *mainloop,
+ struct pa_operation *operation)
+{
+ pa_operation_state_t state;
+
+ assert(mainloop != NULL);
+ assert(operation != NULL);
+
+ state = pa_operation_get_state(operation);
+ while (state == PA_OPERATION_RUNNING) {
+ pa_threaded_mainloop_wait(mainloop);
+ state = pa_operation_get_state(operation);
+ }
+
+ pa_operation_unref(operation);
+
+ return state == PA_OPERATION_DONE;
+}
+
+static void
+sink_input_cb(G_GNUC_UNUSED pa_context *context, const pa_sink_input_info *i,
+ int eol, void *userdata)
+{
+
+ struct pulse_mixer *pm = userdata;
+
+ if (eol) {
+ g_debug("eol error sink_input_cb");
+ return;
+ }
+
+ if (i == NULL) {
+ g_debug("Sink input callback failure");
+ return;
+ }
+
+ g_debug("sink input cb %s, index %d ",i->name,i->index);
+
+ if (strcmp(i->name,pm->output_name) == 0) {
+ pm->index = i->index;
+ pm->online = true;
+ pm->volume = i->volume;
+ } else
+ g_debug("bad name");
+}
+
+static void
+sink_input_vol(G_GNUC_UNUSED pa_context *context, const pa_sink_input_info *i,
+ int eol, void *userdata)
+{
+
+ struct pulse_mixer *pm = userdata;
+
+ if (eol) {
+ g_debug("eol error sink_input_vol");
+ return;
+ }
+
+ if (i == NULL) {
+ g_debug("Sink input callback failure");
+ return;
+ }
+
+ g_debug("sink input vol %s, index %d ", i->name, i->index);
+
+ pm->volume = i->volume;
+
+ pa_threaded_mainloop_signal(pm->mainloop, 0);
+}
+
+static void
+subscribe_cb(pa_context *c, pa_subscription_event_type_t t,
+ uint32_t idx, void *userdata)
+{
+
+ struct pulse_mixer *pm = userdata;
+
+ g_debug("subscribe call back");
+
+ switch (t & PA_SUBSCRIPTION_EVENT_FACILITY_MASK) {
+ case PA_SUBSCRIPTION_EVENT_SINK_INPUT:
+ if ((t & PA_SUBSCRIPTION_EVENT_TYPE_MASK) ==
+ PA_SUBSCRIPTION_EVENT_REMOVE &&
+ pm->index == idx)
+ pm->online = false;
+ else {
+ pa_operation *o;
+
+ o = pa_context_get_sink_input_info(c, idx,
+ sink_input_cb, pm);
+ if (o == NULL) {
+ g_debug("pa_context_get_sink_input_info() failed");
+ return;
+ }
+
+ pa_operation_unref(o);
+ }
+
+ break;
+ }
+}
+
+static void
+context_state_cb(pa_context *context, void *userdata)
+{
+ struct pulse_mixer *pm = userdata;
+
+ switch (pa_context_get_state(context)) {
+ case PA_CONTEXT_READY: {
+ pa_operation *o;
+
+ pa_context_set_subscribe_callback(context, subscribe_cb, pm);
+
+ o = pa_context_subscribe(context,
+ (pa_subscription_mask_t)PA_SUBSCRIPTION_MASK_SINK_INPUT,
+ NULL, NULL);
+ if (o == NULL) {
+ g_debug("pa_context_subscribe() failed");
+ return;
+ }
+
+ pa_operation_unref(o);
+
+ o = pa_context_get_sink_input_info_list(context,
+ sink_input_cb, pm);
+ if (o == NULL) {
+ g_debug("pa_context_get_sink_input_info_list() failed");
+ return;
+ }
+
+ pa_operation_unref(o);
+
+ pa_threaded_mainloop_signal(pm->mainloop, 0);
+ break;
+ }
+
+ case PA_CONTEXT_UNCONNECTED:
+ case PA_CONTEXT_CONNECTING:
+ case PA_CONTEXT_AUTHORIZING:
+ case PA_CONTEXT_SETTING_NAME:
+ break;
+ case PA_CONTEXT_TERMINATED:
+ case PA_CONTEXT_FAILED:
+ pa_threaded_mainloop_signal(pm->mainloop, 0);
+ break;
+ }
+}
+
+
+static struct mixer *
+pulse_mixer_init(const struct config_param *param)
+{
+ struct pulse_mixer *pm = g_new(struct pulse_mixer,1);
+ mixer_init(&pm->base, &pulse_mixer_plugin);
+
+ pm->online = false;
+
+ pm->server = config_get_block_string(param, "server", NULL);
+ pm->sink = config_get_block_string(param, "sink", NULL);
+ pm->output_name = config_get_block_string(param, "name", NULL);
+
+ return &pm->base;
+}
+
+static void
+pulse_mixer_finish(struct mixer *data)
+{
+ struct pulse_mixer *pm = (struct pulse_mixer *) data;
+
+ g_free(pm);
+}
+
+static bool
+pulse_mixer_setup(struct pulse_mixer *pm)
+{
+ pa_context_set_state_callback(pm->context, context_state_cb, pm);
+
+ if (pa_context_connect(pm->context, pm->server,
+ (pa_context_flags_t)0, NULL) < 0) {
+ g_debug("context server fail");
+ return false;
+ }
+
+ pa_threaded_mainloop_lock(pm->mainloop);
+
+ if (pa_threaded_mainloop_start(pm->mainloop) < 0) {
+ pa_threaded_mainloop_unlock(pm->mainloop);
+ g_debug("error start mainloop");
+ return false;
+ }
+
+ pa_threaded_mainloop_wait(pm->mainloop);
+
+ if (pa_context_get_state(pm->context) != PA_CONTEXT_READY) {
+ pa_threaded_mainloop_unlock(pm->mainloop);
+ g_debug("error context not ready");
+ return false;
+ }
+
+ pa_threaded_mainloop_unlock(pm->mainloop);
+
+ return true;
+}
+
+static bool
+pulse_mixer_open(struct mixer *data)
+{
+ struct pulse_mixer *pm = (struct pulse_mixer *) data;
+
+ g_debug("pulse mixer open");
+
+ pm->index = 0;
+ pm->online = false;
+
+ pm->mainloop = pa_threaded_mainloop_new();
+ if (pm->mainloop == NULL) {
+ g_debug("failed mainloop");
+ return false;
+ }
+
+ pm->context = pa_context_new(pa_threaded_mainloop_get_api(pm->mainloop),
+ "Mixer mpd");
+ if (pm->context == NULL) {
+ pa_threaded_mainloop_stop(pm->mainloop);
+ pa_threaded_mainloop_free(pm->mainloop);
+ g_debug("failed context");
+ return false;
+ }
+
+ if (!pulse_mixer_setup(pm)) {
+ pa_threaded_mainloop_stop(pm->mainloop);
+ pa_context_disconnect(pm->context);
+ pa_context_unref(pm->context);
+ pa_threaded_mainloop_free(pm->mainloop);
+ return false;
+ }
+
+ return true;
+}
+
+static void
+pulse_mixer_close(struct mixer *data)
+{
+ struct pulse_mixer *pm = (struct pulse_mixer *) data;
+
+ pa_threaded_mainloop_stop(pm->mainloop);
+ pa_context_disconnect(pm->context);
+ pa_context_unref(pm->context);
+ pa_threaded_mainloop_free(pm->mainloop);
+
+ pm->online = false;
+}
+
+static int
+pulse_mixer_get_volume(struct mixer *mixer)
+{
+ struct pulse_mixer *pm = (struct pulse_mixer *) mixer;
+ int ret;
+ pa_operation *o;
+
+ pa_threaded_mainloop_lock(pm->mainloop);
+
+ if (!pm->online) {
+ pa_threaded_mainloop_unlock(pm->mainloop);
+ return false;
+ }
+
+ o = pa_context_get_sink_input_info(pm->context, pm->index,
+ sink_input_vol, pm);
+ if (o == NULL) {
+ pa_threaded_mainloop_unlock(pm->mainloop);
+ g_debug("pa_context_get_sink_input_info() failed");
+ return false;
+ }
+
+ if (!pulse_wait_for_operation(pm->mainloop, o)) {
+ pa_threaded_mainloop_unlock(pm->mainloop);
+ return false;
+ }
+
+ ret = pm->online
+ ? (int)((100*(pa_cvolume_avg(&pm->volume)+1))/PA_VOLUME_NORM)
+ : -1;
+
+ pa_threaded_mainloop_unlock(pm->mainloop);
+
+ return ret;
+}
+
+static bool
+pulse_mixer_set_volume(struct mixer *mixer, unsigned volume)
+{
+ struct pulse_mixer *pm = (struct pulse_mixer *) mixer;
+ struct pa_cvolume cvolume;
+ pa_operation *o;
+
+ pa_threaded_mainloop_lock(pm->mainloop);
+
+ if (!pm->online) {
+ pa_threaded_mainloop_unlock(pm->mainloop);
+ return false;
+ }
+
+ pa_cvolume_set(&cvolume, pm->volume.channels,
+ (pa_volume_t)volume * PA_VOLUME_NORM / 100 + 0.5);
+
+ o = pa_context_set_sink_input_volume(pm->context, pm->index,
+ &cvolume, NULL, NULL);
+ pa_threaded_mainloop_unlock(pm->mainloop);
+ if (o == NULL) {
+ g_debug("pa_context_set_sink_input_volume() failed");
+ return false;
+ }
+
+ pa_operation_unref(o);
+
+ return true;
+}
+
+const struct mixer_plugin pulse_mixer_plugin = {
+ .init = pulse_mixer_init,
+ .finish = pulse_mixer_finish,
+ .open = pulse_mixer_open,
+ .close = pulse_mixer_close,
+ .get_volume = pulse_mixer_get_volume,
+ .set_volume = pulse_mixer_set_volume,
+};