mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

stream: call the moved_callback when moved

Browse source
This commit is contained in:
Wim Taymans 2020-08-19 16:48:25 +02:00
parent 4e17d4cdf8
commit bb323a82a7
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
pipewire-pulseaudio/src/stream.c
View file

@ -61,13 +61,13 @@ static void configure_device(pa_stream *s)
{ {
struct global *g; struct global *g;
const char *str; const char *str;
uint32_t old = s->device_index;
g = pa_context_find_linked(s->context, pa_stream_get_index(s)); g = pa_context_find_linked(s->context, pa_stream_get_index(s));
if (g == NULL) { if (g == NULL) {
s->device_index = PA_INVALID_INDEX; s->device_index = PA_INVALID_INDEX;
s->device_name = NULL; s->device_name = NULL;
} } else {
else {
if (s->direction == PA_STREAM_RECORD) { if (s->direction == PA_STREAM_RECORD) {
if (g->mask == (PA_SUBSCRIPTION_MASK_SINK | PA_SUBSCRIPTION_MASK_SOURCE)) if (g->mask == (PA_SUBSCRIPTION_MASK_SINK | PA_SUBSCRIPTION_MASK_SOURCE))
s->device_index = g->node_info.monitor; s->device_index = g->node_info.monitor;
@ -85,6 +85,9 @@ static void configure_device(pa_stream *s)
s->device_name = strdup(str); s->device_name = strdup(str);
} }
pw_log_debug("stream %p: linked to %d '%s'", s, s->device_index, s->device_name); pw_log_debug("stream %p: linked to %d '%s'", s, s->device_index, s->device_name);
if (old != s->device_index && s->moved_callback)
s->moved_callback(s, s->moved_userdata);
} }
static void stream_destroy(void *data) static void stream_destroy(void *data)