[pulseaudio-discuss] [RFC v2 1/6] bluetooth: module-bluetooth-policy initial commit
Frédéric Dalleau
frederic.dalleau at linux.intel.com
Fri Jan 27 02:08:23 PST 2012
---
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
More information about the pulseaudio-discuss
mailing list