/*-*- Mode: C; c-basic-offset: 2 -*-*/ /* * GStreamer pulseaudio plugin * * Copyright (c) 2004-2008 Lennart Poettering * * gst-pulse 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.1 of the * License, or (at your option) any later version. * * gst-pulse 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 gst-pulse; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 * USA. */ /* FIXME 0.11: suppress warnings for deprecated API such as GValueArray * with newer GLib versions (>= 2.31.0) */ #define GLIB_DISABLE_DEPRECATION_WARNINGS #ifdef HAVE_CONFIG_H #include "config.h" #endif #include <gst/audio/audio.h> #include "pulseprobe.h" #include "pulseutil.h" GST_DEBUG_CATEGORY_EXTERN (pulse_debug); #define GST_CAT_DEFAULT pulse_debug static void gst_pulseprobe_context_state_cb (pa_context * context, void *userdata) { GstPulseProbe *c = (GstPulseProbe *) userdata; /* Called from the background thread! */ switch (pa_context_get_state (context)) { case PA_CONTEXT_READY: case PA_CONTEXT_TERMINATED: case PA_CONTEXT_FAILED: pa_threaded_mainloop_signal (c->mainloop, 0); break; case PA_CONTEXT_UNCONNECTED: case PA_CONTEXT_CONNECTING: case PA_CONTEXT_AUTHORIZING: case PA_CONTEXT_SETTING_NAME: break; } } static void gst_pulseprobe_sink_info_cb (pa_context * context, const pa_sink_info * i, int eol, void *userdata) { GstPulseProbe *c = (GstPulseProbe *) userdata; /* Called from the background thread! */ if (eol || !i) { c->operation_success = eol > 0; pa_threaded_mainloop_signal (c->mainloop, 0); } if (i) c->devices = g_list_append (c->devices, g_strdup (i->name)); } static void gst_pulseprobe_source_info_cb (pa_context * context, const pa_source_info * i, int eol, void *userdata) { GstPulseProbe *c = (GstPulseProbe *) userdata; /* Called from the background thread! */ if (eol || !i) { c->operation_success = eol > 0; pa_threaded_mainloop_signal (c->mainloop, 0); } if (i) c->devices = g_list_append (c->devices, g_strdup (i->name)); } static void gst_pulseprobe_invalidate (GstPulseProbe * c) { g_list_foreach (c->devices, (GFunc) g_free, NULL); g_list_free (c->devices); c->devices = NULL; c->devices_valid = FALSE; } static gboolean gst_pulseprobe_open (GstPulseProbe * c) { int e; gchar *name; g_assert (c); GST_DEBUG_OBJECT (c->object, "probe open"); c->mainloop = pa_threaded_mainloop_new (); if (!c->mainloop) return FALSE; e = pa_threaded_mainloop_start (c->mainloop); if (e < 0) return FALSE; name = gst_pulse_client_name (); pa_threaded_mainloop_lock (c->mainloop); if (!(c->context = pa_context_new (pa_threaded_mainloop_get_api (c->mainloop), name))) { GST_WARNING_OBJECT (c->object, "Failed to create context"); goto unlock_and_fail; } pa_context_set_state_callback (c->context, gst_pulseprobe_context_state_cb, c); if (pa_context_connect (c->context, c->server, 0, NULL) < 0) { GST_WARNING_OBJECT (c->object, "Failed to connect context: %s", pa_strerror (pa_context_errno (c->context))); goto unlock_and_fail; } for (;;) { pa_context_state_t state; state = pa_context_get_state (c->context); if (!PA_CONTEXT_IS_GOOD (state)) { GST_WARNING_OBJECT (c->object, "Failed to connect context: %s", pa_strerror (pa_context_errno (c->context))); goto unlock_and_fail; } if (state == PA_CONTEXT_READY) break; /* Wait until the context is ready */ pa_threaded_mainloop_wait (c->mainloop); } pa_threaded_mainloop_unlock (c->mainloop); g_free (name); gst_pulseprobe_invalidate (c); return TRUE; unlock_and_fail: if (c->mainloop) pa_threaded_mainloop_unlock (c->mainloop); g_free (name); return FALSE; } static gboolean gst_pulseprobe_is_dead (GstPulseProbe * pulseprobe) { if (!pulseprobe->context || !PA_CONTEXT_IS_GOOD (pa_context_get_state (pulseprobe->context))) { const gchar *err_str = pulseprobe->context ? pa_strerror (pa_context_errno (pulseprobe->context)) : NULL; GST_ELEMENT_ERROR ((pulseprobe), RESOURCE, FAILED, ("Disconnected: %s", err_str), (NULL)); return TRUE; } return FALSE; } static gboolean gst_pulseprobe_enumerate (GstPulseProbe * c) { pa_operation *o = NULL; GST_DEBUG_OBJECT (c->object, "probe enumerate"); pa_threaded_mainloop_lock (c->mainloop); if (c->enumerate_sinks) { /* Get sink info */ if (!(o = pa_context_get_sink_info_list (c->context, gst_pulseprobe_sink_info_cb, c))) { GST_WARNING_OBJECT (c->object, "Failed to get sink info: %s", pa_strerror (pa_context_errno (c->context))); goto unlock_and_fail; } c->operation_success = FALSE; while (pa_operation_get_state (o) == PA_OPERATION_RUNNING) { if (gst_pulseprobe_is_dead (c)) goto unlock_and_fail; pa_threaded_mainloop_wait (c->mainloop); } if (!c->operation_success) { GST_WARNING_OBJECT (c->object, "Failed to get sink info: %s", pa_strerror (pa_context_errno (c->context))); goto unlock_and_fail; } pa_operation_unref (o); o = NULL; } if (c->enumerate_sources) { /* Get source info */ if (!(o = pa_context_get_source_info_list (c->context, gst_pulseprobe_source_info_cb, c))) { GST_WARNING_OBJECT (c->object, "Failed to get source info: %s", pa_strerror (pa_context_errno (c->context))); goto unlock_and_fail; } c->operation_success = FALSE; while (pa_operation_get_state (o) == PA_OPERATION_RUNNING) { if (gst_pulseprobe_is_dead (c)) goto unlock_and_fail; pa_threaded_mainloop_wait (c->mainloop); } if (!c->operation_success) { GST_WARNING_OBJECT (c->object, "Failed to get sink info: %s", pa_strerror (pa_context_errno (c->context))); goto unlock_and_fail; } pa_operation_unref (o); o = NULL; } c->devices_valid = TRUE; pa_threaded_mainloop_unlock (c->mainloop); return TRUE; unlock_and_fail: if (o) pa_operation_unref (o); pa_threaded_mainloop_unlock (c->mainloop); return FALSE; } static void gst_pulseprobe_close (GstPulseProbe * c) { g_assert (c); GST_DEBUG_OBJECT (c->object, "probe close"); if (c->mainloop) pa_threaded_mainloop_stop (c->mainloop); if (c->context) { pa_context_disconnect (c->context); pa_context_set_state_callback (c->context, NULL, NULL); pa_context_unref (c->context); c->context = NULL; } if (c->mainloop) { pa_threaded_mainloop_free (c->mainloop); c->mainloop = NULL; } } GstPulseProbe * gst_pulseprobe_new (GObject * object, GObjectClass * klass, guint prop_id, const gchar * server, gboolean sinks, gboolean sources) { GstPulseProbe *c = NULL; c = g_new (GstPulseProbe, 1); c->object = object; /* We don't inc the ref counter here to avoid a ref loop */ c->server = g_strdup (server); c->enumerate_sinks = sinks; c->enumerate_sources = sources; c->mainloop = NULL; c->context = NULL; c->prop_id = prop_id; c->properties = g_list_append (NULL, g_object_class_find_property (klass, "device")); c->devices = NULL; c->devices_valid = FALSE; c->operation_success = FALSE; return c; } void gst_pulseprobe_free (GstPulseProbe * c) { g_assert (c); gst_pulseprobe_close (c); g_list_free (c->properties); g_free (c->server); g_list_foreach (c->devices, (GFunc) g_free, NULL); g_list_free (c->devices); g_free (c); } const GList * gst_pulseprobe_get_properties (GstPulseProbe * c) { return c->properties; } gboolean gst_pulseprobe_needs_probe (GstPulseProbe * c, guint prop_id, const GParamSpec * pspec) { if (prop_id == c->prop_id) return !c->devices_valid; G_OBJECT_WARN_INVALID_PROPERTY_ID (c->object, prop_id, pspec); return FALSE; } void gst_pulseprobe_probe_property (GstPulseProbe * c, guint prop_id, const GParamSpec * pspec) { if (prop_id != c->prop_id) { G_OBJECT_WARN_INVALID_PROPERTY_ID (c->object, prop_id, pspec); return; } if (gst_pulseprobe_open (c)) { gst_pulseprobe_enumerate (c); gst_pulseprobe_close (c); } } #if 0 GValueArray * gst_pulseprobe_get_values (GstPulseProbe * c, guint prop_id, const GParamSpec * pspec) { GValueArray *array; GValue value = { 0 }; GList *item; if (prop_id != c->prop_id) { G_OBJECT_WARN_INVALID_PROPERTY_ID (c->object, prop_id, pspec); return NULL; } if (!c->devices_valid) return NULL; array = g_value_array_new (g_list_length (c->devices)); g_value_init (&value, G_TYPE_STRING); for (item = c->devices; item != NULL; item = item->next) { GST_WARNING_OBJECT (c->object, "device found: %s", (const gchar *) item->data); g_value_set_string (&value, (const gchar *) item->data); g_value_array_append (array, &value); } g_value_unset (&value); return array; } #endif void gst_pulseprobe_set_server (GstPulseProbe * c, const gchar * server) { g_assert (c); gst_pulseprobe_invalidate (c); g_free (c->server); c->server = g_strdup (server); }