#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_assert(events == PA_IO_EVENT_INPUT);
pa_asyncmsgq_ref(aq = q->outq);
- pa_asyncmsgq_write_after_poll(aq);
+ pa_asyncmsgq_read_after_poll(aq);
for (;;) {
pa_msgobject *object;
* dispatching anyway. */
if (!pa_asyncmsgq_dispatching(q->outq))
- pa_asyncmsgq_flush(q->outq, TRUE);
+ pa_asyncmsgq_flush(q->outq, true);
q->mainloop->io_free(q->read_event);
q->mainloop->io_free(q->write_event);