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: also recycle buffers

Browse source
This commit is contained in:
Wim Taymans 2019-03-08 17:16:44 +01:00
parent fd373ce4d2
commit 317493a2dc
1 changed files with 2 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/pipewire/stream.c
View file

@ -1337,15 +1337,8 @@ do_process(struct spa_loop *loop,
bool async, uint32_t seq, const void *data, size_t size, void *user_data) bool async, uint32_t seq, const void *data, size_t size, void *user_data)
{ {
struct stream *impl = user_data; struct stream *impl = user_data;
struct buffer *b; int res = impl_node_process_output(&impl->impl_node);
struct spa_io_buffers *io = impl->io; return impl->callbacks->ready(impl->callbacks_data, res);
if ((b = pop_queue(impl, &impl->queued)) != NULL) {
io->buffer_id = b->id;
io->status = SPA_STATUS_HAVE_BUFFER;
pw_log_trace("stream %p: pop %d %p", impl, b->id, io);
}
return impl->callbacks->ready(impl->callbacks_data, io->status);
} }
static inline int call_trigger(struct stream *impl) static inline int call_trigger(struct stream *impl)