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

stream: clear queued items when clearing buffers

Browse source
This commit is contained in:
Wim Taymans 2018-12-04 13:36:37 +01:00
parent dd28116f12
commit 53c2eb2625
1 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/pipewire/stream.c
View file

@ -201,6 +201,11 @@ static inline struct buffer *pop_queue(struct stream *stream, struct queue *queu
return buffer; return buffer;
} }
static inline void clear_queue(struct stream *stream, struct queue *queue)
{
spa_ringbuffer_init(&queue->ring);
queue->incount = queue->outcount;
}
static bool stream_set_state(struct pw_stream *stream, enum pw_stream_state state, const char *error) static bool stream_set_state(struct pw_stream *stream, enum pw_stream_state state, const char *error)
{ {
@ -546,8 +551,8 @@ static void clear_buffers(struct pw_stream *stream)
} }
} }
impl->n_buffers = 0; impl->n_buffers = 0;
spa_ringbuffer_init(&impl->dequeued.ring); clear_queue(impl, &impl->dequeued);
spa_ringbuffer_init(&impl->queued.ring); clear_queue(impl, &impl->queued);
} }
static int impl_port_use_buffers(struct spa_node *node, enum spa_direction direction, uint32_t port_id, static int impl_port_use_buffers(struct spa_node *node, enum spa_direction direction, uint32_t port_id,