mirror of
https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git
synced 2025-12-29 11:08:35 -05:00
9e21182e01
Previously we might have dropped messages from IO trheads to the main thread. This tuend out to be problematic since this cause SHM release messages to be lost. More visibly however this could cause playback freezing when moving streams between sinks and removing the old sink right away.
134 lines
4 KiB
C
134 lines
4 KiB
C
/***
|
|
This file is part of PulseAudio.
|
|
|
|
Copyright 2006 Lennart Poettering
|
|
|
|
PulseAudio is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU Lesser General Public License as
|
|
published by the Free Software Foundation; either version 2.1 of the
|
|
License, or (at your option) any later version.
|
|
|
|
PulseAudio is distributed in the hope that it will be useful, but
|
|
WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Lesser General Public License for more details.
|
|
|
|
You should have received a copy of the GNU Lesser General Public
|
|
License along with PulseAudio; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
|
|
USA.
|
|
***/
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include <config.h>
|
|
#endif
|
|
|
|
#include <unistd.h>
|
|
#include <errno.h>
|
|
|
|
#include <pulse/xmalloc.h>
|
|
|
|
#include <pulsecore/atomic.h>
|
|
#include <pulsecore/once.h>
|
|
#include <pulsecore/log.h>
|
|
#include <pulsecore/thread.h>
|
|
#include <pulsecore/semaphore.h>
|
|
#include <pulsecore/macro.h>
|
|
#include <pulsecore/core-util.h>
|
|
#include <pulsecore/flist.h>
|
|
|
|
#include "thread-mq.h"
|
|
|
|
PA_STATIC_TLS_DECLARE_NO_FREE(thread_mq);
|
|
|
|
static void asyncmsgq_read_cb(pa_mainloop_api*api, pa_io_event* e, int fd, pa_io_event_flags_t events, void *userdata) {
|
|
pa_thread_mq *q = userdata;
|
|
pa_asyncmsgq *aq;
|
|
|
|
pa_assert(pa_asyncmsgq_read_fd(q->outq) == fd);
|
|
pa_assert(events == PA_IO_EVENT_INPUT);
|
|
|
|
pa_asyncmsgq_ref(aq = q->outq);
|
|
pa_asyncmsgq_write_after_poll(aq);
|
|
|
|
for (;;) {
|
|
pa_msgobject *object;
|
|
int code;
|
|
void *data;
|
|
int64_t offset;
|
|
pa_memchunk chunk;
|
|
|
|
/* Check whether there is a message for us to process */
|
|
while (pa_asyncmsgq_get(aq, &object, &code, &data, &offset, &chunk, 0) == 0) {
|
|
int ret;
|
|
|
|
ret = pa_asyncmsgq_dispatch(object, code, data, offset, &chunk);
|
|
pa_asyncmsgq_done(aq, ret);
|
|
}
|
|
|
|
if (pa_asyncmsgq_read_before_poll(aq) == 0)
|
|
break;
|
|
}
|
|
|
|
pa_asyncmsgq_unref(aq);
|
|
}
|
|
|
|
static void asyncmsgq_write_cb(pa_mainloop_api*api, pa_io_event* e, int fd, pa_io_event_flags_t events, void *userdata) {
|
|
pa_thread_mq *q = userdata;
|
|
|
|
pa_assert(pa_asyncmsgq_write_fd(q->inq) == fd);
|
|
pa_assert(events == PA_IO_EVENT_INPUT);
|
|
|
|
pa_asyncmsgq_write_after_poll(q->inq);
|
|
pa_asyncmsgq_write_before_poll(q->inq);
|
|
}
|
|
|
|
void pa_thread_mq_init(pa_thread_mq *q, pa_mainloop_api *mainloop, pa_rtpoll *rtpoll) {
|
|
pa_assert(q);
|
|
pa_assert(mainloop);
|
|
|
|
q->mainloop = mainloop;
|
|
pa_assert_se(q->inq = pa_asyncmsgq_new(0));
|
|
pa_assert_se(q->outq = pa_asyncmsgq_new(0));
|
|
|
|
pa_assert_se(pa_asyncmsgq_read_before_poll(q->outq) == 0);
|
|
pa_assert_se(q->read_event = mainloop->io_new(mainloop, pa_asyncmsgq_read_fd(q->outq), PA_IO_EVENT_INPUT, asyncmsgq_read_cb, q));
|
|
|
|
pa_asyncmsgq_write_before_poll(q->inq);
|
|
pa_assert_se(q->write_event = mainloop->io_new(mainloop, pa_asyncmsgq_write_fd(q->inq), PA_IO_EVENT_INPUT, asyncmsgq_write_cb, q));
|
|
|
|
pa_rtpoll_item_new_asyncmsgq_read(rtpoll, PA_RTPOLL_EARLY, q->inq);
|
|
pa_rtpoll_item_new_asyncmsgq_write(rtpoll, PA_RTPOLL_LATE, q->outq);
|
|
}
|
|
|
|
void pa_thread_mq_done(pa_thread_mq *q) {
|
|
pa_assert(q);
|
|
|
|
/* Since we are called from main context we can be sure that the
|
|
* inq is empty. However, the outq might still contain messages
|
|
* for the main loop, which we need to dispatch (e.g. release
|
|
* msgs, other stuff). Hence do so. */
|
|
|
|
pa_asyncmsgq_flush(q->outq, TRUE);
|
|
|
|
q->mainloop->io_free(q->read_event);
|
|
q->mainloop->io_free(q->write_event);
|
|
q->read_event = q->write_event = NULL;
|
|
|
|
pa_asyncmsgq_unref(q->inq);
|
|
pa_asyncmsgq_unref(q->outq);
|
|
q->inq = q->outq = NULL;
|
|
|
|
q->mainloop = NULL;
|
|
}
|
|
|
|
void pa_thread_mq_install(pa_thread_mq *q) {
|
|
pa_assert(q);
|
|
|
|
pa_assert(!(PA_STATIC_TLS_GET(thread_mq)));
|
|
PA_STATIC_TLS_SET(thread_mq, q);
|
|
}
|
|
|
|
pa_thread_mq *pa_thread_mq_get(void) {
|
|
return PA_STATIC_TLS_GET(thread_mq);
|
|
}
|