mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-03 09:01:54 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

stream: notify about port IO areas as well

Browse source
This commit is contained in:
Wim Taymans 2021-01-08 16:52:42 +01:00
parent 7f007b6bca
commit 03430da64a
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/pipewire/stream.c
View file

@ -509,6 +509,7 @@ static int impl_port_set_io(void *object, enum spa_direction direction, uint32_t
uint32_t id, void *data, size_t size) uint32_t id, void *data, size_t size)
{ {
struct stream *impl = object; struct stream *impl = object;
struct pw_stream *stream = &impl->this;
pw_log_debug(NAME" %p: set io id %d (%s) %p %zd", impl, id, pw_log_debug(NAME" %p: set io id %d (%s) %p %zd", impl, id,
spa_debug_type_find_name(spa_type_io, id), data, size); spa_debug_type_find_name(spa_type_io, id), data, size);
@ -520,9 +521,9 @@ static int impl_port_set_io(void *object, enum spa_direction direction, uint32_t
else else
impl->io = NULL; impl->io = NULL;
break; break;
default:
return -ENOENT;
} }
pw_stream_emit_io_changed(stream, id, data, size);
return 0; return 0;
} }
@ -814,7 +815,8 @@ static int impl_node_process_output(void *object)
uint32_t index; uint32_t index;
again: again:
pw_log_trace(NAME" %p: process out status:%d id:%d", stream, io->status, io->buffer_id); pw_log_trace(NAME" %p: process out status:%d id:%d", stream,
io->status, io->buffer_id);
if ((res = io->status) != SPA_STATUS_HAVE_DATA) { if ((res = io->status) != SPA_STATUS_HAVE_DATA) {
/* recycle old buffer */ /* recycle old buffer */