|
|
43a070 |
From 84dbc69202771252b0c7a0d8b6b32f728931bb7f Mon Sep 17 00:00:00 2001
|
|
|
43a070 |
From: Tanu Kaskinen <tanuk@iki.fi>
|
|
|
43a070 |
Date: Thu, 16 Feb 2017 12:09:38 +0200
|
|
|
43a070 |
Subject: [PATCH 3/4] improve default sink/source handling
|
|
|
43a070 |
|
|
|
43a070 |
Currently the default sink policy is simple: either the user has
|
|
|
43a070 |
configured it explicitly, in which case we always use that as the
|
|
|
43a070 |
default, or we pick the sink with the highest priority. The sink
|
|
|
43a070 |
priorities are currently static, so there's no need to worry about
|
|
|
43a070 |
updating the default sink when sink priorities change.
|
|
|
43a070 |
|
|
|
43a070 |
I intend to make things a bit more complex: if the active port of a sink
|
|
|
43a070 |
is unavailable, the sink should not be the default sink, and I also want
|
|
|
43a070 |
to make sink priorities dependent on the active port, so changing the
|
|
|
43a070 |
port should cause re-evaluation of which sink to choose as the default.
|
|
|
43a070 |
Currently the default sink choice is done only when someone calls
|
|
|
43a070 |
pa_namereg_get_default_sink(), and change notifications are only sent
|
|
|
43a070 |
when a sink is created or destroyed. That makes it hard to add new rules
|
|
|
43a070 |
to the default sink selection policy.
|
|
|
43a070 |
|
|
|
43a070 |
This patch moves the default sink selection to
|
|
|
43a070 |
pa_core_update_default_sink(), which is called whenever something
|
|
|
43a070 |
happens that can affect the default sink choice. That function needs to
|
|
|
43a070 |
know the previous choice in order to send change notifications as
|
|
|
43a070 |
appropriate, but previously pa_core.default_sink was only set when the
|
|
|
43a070 |
user had configured it explicitly. Now pa_core.default_sink is always
|
|
|
43a070 |
set (unless there are no sinks at all), so pa_core_update_default_sink()
|
|
|
43a070 |
can use that to get the previous choice. The user configuration is saved
|
|
|
43a070 |
in a new variable, pa_core.configured_default_sink.
|
|
|
43a070 |
|
|
|
43a070 |
pa_namereg_get_default_sink() is now unnecessary, because
|
|
|
43a070 |
pa_core.default_sink can be used directly to get the
|
|
|
43a070 |
currently-considered-best sink. pa_namereg_set_default_sink() is
|
|
|
43a070 |
replaced by pa_core_set_configured_default_sink().
|
|
|
43a070 |
|
|
|
43a070 |
I haven't confirmed it, but I expect that this patch will fix problems
|
|
|
43a070 |
in the D-Bus protocol related to default sink handling. The D-Bus
|
|
|
43a070 |
protocol used to get confused when the current default sink gets
|
|
|
43a070 |
removed. It would incorrectly think that if there's no explicitly
|
|
|
43a070 |
configured default sink, then there's no default sink at all. Even
|
|
|
43a070 |
worse, when the D-Bus thinks that there's no default sink, it concludes
|
|
|
43a070 |
that there are no sinks at all, which made it impossible to configure
|
|
|
43a070 |
the default sink via the D-Bus interface. Now that pa_core.default_sink
|
|
|
43a070 |
is always set, except when there really aren't any sinks, the D-Bus
|
|
|
43a070 |
protocol should behave correctly.
|
|
|
43a070 |
|
|
|
43a070 |
BugLink: https://bugs.freedesktop.org/show_bug.cgi?id=99425
|
|
|
43a070 |
---
|
|
|
43a070 |
src/modules/dbus/iface-core.c | 114 +++++++++++++------
|
|
|
43a070 |
src/modules/dbus/iface-sample.c | 10 +-
|
|
|
43a070 |
src/modules/module-default-device-restore.c | 14 +--
|
|
|
43a070 |
src/modules/module-intended-roles.c | 37 +++---
|
|
|
43a070 |
src/modules/module-rescue-streams.c | 20 ++--
|
|
|
43a070 |
src/modules/module-switch-on-connect.c | 30 ++---
|
|
|
43a070 |
src/pulsecore/cli-command.c | 20 ++--
|
|
|
43a070 |
src/pulsecore/cli-text.c | 12 +-
|
|
|
43a070 |
src/pulsecore/core.c | 170 ++++++++++++++++++++++++++++
|
|
|
43a070 |
src/pulsecore/core.h | 28 ++++-
|
|
|
43a070 |
src/pulsecore/namereg.c | 115 +------------------
|
|
|
43a070 |
src/pulsecore/namereg.h | 6 -
|
|
|
43a070 |
src/pulsecore/protocol-native.c | 19 ++--
|
|
|
43a070 |
src/pulsecore/sink.c | 7 ++
|
|
|
43a070 |
src/pulsecore/source.c | 7 ++
|
|
|
43a070 |
15 files changed, 370 insertions(+), 239 deletions(-)
|
|
|
43a070 |
|
|
|
43a070 |
diff --git a/src/modules/dbus/iface-core.c b/src/modules/dbus/iface-core.c
|
|
|
43a070 |
index 508913de1..3f368ab46 100644
|
|
|
43a070 |
--- a/src/modules/dbus/iface-core.c
|
|
|
43a070 |
+++ b/src/modules/dbus/iface-core.c
|
|
|
43a070 |
@@ -721,7 +721,7 @@ static void handle_set_fallback_sink(DBusConnection *conn, DBusMessage *msg, DBu
|
|
|
43a070 |
return;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- pa_namereg_set_default_sink(c->core, pa_dbusiface_device_get_sink(fallback_sink));
|
|
|
43a070 |
+ pa_core_set_configured_default_sink(c->core, pa_dbusiface_device_get_sink(fallback_sink));
|
|
|
43a070 |
|
|
|
43a070 |
pa_dbus_send_empty_reply(conn, msg);
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -809,7 +809,7 @@ static void handle_set_fallback_source(DBusConnection *conn, DBusMessage *msg, D
|
|
|
43a070 |
return;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- pa_namereg_set_default_source(c->core, pa_dbusiface_device_get_source(fallback_source));
|
|
|
43a070 |
+ pa_core_set_configured_default_source(c->core, pa_dbusiface_device_get_source(fallback_source));
|
|
|
43a070 |
|
|
|
43a070 |
pa_dbus_send_empty_reply(conn, msg);
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -1692,6 +1692,28 @@ static pa_hook_result_t sample_cache_removed_cb(void *hook_data, void *call_data
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
+static pa_dbusiface_device *create_dbus_object_for_sink(pa_dbusiface_core *c, pa_sink *s) {
|
|
|
43a070 |
+ pa_dbusiface_device *d;
|
|
|
43a070 |
+ const char *object_path;
|
|
|
43a070 |
+ DBusMessage *signal_msg;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ d = pa_dbusiface_device_new_sink(c, s);
|
|
|
43a070 |
+ object_path = pa_dbusiface_device_get_path(d);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert_se(pa_hashmap_put(c->sinks_by_index, PA_UINT32_TO_PTR(s->index), d) >= 0);
|
|
|
43a070 |
+ pa_assert_se(pa_hashmap_put(c->sinks_by_path, (char *) object_path, d) >= 0);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert_se((signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
|
|
|
43a070 |
+ PA_DBUS_CORE_INTERFACE,
|
|
|
43a070 |
+ signals[SIGNAL_NEW_SINK].name)));
|
|
|
43a070 |
+ pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_dbus_protocol_send_signal(c->dbus_protocol, signal_msg);
|
|
|
43a070 |
+ dbus_message_unref(signal_msg);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ return d;
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
static pa_hook_result_t default_sink_changed_cb(void *hook_data, void *call_data, void *slot_data) {
|
|
|
43a070 |
pa_dbusiface_core *c = slot_data;
|
|
|
43a070 |
pa_sink *new_fallback_sink = call_data;
|
|
|
43a070 |
@@ -1707,7 +1729,15 @@ static pa_hook_result_t default_sink_changed_cb(void *hook_data, void *call_data
|
|
|
43a070 |
c->fallback_sink = new_fallback_sink ? pa_sink_ref(new_fallback_sink) : NULL;
|
|
|
43a070 |
|
|
|
43a070 |
if (c->fallback_sink) {
|
|
|
43a070 |
- pa_assert_se((device_iface = pa_hashmap_get(c->sinks_by_index, PA_UINT32_TO_PTR(c->fallback_sink->index))));
|
|
|
43a070 |
+ device_iface = pa_hashmap_get(c->sinks_by_index, PA_UINT32_TO_PTR(c->fallback_sink->index));
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* It's possible that we haven't created a dbus object for the
|
|
|
43a070 |
+ * source yet, because if a new source immediately becomes the
|
|
|
43a070 |
+ * default source, the default source change hook is fired before
|
|
|
43a070 |
+ * the put hook. */
|
|
|
43a070 |
+ if (!device_iface)
|
|
|
43a070 |
+ device_iface = create_dbus_object_for_sink(c, c->fallback_sink);
|
|
|
43a070 |
+
|
|
|
43a070 |
object_path = pa_dbusiface_device_get_path(device_iface);
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert_se((signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
|
|
|
43a070 |
@@ -1730,6 +1760,28 @@ static pa_hook_result_t default_sink_changed_cb(void *hook_data, void *call_data
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
+static pa_dbusiface_device *create_dbus_object_for_source(pa_dbusiface_core *c, pa_source *s) {
|
|
|
43a070 |
+ pa_dbusiface_device *d;
|
|
|
43a070 |
+ const char *object_path;
|
|
|
43a070 |
+ DBusMessage *signal_msg;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ d = pa_dbusiface_device_new_source(c, s);
|
|
|
43a070 |
+ object_path = pa_dbusiface_device_get_path(d);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert_se(pa_hashmap_put(c->sources_by_index, PA_UINT32_TO_PTR(s->index), d) >= 0);
|
|
|
43a070 |
+ pa_assert_se(pa_hashmap_put(c->sources_by_path, (char *) object_path, d) >= 0);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert_se((signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
|
|
|
43a070 |
+ PA_DBUS_CORE_INTERFACE,
|
|
|
43a070 |
+ signals[SIGNAL_NEW_SOURCE].name)));
|
|
|
43a070 |
+ pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_dbus_protocol_send_signal(c->dbus_protocol, signal_msg);
|
|
|
43a070 |
+ dbus_message_unref(signal_msg);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ return d;
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
static pa_hook_result_t default_source_changed_cb(void *hook_data, void *call_data, void *slot_data) {
|
|
|
43a070 |
pa_dbusiface_core *c = slot_data;
|
|
|
43a070 |
pa_source *new_fallback_source = call_data;
|
|
|
43a070 |
@@ -1745,7 +1797,15 @@ static pa_hook_result_t default_source_changed_cb(void *hook_data, void *call_da
|
|
|
43a070 |
c->fallback_source = new_fallback_source ? pa_source_ref(new_fallback_source) : NULL;
|
|
|
43a070 |
|
|
|
43a070 |
if (c->fallback_source) {
|
|
|
43a070 |
- pa_assert_se((device_iface = pa_hashmap_get(c->sources_by_index, PA_UINT32_TO_PTR(c->fallback_source->index))));
|
|
|
43a070 |
+ device_iface = pa_hashmap_get(c->sources_by_index, PA_UINT32_TO_PTR(c->fallback_source->index));
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* It's possible that we haven't created a dbus object for the
|
|
|
43a070 |
+ * source yet, because if a new source immediately becomes the
|
|
|
43a070 |
+ * default source, the default source change hook is fired before
|
|
|
43a070 |
+ * the put hook. */
|
|
|
43a070 |
+ if (!device_iface)
|
|
|
43a070 |
+ device_iface = create_dbus_object_for_source(c, c->fallback_source);
|
|
|
43a070 |
+
|
|
|
43a070 |
object_path = pa_dbusiface_device_get_path(device_iface);
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert_se((signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
|
|
|
43a070 |
@@ -1983,26 +2043,17 @@ static pa_hook_result_t client_unlink_cb(void *hook_data, void *call_data, void
|
|
|
43a070 |
static pa_hook_result_t sink_put_cb(void *hook_data, void *call_data, void *slot_data) {
|
|
|
43a070 |
pa_dbusiface_core *c = slot_data;
|
|
|
43a070 |
pa_sink *s = call_data;
|
|
|
43a070 |
- pa_dbusiface_device *d = NULL;
|
|
|
43a070 |
- const char *object_path = NULL;
|
|
|
43a070 |
- DBusMessage *signal_msg = NULL;
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
pa_assert(s);
|
|
|
43a070 |
|
|
|
43a070 |
- d = pa_dbusiface_device_new_sink(c, s);
|
|
|
43a070 |
- object_path = pa_dbusiface_device_get_path(d);
|
|
|
43a070 |
-
|
|
|
43a070 |
- pa_assert_se(pa_hashmap_put(c->sinks_by_index, PA_UINT32_TO_PTR(s->index), d) >= 0);
|
|
|
43a070 |
- pa_assert_se(pa_hashmap_put(c->sinks_by_path, (char *) object_path, d) >= 0);
|
|
|
43a070 |
-
|
|
|
43a070 |
- pa_assert_se(signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
|
|
|
43a070 |
- PA_DBUS_CORE_INTERFACE,
|
|
|
43a070 |
- signals[SIGNAL_NEW_SINK].name));
|
|
|
43a070 |
- pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
|
|
|
43a070 |
+ /* We may have alredy encountered this sink, because if the new sink was
|
|
|
43a070 |
+ * chosen as the default sink, the default sink change hook was fired
|
|
|
43a070 |
+ * first, and we saw the sink in default_sink_changed_cb(). */
|
|
|
43a070 |
+ if (pa_hashmap_get(c->sinks_by_index, PA_UINT32_TO_PTR(s->index)))
|
|
|
43a070 |
+ return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
- pa_dbus_protocol_send_signal(c->dbus_protocol, signal_msg);
|
|
|
43a070 |
- dbus_message_unref(signal_msg);
|
|
|
43a070 |
+ create_dbus_object_for_sink(c, s);
|
|
|
43a070 |
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -2037,26 +2088,17 @@ static pa_hook_result_t sink_unlink_cb(void *hook_data, void *call_data, void *s
|
|
|
43a070 |
static pa_hook_result_t source_put_cb(void *hook_data, void *call_data, void *slot_data) {
|
|
|
43a070 |
pa_dbusiface_core *c = slot_data;
|
|
|
43a070 |
pa_source *s = call_data;
|
|
|
43a070 |
- pa_dbusiface_device *d = NULL;
|
|
|
43a070 |
- const char *object_path = NULL;
|
|
|
43a070 |
- DBusMessage *signal_msg = NULL;
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
pa_assert(s);
|
|
|
43a070 |
|
|
|
43a070 |
- d = pa_dbusiface_device_new_source(c, s);
|
|
|
43a070 |
- object_path = pa_dbusiface_device_get_path(d);
|
|
|
43a070 |
-
|
|
|
43a070 |
- pa_assert_se(pa_hashmap_put(c->sources_by_index, PA_UINT32_TO_PTR(s->index), d) >= 0);
|
|
|
43a070 |
- pa_assert_se(pa_hashmap_put(c->sources_by_path, (char *) object_path, d) >= 0);
|
|
|
43a070 |
-
|
|
|
43a070 |
- pa_assert_se((signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
|
|
|
43a070 |
- PA_DBUS_CORE_INTERFACE,
|
|
|
43a070 |
- signals[SIGNAL_NEW_SOURCE].name)));
|
|
|
43a070 |
- pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
|
|
|
43a070 |
+ /* We may have alredy encountered this source, because if the new source
|
|
|
43a070 |
+ * was chosen as the default source, the default source change hook was
|
|
|
43a070 |
+ * fired first, and we saw the source in default_source_changed_cb(). */
|
|
|
43a070 |
+ if (pa_hashmap_get(c->sources_by_index, PA_UINT32_TO_PTR(s->index)))
|
|
|
43a070 |
+ return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
- pa_dbus_protocol_send_signal(c->dbus_protocol, signal_msg);
|
|
|
43a070 |
- dbus_message_unref(signal_msg);
|
|
|
43a070 |
+ create_dbus_object_for_source(c, s);
|
|
|
43a070 |
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -2158,8 +2200,8 @@ pa_dbusiface_core *pa_dbusiface_core_new(pa_core *core) {
|
|
|
43a070 |
c->samples = pa_hashmap_new_full(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func, NULL, (pa_free_cb_t) pa_dbusiface_sample_free);
|
|
|
43a070 |
c->modules = pa_hashmap_new_full(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func, NULL, (pa_free_cb_t) pa_dbusiface_module_free);
|
|
|
43a070 |
c->clients = pa_hashmap_new_full(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func, NULL, (pa_free_cb_t) pa_dbusiface_client_free);
|
|
|
43a070 |
- c->fallback_sink = pa_namereg_get_default_sink(core);
|
|
|
43a070 |
- c->fallback_source = pa_namereg_get_default_source(core);
|
|
|
43a070 |
+ c->fallback_sink = core->default_sink;
|
|
|
43a070 |
+ c->fallback_source = core->default_source;
|
|
|
43a070 |
c->default_sink_changed_slot = pa_hook_connect(&core->hooks[PA_CORE_HOOK_DEFAULT_SINK_CHANGED],
|
|
|
43a070 |
PA_HOOK_NORMAL, default_sink_changed_cb, c);
|
|
|
43a070 |
c->default_source_changed_slot = pa_hook_connect(&core->hooks[PA_CORE_HOOK_DEFAULT_SOURCE_CHANGED],
|
|
|
43a070 |
diff --git a/src/modules/dbus/iface-sample.c b/src/modules/dbus/iface-sample.c
|
|
|
43a070 |
index 61f2ba091..51189196d 100644
|
|
|
43a070 |
--- a/src/modules/dbus/iface-sample.c
|
|
|
43a070 |
+++ b/src/modules/dbus/iface-sample.c
|
|
|
43a070 |
@@ -352,7 +352,6 @@ static void handle_play(DBusConnection *conn, DBusMessage *msg, void *userdata)
|
|
|
43a070 |
DBusMessageIter msg_iter;
|
|
|
43a070 |
dbus_uint32_t volume = 0;
|
|
|
43a070 |
pa_proplist *property_list = NULL;
|
|
|
43a070 |
- pa_sink *sink = NULL;
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert(conn);
|
|
|
43a070 |
pa_assert(msg);
|
|
|
43a070 |
@@ -370,13 +369,18 @@ static void handle_play(DBusConnection *conn, DBusMessage *msg, void *userdata)
|
|
|
43a070 |
goto finish;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- if (!(sink = pa_namereg_get_default_sink(s->sample->core))) {
|
|
|
43a070 |
+ if (!s->sample->core->default_sink) {
|
|
|
43a070 |
pa_dbus_send_error(conn, msg, DBUS_ERROR_FAILED,
|
|
|
43a070 |
"Can't play sample %s, because there are no sinks available.", s->sample->name);
|
|
|
43a070 |
goto finish;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- if (pa_scache_play_item(s->sample->core, s->sample->name, sink, volume, property_list, NULL) < 0) {
|
|
|
43a070 |
+ if (pa_scache_play_item(s->sample->core,
|
|
|
43a070 |
+ s->sample->name,
|
|
|
43a070 |
+ s->sample->core->default_sink,
|
|
|
43a070 |
+ volume,
|
|
|
43a070 |
+ property_list,
|
|
|
43a070 |
+ NULL) < 0) {
|
|
|
43a070 |
pa_dbus_send_error(conn, msg, DBUS_ERROR_FAILED, "Playing sample %s failed.", s->sample->name);
|
|
|
43a070 |
goto finish;
|
|
|
43a070 |
}
|
|
|
43a070 |
diff --git a/src/modules/module-default-device-restore.c b/src/modules/module-default-device-restore.c
|
|
|
43a070 |
index d76e28e68..56fee67f8 100644
|
|
|
43a070 |
--- a/src/modules/module-default-device-restore.c
|
|
|
43a070 |
+++ b/src/modules/module-default-device-restore.c
|
|
|
43a070 |
@@ -56,7 +56,7 @@ static void load(struct userdata *u) {
|
|
|
43a070 |
|
|
|
43a070 |
/* We never overwrite manually configured settings */
|
|
|
43a070 |
|
|
|
43a070 |
- if (u->core->default_sink)
|
|
|
43a070 |
+ if (u->core->configured_default_sink)
|
|
|
43a070 |
pa_log_info("Manually configured default sink, not overwriting.");
|
|
|
43a070 |
else if ((f = pa_fopen_cloexec(u->sink_filename, "r"))) {
|
|
|
43a070 |
char ln[256] = "";
|
|
|
43a070 |
@@ -69,7 +69,7 @@ static void load(struct userdata *u) {
|
|
|
43a070 |
if (!ln[0])
|
|
|
43a070 |
pa_log_info("No previous default sink setting, ignoring.");
|
|
|
43a070 |
else if ((s = pa_namereg_get(u->core, ln, PA_NAMEREG_SINK))) {
|
|
|
43a070 |
- pa_namereg_set_default_sink(u->core, s);
|
|
|
43a070 |
+ pa_core_set_configured_default_sink(u->core, s);
|
|
|
43a070 |
pa_log_info("Restored default sink '%s'.", ln);
|
|
|
43a070 |
} else
|
|
|
43a070 |
pa_log_info("Saved default sink '%s' not existent, not restoring default sink setting.", ln);
|
|
|
43a070 |
@@ -77,7 +77,7 @@ static void load(struct userdata *u) {
|
|
|
43a070 |
} else if (errno != ENOENT)
|
|
|
43a070 |
pa_log("Failed to load default sink: %s", pa_cstrerror(errno));
|
|
|
43a070 |
|
|
|
43a070 |
- if (u->core->default_source)
|
|
|
43a070 |
+ if (u->core->configured_default_source)
|
|
|
43a070 |
pa_log_info("Manually configured default source, not overwriting.");
|
|
|
43a070 |
else if ((f = pa_fopen_cloexec(u->source_filename, "r"))) {
|
|
|
43a070 |
char ln[256] = "";
|
|
|
43a070 |
@@ -90,7 +90,7 @@ static void load(struct userdata *u) {
|
|
|
43a070 |
if (!ln[0])
|
|
|
43a070 |
pa_log_info("No previous default source setting, ignoring.");
|
|
|
43a070 |
else if ((s = pa_namereg_get(u->core, ln, PA_NAMEREG_SOURCE))) {
|
|
|
43a070 |
- pa_namereg_set_default_source(u->core, s);
|
|
|
43a070 |
+ pa_core_set_configured_default_source(u->core, s);
|
|
|
43a070 |
pa_log_info("Restored default source '%s'.", ln);
|
|
|
43a070 |
} else
|
|
|
43a070 |
pa_log_info("Saved default source '%s' not existent, not restoring default source setting.", ln);
|
|
|
43a070 |
@@ -107,8 +107,7 @@ static void save(struct userdata *u) {
|
|
|
43a070 |
|
|
|
43a070 |
if (u->sink_filename) {
|
|
|
43a070 |
if ((f = pa_fopen_cloexec(u->sink_filename, "w"))) {
|
|
|
43a070 |
- pa_sink *s = pa_namereg_get_default_sink(u->core);
|
|
|
43a070 |
- fprintf(f, "%s\n", s ? s->name : "");
|
|
|
43a070 |
+ fprintf(f, "%s\n", u->core->default_sink ? u->core->default_sink->name : "");
|
|
|
43a070 |
fclose(f);
|
|
|
43a070 |
} else
|
|
|
43a070 |
pa_log("Failed to save default sink: %s", pa_cstrerror(errno));
|
|
|
43a070 |
@@ -116,8 +115,7 @@ static void save(struct userdata *u) {
|
|
|
43a070 |
|
|
|
43a070 |
if (u->source_filename) {
|
|
|
43a070 |
if ((f = pa_fopen_cloexec(u->source_filename, "w"))) {
|
|
|
43a070 |
- pa_source *s = pa_namereg_get_default_source(u->core);
|
|
|
43a070 |
- fprintf(f, "%s\n", s ? s->name : "");
|
|
|
43a070 |
+ fprintf(f, "%s\n", u->core->default_source ? u->core->default_source->name : "");
|
|
|
43a070 |
fclose(f);
|
|
|
43a070 |
} else
|
|
|
43a070 |
pa_log("Failed to save default source: %s", pa_cstrerror(errno));
|
|
|
43a070 |
diff --git a/src/modules/module-intended-roles.c b/src/modules/module-intended-roles.c
|
|
|
43a070 |
index 60ec7e982..f906b8800 100644
|
|
|
43a070 |
--- a/src/modules/module-intended-roles.c
|
|
|
43a070 |
+++ b/src/modules/module-intended-roles.c
|
|
|
43a070 |
@@ -69,7 +69,7 @@ static bool role_match(pa_proplist *proplist, const char *role) {
|
|
|
43a070 |
|
|
|
43a070 |
static pa_hook_result_t sink_input_new_hook_callback(pa_core *c, pa_sink_input_new_data *new_data, struct userdata *u) {
|
|
|
43a070 |
const char *role;
|
|
|
43a070 |
- pa_sink *s, *def;
|
|
|
43a070 |
+ pa_sink *s;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
@@ -92,13 +92,13 @@ static pa_hook_result_t sink_input_new_hook_callback(pa_core *c, pa_sink_input_n
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
/* Prefer the default sink over any other sink, just in case... */
|
|
|
43a070 |
- if ((def = pa_namereg_get_default_sink(c)))
|
|
|
43a070 |
- if (role_match(def->proplist, role) && pa_sink_input_new_data_set_sink(new_data, def, false))
|
|
|
43a070 |
+ if (c->default_sink)
|
|
|
43a070 |
+ if (role_match(c->default_sink->proplist, role) && pa_sink_input_new_data_set_sink(new_data, c->default_sink, false))
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
/* @todo: favour the highest priority device, not the first one we find? */
|
|
|
43a070 |
PA_IDXSET_FOREACH(s, c->sinks, idx) {
|
|
|
43a070 |
- if (s == def)
|
|
|
43a070 |
+ if (s == c->default_sink)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
if (!PA_SINK_IS_LINKED(pa_sink_get_state(s)))
|
|
|
43a070 |
@@ -113,7 +113,7 @@ static pa_hook_result_t sink_input_new_hook_callback(pa_core *c, pa_sink_input_n
|
|
|
43a070 |
|
|
|
43a070 |
static pa_hook_result_t source_output_new_hook_callback(pa_core *c, pa_source_output_new_data *new_data, struct userdata *u) {
|
|
|
43a070 |
const char *role;
|
|
|
43a070 |
- pa_source *s, *def;
|
|
|
43a070 |
+ pa_source *s;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
@@ -136,9 +136,9 @@ static pa_hook_result_t source_output_new_hook_callback(pa_core *c, pa_source_ou
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
/* Prefer the default source over any other source, just in case... */
|
|
|
43a070 |
- if ((def = pa_namereg_get_default_source(c)))
|
|
|
43a070 |
- if (role_match(def->proplist, role)) {
|
|
|
43a070 |
- pa_source_output_new_data_set_source(new_data, def, false);
|
|
|
43a070 |
+ if (c->default_source)
|
|
|
43a070 |
+ if (role_match(c->default_source->proplist, role)) {
|
|
|
43a070 |
+ pa_source_output_new_data_set_source(new_data, c->default_source, false);
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
@@ -146,7 +146,7 @@ static pa_hook_result_t source_output_new_hook_callback(pa_core *c, pa_source_ou
|
|
|
43a070 |
if (s->monitor_of)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
- if (s == def)
|
|
|
43a070 |
+ if (s == c->default_source)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
if (!PA_SOURCE_IS_LINKED(pa_source_get_state(s)))
|
|
|
43a070 |
@@ -259,7 +259,6 @@ static pa_hook_result_t source_put_hook_callback(pa_core *c, pa_source *source,
|
|
|
43a070 |
static pa_hook_result_t sink_unlink_hook_callback(pa_core *c, pa_sink *sink, struct userdata *u) {
|
|
|
43a070 |
pa_sink_input *si;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
- pa_sink *def;
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
pa_assert(sink);
|
|
|
43a070 |
@@ -271,7 +270,7 @@ static pa_hook_result_t sink_unlink_hook_callback(pa_core *c, pa_sink *sink, str
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
/* If there not default sink, then there is no sink at all */
|
|
|
43a070 |
- if (!(def = pa_namereg_get_default_sink(c)))
|
|
|
43a070 |
+ if (!c->default_sink)
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
PA_IDXSET_FOREACH(si, sink->inputs, idx) {
|
|
|
43a070 |
@@ -286,14 +285,14 @@ static pa_hook_result_t sink_unlink_hook_callback(pa_core *c, pa_sink *sink, str
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
/* Would the default sink fit? If so, let's use it */
|
|
|
43a070 |
- if (def != sink && role_match(def->proplist, role))
|
|
|
43a070 |
- if (pa_sink_input_move_to(si, def, false) >= 0)
|
|
|
43a070 |
+ if (c->default_sink != sink && role_match(c->default_sink->proplist, role))
|
|
|
43a070 |
+ if (pa_sink_input_move_to(si, c->default_sink, false) >= 0)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
/* Try to find some other fitting sink */
|
|
|
43a070 |
/* @todo: favour the highest priority device, not the first one we find? */
|
|
|
43a070 |
PA_IDXSET_FOREACH(d, c->sinks, jdx) {
|
|
|
43a070 |
- if (d == def || d == sink)
|
|
|
43a070 |
+ if (d == c->default_sink || d == sink)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
if (!PA_SINK_IS_LINKED(pa_sink_get_state(d)))
|
|
|
43a070 |
@@ -311,7 +310,6 @@ static pa_hook_result_t sink_unlink_hook_callback(pa_core *c, pa_sink *sink, str
|
|
|
43a070 |
static pa_hook_result_t source_unlink_hook_callback(pa_core *c, pa_source *source, struct userdata *u) {
|
|
|
43a070 |
pa_source_output *so;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
- pa_source *def;
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
pa_assert(source);
|
|
|
43a070 |
@@ -323,7 +321,7 @@ static pa_hook_result_t source_unlink_hook_callback(pa_core *c, pa_source *sourc
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
/* If there not default source, then there is no source at all */
|
|
|
43a070 |
- if (!(def = pa_namereg_get_default_source(c)))
|
|
|
43a070 |
+ if (!c->default_source)
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
PA_IDXSET_FOREACH(so, source->outputs, idx) {
|
|
|
43a070 |
@@ -341,15 +339,16 @@ static pa_hook_result_t source_unlink_hook_callback(pa_core *c, pa_source *sourc
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
/* Would the default source fit? If so, let's use it */
|
|
|
43a070 |
- if (def != source && role_match(def->proplist, role) && !source->monitor_of == !def->monitor_of) {
|
|
|
43a070 |
- pa_source_output_move_to(so, def, false);
|
|
|
43a070 |
+ if (c->default_source != source && role_match(c->default_source->proplist, role)
|
|
|
43a070 |
+ && !source->monitor_of == !c->default_source->monitor_of) {
|
|
|
43a070 |
+ pa_source_output_move_to(so, c->default_source, false);
|
|
|
43a070 |
continue;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
/* Try to find some other fitting source */
|
|
|
43a070 |
/* @todo: favour the highest priority device, not the first one we find? */
|
|
|
43a070 |
PA_IDXSET_FOREACH(d, c->sources, jdx) {
|
|
|
43a070 |
- if (d == def || d == source)
|
|
|
43a070 |
+ if (d == c->default_source || d == source)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
if (!PA_SOURCE_IS_LINKED(pa_source_get_state(d)))
|
|
|
43a070 |
diff --git a/src/modules/module-rescue-streams.c b/src/modules/module-rescue-streams.c
|
|
|
43a070 |
index 60ac1c4cf..d3c9953ec 100644
|
|
|
43a070 |
--- a/src/modules/module-rescue-streams.c
|
|
|
43a070 |
+++ b/src/modules/module-rescue-streams.c
|
|
|
43a070 |
@@ -96,7 +96,7 @@ static void build_group_ports(pa_hashmap *g_ports, pa_hashmap *s_ports) {
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
static pa_sink* find_evacuation_sink(pa_core *c, pa_sink_input *i, pa_sink *skip) {
|
|
|
43a070 |
- pa_sink *target, *def, *fb_sink = NULL;
|
|
|
43a070 |
+ pa_sink *target, *fb_sink = NULL;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
pa_hashmap *all_ports;
|
|
|
43a070 |
pa_device_port *best_port;
|
|
|
43a070 |
@@ -104,15 +104,13 @@ static pa_sink* find_evacuation_sink(pa_core *c, pa_sink_input *i, pa_sink *skip
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
pa_assert(i);
|
|
|
43a070 |
|
|
|
43a070 |
- def = pa_namereg_get_default_sink(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (def && def != skip && pa_sink_input_may_move_to(i, def))
|
|
|
43a070 |
- return def;
|
|
|
43a070 |
+ if (c->default_sink && c->default_sink != skip && pa_sink_input_may_move_to(i, c->default_sink))
|
|
|
43a070 |
+ return c->default_sink;
|
|
|
43a070 |
|
|
|
43a070 |
all_ports = pa_hashmap_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func);
|
|
|
43a070 |
|
|
|
43a070 |
PA_IDXSET_FOREACH(target, c->sinks, idx) {
|
|
|
43a070 |
- if (target == def)
|
|
|
43a070 |
+ if (target == c->default_sink)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
if (target == skip)
|
|
|
43a070 |
@@ -204,7 +202,7 @@ static pa_hook_result_t sink_input_move_fail_hook_callback(pa_core *c, pa_sink_i
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
static pa_source* find_evacuation_source(pa_core *c, pa_source_output *o, pa_source *skip) {
|
|
|
43a070 |
- pa_source *target, *def, *fb_source = NULL;
|
|
|
43a070 |
+ pa_source *target, *fb_source = NULL;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
pa_hashmap *all_ports;
|
|
|
43a070 |
pa_device_port *best_port;
|
|
|
43a070 |
@@ -212,15 +210,13 @@ static pa_source* find_evacuation_source(pa_core *c, pa_source_output *o, pa_sou
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
pa_assert(o);
|
|
|
43a070 |
|
|
|
43a070 |
- def = pa_namereg_get_default_source(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (def && def != skip && pa_source_output_may_move_to(o, def))
|
|
|
43a070 |
- return def;
|
|
|
43a070 |
+ if (c->default_source && c->default_source != skip && pa_source_output_may_move_to(o, c->default_source))
|
|
|
43a070 |
+ return c->default_source;
|
|
|
43a070 |
|
|
|
43a070 |
all_ports = pa_hashmap_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func);
|
|
|
43a070 |
|
|
|
43a070 |
PA_IDXSET_FOREACH(target, c->sources, idx) {
|
|
|
43a070 |
- if (target == def)
|
|
|
43a070 |
+ if (target == c->default_source)
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
if (target == skip)
|
|
|
43a070 |
diff --git a/src/modules/module-switch-on-connect.c b/src/modules/module-switch-on-connect.c
|
|
|
43a070 |
index c844add6e..776c923ee 100644
|
|
|
43a070 |
--- a/src/modules/module-switch-on-connect.c
|
|
|
43a070 |
+++ b/src/modules/module-switch-on-connect.c
|
|
|
43a070 |
@@ -55,7 +55,7 @@ struct userdata {
|
|
|
43a070 |
static pa_hook_result_t sink_put_hook_callback(pa_core *c, pa_sink *sink, void* userdata) {
|
|
|
43a070 |
pa_sink_input *i;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
- pa_sink *def;
|
|
|
43a070 |
+ pa_sink *old_default_sink;
|
|
|
43a070 |
const char *s;
|
|
|
43a070 |
struct userdata *u = userdata;
|
|
|
43a070 |
|
|
|
43a070 |
@@ -75,24 +75,25 @@ static pa_hook_result_t sink_put_hook_callback(pa_core *c, pa_sink *sink, void*
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- def = pa_namereg_get_default_sink(c);
|
|
|
43a070 |
- if (def == sink)
|
|
|
43a070 |
+ if (c->default_sink == sink)
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
if (u->only_from_unavailable)
|
|
|
43a070 |
- if (!def->active_port || def->active_port->available != PA_AVAILABLE_NO)
|
|
|
43a070 |
+ if (!c->default_sink->active_port || c->default_sink->active_port->available != PA_AVAILABLE_NO)
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
+ old_default_sink = c->default_sink;
|
|
|
43a070 |
+
|
|
|
43a070 |
/* Actually do the switch to the new sink */
|
|
|
43a070 |
- pa_namereg_set_default_sink(c, sink);
|
|
|
43a070 |
+ pa_core_set_configured_default_sink(c, sink);
|
|
|
43a070 |
|
|
|
43a070 |
/* Now move all old inputs over */
|
|
|
43a070 |
- if (pa_idxset_size(def->inputs) <= 0) {
|
|
|
43a070 |
+ if (pa_idxset_size(old_default_sink->inputs) <= 0) {
|
|
|
43a070 |
pa_log_debug("No sink inputs to move away.");
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- PA_IDXSET_FOREACH(i, def->inputs, idx) {
|
|
|
43a070 |
+ PA_IDXSET_FOREACH(i, old_default_sink->inputs, idx) {
|
|
|
43a070 |
if (i->save_sink || !PA_SINK_INPUT_IS_LINKED(i->state))
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
@@ -110,7 +111,7 @@ static pa_hook_result_t sink_put_hook_callback(pa_core *c, pa_sink *sink, void*
|
|
|
43a070 |
static pa_hook_result_t source_put_hook_callback(pa_core *c, pa_source *source, void* userdata) {
|
|
|
43a070 |
pa_source_output *o;
|
|
|
43a070 |
uint32_t idx;
|
|
|
43a070 |
- pa_source *def;
|
|
|
43a070 |
+ pa_source *old_default_source;
|
|
|
43a070 |
const char *s;
|
|
|
43a070 |
struct userdata *u = userdata;
|
|
|
43a070 |
|
|
|
43a070 |
@@ -134,24 +135,25 @@ static pa_hook_result_t source_put_hook_callback(pa_core *c, pa_source *source,
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- def = pa_namereg_get_default_source(c);
|
|
|
43a070 |
- if (def == source)
|
|
|
43a070 |
+ if (c->default_source == source)
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
if (u->only_from_unavailable)
|
|
|
43a070 |
- if (!def->active_port || def->active_port->available != PA_AVAILABLE_NO)
|
|
|
43a070 |
+ if (!c->default_source->active_port || c->default_source->active_port->available != PA_AVAILABLE_NO)
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
|
|
|
43a070 |
+ old_default_source = c->default_source;
|
|
|
43a070 |
+
|
|
|
43a070 |
/* Actually do the switch to the new source */
|
|
|
43a070 |
- pa_namereg_set_default_source(c, source);
|
|
|
43a070 |
+ pa_core_set_configured_default_source(c, source);
|
|
|
43a070 |
|
|
|
43a070 |
/* Now move all old outputs over */
|
|
|
43a070 |
- if (pa_idxset_size(def->outputs) <= 0) {
|
|
|
43a070 |
+ if (pa_idxset_size(old_default_source->outputs) <= 0) {
|
|
|
43a070 |
pa_log_debug("No source outputs to move away.");
|
|
|
43a070 |
return PA_HOOK_OK;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- PA_IDXSET_FOREACH(o, def->outputs, idx) {
|
|
|
43a070 |
+ PA_IDXSET_FOREACH(o, old_default_source->outputs, idx) {
|
|
|
43a070 |
if (o->save_source || !PA_SOURCE_OUTPUT_IS_LINKED(o->state))
|
|
|
43a070 |
continue;
|
|
|
43a070 |
|
|
|
43a070 |
diff --git a/src/pulsecore/cli-command.c b/src/pulsecore/cli-command.c
|
|
|
43a070 |
index 9a7360582..5a632be45 100644
|
|
|
43a070 |
--- a/src/pulsecore/cli-command.c
|
|
|
43a070 |
+++ b/src/pulsecore/cli-command.c
|
|
|
43a070 |
@@ -344,8 +344,6 @@ static int pa_cli_command_stat(pa_core *c, pa_tokenizer *t, pa_strbuf *buf, bool
|
|
|
43a070 |
char bytes[PA_BYTES_SNPRINT_MAX];
|
|
|
43a070 |
const pa_mempool_stat *mstat;
|
|
|
43a070 |
unsigned k;
|
|
|
43a070 |
- pa_sink *def_sink;
|
|
|
43a070 |
- pa_source *def_source;
|
|
|
43a070 |
|
|
|
43a070 |
static const char* const type_table[PA_MEMBLOCK_TYPE_MAX] = {
|
|
|
43a070 |
[PA_MEMBLOCK_POOL] = "POOL",
|
|
|
43a070 |
@@ -388,12 +386,10 @@ static int pa_cli_command_stat(pa_core *c, pa_tokenizer *t, pa_strbuf *buf, bool
|
|
|
43a070 |
pa_strbuf_printf(buf, "Default channel map: %s\n",
|
|
|
43a070 |
pa_channel_map_snprint(cm, sizeof(cm), &c->default_channel_map));
|
|
|
43a070 |
|
|
|
43a070 |
- def_sink = pa_namereg_get_default_sink(c);
|
|
|
43a070 |
- def_source = pa_namereg_get_default_source(c);
|
|
|
43a070 |
pa_strbuf_printf(buf, "Default sink name: %s\n"
|
|
|
43a070 |
"Default source name: %s\n",
|
|
|
43a070 |
- def_sink ? def_sink->name : "none",
|
|
|
43a070 |
- def_source ? def_source->name : "none");
|
|
|
43a070 |
+ c->default_sink ? c->default_sink->name : "none",
|
|
|
43a070 |
+ c->default_source ? c->default_source->name : "none");
|
|
|
43a070 |
|
|
|
43a070 |
for (k = 0; k < PA_MEMBLOCK_TYPE_MAX; k++)
|
|
|
43a070 |
pa_strbuf_printf(buf,
|
|
|
43a070 |
@@ -1034,7 +1030,7 @@ static int pa_cli_command_sink_default(pa_core *c, pa_tokenizer *t, pa_strbuf *b
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
if ((s = pa_namereg_get(c, n, PA_NAMEREG_SINK)))
|
|
|
43a070 |
- pa_namereg_set_default_sink(c, s);
|
|
|
43a070 |
+ pa_core_set_configured_default_sink(c, s);
|
|
|
43a070 |
else
|
|
|
43a070 |
pa_strbuf_printf(buf, "Sink %s does not exist.\n", n);
|
|
|
43a070 |
|
|
|
43a070 |
@@ -1056,7 +1052,7 @@ static int pa_cli_command_source_default(pa_core *c, pa_tokenizer *t, pa_strbuf
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
if ((s = pa_namereg_get(c, n, PA_NAMEREG_SOURCE)))
|
|
|
43a070 |
- pa_namereg_set_default_source(c, s);
|
|
|
43a070 |
+ pa_core_set_configured_default_source(c, s);
|
|
|
43a070 |
else
|
|
|
43a070 |
pa_strbuf_printf(buf, "Source %s does not exist.\n", n);
|
|
|
43a070 |
return 0;
|
|
|
43a070 |
@@ -1850,20 +1846,20 @@ static int pa_cli_command_dump(pa_core *c, pa_tokenizer *t, pa_strbuf *buf, bool
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
nl = false;
|
|
|
43a070 |
- if ((sink = pa_namereg_get_default_sink(c))) {
|
|
|
43a070 |
+ if (c->default_sink) {
|
|
|
43a070 |
if (!nl) {
|
|
|
43a070 |
pa_strbuf_puts(buf, "\n");
|
|
|
43a070 |
nl = true;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- pa_strbuf_printf(buf, "set-default-sink %s\n", sink->name);
|
|
|
43a070 |
+ pa_strbuf_printf(buf, "set-default-sink %s\n", c->default_sink->name);
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
- if ((source = pa_namereg_get_default_source(c))) {
|
|
|
43a070 |
+ if (c->default_source) {
|
|
|
43a070 |
if (!nl)
|
|
|
43a070 |
pa_strbuf_puts(buf, "\n");
|
|
|
43a070 |
|
|
|
43a070 |
- pa_strbuf_printf(buf, "set-default-source %s\n", source->name);
|
|
|
43a070 |
+ pa_strbuf_printf(buf, "set-default-source %s\n", c->default_source->name);
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
pa_strbuf_puts(buf, "\n### EOF\n");
|
|
|
43a070 |
diff --git a/src/pulsecore/cli-text.c b/src/pulsecore/cli-text.c
|
|
|
43a070 |
index af79a1ebe..ded82f6e4 100644
|
|
|
43a070 |
--- a/src/pulsecore/cli-text.c
|
|
|
43a070 |
+++ b/src/pulsecore/cli-text.c
|
|
|
43a070 |
@@ -232,7 +232,7 @@ static const char *source_state_to_string(pa_source_state_t state) {
|
|
|
43a070 |
|
|
|
43a070 |
char *pa_sink_list_to_string(pa_core *c) {
|
|
|
43a070 |
pa_strbuf *s;
|
|
|
43a070 |
- pa_sink *sink, *default_sink;
|
|
|
43a070 |
+ pa_sink *sink;
|
|
|
43a070 |
uint32_t idx = PA_IDXSET_INVALID;
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
|
|
|
43a070 |
@@ -240,8 +240,6 @@ char *pa_sink_list_to_string(pa_core *c) {
|
|
|
43a070 |
|
|
|
43a070 |
pa_strbuf_printf(s, "%u sink(s) available.\n", pa_idxset_size(c->sinks));
|
|
|
43a070 |
|
|
|
43a070 |
- default_sink = pa_namereg_get_default_sink(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
PA_IDXSET_FOREACH(sink, c->sinks, idx) {
|
|
|
43a070 |
char ss[PA_SAMPLE_SPEC_SNPRINT_MAX],
|
|
|
43a070 |
cv[PA_CVOLUME_SNPRINT_VERBOSE_MAX],
|
|
|
43a070 |
@@ -273,7 +271,7 @@ char *pa_sink_list_to_string(pa_core *c) {
|
|
|
43a070 |
"\tchannel map: %s%s%s\n"
|
|
|
43a070 |
"\tused by: %u\n"
|
|
|
43a070 |
"\tlinked by: %u\n",
|
|
|
43a070 |
- sink == default_sink ? '*' : ' ',
|
|
|
43a070 |
+ sink == c->default_sink ? '*' : ' ',
|
|
|
43a070 |
sink->index,
|
|
|
43a070 |
sink->name,
|
|
|
43a070 |
sink->driver,
|
|
|
43a070 |
@@ -350,7 +348,7 @@ char *pa_sink_list_to_string(pa_core *c) {
|
|
|
43a070 |
|
|
|
43a070 |
char *pa_source_list_to_string(pa_core *c) {
|
|
|
43a070 |
pa_strbuf *s;
|
|
|
43a070 |
- pa_source *source, *default_source;
|
|
|
43a070 |
+ pa_source *source;
|
|
|
43a070 |
uint32_t idx = PA_IDXSET_INVALID;
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
|
|
|
43a070 |
@@ -358,8 +356,6 @@ char *pa_source_list_to_string(pa_core *c) {
|
|
|
43a070 |
|
|
|
43a070 |
pa_strbuf_printf(s, "%u source(s) available.\n", pa_idxset_size(c->sources));
|
|
|
43a070 |
|
|
|
43a070 |
- default_source = pa_namereg_get_default_source(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
PA_IDXSET_FOREACH(source, c->sources, idx) {
|
|
|
43a070 |
char ss[PA_SAMPLE_SPEC_SNPRINT_MAX],
|
|
|
43a070 |
cv[PA_CVOLUME_SNPRINT_VERBOSE_MAX],
|
|
|
43a070 |
@@ -389,7 +385,7 @@ char *pa_source_list_to_string(pa_core *c) {
|
|
|
43a070 |
"\tchannel map: %s%s%s\n"
|
|
|
43a070 |
"\tused by: %u\n"
|
|
|
43a070 |
"\tlinked by: %u\n",
|
|
|
43a070 |
- source == default_source ? '*' : ' ',
|
|
|
43a070 |
+ source == c->default_source ? '*' : ' ',
|
|
|
43a070 |
source->index,
|
|
|
43a070 |
source->name,
|
|
|
43a070 |
source->driver,
|
|
|
43a070 |
diff --git a/src/pulsecore/core.c b/src/pulsecore/core.c
|
|
|
43a070 |
index 2a96dfa5e..da1abb3ba 100644
|
|
|
43a070 |
--- a/src/pulsecore/core.c
|
|
|
43a070 |
+++ b/src/pulsecore/core.c
|
|
|
43a070 |
@@ -223,6 +223,176 @@ static void core_free(pa_object *o) {
|
|
|
43a070 |
pa_xfree(c);
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
+void pa_core_set_configured_default_sink(pa_core *core, pa_sink *sink) {
|
|
|
43a070 |
+ pa_sink *old_sink;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert(core);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ old_sink = core->configured_default_sink;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (sink == old_sink)
|
|
|
43a070 |
+ return;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ core->configured_default_sink = sink;
|
|
|
43a070 |
+ pa_log_info("configured_default_sink: %s -> %s",
|
|
|
43a070 |
+ old_sink ? old_sink->name : "(unset)", sink ? sink->name : "(unset)");
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_core_update_default_sink(core);
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
+void pa_core_set_configured_default_source(pa_core *core, pa_source *source) {
|
|
|
43a070 |
+ pa_source *old_source;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert(core);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ old_source = core->configured_default_source;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (source == old_source)
|
|
|
43a070 |
+ return;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ core->configured_default_source = source;
|
|
|
43a070 |
+ pa_log_info("configured_default_source: %s -> %s",
|
|
|
43a070 |
+ old_source ? old_source->name : "(unset)", source ? source->name : "(unset)");
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_core_update_default_source(core);
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
+/* a < b -> return -1
|
|
|
43a070 |
+ * a == b -> return 0
|
|
|
43a070 |
+ * a > b -> return 1 */
|
|
|
43a070 |
+static int compare_sinks(pa_sink *a, pa_sink *b) {
|
|
|
43a070 |
+ pa_core *core;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ core = a->core;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* The configured default sink is preferred over any other sink. */
|
|
|
43a070 |
+ if (b == core->configured_default_sink)
|
|
|
43a070 |
+ return -1;
|
|
|
43a070 |
+ if (a == core->configured_default_sink)
|
|
|
43a070 |
+ return 1;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (a->priority < b->priority)
|
|
|
43a070 |
+ return -1;
|
|
|
43a070 |
+ if (a->priority > b->priority)
|
|
|
43a070 |
+ return 1;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* It's hard to find any difference between these sinks, but maybe one of
|
|
|
43a070 |
+ * them is already the default sink? If so, it's best to keep it as the
|
|
|
43a070 |
+ * default to avoid changing the routing for no good reason. */
|
|
|
43a070 |
+ if (b == core->default_sink)
|
|
|
43a070 |
+ return -1;
|
|
|
43a070 |
+ if (a == core->default_sink)
|
|
|
43a070 |
+ return 1;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ return 0;
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
+void pa_core_update_default_sink(pa_core *core) {
|
|
|
43a070 |
+ pa_sink *best = NULL;
|
|
|
43a070 |
+ pa_sink *sink;
|
|
|
43a070 |
+ uint32_t idx;
|
|
|
43a070 |
+ pa_sink *old_default_sink;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert(core);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ PA_IDXSET_FOREACH(sink, core->sinks, idx) {
|
|
|
43a070 |
+ if (!best) {
|
|
|
43a070 |
+ best = sink;
|
|
|
43a070 |
+ continue;
|
|
|
43a070 |
+ }
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (compare_sinks(sink, best) > 0)
|
|
|
43a070 |
+ best = sink;
|
|
|
43a070 |
+ }
|
|
|
43a070 |
+
|
|
|
43a070 |
+ old_default_sink = core->default_sink;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (best == old_default_sink)
|
|
|
43a070 |
+ return;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ core->default_sink = best;
|
|
|
43a070 |
+ pa_log_info("default_sink: %s -> %s",
|
|
|
43a070 |
+ old_default_sink ? old_default_sink->name : "(unset)", best ? best->name : "(unset)");
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* If the default sink changed, it may be that the default source has to be
|
|
|
43a070 |
+ * changed too, because monitor sources are prioritized partly based on the
|
|
|
43a070 |
+ * priorities of the monitored sinks. */
|
|
|
43a070 |
+ pa_core_update_default_source(core);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_subscription_post(core, PA_SUBSCRIPTION_EVENT_SERVER | PA_SUBSCRIPTION_EVENT_CHANGE, PA_INVALID_INDEX);
|
|
|
43a070 |
+ pa_hook_fire(&core->hooks[PA_CORE_HOOK_DEFAULT_SINK_CHANGED], core->default_sink);
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
+/* a < b -> return -1
|
|
|
43a070 |
+ * a == b -> return 0
|
|
|
43a070 |
+ * a > b -> return 1 */
|
|
|
43a070 |
+static int compare_sources(pa_source *a, pa_source *b) {
|
|
|
43a070 |
+ pa_core *core;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ core = a->core;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* The configured default source is preferred over any other source. */
|
|
|
43a070 |
+ if (b == core->configured_default_source)
|
|
|
43a070 |
+ return -1;
|
|
|
43a070 |
+ if (a == core->configured_default_source)
|
|
|
43a070 |
+ return 1;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* Monitor sources lose to non-monitor sources. */
|
|
|
43a070 |
+ if (a->monitor_of && !b->monitor_of)
|
|
|
43a070 |
+ return -1;
|
|
|
43a070 |
+ if (!a->monitor_of && b->monitor_of)
|
|
|
43a070 |
+ return 1;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (a->priority < b->priority)
|
|
|
43a070 |
+ return -1;
|
|
|
43a070 |
+ if (a->priority > b->priority)
|
|
|
43a070 |
+ return 1;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* If the sources are monitors, we can compare the monitored sinks. */
|
|
|
43a070 |
+ if (a->monitor_of)
|
|
|
43a070 |
+ return compare_sinks(a->monitor_of, b->monitor_of);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* It's hard to find any difference between these sources, but maybe one of
|
|
|
43a070 |
+ * them is already the default source? If so, it's best to keep it as the
|
|
|
43a070 |
+ * default to avoid changing the routing for no good reason. */
|
|
|
43a070 |
+ if (b == core->default_source)
|
|
|
43a070 |
+ return -1;
|
|
|
43a070 |
+ if (a == core->default_source)
|
|
|
43a070 |
+ return 1;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ return 0;
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
+void pa_core_update_default_source(pa_core *core) {
|
|
|
43a070 |
+ pa_source *best = NULL;
|
|
|
43a070 |
+ pa_source *source;
|
|
|
43a070 |
+ uint32_t idx;
|
|
|
43a070 |
+ pa_source *old_default_source;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ pa_assert(core);
|
|
|
43a070 |
+
|
|
|
43a070 |
+ PA_IDXSET_FOREACH(source, core->sources, idx) {
|
|
|
43a070 |
+ if (!best) {
|
|
|
43a070 |
+ best = source;
|
|
|
43a070 |
+ continue;
|
|
|
43a070 |
+ }
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (compare_sources(source, best) > 0)
|
|
|
43a070 |
+ best = source;
|
|
|
43a070 |
+ }
|
|
|
43a070 |
+
|
|
|
43a070 |
+ old_default_source = core->default_source;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ if (best == old_default_source)
|
|
|
43a070 |
+ return;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ core->default_source = best;
|
|
|
43a070 |
+ pa_log_info("default_source: %s -> %s",
|
|
|
43a070 |
+ old_default_source ? old_default_source->name : "(unset)", best ? best->name : "(unset)");
|
|
|
43a070 |
+ pa_subscription_post(core, PA_SUBSCRIPTION_EVENT_SERVER | PA_SUBSCRIPTION_EVENT_CHANGE, PA_INVALID_INDEX);
|
|
|
43a070 |
+ pa_hook_fire(&core->hooks[PA_CORE_HOOK_DEFAULT_SOURCE_CHANGED], core->default_source);
|
|
|
43a070 |
+}
|
|
|
43a070 |
+
|
|
|
43a070 |
static void exit_callback(pa_mainloop_api *m, pa_time_event *e, const struct timeval *t, void *userdata) {
|
|
|
43a070 |
pa_core *c = userdata;
|
|
|
43a070 |
pa_assert(c->exit_event == e);
|
|
|
43a070 |
diff --git a/src/pulsecore/core.h b/src/pulsecore/core.h
|
|
|
43a070 |
index 802111ba1..6e613edeb 100644
|
|
|
43a070 |
--- a/src/pulsecore/core.h
|
|
|
43a070 |
+++ b/src/pulsecore/core.h
|
|
|
43a070 |
@@ -160,9 +160,18 @@ struct pa_core {
|
|
|
43a070 |
/* Some hashmaps for all sorts of entities */
|
|
|
43a070 |
pa_hashmap *namereg, *shared;
|
|
|
43a070 |
|
|
|
43a070 |
- /* The default sink/source */
|
|
|
43a070 |
- pa_source *default_source;
|
|
|
43a070 |
+ /* The default sink/source as configured by the user. If the user hasn't
|
|
|
43a070 |
+ * explicitly configured anything, these are set to NULL. */
|
|
|
43a070 |
+ pa_sink *configured_default_sink;
|
|
|
43a070 |
+ pa_source *configured_default_source;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ /* The effective default sink/source. If no sink or source is explicitly
|
|
|
43a070 |
+ * configured as the default, we pick the device that ranks highest
|
|
|
43a070 |
+ * according to the compare_sinks() and compare_sources() functions in
|
|
|
43a070 |
+ * core.c. pa_core_update_default_sink/source() has to be called whenever
|
|
|
43a070 |
+ * anything changes that might change the comparison results. */
|
|
|
43a070 |
pa_sink *default_sink;
|
|
|
43a070 |
+ pa_source *default_source;
|
|
|
43a070 |
|
|
|
43a070 |
pa_channel_map default_channel_map;
|
|
|
43a070 |
pa_sample_spec default_sample_spec;
|
|
|
43a070 |
@@ -223,6 +232,21 @@ enum {
|
|
|
43a070 |
|
|
|
43a070 |
pa_core* pa_core_new(pa_mainloop_api *m, bool shared, bool enable_memfd, size_t shm_size);
|
|
|
43a070 |
|
|
|
43a070 |
+void pa_core_set_configured_default_sink(pa_core *core, pa_sink *sink);
|
|
|
43a070 |
+void pa_core_set_configured_default_source(pa_core *core, pa_source *source);
|
|
|
43a070 |
+
|
|
|
43a070 |
+/* These should be called whenever something changes that may affect the
|
|
|
43a070 |
+ * default sink or source choice.
|
|
|
43a070 |
+ *
|
|
|
43a070 |
+ * If the default source choice happens between two monitor sources, the
|
|
|
43a070 |
+ * monitored sinks are compared, so if the default sink changes, the default
|
|
|
43a070 |
+ * source may change too. However, pa_core_update_default_sink() calls
|
|
|
43a070 |
+ * pa_core_update_default_source() internally, so it's sufficient to only call
|
|
|
43a070 |
+ * pa_core_update_default_sink() when something happens that affects the sink
|
|
|
43a070 |
+ * ordering. */
|
|
|
43a070 |
+void pa_core_update_default_sink(pa_core *core);
|
|
|
43a070 |
+void pa_core_update_default_source(pa_core *core);
|
|
|
43a070 |
+
|
|
|
43a070 |
/* Check whether no one is connected to this core */
|
|
|
43a070 |
void pa_core_check_idle(pa_core *c);
|
|
|
43a070 |
|
|
|
43a070 |
diff --git a/src/pulsecore/namereg.c b/src/pulsecore/namereg.c
|
|
|
43a070 |
index 47bfc087f..0b7388592 100644
|
|
|
43a070 |
--- a/src/pulsecore/namereg.c
|
|
|
43a070 |
+++ b/src/pulsecore/namereg.c
|
|
|
43a070 |
@@ -168,17 +168,6 @@ const char *pa_namereg_register(pa_core *c, const char *name, pa_namereg_type_t
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert_se(pa_hashmap_put(c->namereg, e->name, e) >= 0);
|
|
|
43a070 |
|
|
|
43a070 |
- /* If a sink or source is registered and there was none registered
|
|
|
43a070 |
- * before we inform the clients which then can ask for the default
|
|
|
43a070 |
- * sink/source which is then assigned. We don't adjust the default
|
|
|
43a070 |
- * sink/source here right away to give the module the chance to
|
|
|
43a070 |
- * register more sinks/sources before we choose a new default
|
|
|
43a070 |
- * sink/source. */
|
|
|
43a070 |
-
|
|
|
43a070 |
- if ((!c->default_sink && type == PA_NAMEREG_SINK) ||
|
|
|
43a070 |
- (!c->default_source && type == PA_NAMEREG_SOURCE))
|
|
|
43a070 |
- pa_subscription_post(c, PA_SUBSCRIPTION_EVENT_SERVER|PA_SUBSCRIPTION_EVENT_CHANGE, PA_INVALID_INDEX);
|
|
|
43a070 |
-
|
|
|
43a070 |
return e->name;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
@@ -189,12 +178,6 @@ void pa_namereg_unregister(pa_core *c, const char *name) {
|
|
|
43a070 |
pa_assert(name);
|
|
|
43a070 |
|
|
|
43a070 |
pa_assert_se(e = pa_hashmap_remove(c->namereg, name));
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (c->default_sink == e->data)
|
|
|
43a070 |
- pa_namereg_set_default_sink(c, NULL);
|
|
|
43a070 |
- else if (c->default_source == e->data)
|
|
|
43a070 |
- pa_namereg_set_default_source(c, NULL);
|
|
|
43a070 |
-
|
|
|
43a070 |
pa_xfree(e->name);
|
|
|
43a070 |
pa_xfree(e);
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -205,22 +188,16 @@ void* pa_namereg_get(pa_core *c, const char *name, pa_namereg_type_t type) {
|
|
|
43a070 |
pa_assert(c);
|
|
|
43a070 |
|
|
|
43a070 |
if (type == PA_NAMEREG_SOURCE && (!name || pa_streq(name, "@DEFAULT_SOURCE@"))) {
|
|
|
43a070 |
- pa_source *s;
|
|
|
43a070 |
-
|
|
|
43a070 |
- if ((s = pa_namereg_get_default_source(c)))
|
|
|
43a070 |
- return s;
|
|
|
43a070 |
+ return c->default_source;
|
|
|
43a070 |
|
|
|
43a070 |
} else if (type == PA_NAMEREG_SINK && (!name || pa_streq(name, "@DEFAULT_SINK@"))) {
|
|
|
43a070 |
- pa_sink *s;
|
|
|
43a070 |
-
|
|
|
43a070 |
- if ((s = pa_namereg_get_default_sink(c)))
|
|
|
43a070 |
- return s;
|
|
|
43a070 |
+ return c->default_sink;
|
|
|
43a070 |
|
|
|
43a070 |
} else if (type == PA_NAMEREG_SOURCE && name && pa_streq(name, "@DEFAULT_MONITOR@")) {
|
|
|
43a070 |
- pa_sink *s;
|
|
|
43a070 |
-
|
|
|
43a070 |
- if ((s = pa_namereg_get(c, NULL, PA_NAMEREG_SINK)))
|
|
|
43a070 |
- return s->monitor_source;
|
|
|
43a070 |
+ if (c->default_sink)
|
|
|
43a070 |
+ return c->default_sink->monitor_source;
|
|
|
43a070 |
+ else
|
|
|
43a070 |
+ return NULL;
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
if (!name)
|
|
|
43a070 |
@@ -248,83 +225,3 @@ void* pa_namereg_get(pa_core *c, const char *name, pa_namereg_type_t type) {
|
|
|
43a070 |
|
|
|
43a070 |
return NULL;
|
|
|
43a070 |
}
|
|
|
43a070 |
-
|
|
|
43a070 |
-pa_sink* pa_namereg_set_default_sink(pa_core*c, pa_sink *s) {
|
|
|
43a070 |
- pa_assert(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (s && !PA_SINK_IS_LINKED(pa_sink_get_state(s)))
|
|
|
43a070 |
- return NULL;
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (c->default_sink != s) {
|
|
|
43a070 |
- c->default_sink = s;
|
|
|
43a070 |
- pa_hook_fire(&c->hooks[PA_CORE_HOOK_DEFAULT_SINK_CHANGED], c->default_sink);
|
|
|
43a070 |
- pa_subscription_post(c, PA_SUBSCRIPTION_EVENT_SERVER|PA_SUBSCRIPTION_EVENT_CHANGE, PA_INVALID_INDEX);
|
|
|
43a070 |
- }
|
|
|
43a070 |
-
|
|
|
43a070 |
- return s;
|
|
|
43a070 |
-}
|
|
|
43a070 |
-
|
|
|
43a070 |
-pa_source* pa_namereg_set_default_source(pa_core*c, pa_source *s) {
|
|
|
43a070 |
- pa_assert(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (s && !PA_SOURCE_IS_LINKED(pa_source_get_state(s)))
|
|
|
43a070 |
- return NULL;
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (c->default_source != s) {
|
|
|
43a070 |
- c->default_source = s;
|
|
|
43a070 |
- pa_hook_fire(&c->hooks[PA_CORE_HOOK_DEFAULT_SOURCE_CHANGED], c->default_source);
|
|
|
43a070 |
- pa_subscription_post(c, PA_SUBSCRIPTION_EVENT_SERVER|PA_SUBSCRIPTION_EVENT_CHANGE, PA_INVALID_INDEX);
|
|
|
43a070 |
- }
|
|
|
43a070 |
-
|
|
|
43a070 |
- return s;
|
|
|
43a070 |
-}
|
|
|
43a070 |
-
|
|
|
43a070 |
-pa_sink *pa_namereg_get_default_sink(pa_core *c) {
|
|
|
43a070 |
- pa_sink *s, *best = NULL;
|
|
|
43a070 |
- uint32_t idx;
|
|
|
43a070 |
-
|
|
|
43a070 |
- pa_assert(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (c->default_sink && PA_SINK_IS_LINKED(pa_sink_get_state(c->default_sink)))
|
|
|
43a070 |
- return c->default_sink;
|
|
|
43a070 |
-
|
|
|
43a070 |
- PA_IDXSET_FOREACH(s, c->sinks, idx)
|
|
|
43a070 |
- if (PA_SINK_IS_LINKED(pa_sink_get_state(s)))
|
|
|
43a070 |
- if (!best || s->priority > best->priority)
|
|
|
43a070 |
- best = s;
|
|
|
43a070 |
-
|
|
|
43a070 |
- return best;
|
|
|
43a070 |
-}
|
|
|
43a070 |
-
|
|
|
43a070 |
-pa_source *pa_namereg_get_default_source(pa_core *c) {
|
|
|
43a070 |
- pa_source *s, *best = NULL;
|
|
|
43a070 |
- uint32_t idx;
|
|
|
43a070 |
-
|
|
|
43a070 |
- pa_assert(c);
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (c->default_source && PA_SOURCE_IS_LINKED(pa_source_get_state(c->default_source)))
|
|
|
43a070 |
- return c->default_source;
|
|
|
43a070 |
-
|
|
|
43a070 |
- /* First, try to find one that isn't a monitor */
|
|
|
43a070 |
- PA_IDXSET_FOREACH(s, c->sources, idx)
|
|
|
43a070 |
- if (!s->monitor_of && PA_SOURCE_IS_LINKED(pa_source_get_state(s)))
|
|
|
43a070 |
- if (!best ||
|
|
|
43a070 |
- s->priority > best->priority)
|
|
|
43a070 |
- best = s;
|
|
|
43a070 |
-
|
|
|
43a070 |
- if (best)
|
|
|
43a070 |
- return best;
|
|
|
43a070 |
-
|
|
|
43a070 |
- /* Then, fallback to a monitor */
|
|
|
43a070 |
- PA_IDXSET_FOREACH(s, c->sources, idx)
|
|
|
43a070 |
- if (PA_SOURCE_IS_LINKED(pa_source_get_state(s)))
|
|
|
43a070 |
- if (!best ||
|
|
|
43a070 |
- s->priority > best->priority ||
|
|
|
43a070 |
- (s->priority == best->priority &&
|
|
|
43a070 |
- s->monitor_of &&
|
|
|
43a070 |
- best->monitor_of &&
|
|
|
43a070 |
- s->monitor_of->priority > best->monitor_of->priority))
|
|
|
43a070 |
- best = s;
|
|
|
43a070 |
-
|
|
|
43a070 |
- return best;
|
|
|
43a070 |
-}
|
|
|
43a070 |
diff --git a/src/pulsecore/namereg.h b/src/pulsecore/namereg.h
|
|
|
43a070 |
index 467db5d43..eb3475ad3 100644
|
|
|
43a070 |
--- a/src/pulsecore/namereg.h
|
|
|
43a070 |
+++ b/src/pulsecore/namereg.h
|
|
|
43a070 |
@@ -36,12 +36,6 @@ const char *pa_namereg_register(pa_core *c, const char *name, pa_namereg_type_t
|
|
|
43a070 |
void pa_namereg_unregister(pa_core *c, const char *name);
|
|
|
43a070 |
void* pa_namereg_get(pa_core *c, const char *name, pa_namereg_type_t type);
|
|
|
43a070 |
|
|
|
43a070 |
-pa_sink* pa_namereg_set_default_sink(pa_core*c, pa_sink *s);
|
|
|
43a070 |
-pa_source* pa_namereg_set_default_source(pa_core*c, pa_source *s);
|
|
|
43a070 |
-
|
|
|
43a070 |
-pa_sink *pa_namereg_get_default_sink(pa_core *c);
|
|
|
43a070 |
-pa_source *pa_namereg_get_default_source(pa_core *c);
|
|
|
43a070 |
-
|
|
|
43a070 |
bool pa_namereg_is_valid_name(const char *name);
|
|
|
43a070 |
bool pa_namereg_is_valid_name_or_wildcard(const char *name, pa_namereg_type_t type);
|
|
|
43a070 |
char* pa_namereg_make_valid_name(const char *name);
|
|
|
43a070 |
diff --git a/src/pulsecore/protocol-native.c b/src/pulsecore/protocol-native.c
|
|
|
43a070 |
index 13f4f6238..8869ae4fa 100644
|
|
|
43a070 |
--- a/src/pulsecore/protocol-native.c
|
|
|
43a070 |
+++ b/src/pulsecore/protocol-native.c
|
|
|
43a070 |
@@ -3637,10 +3637,9 @@ static void command_get_info_list(pa_pdispatch *pd, uint32_t command, uint32_t t
|
|
|
43a070 |
static void command_get_server_info(pa_pdispatch *pd, uint32_t command, uint32_t tag, pa_tagstruct *t, void *userdata) {
|
|
|
43a070 |
pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
|
|
|
43a070 |
pa_tagstruct *reply;
|
|
|
43a070 |
- pa_sink *def_sink;
|
|
|
43a070 |
- pa_source *def_source;
|
|
|
43a070 |
pa_sample_spec fixed_ss;
|
|
|
43a070 |
char *h, *u;
|
|
|
43a070 |
+ pa_core *core;
|
|
|
43a070 |
|
|
|
43a070 |
pa_native_connection_assert_ref(c);
|
|
|
43a070 |
pa_assert(t);
|
|
|
43a070 |
@@ -3664,18 +3663,18 @@ static void command_get_server_info(pa_pdispatch *pd, uint32_t command, uint32_t
|
|
|
43a070 |
pa_tagstruct_puts(reply, h);
|
|
|
43a070 |
pa_xfree(h);
|
|
|
43a070 |
|
|
|
43a070 |
- fixup_sample_spec(c, &fixed_ss, &c->protocol->core->default_sample_spec);
|
|
|
43a070 |
+ core = c->protocol->core;
|
|
|
43a070 |
+
|
|
|
43a070 |
+ fixup_sample_spec(c, &fixed_ss, &core->default_sample_spec);
|
|
|
43a070 |
pa_tagstruct_put_sample_spec(reply, &fixed_ss);
|
|
|
43a070 |
|
|
|
43a070 |
- def_sink = pa_namereg_get_default_sink(c->protocol->core);
|
|
|
43a070 |
- pa_tagstruct_puts(reply, def_sink ? def_sink->name : NULL);
|
|
|
43a070 |
- def_source = pa_namereg_get_default_source(c->protocol->core);
|
|
|
43a070 |
- pa_tagstruct_puts(reply, def_source ? def_source->name : NULL);
|
|
|
43a070 |
+ pa_tagstruct_puts(reply, core->default_sink ? core->default_sink->name : NULL);
|
|
|
43a070 |
+ pa_tagstruct_puts(reply, core->default_source ? core->default_source->name : NULL);
|
|
|
43a070 |
|
|
|
43a070 |
pa_tagstruct_putu32(reply, c->protocol->core->cookie);
|
|
|
43a070 |
|
|
|
43a070 |
if (c->version >= 15)
|
|
|
43a070 |
- pa_tagstruct_put_channel_map(reply, &c->protocol->core->default_channel_map);
|
|
|
43a070 |
+ pa_tagstruct_put_channel_map(reply, &core->default_channel_map);
|
|
|
43a070 |
|
|
|
43a070 |
pa_pstream_send_tagstruct(c->pstream, reply);
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -4347,7 +4346,7 @@ static void command_set_default_sink_or_source(pa_pdispatch *pd, uint32_t comman
|
|
|
43a070 |
source = pa_namereg_get(c->protocol->core, s, PA_NAMEREG_SOURCE);
|
|
|
43a070 |
CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY);
|
|
|
43a070 |
|
|
|
43a070 |
- pa_namereg_set_default_source(c->protocol->core, source);
|
|
|
43a070 |
+ pa_core_set_configured_default_source(c->protocol->core, source);
|
|
|
43a070 |
} else {
|
|
|
43a070 |
pa_sink *sink;
|
|
|
43a070 |
pa_assert(command == PA_COMMAND_SET_DEFAULT_SINK);
|
|
|
43a070 |
@@ -4355,7 +4354,7 @@ static void command_set_default_sink_or_source(pa_pdispatch *pd, uint32_t comman
|
|
|
43a070 |
sink = pa_namereg_get(c->protocol->core, s, PA_NAMEREG_SINK);
|
|
|
43a070 |
CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY);
|
|
|
43a070 |
|
|
|
43a070 |
- pa_namereg_set_default_sink(c->protocol->core, sink);
|
|
|
43a070 |
+ pa_core_set_configured_default_sink(c->protocol->core, sink);
|
|
|
43a070 |
}
|
|
|
43a070 |
|
|
|
43a070 |
pa_pstream_send_simple_ack(c->pstream, tag);
|
|
|
43a070 |
diff --git a/src/pulsecore/sink.c b/src/pulsecore/sink.c
|
|
|
43a070 |
index ebb13c2c9..b4b373a58 100644
|
|
|
43a070 |
--- a/src/pulsecore/sink.c
|
|
|
43a070 |
+++ b/src/pulsecore/sink.c
|
|
|
43a070 |
@@ -660,6 +660,8 @@ void pa_sink_put(pa_sink* s) {
|
|
|
43a070 |
|
|
|
43a070 |
pa_source_put(s->monitor_source);
|
|
|
43a070 |
|
|
|
43a070 |
+ pa_core_update_default_sink(s->core);
|
|
|
43a070 |
+
|
|
|
43a070 |
pa_subscription_post(s->core, PA_SUBSCRIPTION_EVENT_SINK | PA_SUBSCRIPTION_EVENT_NEW, s->index);
|
|
|
43a070 |
pa_hook_fire(&s->core->hooks[PA_CORE_HOOK_SINK_PUT], s);
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -690,6 +692,11 @@ void pa_sink_unlink(pa_sink* s) {
|
|
|
43a070 |
pa_namereg_unregister(s->core, s->name);
|
|
|
43a070 |
pa_idxset_remove_by_data(s->core->sinks, s, NULL);
|
|
|
43a070 |
|
|
|
43a070 |
+ if (s == s->core->configured_default_sink)
|
|
|
43a070 |
+ pa_core_set_configured_default_sink(s->core, NULL);
|
|
|
43a070 |
+ else
|
|
|
43a070 |
+ pa_core_update_default_sink(s->core);
|
|
|
43a070 |
+
|
|
|
43a070 |
if (s->card)
|
|
|
43a070 |
pa_idxset_remove_by_data(s->card->sinks, s, NULL);
|
|
|
43a070 |
|
|
|
43a070 |
diff --git a/src/pulsecore/source.c b/src/pulsecore/source.c
|
|
|
43a070 |
index 3f0f53b52..ccf8efc91 100644
|
|
|
43a070 |
--- a/src/pulsecore/source.c
|
|
|
43a070 |
+++ b/src/pulsecore/source.c
|
|
|
43a070 |
@@ -603,6 +603,8 @@ void pa_source_put(pa_source *s) {
|
|
|
43a070 |
else
|
|
|
43a070 |
pa_assert_se(source_set_state(s, PA_SOURCE_IDLE) == 0);
|
|
|
43a070 |
|
|
|
43a070 |
+ pa_core_update_default_source(s->core);
|
|
|
43a070 |
+
|
|
|
43a070 |
pa_subscription_post(s->core, PA_SUBSCRIPTION_EVENT_SOURCE | PA_SUBSCRIPTION_EVENT_NEW, s->index);
|
|
|
43a070 |
pa_hook_fire(&s->core->hooks[PA_CORE_HOOK_SOURCE_PUT], s);
|
|
|
43a070 |
}
|
|
|
43a070 |
@@ -632,6 +634,11 @@ void pa_source_unlink(pa_source *s) {
|
|
|
43a070 |
pa_namereg_unregister(s->core, s->name);
|
|
|
43a070 |
pa_idxset_remove_by_data(s->core->sources, s, NULL);
|
|
|
43a070 |
|
|
|
43a070 |
+ if (s == s->core->configured_default_source)
|
|
|
43a070 |
+ pa_core_set_configured_default_source(s->core, NULL);
|
|
|
43a070 |
+ else
|
|
|
43a070 |
+ pa_core_update_default_source(s->core);
|
|
|
43a070 |
+
|
|
|
43a070 |
if (s->card)
|
|
|
43a070 |
pa_idxset_remove_by_data(s->card->sources, s, NULL);
|
|
|
43a070 |
|
|
|
43a070 |
--
|
|
|
43a070 |
2.14.3
|
|
|
43a070 |
|