diff options
author | Lennart Poettering <lennart@poettering.net> | 2009-01-23 22:40:02 +0100 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2009-01-23 22:40:02 +0100 |
commit | 640d317df93f205d5830b9f7b106233ddb6d2f9e (patch) | |
tree | 33034e3b3e4a8443ca7c0d47e0be48b84f6ef36b /src/pulsecore/source.c | |
parent | 29cb778dcc3ceff2bb16520a16388cc21cd32884 (diff) |
add functions to move all inputs of a sink away/similar for source outputs
Diffstat (limited to 'src/pulsecore/source.c')
-rw-r--r-- | src/pulsecore/source.c | 52 |
1 files changed, 52 insertions, 0 deletions
diff --git a/src/pulsecore/source.c b/src/pulsecore/source.c index fea66b7e..3cddd099 100644 --- a/src/pulsecore/source.c +++ b/src/pulsecore/source.c @@ -412,6 +412,58 @@ int pa_source_suspend(pa_source *s, pa_bool_t suspend) { return source_set_state(s, pa_source_used_by(s) ? PA_SOURCE_RUNNING : PA_SOURCE_IDLE); } +/* Called from main context */ +pa_queue *pa_source_move_all_start(pa_source *s) { + pa_queue *q; + pa_source_output *o, *n; + uint32_t idx; + + pa_source_assert_ref(s); + pa_assert(PA_SOURCE_IS_LINKED(s->state)); + + q = pa_queue_new(); + + for (o = PA_SOURCE_OUTPUT(pa_idxset_first(s->outputs, &idx)); o; o = n) { + n = PA_SOURCE_OUTPUT(pa_idxset_next(s->outputs, &idx)); + + if (pa_source_output_start_move(o) >= 0) + pa_queue_push(q, pa_source_output_ref(o)); + } + + return q; +} + +/* Called from main context */ +void pa_source_move_all_finish(pa_source *s, pa_queue *q) { + pa_source_output *o; + + pa_source_assert_ref(s); + pa_assert(PA_SOURCE_IS_LINKED(s->state)); + pa_assert(q); + + while ((o = PA_SOURCE_OUTPUT(pa_queue_pop(q)))) { + if (pa_source_output_finish_move(o, s) < 0) + pa_source_output_unlink(o); + + pa_source_output_unref(o); + } + + pa_queue_free(q, NULL, NULL); +} + +/* Called from main context */ +void pa_source_move_all_fail(pa_queue *q) { + pa_source_output *o; + pa_assert(q); + + while ((o = PA_SOURCE_OUTPUT(pa_queue_pop(q)))) { + pa_source_output_unlink(o); + pa_source_output_unref(o); + } + + pa_queue_free(q, NULL, NULL); +} + /* Called from IO thread context */ void pa_source_process_rewind(pa_source *s, size_t nbytes) { pa_source_output *o; |