2 This file is part of PulseAudio.
4 Copyright 2006 Lennart Poettering
6 PulseAudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as published
8 by the Free Software Foundation; either version 2.1 of the License,
9 or (at your option) any later version.
11 PulseAudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public License
17 along with PulseAudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
26 #include <pulse/xmalloc.h>
28 #include <pulsecore/core.h>
29 #include <pulsecore/sink-input.h>
30 #include <pulsecore/source-output.h>
31 #include <pulsecore/modargs.h>
32 #include <pulsecore/log.h>
33 #include <pulsecore/namereg.h>
34 #include <pulsecore/core-util.h>
36 #include "module-rescue-streams-symdef.h"
38 PA_MODULE_AUTHOR("Lennart Poettering");
39 PA_MODULE_DESCRIPTION("When a sink/source is removed, try to move their streams to the default sink/source");
40 PA_MODULE_VERSION(PACKAGE_VERSION);
41 PA_MODULE_LOAD_ONCE(TRUE);
43 static const char* const valid_modargs[] = {
51 *sink_input_move_fail_slot,
52 *source_output_move_fail_slot;
55 static pa_sink* find_evacuation_sink(pa_core *c, pa_sink_input *i, pa_sink *skip) {
56 pa_sink *target, *def;
62 def = pa_namereg_get_default_sink(c);
64 if (def && def != skip && pa_sink_input_may_move_to(i, def))
67 PA_IDXSET_FOREACH(target, c->sinks, idx) {
74 if (!PA_SINK_IS_LINKED(pa_sink_get_state(target)))
77 if (pa_sink_input_may_move_to(i, target))
81 pa_log_debug("No evacuation sink found.");
85 static pa_hook_result_t sink_unlink_hook_callback(pa_core *c, pa_sink *sink, void* userdata) {
92 /* There's no point in doing anything if the core is shut down anyway */
93 if (c->state == PA_CORE_SHUTDOWN)
96 if (pa_idxset_size(sink->inputs) <= 0) {
97 pa_log_debug("No sink inputs to move away.");
101 PA_IDXSET_FOREACH(i, sink->inputs, idx) {
104 if (!(target = find_evacuation_sink(c, i, sink)))
107 if (pa_sink_input_move_to(i, target, FALSE) < 0)
108 pa_log_info("Failed to move sink input %u \"%s\" to %s.", i->index,
109 pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_APPLICATION_NAME)), target->name);
111 pa_log_info("Successfully moved sink input %u \"%s\" to %s.", i->index,
112 pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_APPLICATION_NAME)), target->name);
118 static pa_hook_result_t sink_input_move_fail_hook_callback(pa_core *c, pa_sink_input *i, void *userdata) {
124 /* There's no point in doing anything if the core is shut down anyway */
125 if (c->state == PA_CORE_SHUTDOWN)
128 if (!(target = find_evacuation_sink(c, i, NULL)))
131 if (pa_sink_input_finish_move(i, target, FALSE) < 0) {
132 pa_log_info("Failed to move sink input %u \"%s\" to %s.", i->index,
133 pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_APPLICATION_NAME)), target->name);
137 pa_log_info("Successfully moved sink input %u \"%s\" to %s.", i->index,
138 pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_APPLICATION_NAME)), target->name);
143 static pa_source* find_evacuation_source(pa_core *c, pa_source_output *o, pa_source *skip) {
144 pa_source *target, *def;
150 def = pa_namereg_get_default_source(c);
152 if (def && def != skip && pa_source_output_may_move_to(o, def))
155 PA_IDXSET_FOREACH(target, c->sources, idx) {
162 if (skip && !target->monitor_of != !skip->monitor_of)
165 if (!PA_SOURCE_IS_LINKED(pa_source_get_state(target)))
168 if (pa_source_output_may_move_to(o, target))
172 pa_log_debug("No evacuation source found.");
176 static pa_hook_result_t source_unlink_hook_callback(pa_core *c, pa_source *source, void* userdata) {
183 /* There's no point in doing anything if the core is shut down anyway */
184 if (c->state == PA_CORE_SHUTDOWN)
187 if (pa_idxset_size(source->outputs) <= 0) {
188 pa_log_debug("No source outputs to move away.");
192 PA_IDXSET_FOREACH(o, source->outputs, idx) {
195 if (!(target = find_evacuation_source(c, o, source)))
198 if (pa_source_output_move_to(o, target, FALSE) < 0)
199 pa_log_info("Failed to move source output %u \"%s\" to %s.", o->index,
200 pa_strnull(pa_proplist_gets(o->proplist, PA_PROP_APPLICATION_NAME)), target->name);
202 pa_log_info("Successfully moved source output %u \"%s\" to %s.", o->index,
203 pa_strnull(pa_proplist_gets(o->proplist, PA_PROP_APPLICATION_NAME)), target->name);
209 static pa_hook_result_t source_output_move_fail_hook_callback(pa_core *c, pa_source_output *i, void *userdata) {
215 /* There's no point in doing anything if the core is shut down anyway */
216 if (c->state == PA_CORE_SHUTDOWN)
219 if (!(target = find_evacuation_source(c, i, NULL)))
222 if (pa_source_output_finish_move(i, target, FALSE) < 0) {
223 pa_log_info("Failed to move source input %u \"%s\" to %s.", i->index,
224 pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_APPLICATION_NAME)), target->name);
228 pa_log_info("Successfully moved source input %u \"%s\" to %s.", i->index,
229 pa_strnull(pa_proplist_gets(i->proplist, PA_PROP_APPLICATION_NAME)), target->name);
234 int pa__init(pa_module*m) {
240 if (!(ma = pa_modargs_new(m->argument, valid_modargs))) {
241 pa_log("Failed to parse module arguments");
245 m->userdata = u = pa_xnew(struct userdata, 1);
247 /* A little bit later than module-stream-restore, module-intended-roles... */
248 u->sink_unlink_slot = pa_hook_connect(&m->core->hooks[PA_CORE_HOOK_SINK_UNLINK], PA_HOOK_LATE+20, (pa_hook_cb_t) sink_unlink_hook_callback, u);
249 u->source_unlink_slot = pa_hook_connect(&m->core->hooks[PA_CORE_HOOK_SOURCE_UNLINK], PA_HOOK_LATE+20, (pa_hook_cb_t) source_unlink_hook_callback, u);
251 u->sink_input_move_fail_slot = pa_hook_connect(&m->core->hooks[PA_CORE_HOOK_SINK_INPUT_MOVE_FAIL], PA_HOOK_LATE+20, (pa_hook_cb_t) sink_input_move_fail_hook_callback, u);
252 u->source_output_move_fail_slot = pa_hook_connect(&m->core->hooks[PA_CORE_HOOK_SOURCE_OUTPUT_MOVE_FAIL], PA_HOOK_LATE+20, (pa_hook_cb_t) source_output_move_fail_hook_callback, u);
258 void pa__done(pa_module*m) {
263 if (!(u = m->userdata))
266 if (u->sink_unlink_slot)
267 pa_hook_slot_free(u->sink_unlink_slot);
268 if (u->source_unlink_slot)
269 pa_hook_slot_free(u->source_unlink_slot);
271 if (u->sink_input_move_fail_slot)
272 pa_hook_slot_free(u->sink_input_move_fail_slot);
273 if (u->source_output_move_fail_slot)
274 pa_hook_slot_free(u->source_output_move_fail_slot);