summaryrefslogtreecommitdiffstats
path: root/src/polypprobe.c
diff options
context:
space:
mode:
authorLennart Poettering <lennart@poettering.net>2006-06-20 19:29:12 +0000
committerLennart Poettering <lennart@poettering.net>2006-06-20 19:29:12 +0000
commitd84317d5a95ac21de8aa673eff64e00e40f82557 (patch)
tree50c8793ea07cf2f5df2eccdce68ead76534ba061 /src/polypprobe.c
parent4290b897a297e311484f46b1cac2f6b5296a38fe (diff)
rename source files
git-svn-id: file:///home/lennart/svn/public/gst-pulse/trunk@41 bb39ca4e-bce3-0310-b5d4-eea78a553289
Diffstat (limited to 'src/polypprobe.c')
-rw-r--r--src/polypprobe.c322
1 files changed, 0 insertions, 322 deletions
diff --git a/src/polypprobe.c b/src/polypprobe.c
deleted file mode 100644
index adb5212..0000000
--- a/src/polypprobe.c
+++ /dev/null
@@ -1,322 +0,0 @@
-/* $Id$ */
-
-/***
- This file is part of gst-pulse.
-
- 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307
- USA.
-***/
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#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) {
- GstPolypProbe *c = (GstPolypProbe*) 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) {
- GstPolypProbe *c = (GstPolypProbe*) 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) {
- GstPolypProbe *c = (GstPolypProbe*) 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(GstPolypProbe *c) {
- g_list_foreach(c->devices, (GFunc) g_free, NULL);
- g_list_free(c->devices);
- c->devices = NULL;
- c->devices_valid = 0;
-}
-
-static gboolean gst_pulseprobe_open(GstPolypProbe *c) {
- int e;
- gchar *name = gst_pulse_client_name();
-
- g_assert(c);
-
- c->mainloop = pa_threaded_mainloop_new();
- g_assert(c->mainloop);
-
- e = pa_threaded_mainloop_start(c->mainloop);
- g_assert(e == 0);
-
- pa_threaded_mainloop_lock(c->mainloop);
-
- if (!(c->context = pa_context_new(pa_threaded_mainloop_get_api(c->mainloop), name))) {
- GST_WARNING("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("Failed to connect context: %s", pa_strerror(pa_context_errno(c->context)));
- goto unlock_and_fail;
- }
-
- /* Wait until the context is ready */
- pa_threaded_mainloop_wait(c->mainloop);
-
- if (pa_context_get_state(c->context) != PA_CONTEXT_READY) {
- GST_WARNING("Failed to connect context: %s", pa_strerror(pa_context_errno(c->context)));
- goto unlock_and_fail;
- }
-
- 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;
-}
-
-#define CHECK_DEAD_GOTO(c, label) do { \
-if (!(c)->context || pa_context_get_state((c)->context) != PA_CONTEXT_READY) { \
- GST_WARNING("Not connected: %s", (c)->context ? pa_strerror(pa_context_errno((c)->context)) : "NULL"); \
- goto label; \
-} \
-} while(0);
-
-static gboolean gst_pulseprobe_enumerate(GstPolypProbe *c) {
- pa_operation *o = NULL;
-
- 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("Failed to get sink info: %s", pa_strerror(pa_context_errno(c->context)));
- goto unlock_and_fail;
- }
-
- c->operation_success = 0;
- while (pa_operation_get_state(o) != PA_OPERATION_DONE) {
- pa_threaded_mainloop_wait(c->mainloop);
- CHECK_DEAD_GOTO(c, unlock_and_fail);
- }
-
- if (!c->operation_success) {
- GST_WARNING("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("Failed to get source info: %s", pa_strerror(pa_context_errno(c->context)));
- goto unlock_and_fail;
- }
-
- c->operation_success = 0;
- while (pa_operation_get_state(o) != PA_OPERATION_DONE) {
- pa_threaded_mainloop_wait(c->mainloop);
- CHECK_DEAD_GOTO(c, unlock_and_fail);
- }
-
- if (!c->operation_success) {
- GST_WARNING("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 = 1;
-
- 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(GstPolypProbe *c) {
- g_assert(c);
-
- if (c->mainloop)
- pa_threaded_mainloop_stop(c->mainloop);
-
- if (c->context) {
- pa_context_disconnect(c->context);
- pa_context_unref(c->context);
- c->context = NULL;
- }
-
- if (c->mainloop) {
- pa_threaded_mainloop_free(c->mainloop);
- c->mainloop = NULL;
- }
-}
-
-GstPolypProbe* gst_pulseprobe_new(GObjectClass *klass, guint prop_id, const gchar *server, gboolean sinks, gboolean sources) {
- GstPolypProbe *c = NULL;
-
- c = g_new(GstPolypProbe, 1);
- 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 = 0;
-
- return c;
-}
-
-void gst_pulseprobe_free(GstPolypProbe* 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(GstPolypProbe *c) {
- return c->properties;
-}
-
-gboolean gst_pulseprobe_needs_probe(GstPolypProbe *c, guint prop_id, const GParamSpec *pspec) {
-
- if (prop_id == c->prop_id)
- return !c->devices_valid;
-
- G_OBJECT_WARN_INVALID_PROPERTY_ID(c, prop_id, pspec);
- return FALSE;
-}
-
-void gst_pulseprobe_probe_property(GstPolypProbe *c, guint prop_id, const GParamSpec *pspec) {
-
- if (prop_id != c->prop_id) {
- G_OBJECT_WARN_INVALID_PROPERTY_ID(c, prop_id, pspec);
- return;
- }
-
- if (gst_pulseprobe_open(c)) {
- gst_pulseprobe_enumerate(c);
- gst_pulseprobe_close(c);
- }
-}
-
-GValueArray *gst_pulseprobe_get_values(GstPolypProbe *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, 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("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;
-}
-
-void gst_pulseprobe_set_server(GstPolypProbe *c, const gchar *server) {
- g_assert(c);
-
- gst_pulseprobe_invalidate(c);
-
- g_free(c->server);
- c->server = g_strdup(server);
-}