+++ /dev/null
-/*-*- 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);
-}
+++ /dev/null
-/*-*- 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.
- */
-
-#ifndef __GST_PULSEPROBE_H__
-#define __GST_PULSEPROBE_H__
-
-#include <gst/gst.h>
-
-G_BEGIN_DECLS
-
-#include <pulse/pulseaudio.h>
-#include <pulse/thread-mainloop.h>
-
-typedef struct _GstPulseProbe GstPulseProbe;
-
-struct _GstPulseProbe
-{
- GObject *object;
- gchar *server;
-
- GList *devices;
- gboolean devices_valid:1;
-
- gboolean operation_success:1;
-
- gboolean enumerate_sinks:1;
- gboolean enumerate_sources:1;
-
- pa_threaded_mainloop *mainloop;
- pa_context *context;
-
- GList *properties;
- guint prop_id;
-};
-
-GstPulseProbe *gst_pulseprobe_new (GObject *object, GObjectClass * klass,
- guint prop_id, const gchar * server, gboolean sinks, gboolean sources);
-void gst_pulseprobe_free (GstPulseProbe * probe);
-
-const GList *gst_pulseprobe_get_properties (GstPulseProbe * probe);
-
-gboolean gst_pulseprobe_needs_probe (GstPulseProbe * probe, guint prop_id,
- const GParamSpec * pspec);
-void gst_pulseprobe_probe_property (GstPulseProbe * probe, guint prop_id,
- const GParamSpec * pspec);
-#if 0
-GValueArray *gst_pulseprobe_get_values (GstPulseProbe * probe, guint prop_id,
- const GParamSpec * pspec);
-#endif
-
-void gst_pulseprobe_set_server (GstPulseProbe * c, const gchar * server);
-
-#define GST_IMPLEMENT_PULSEPROBE_METHODS(Type, interface_as_function) \
-static const GList* \
-interface_as_function ## _get_properties(GstPropertyProbe * probe) \
-{ \
- Type *this = (Type*) probe; \
- \
- g_return_val_if_fail(this != NULL, NULL); \
- g_return_val_if_fail(this->probe != NULL, NULL); \
- \
- return gst_pulseprobe_get_properties(this->probe); \
-} \
-static gboolean \
-interface_as_function ## _needs_probe(GstPropertyProbe *probe, guint prop_id, \
- const GParamSpec *pspec) \
-{ \
- Type *this = (Type*) probe; \
- \
- g_return_val_if_fail(this != NULL, FALSE); \
- g_return_val_if_fail(this->probe != NULL, FALSE); \
- \
- return gst_pulseprobe_needs_probe(this->probe, prop_id, pspec); \
-} \
-static void \
-interface_as_function ## _probe_property(GstPropertyProbe *probe, \
- guint prop_id, const GParamSpec *pspec) \
-{ \
- Type *this = (Type*) probe; \
- \
- g_return_if_fail(this != NULL); \
- g_return_if_fail(this->probe != NULL); \
- \
- gst_pulseprobe_probe_property(this->probe, prop_id, pspec); \
-} \
-static GValueArray* \
-interface_as_function ## _get_values(GstPropertyProbe *probe, guint prop_id, \
- const GParamSpec *pspec) \
-{ \
- Type *this = (Type*) probe; \
- \
- g_return_val_if_fail(this != NULL, NULL); \
- g_return_val_if_fail(this->probe != NULL, NULL); \
- \
- return gst_pulseprobe_get_values(this->probe, prop_id, pspec); \
-} \
-static void \
-interface_as_function ## _property_probe_interface_init(GstPropertyProbeInterface *iface)\
-{ \
- iface->get_properties = interface_as_function ## _get_properties; \
- iface->needs_probe = interface_as_function ## _needs_probe; \
- iface->probe_property = interface_as_function ## _probe_property; \
- iface->get_values = interface_as_function ## _get_values; \
-}
-
-G_END_DECLS
-
-#endif