]>
code.delx.au - pulseaudio/blob - src/tests/asyncq-test.c
2 This file is part of PulseAudio.
4 PulseAudio is free software; you can redistribute it and/or modify
5 it under the terms of the GNU Lesser General Public License as published
6 by the Free Software Foundation; either version 2.1 of the License,
7 or (at your option) any later version.
9 PulseAudio is distributed in the hope that it will be useful, but
10 WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 General Public License for more details.
14 You should have received a copy of the GNU Lesser General Public License
15 along with PulseAudio; if not, write to the Free Software
16 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
28 #include <pulse/util.h>
29 #include <pulsecore/asyncq.h>
30 #include <pulsecore/thread.h>
31 #include <pulsecore/log.h>
32 #include <pulsecore/macro.h>
34 static void producer(void *_q
) {
38 for (i
= 0; i
< 1000; i
++) {
39 pa_log_debug("pushing %i", i
);
40 pa_asyncq_push(q
, PA_UINT_TO_PTR(i
+1), 1);
43 pa_asyncq_push(q
, PA_UINT_TO_PTR(-1), TRUE
);
44 pa_log_debug("pushed end");
47 static void consumer(void *_q
) {
55 p
= pa_asyncq_pop(q
, TRUE
);
57 if (p
== PA_UINT_TO_PTR(-1))
60 pa_assert(p
== PA_UINT_TO_PTR(i
+1));
62 pa_log_debug("popped %i", i
);
65 pa_log_debug("popped end");
68 int main(int argc
, char *argv
[]) {
72 if (!getenv("MAKE_CHECK"))
73 pa_log_set_level(PA_LOG_DEBUG
);
75 pa_assert_se(q
= pa_asyncq_new(0));
77 pa_assert_se(t1
= pa_thread_new("producer", producer
, q
));
78 pa_assert_se(t2
= pa_thread_new("consumer", consumer
, q
));
83 pa_asyncq_free(q
, NULL
);