mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-04 13:29:59 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

asyncmsgq: add pa_asyncmsgq_flush() call

Browse source
This commit is contained in:
Lennart Poettering 2009-08-14 04:17:48 +02:00
parent a42c597f0a
commit 446fb2c9fe
2 changed files with 34 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

36
src/pulsecore/asyncmsgq.c
View file

@ -26,14 +26,16 @@
#include <unistd.h> #include <unistd.h>
#include <errno.h> #include <errno.h>
#include <pulse/xmalloc.h>
#include <pulsecore/atomic.h> #include <pulsecore/atomic.h>
#include <pulsecore/macro.h>
#include <pulsecore/log.h> #include <pulsecore/log.h>
#include <pulsecore/thread.h> #include <pulsecore/thread.h>
#include <pulsecore/semaphore.h> #include <pulsecore/semaphore.h>
#include <pulsecore/macro.h> #include <pulsecore/macro.h>
#include <pulsecore/core-util.h> #include <pulsecore/core-util.h>
#include <pulsecore/flist.h> #include <pulsecore/flist.h>
#include <pulse/xmalloc.h>
#include "asyncmsgq.h" #include "asyncmsgq.h"
@ -76,7 +78,7 @@ static void asyncmsgq_free(pa_asyncmsgq *a) {
struct asyncmsgq_item *i; struct asyncmsgq_item *i;
pa_assert(a); pa_assert(a);
while ((i = pa_asyncq_pop(a->asyncq, 0))) { while ((i = pa_asyncq_pop(a->asyncq, FALSE))) {
pa_assert(!i->semaphore); pa_assert(!i->semaphore);
@ -246,7 +248,7 @@ int pa_asyncmsgq_wait_for(pa_asyncmsgq *a, int code) {
pa_memchunk chunk; pa_memchunk chunk;
int ret; int ret;
if (pa_asyncmsgq_get(a, &o, &c, &data, &offset, &chunk, 1) < 0) if (pa_asyncmsgq_get(a, &o, &c, &data, &offset, &chunk, TRUE) < 0)
return -1; return -1;
ret = pa_asyncmsgq_dispatch(o, c, data, offset, &chunk); ret = pa_asyncmsgq_dispatch(o, c, data, offset, &chunk);
@ -269,7 +271,7 @@ int pa_asyncmsgq_process_one(pa_asyncmsgq *a) {
pa_assert(PA_REFCNT_VALUE(a) > 0); pa_assert(PA_REFCNT_VALUE(a) > 0);
if (pa_asyncmsgq_get(a, &object, &code, &data, &offset, &chunk, 0) < 0) if (pa_asyncmsgq_get(a, &object, &code, &data, &offset, &chunk, FALSE) < 0)
return 0; return 0;
pa_asyncmsgq_ref(a); pa_asyncmsgq_ref(a);
@ -323,3 +325,29 @@ int pa_asyncmsgq_dispatch(pa_msgobject *object, int code, void *userdata, int64_
return 0; return 0;
} }
void pa_asyncmsgq_flush(pa_asyncmsgq *a, pa_bool_t run) {
pa_assert(PA_REFCNT_VALUE(a) > 0);
for (;;) {
pa_msgobject *object;
int code;
void *data;
int64_t offset;
pa_memchunk chunk;
int ret;
if (pa_asyncmsgq_get(a, &object, &code, &data, &offset, &chunk, FALSE) < 0)
return;
if (!run) {
pa_asyncmsgq_done(a, -1);
continue;
}
pa_asyncmsgq_ref(a);
ret = pa_asyncmsgq_dispatch(object, code, data, offset, &chunk);
pa_asyncmsgq_done(a, ret);
pa_asyncmsgq_unref(a);
}
}

2
src/pulsecore/asyncmsgq.h
View file

@ -66,6 +66,8 @@ void pa_asyncmsgq_done(pa_asyncmsgq *q, int ret);
int pa_asyncmsgq_wait_for(pa_asyncmsgq *a, int code); int pa_asyncmsgq_wait_for(pa_asyncmsgq *a, int code);
int pa_asyncmsgq_process_one(pa_asyncmsgq *a); int pa_asyncmsgq_process_one(pa_asyncmsgq *a);
void pa_asyncmsgq_flush(pa_asyncmsgq *a, pa_bool_t run);
/* For the reading side */ /* For the reading side */
int pa_asyncmsgq_read_fd(pa_asyncmsgq *q); int pa_asyncmsgq_read_fd(pa_asyncmsgq *q);
int pa_asyncmsgq_read_before_poll(pa_asyncmsgq *a); int pa_asyncmsgq_read_before_poll(pa_asyncmsgq *a);