diff --git a/src/pulsecore/rtpoll.c b/src/pulsecore/rtpoll.c index f427ef36c..13c8677ad 100644 --- a/src/pulsecore/rtpoll.c +++ b/src/pulsecore/rtpoll.c @@ -557,7 +557,9 @@ static int asyncmsgq_read_work(pa_rtpoll_item *i) { if (!object && code == PA_MESSAGE_SHUTDOWN) { pa_asyncmsgq_done(i->userdata, 0); - pa_rtpoll_quit(i->rtpoll); + /* Requests the loop to exit. Will cause the next iteration of + * pa_rtpoll_run() to return 0 */ + i->rtpoll->quit = true; return 1; } @@ -625,12 +627,6 @@ pa_rtpoll_item *pa_rtpoll_item_new_asyncmsgq_write(pa_rtpoll *p, pa_rtpoll_prior return i; } -void pa_rtpoll_quit(pa_rtpoll *p) { - pa_assert(p); - - p->quit = true; -} - bool pa_rtpoll_timer_elapsed(pa_rtpoll *p) { pa_assert(p); diff --git a/src/pulsecore/rtpoll.h b/src/pulsecore/rtpoll.h index 4f09ab841..8f0715ac1 100644 --- a/src/pulsecore/rtpoll.h +++ b/src/pulsecore/rtpoll.h @@ -98,8 +98,4 @@ pa_rtpoll_item *pa_rtpoll_item_new_fdsem(pa_rtpoll *p, pa_rtpoll_priority_t prio pa_rtpoll_item *pa_rtpoll_item_new_asyncmsgq_read(pa_rtpoll *p, pa_rtpoll_priority_t prio, pa_asyncmsgq *q); pa_rtpoll_item *pa_rtpoll_item_new_asyncmsgq_write(pa_rtpoll *p, pa_rtpoll_priority_t prio, pa_asyncmsgq *q); -/* Requests the loop to exit. Will cause the next iteration of - * pa_rtpoll_run() to return 0 */ -void pa_rtpoll_quit(pa_rtpoll *p); - #endif