summaryrefslogtreecommitdiff
path: root/backends/pulse/pulse.c
diff options
context:
space:
mode:
authorMichal Ratajsky <[email protected]>2014-05-24 00:15:24 +0200
committerMichal Ratajsky <[email protected]>2014-05-24 00:15:24 +0200
commitcaf4d9b8b8b0d26856d2d64f00ab23756867a923 (patch)
treebfe58f689a50c3f7f9da3349fbfbc8d42a21a30a /backends/pulse/pulse.c
downloadlibmatemixer-caf4d9b8b8b0d26856d2d64f00ab23756867a923.tar.bz2
libmatemixer-caf4d9b8b8b0d26856d2d64f00ab23756867a923.tar.xz
Initial commit
Diffstat (limited to 'backends/pulse/pulse.c')
-rw-r--r--backends/pulse/pulse.c371
1 files changed, 371 insertions, 0 deletions
diff --git a/backends/pulse/pulse.c b/backends/pulse/pulse.c
new file mode 100644
index 0000000..e969dcf
--- /dev/null
+++ b/backends/pulse/pulse.c
@@ -0,0 +1,371 @@
+/*
+ * Copyright (C) 2014 Michal Ratajsky <[email protected]>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the licence, or (at your option) any later version.
+ *
+ * This library 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <glib.h>
+#include <glib-object.h>
+#include <sys/types.h>
+#include <unistd.h>
+
+#include <libmatemixer/matemixer-backend.h>
+#include <libmatemixer/matemixer-backend-module.h>
+
+#include <pulse/pulseaudio.h>
+#include <pulse/thread-mainloop.h>
+
+#include "pulse.h"
+#include "pulse-device.h"
+
+#define BACKEND_NAME "PulseAudio"
+#define BACKEND_PRIORITY 0
+
+struct _MateMixerPulsePrivate
+{
+ pa_threaded_mainloop *mainloop;
+ pa_context *context;
+ GHashTable *devices;
+};
+
+/* Support function for dynamic loading of the backend module */
+void backend_module_init (GTypeModule *module);
+void backend_module_free (void);
+
+const MateMixerBackendModuleInfo *backend_module_get_info (void);
+
+static void mate_mixer_backend_interface_init (MateMixerBackendInterface *iface);
+
+static void pulse_card_info_cb (pa_context *c,
+ const pa_card_info *info,
+ int eol,
+ void *userdata);
+
+static void pulse_card_update (MateMixerPulse *pulse, const pa_card_info *i);
+
+static void pulse_state_cb (pa_context *c, void *userdata);
+
+static void pulse_subscribe_cb (pa_context *c,
+ pa_subscription_event_type_t t,
+ uint32_t idx,
+ void *userdata);
+
+static gchar *pulse_get_app_name (void);
+
+G_DEFINE_DYNAMIC_TYPE_EXTENDED (MateMixerPulse, mate_mixer_pulse,
+ G_TYPE_OBJECT, 0,
+ G_IMPLEMENT_INTERFACE_DYNAMIC (MATE_MIXER_TYPE_BACKEND,
+ mate_mixer_backend_interface_init))
+
+static MateMixerBackendModuleInfo info;
+
+void
+backend_module_init (GTypeModule *module)
+{
+ mate_mixer_pulse_register_type (module);
+
+ info.name = BACKEND_NAME;
+ info.priority = BACKEND_PRIORITY;
+ info.g_type = MATE_MIXER_TYPE_PULSE;
+ info.backend_type = MATE_MIXER_BACKEND_TYPE_PULSE;
+}
+
+void
+backend_module_free (void)
+{
+}
+
+const MateMixerBackendModuleInfo *
+backend_module_get_info (void)
+{
+ return &info;
+}
+
+static void
+mate_mixer_backend_interface_init (MateMixerBackendInterface *iface)
+{
+ iface->open = mate_mixer_pulse_open;
+ iface->close = mate_mixer_pulse_close;
+ iface->list_devices = mate_mixer_pulse_list_devices;
+}
+
+static void
+mate_mixer_pulse_init (MateMixerPulse *pulse)
+{
+ pulse->priv = G_TYPE_INSTANCE_GET_PRIVATE (
+ pulse,
+ MATE_MIXER_TYPE_PULSE,
+ MateMixerPulsePrivate);
+
+ pulse->priv->devices = g_hash_table_new_full (
+ g_direct_hash,
+ g_direct_equal,
+ NULL,
+ g_object_unref);
+}
+
+static void
+mate_mixer_pulse_finalize (GObject *object)
+{
+ MateMixerPulse *pulse;
+
+ pulse = MATE_MIXER_PULSE (object);
+
+ g_hash_table_destroy (pulse->priv->devices);
+
+ G_OBJECT_CLASS (mate_mixer_pulse_parent_class)->finalize (object);
+}
+
+static void
+mate_mixer_pulse_class_init (MateMixerPulseClass *klass)
+{
+ GObjectClass *object_class;
+
+ object_class = G_OBJECT_CLASS (klass);
+ object_class->finalize = mate_mixer_pulse_finalize;
+
+ g_type_class_add_private (object_class, sizeof (MateMixerPulsePrivate));
+}
+
+/* Called in the code generated by G_DEFINE_DYNAMIC_TYPE_EXTENDED() */
+static void
+mate_mixer_pulse_class_finalize (MateMixerPulseClass *klass)
+{
+}
+
+gboolean
+mate_mixer_pulse_open (MateMixerBackend *backend)
+{
+ int ret;
+ gchar *app_name;
+ MateMixerPulse *pulse;
+
+ g_return_val_if_fail (MATE_MIXER_IS_BACKEND (backend), FALSE);
+
+ pulse = MATE_MIXER_PULSE (backend);
+
+ g_return_val_if_fail (pulse->priv->mainloop == NULL, FALSE);
+
+ pulse->priv->mainloop = pa_threaded_mainloop_new ();
+ if (G_UNLIKELY (pulse->priv->mainloop == NULL)) {
+ g_warning ("Failed to created PulseAudio main loop");
+ return FALSE;
+ }
+
+ app_name = pulse_get_app_name ();
+
+ pulse->priv->context = pa_context_new (
+ pa_threaded_mainloop_get_api (pulse->priv->mainloop),
+ app_name);
+
+ g_free (app_name);
+
+ if (G_UNLIKELY (pulse->priv->context == NULL)) {
+ g_warning ("Failed to created PulseAudio context");
+
+ pa_threaded_mainloop_free (pulse->priv->mainloop);
+ pulse->priv->mainloop = NULL;
+ return FALSE;
+ }
+
+ // XXX: investigate PA_CONTEXT_NOFAIL
+ ret = pa_context_connect (pulse->priv->context, NULL, PA_CONTEXT_NOFLAGS, NULL);
+ if (ret < 0) {
+ g_warning ("Failed to connect to PulseAudio server: %s", pa_strerror (ret));
+
+ pa_context_unref (pulse->priv->context);
+ pa_threaded_mainloop_free (pulse->priv->mainloop);
+
+ pulse->priv->context = NULL;
+ pulse->priv->mainloop = NULL;
+ return FALSE;
+ }
+
+ g_debug ("Connected to PulseAudio server");
+
+ pa_threaded_mainloop_lock (pulse->priv->mainloop);
+
+ pa_context_set_state_callback (pulse->priv->context,
+ pulse_state_cb,
+ backend);
+ pa_context_set_subscribe_callback (pulse->priv->context,
+ pulse_subscribe_cb,
+ backend);
+
+ ret = pa_threaded_mainloop_start (pulse->priv->mainloop);
+ if (ret < 0) {
+ g_warning ("Failed to start PulseAudio main loop: %s", pa_strerror (ret));
+
+ pa_threaded_mainloop_unlock (pulse->priv->mainloop);
+
+ pa_context_unref (pulse->priv->context);
+ pa_threaded_mainloop_free (pulse->priv->mainloop);
+
+ pulse->priv->context = NULL;
+ pulse->priv->mainloop = NULL;
+ return FALSE;
+ }
+
+ while (pa_context_get_state (pulse->priv->context) != PA_CONTEXT_READY) {
+ // XXX this will get stuck if connection fails
+ pa_threaded_mainloop_wait (pulse->priv->mainloop);
+ }
+
+ pa_threaded_mainloop_unlock (pulse->priv->mainloop);
+
+ return TRUE;
+}
+
+void
+mate_mixer_pulse_close (MateMixerBackend *backend)
+{
+ MateMixerPulse *pulse;
+
+ g_return_if_fail (MATE_MIXER_IS_BACKEND (backend));
+
+ pulse = MATE_MIXER_PULSE (backend);
+
+ g_return_if_fail (pulse->priv->mainloop != NULL);
+
+ pa_threaded_mainloop_stop (pulse->priv->mainloop);
+
+ pa_context_unref (pulse->priv->context);
+ pa_threaded_mainloop_free (pulse->priv->mainloop);
+
+ pulse->priv->context = NULL;
+ pulse->priv->mainloop = NULL;
+}
+
+GList *
+mate_mixer_pulse_list_devices (MateMixerBackend *backend)
+{
+ MateMixerPulse *pulse;
+ pa_operation *o;
+
+ g_return_val_if_fail (MATE_MIXER_IS_BACKEND (backend), NULL);
+
+ pulse = MATE_MIXER_PULSE (backend);
+
+ pa_threaded_mainloop_lock (pulse->priv->mainloop);
+
+ o = pa_context_get_card_info_list (pulse->priv->context, pulse_card_info_cb, pulse);
+ if (o == NULL) {
+ g_warning ("Failed to read card list: %s",
+ pa_strerror (pa_context_errno (pulse->priv->context)));
+
+ pa_threaded_mainloop_unlock (pulse->priv->mainloop);
+ return NULL;
+ }
+
+ while (pa_operation_get_state (o) == PA_OPERATION_RUNNING)
+ pa_threaded_mainloop_wait (pulse->priv->mainloop);
+
+ pa_operation_unref (o);
+ pa_threaded_mainloop_unlock (pulse->priv->mainloop);
+
+ return g_hash_table_get_values (pulse->priv->devices);
+}
+
+static void
+pulse_card_info_cb (pa_context *c, const pa_card_info *info, int eol, void *userdata)
+{
+ MateMixerPulse *pulse;
+
+ pulse = MATE_MIXER_PULSE (userdata);
+
+ if (!eol)
+ pulse_card_update (pulse, info);
+
+ pa_threaded_mainloop_signal (pulse->priv->mainloop, 0);
+}
+
+static void
+pulse_card_update (MateMixerPulse *pulse, const pa_card_info *info)
+{
+ gpointer item;
+
+ item = g_hash_table_lookup (pulse->priv->devices, GINT_TO_POINTER (info->index));
+ if (item) {
+ /* The card is already known, just update the fields that may
+ * have changed */
+ mate_mixer_pulse_device_update (MATE_MIXER_PULSE_DEVICE (item), info);
+ } else {
+ MateMixerPulseDevice *device = mate_mixer_pulse_device_new (info);
+
+ if (G_UNLIKELY (device == NULL))
+ g_warning ("Failed to process PulseAudio sound device");
+ else
+ g_hash_table_insert (
+ pulse->priv->devices,
+ GINT_TO_POINTER (info->index),
+ device);
+ }
+}
+
+static void
+pulse_state_cb (pa_context *c, void *userdata)
+{
+ MateMixerPulse *pulse;
+
+ pulse = MATE_MIXER_PULSE (userdata);
+
+ // TODO: handle errors
+
+ switch (pa_context_get_state (c)) {
+ case PA_CONTEXT_UNCONNECTED:
+ break;
+ case PA_CONTEXT_CONNECTING:
+ break;
+ case PA_CONTEXT_AUTHORIZING:
+ break;
+ case PA_CONTEXT_SETTING_NAME:
+ break;
+ case PA_CONTEXT_READY:
+ break;
+ case PA_CONTEXT_FAILED:
+ break;
+ case PA_CONTEXT_TERMINATED:
+ break;
+ default:
+ break;
+ }
+
+ pa_threaded_mainloop_signal (pulse->priv->mainloop, FALSE);
+}
+
+static void
+pulse_subscribe_cb (pa_context *c,
+ pa_subscription_event_type_t t,
+ uint32_t idx,
+ void *userdata)
+{
+ // TODO
+}
+
+static gchar *
+pulse_get_app_name (void)
+{
+ const char *name_app;
+ char name_buf[256];
+
+ /* Inspired by GStreamer's pulse plugin */
+ name_app = g_get_application_name ();
+ if (name_app != NULL)
+ return g_strdup (name_app);
+
+ if (pa_get_binary_name (name_buf, sizeof (name_buf)) != NULL)
+ return g_strdup (name_buf);
+
+ return g_strdup_printf ("libmatemixer-%lu", (gulong) getpid ());
+}
generated by cgit v1.2.1 (git 2.18.0) at 2024-07-23 12:03:18 +0000