/* * 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; }; 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) { 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) { g_debug("Sink input callback failure"); return; } g_debug("sink input vol %s, index %d ", i->name, i->index); *pm->volume=i->volume; } static void subscribe_cb(G_GNUC_UNUSED 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; if (!(o = pa_context_get_sink_input_info(pm->context, idx, sink_input_cb, pm))) { 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); if (!(o = pa_context_subscribe(context, (pa_subscription_mask_t) (PA_SUBSCRIPTION_MASK_SINK_INPUT), NULL, NULL))) { g_debug("pa_context_subscribe() failed"); return; } pa_operation_unref(o); if (!(o = pa_context_get_sink_input_info_list(context, sink_input_cb, pm))) { 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); pm->server = NULL; pm->sink = NULL; pm->context=NULL; pm->mainloop=NULL; pm->volume=NULL; pm->output_name=NULL; pm->index=0; pm->online=false; pm->volume = g_new(struct pa_cvolume,1); 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; pm->context = NULL; pm->mainloop = NULL; pm->volume = NULL; pm->online = false; 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(G_GNUC_UNUSED struct mixer *data) { struct pulse_mixer *pm = (struct pulse_mixer *) data; g_debug("pulse mixer open"); if(!(pm->mainloop = pa_threaded_mainloop_new())) { g_debug("failed mainloop"); return false; } if(!(pm->context = pa_context_new(pa_threaded_mainloop_get_api(pm->mainloop), "Mixer mpd"))) { 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(G_GNUC_UNUSED struct mixer *data) { struct pulse_mixer *pm=(struct pulse_mixer *) data; if (pm->mainloop) pa_threaded_mainloop_stop(pm->mainloop); if (pm->context) { pa_context_disconnect(pm->context); pa_context_unref(pm->context); pm->context = NULL; } if (pm->mainloop) { pa_threaded_mainloop_free(pm->mainloop); pm->mainloop = NULL; } } static int pulse_mixer_get_volume(struct mixer *mixer) { struct pulse_mixer *pm=(struct pulse_mixer *) mixer; int ret; pa_operation *o; g_debug("get_volume %s", pm->online == TRUE ? "online" : "offline"); if(pm->online) { if (!(o = pa_context_get_sink_input_info(pm->context, pm->index, sink_input_vol, pm))) { g_debug("pa_context_get_sink_input_info() failed"); return false; } pa_operation_unref(o); ret = (int)((100*(pa_cvolume_avg(pm->volume)+1))/PA_VOLUME_NORM); g_debug("volume %d", ret); return ret; } return false; } static bool pulse_mixer_set_volume(struct mixer *mixer, unsigned volume) { struct pulse_mixer *pm=(struct pulse_mixer *) mixer; pa_operation *o; if (pm->online) { pa_cvolume_set(pm->volume, (pm->volume)->channels, (pa_volume_t)(volume)*PA_VOLUME_NORM/100+0.5); if (!(o = pa_context_set_sink_input_volume(pm->context, pm->index, pm->volume, NULL, NULL))) { g_debug("pa_context_set_sink_input_volume() failed"); return false; } pa_operation_unref(o); } return true; } const struct mixer_plugin pulse_mixer = { .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, };