mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-12-16 08:56:45 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: cancel items from work-queue

Browse source 
Make sure we cancel any pending work-queue items for the object before
we destroy the object.
This commit is contained in:
Wim Taymans 2021-04-21 13:23:13 +02:00
parent 639e6ea644
commit fbd6a62b73
1 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/modules/module-protocol-pulse/pulse-server.c
View file

@ -970,6 +970,8 @@ static void stream_free(struct stream *stream)
spa_hook_remove(&stream->stream_listener); spa_hook_remove(&stream->stream_listener);
pw_stream_destroy(stream->stream); pw_stream_destroy(stream->stream);
} }
pw_work_queue_cancel(impl->work_queue, stream, SPA_ID_INVALID);
if (stream->buffer) if (stream->buffer)
free(stream->buffer); free(stream->buffer);
if (stream->props) if (stream->props)
@ -2640,8 +2642,11 @@ struct pending_sample {
static void pending_sample_free(struct pending_sample *ps) static void pending_sample_free(struct pending_sample *ps)
{ {
struct client *client = ps->client;
struct impl *impl = client->impl;
spa_list_remove(&ps->link); spa_list_remove(&ps->link);
spa_hook_remove(&ps->listener); spa_hook_remove(&ps->listener);
pw_work_queue_cancel(impl->work_queue, ps, SPA_ID_INVALID);
ps->client->ref--; ps->client->ref--;
sample_play_destroy(ps->play); sample_play_destroy(ps->play);
} }