diff options
author | Lennart Poettering <lennart@poettering.net> | 2007-09-14 21:51:05 +0000 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2007-09-14 21:51:05 +0000 |
commit | 3396b65f15a06ff312e318bc05e502ba402c564e (patch) | |
tree | 5087148cbe36f765f9fff99528d812c198799c63 /src/pulsecore/thread-mq.c | |
parent | f0b9dce32e4c5d77f57364ccdc7795f828f7f6a0 (diff) |
simplify rt loops a bit by moving more code into pa_rtpoll. It is now possible to attach "work" functions to a pa_rtpoll_item, which will be called in each loop iteration. This allows us to hide the message processing in the RT loops and to drop the seperate sink_input->process hooks. Basically, only the driver-specific code remains in the RT loops.
git-svn-id: file:///home/lennart/svn/public/pulseaudio/branches/lennart@1822 fefdeb5f-60dc-0310-8127-8f9354f1896f
Diffstat (limited to 'src/pulsecore/thread-mq.c')
-rw-r--r-- | src/pulsecore/thread-mq.c | 25 |
1 files changed, 0 insertions, 25 deletions
diff --git a/src/pulsecore/thread-mq.c b/src/pulsecore/thread-mq.c index 3000246a..d572f6e0 100644 --- a/src/pulsecore/thread-mq.c +++ b/src/pulsecore/thread-mq.c @@ -110,28 +110,3 @@ void pa_thread_mq_install(pa_thread_mq *q) { pa_thread_mq *pa_thread_mq_get(void) { return PA_STATIC_TLS_GET(thread_mq); } - -int pa_thread_mq_process(pa_thread_mq *q) { - pa_msgobject *object; - int code; - void *data; - pa_memchunk chunk; - int64_t offset; - - pa_assert(q); - - if (pa_asyncmsgq_get(q->inq, &object, &code, &data, &offset, &chunk, 0) == 0) { - int ret; - - if (!object && code == PA_MESSAGE_SHUTDOWN) { - pa_asyncmsgq_done(q->inq, 0); - return -1; - } - - ret = pa_asyncmsgq_dispatch(object, code, data, offset, &chunk); - pa_asyncmsgq_done(q->inq, ret); - return 1; - } - - return 0; -} |