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

a2dp-sink: remove sources only once

Browse source
This commit is contained in:
Wim Taymans 2018-04-24 17:21:23 +02:00
parent b122f86e11
commit f9bda23e56
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
spa/plugins/bluez5/a2dp-sink.c
View file

@ -612,6 +612,7 @@ static void a2dp_on_flush(struct spa_source *source)
if ((source->rmask & SPA_IO_OUT) == 0) { if ((source->rmask & SPA_IO_OUT) == 0) {
spa_log_warn(this->log, "error %d", source->rmask); spa_log_warn(this->log, "error %d", source->rmask);
if (this->flush_source.loop)
spa_loop_remove_source(this->data_loop, &this->flush_source); spa_loop_remove_source(this->data_loop, &this->flush_source);
this->source.mask = 0; this->source.mask = 0;
spa_loop_update_source(this->data_loop, &this->source); spa_loop_update_source(this->data_loop, &this->source);
@ -812,12 +813,14 @@ static int do_remove_source(struct spa_loop *loop,
struct impl *this = user_data; struct impl *this = user_data;
struct itimerspec ts; struct itimerspec ts;
if (this->source.loop)
spa_loop_remove_source(this->data_loop, &this->source); spa_loop_remove_source(this->data_loop, &this->source);
ts.it_value.tv_sec = 0; ts.it_value.tv_sec = 0;
ts.it_value.tv_nsec = 0; ts.it_value.tv_nsec = 0;
ts.it_interval.tv_sec = 0; ts.it_interval.tv_sec = 0;
ts.it_interval.tv_nsec = 0; ts.it_interval.tv_nsec = 0;
timerfd_settime(this->timerfd, 0, &ts, NULL); timerfd_settime(this->timerfd, 0, &ts, NULL);
if (this->flush_source.loop)
spa_loop_remove_source(this->data_loop, &this->flush_source); spa_loop_remove_source(this->data_loop, &this->flush_source);
return 0; return 0;