[RFC v2 1/6] bluetooth: module-bluetooth-policy initial commit

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



---
 src/Makefile.am                                 |    7 +
 src/modules/bluetooth/module-bluetooth-policy.c |  211 +++++++++++++++++++++++
 2 files changed, 218 insertions(+), 0 deletions(-)
 create mode 100644 src/modules/bluetooth/module-bluetooth-policy.c

diff --git a/src/Makefile.am b/src/Makefile.am
index 02635fa..6fb8c45 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -1215,6 +1215,7 @@ modlibexec_LTLIBRARIES += \
 		module-bluetooth-discover.la \
 		libbluetooth-ipc.la \
 		libbluetooth-sbc.la \
+		module-bluetooth-policy.la \
 		module-bluetooth-device.la
 
 pulselibexec_PROGRAMS += \
@@ -1304,6 +1305,7 @@ SYMDEF_FILES = \
 		module-udev-detect-symdef.h \
 		module-bluetooth-proximity-symdef.h \
 		module-bluetooth-discover-symdef.h \
+		module-bluetooth-policy-symdef.h \
 		module-bluetooth-device-symdef.h \
 		module-raop-sink-symdef.h \
 		module-raop-discover-symdef.h \
@@ -1902,6 +1904,11 @@ module_bluetooth_device_la_LDFLAGS = $(MODULE_LDFLAGS)
 module_bluetooth_device_la_LIBADD = $(MODULE_LIBADD) $(DBUS_LIBS) libbluetooth-util.la libbluetooth-ipc.la libbluetooth-sbc.la
 module_bluetooth_device_la_CFLAGS = $(AM_CFLAGS) $(DBUS_CFLAGS) -I$(top_srcdir)/src/modules/bluetooth/sbc
 
+module_bluetooth_policy_la_SOURCES = modules/bluetooth/module-bluetooth-policy.c
+module_bluetooth_policy_la_LDFLAGS = $(MODULE_LDFLAGS)
+module_bluetooth_policy_la_LIBADD = $(MODULE_LIBADD) $(DBUS_LIBS) libbluetooth-util.la
+module_bluetooth_policy_la_CFLAGS = $(AM_CFLAGS) $(DBUS_CFLAGS)
+
 # Apple Airtunes/RAOP
 module_raop_sink_la_SOURCES = modules/raop/module-raop-sink.c
 module_raop_sink_la_LDFLAGS = $(MODULE_LDFLAGS)
