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

stream: don't ask for 0 size buffer

Browse source
This commit is contained in:
Wim Taymans 2022-03-29 12:04:06 +02:00
parent 6041d939a0
commit 5fc1ab90f7
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/pipewire/stream.c
View file

@ -549,7 +549,7 @@ static int impl_set_param(void *object, uint32_t id, uint32_t flags, const struc
static inline uint32_t update_requested(struct stream *impl) static inline uint32_t update_requested(struct stream *impl)
{ {
uint32_t index, id; uint32_t index, id, res = 0;
struct buffer *buffer; struct buffer *buffer;
struct spa_io_rate_match *r = impl->rate_match; struct spa_io_rate_match *r = impl->rate_match;
@ -558,9 +558,15 @@ static inline uint32_t update_requested(struct stream *impl)
id = impl->dequeued.ids[index & MASK_BUFFERS]; id = impl->dequeued.ids[index & MASK_BUFFERS];
buffer = &impl->buffers[id]; buffer = &impl->buffers[id];
buffer->this.requested = r ? r->size : 0; if (r) {
buffer->this.requested = r->size;
res = r->size > 0 ? 1 : 0;
} else {
buffer->this.requested = 0;
res = 1;
}
pw_log_trace_fp("%p: update buffer:%u size:%u", impl, id, r->size); pw_log_trace_fp("%p: update buffer:%u size:%u", impl, id, r->size);
return 1; return res;
} }
static int impl_send_command(void *object, const struct spa_command *command) static int impl_send_command(void *object, const struct spa_command *command)