From 317493a2dc558cd371610496f8d49a10f2466fa6 Mon Sep 17 00:00:00 2001
From: Wim Taymans <wtaymans@redhat.com>
Date: Fri, 8 Mar 2019 17:16:44 +0100
Subject: [PATCH] stream: also recycle buffers

---
 src/pipewire/stream.c | 11 ++---------
 1 file changed, 2 insertions(+), 9 deletions(-)

diff --git a/src/pipewire/stream.c b/src/pipewire/stream.c
index f40de7035..29353df8f 100644
--- a/src/pipewire/stream.c
+++ b/src/pipewire/stream.c
@@ -1337,15 +1337,8 @@ do_process(struct spa_loop *loop,
                  bool async, uint32_t seq, const void *data, size_t size, void *user_data)
 {
 	struct stream *impl = user_data;
-	struct buffer *b;
-	struct spa_io_buffers *io = impl->io;
-
-	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);
+	int res = impl_node_process_output(&impl->impl_node);
+	return impl->callbacks->ready(impl->callbacks_data, res);
 }
 
 static inline int call_trigger(struct stream *impl)