diff --git a/src/modules/bluetooth/module-bluetooth-policy.c b/src/modules/bluetooth/module-bluetooth-policy.c
new file mode 100644
index 0000000..44b70e9
--- /dev/null
+++ b/src/modules/bluetooth/module-bluetooth-policy.c
@@ -0,0 +1,211 @@
+/***
+  This file is part of PulseAudio.
+
+  Copyright (C) 2012 Intel Corporation
+
+  PulseAudio 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.
+
+  PulseAudio 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 Lesser General Public License
+  along with PulseAudio; 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 <pulse/xmalloc.h>
+
+#include <pulsecore/core.h>
+#include <pulsecore/sink.h>
+#include <pulsecore/source.h>
+#include <pulsecore/log.h>
+#include <pulsecore/namereg.h>
+#include <pulsecore/core-util.h>
+
+#include "module-bluetooth-policy-symdef.h"
+
+PA_MODULE_AUTHOR("Fr?d?ric Dalleau");
+PA_MODULE_DESCRIPTION("When a sink/source is added, load module-loopback");
+PA_MODULE_VERSION(PACKAGE_VERSION);
+PA_MODULE_LOAD_ONCE(TRUE);
+
+static const char* const valid_modargs[] = {
+    NULL,
+};
+
+struct userdata {
+    pa_hook_slot
+        *sink_put_slot,
+        *source_put_slot;
+    pa_hashmap *hashmap;
+};
+
+/* When a sink is created, loopback default source (microphone) on it */
+static pa_hook_result_t sink_put_hook_callback(pa_core *c, pa_sink *sink, void* userdata) {
+    pa_source *defsource;
+    pa_sink *defsink;
+    struct userdata *u = userdata;
+    const char *s;
+    pa_module *m = NULL;
+    char *args;
+
+    pa_assert(c);
+    pa_assert(sink);
+
+    /* Don't want to run during startup or shutdown */
+    if (c->state != PA_CORE_RUNNING)
+        return PA_HOOK_OK;
+
+    pa_log_debug("Sink %s being created", sink->name);
+
+    m = pa_hashmap_get(u->hashmap, sink->name);
+    if (m) {
+        pa_log_debug("Loopback already loaded for sink %s with args '%s'", sink->name, m->argument);
+        return PA_HOOK_OK;
+    }
+
+    /* Only consider bluetooth sink and sources */
+    if ((s = pa_proplist_gets(sink->proplist, PA_PROP_DEVICE_BUS))) {
+        if (!pa_streq(s, "bluetooth"))
+            return PA_HOOK_OK;
+    }
+
+    /* Prevent loopback default source over default sink */
+    defsink = pa_namereg_get_default_sink(c);
+    if (defsink == sink) {
+        pa_log_debug("Refusing to loopback to default sink %s", sink->name);
+        return PA_HOOK_OK;
+    }
+
+    /* Find suitable source to loopback from */
+    defsource = pa_namereg_get_default_source(c);
+    if (!defsource)
+        defsource = defsink->monitor_source;
+
+    if (!defsource) {
+        pa_log_debug("Cannot find suitable source for loopback to %s", sink->name);
+        return PA_HOOK_OK;
+    }
+
+    /* Load module-loopback with selected source */
+    args = pa_sprintf_malloc("source=\"%s\" sink=\"%s\" source_dont_move=\"true\"", defsource->name, sink->name);
+    m = pa_module_load(c, "module-loopback", args);
+
+    if (m)
+        pa_hashmap_put(u->hashmap, sink->name, m);
+    else
+        pa_log_debug("Failed to loopback sink %s with args '%s'", sink->name, args);
+
+    pa_xfree(args);
+
+    return PA_HOOK_OK;
+}
+
+/* When a source is created, loopback default the source to default sink */
+static pa_hook_result_t source_put_hook_callback(pa_core *c, pa_source *source, void* userdata) {
+    pa_source *defsource;
+    pa_sink *defsink;
+    struct userdata *u = userdata;
+    const char *s;
+    pa_module *m = NULL;
+    char *args;
+
+    pa_assert(c);
+    pa_assert(source);
+
+    /* Don't want to run during startup or shutdown */
+    if (c->state != PA_CORE_RUNNING)
+        return PA_HOOK_OK;
+
+    pa_log_debug("Source %s being created", source->name);
+
+    m = pa_hashmap_get(u->hashmap, source->name);
+    if (m) {
+        pa_log_debug("Loopback already loaded for source  %s with args '%s'", source->name, m->argument);
+        return PA_HOOK_OK;
+    }
+
+    /* Only consider bluetooth sink and sources */
+    if ((s = pa_proplist_gets(source->proplist, PA_PROP_DEVICE_BUS))) {
+        if (!pa_streq(s, "bluetooth"))
+            return PA_HOOK_OK;
+    }
+
+    /* Prevent loopback default source over default sink */
+    defsource = pa_namereg_get_default_source(c);
+    if (defsource == source) {
+        pa_log_debug("Refusing to loopback from default source %s", source->name);
+        return PA_HOOK_OK;
+    }
+
+    /* Find suitable sink to loopback to */
+    defsink = pa_namereg_get_default_sink(c);
+    if (!defsink) {
+        pa_log_debug("Cannot find suitable sink for loopback from %s", source->name);
+        return PA_HOOK_OK;
+    }
+
+    /* Load module-loopback with selected sink */
+    args = pa_sprintf_malloc("source=\"%s\" sink=\"%s\" source_dont_move=\"true\"", source->name, defsink->name);
+    m = pa_module_load(c, "module-loopback", args);
+
+    if (m)
+        pa_hashmap_put(u->hashmap, source->name, m);
+    else
+        pa_log_debug("Failed to loopback source %s with args '%s'", source->name, args);
+
+    pa_xfree(args);
+
+    return PA_HOOK_OK;
+}
+
+int pa__init(pa_module*m) {
+    struct userdata *u;
+
+    pa_assert(m);
+
+    m->userdata = u = pa_xnew0(struct userdata, 1);
+
+    /* A little bit later than module-rescue-streams... */
+    u->sink_put_slot = pa_hook_connect(&m->core->hooks[PA_CORE_HOOK_SINK_PUT], PA_HOOK_LATE+30, (pa_hook_cb_t) sink_put_hook_callback, u);
+    u->source_put_slot = pa_hook_connect(&m->core->hooks[PA_CORE_HOOK_SOURCE_PUT], PA_HOOK_LATE+20, (pa_hook_cb_t) source_put_hook_callback, u);
+    u->hashmap = pa_hashmap_new(pa_idxset_string_hash_func, pa_idxset_string_compare_func);
+
+    return 0;
+}
+
+void pa__done(pa_module*m) {
+    struct userdata *u;
+
+    pa_assert(m);
+
+    if (!(u = m->userdata))
+        return;
+
+    if (u->sink_put_slot)
+        pa_hook_slot_free(u->sink_put_slot);
+    if (u->source_put_slot)
+        pa_hook_slot_free(u->source_put_slot);
+
+    if (u->hashmap) {
+        struct pa_module *mi;
+
+        while ((mi = pa_hashmap_steal_first(u->hashmap))) {
+            pa_module_unload_request(mi, TRUE);
+        }
+
+        pa_hashmap_free(u->hashmap, NULL, NULL);
+    }
+
+    pa_xfree(u);
+}
-- 
1.7.5.4



[Index of Archives]     [Linux Audio Users]     [AMD Graphics]     [Linux USB Devel]     [Linux Audio Users]     [Yosemite News]     [Linux Kernel]     [Linux SCSI]

  Powered by Linux