]>
code.delx.au - pulseaudio/blob - src/pulse/thread-mainloop.c
2 This file is part of PulseAudio.
4 Copyright 2006 Lennart Poettering
5 Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
7 PulseAudio is free software; you can redistribute it and/or modify
8 it under the terms of the GNU Lesser General Public License as published
9 by the Free Software Foundation; either version 2.1 of the License,
10 or (at your option) any later version.
12 PulseAudio is distributed in the hope that it will be useful, but
13 WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 General Public License for more details.
17 You should have received a copy of the GNU Lesser General Public License
18 along with PulseAudio; if not, write to the Free Software
19 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
37 #include <pulsecore/poll.h>
40 #include <pulse/xmalloc.h>
41 #include <pulse/mainloop.h>
42 #include <pulse/i18n.h>
44 #include <pulsecore/log.h>
45 #include <pulsecore/hashmap.h>
46 #include <pulsecore/thread.h>
47 #include <pulsecore/mutex.h>
48 #include <pulsecore/macro.h>
50 #include "thread-mainloop.h"
52 struct pa_threaded_mainloop
{
53 pa_mainloop
*real_mainloop
;
54 volatile int n_waiting
, n_waiting_for_accept
;
58 pa_cond
* cond
, *accept_cond
;
61 static inline int in_worker(pa_threaded_mainloop
*m
) {
62 return pa_thread_self() == m
->thread
;
65 static int poll_func(struct pollfd
*ufds
, unsigned long nfds
, int timeout
, void *userdata
) {
66 pa_mutex
*mutex
= userdata
;
71 /* Before entering poll() we unlock the mutex, so that
72 * avahi_simple_poll_quit() can succeed from another thread. */
74 pa_mutex_unlock(mutex
);
75 r
= poll(ufds
, nfds
, timeout
);
81 static void thread(void *userdata
) {
82 pa_threaded_mainloop
*m
= userdata
;
87 /* Make sure that signals are delivered to the main thread */
89 pthread_sigmask(SIG_BLOCK
, &mask
, NULL
);
92 pa_mutex_lock(m
->mutex
);
94 pa_mainloop_run(m
->real_mainloop
, NULL
);
96 pa_mutex_unlock(m
->mutex
);
99 pa_threaded_mainloop
*pa_threaded_mainloop_new(void) {
100 pa_threaded_mainloop
*m
;
104 m
= pa_xnew(pa_threaded_mainloop
, 1);
106 if (!(m
->real_mainloop
= pa_mainloop_new())) {
111 m
->mutex
= pa_mutex_new(TRUE
, TRUE
);
112 m
->cond
= pa_cond_new();
113 m
->accept_cond
= pa_cond_new();
116 pa_mainloop_set_poll_func(m
->real_mainloop
, poll_func
, m
->mutex
);
123 void pa_threaded_mainloop_free(pa_threaded_mainloop
* m
) {
126 /* Make sure that this function is not called from the helper thread */
127 pa_assert((m
->thread
&& !pa_thread_is_running(m
->thread
)) || !in_worker(m
));
129 pa_threaded_mainloop_stop(m
);
132 pa_thread_free(m
->thread
);
134 pa_mainloop_free(m
->real_mainloop
);
136 pa_mutex_free(m
->mutex
);
137 pa_cond_free(m
->cond
);
138 pa_cond_free(m
->accept_cond
);
143 int pa_threaded_mainloop_start(pa_threaded_mainloop
*m
) {
146 pa_assert(!m
->thread
|| !pa_thread_is_running(m
->thread
));
148 if (!(m
->thread
= pa_thread_new(thread
, m
)))
154 void pa_threaded_mainloop_stop(pa_threaded_mainloop
*m
) {
157 if (!m
->thread
|| !pa_thread_is_running(m
->thread
))
160 /* Make sure that this function is not called from the helper thread */
161 pa_assert(!in_worker(m
));
163 pa_mutex_lock(m
->mutex
);
164 pa_mainloop_quit(m
->real_mainloop
, 0);
165 pa_mutex_unlock(m
->mutex
);
167 pa_thread_join(m
->thread
);
170 void pa_threaded_mainloop_lock(pa_threaded_mainloop
*m
) {
173 /* Make sure that this function is not called from the helper thread */
174 pa_assert(!m
->thread
|| !pa_thread_is_running(m
->thread
) || !in_worker(m
));
176 pa_mutex_lock(m
->mutex
);
179 void pa_threaded_mainloop_unlock(pa_threaded_mainloop
*m
) {
182 /* Make sure that this function is not called from the helper thread */
183 pa_assert(!m
->thread
|| !pa_thread_is_running(m
->thread
) || !in_worker(m
));
185 pa_mutex_unlock(m
->mutex
);
188 /* Called with the lock taken */
189 void pa_threaded_mainloop_signal(pa_threaded_mainloop
*m
, int wait_for_accept
) {
192 pa_cond_signal(m
->cond
, 1);
194 if (wait_for_accept
) {
195 m
->n_waiting_for_accept
++;
197 while (m
->n_waiting_for_accept
> 0)
198 pa_cond_wait(m
->accept_cond
, m
->mutex
);
202 /* Called with the lock taken */
203 void pa_threaded_mainloop_wait(pa_threaded_mainloop
*m
) {
206 /* Make sure that this function is not called from the helper thread */
207 pa_assert(!m
->thread
|| !pa_thread_is_running(m
->thread
) || !in_worker(m
));
211 pa_cond_wait(m
->cond
, m
->mutex
);
213 pa_assert(m
->n_waiting
> 0);
217 /* Called with the lock taken */
218 void pa_threaded_mainloop_accept(pa_threaded_mainloop
*m
) {
221 /* Make sure that this function is not called from the helper thread */
222 pa_assert(!m
->thread
|| !pa_thread_is_running(m
->thread
) || !in_worker(m
));
224 pa_assert(m
->n_waiting_for_accept
> 0);
225 m
->n_waiting_for_accept
--;
227 pa_cond_signal(m
->accept_cond
, 0);
230 int pa_threaded_mainloop_get_retval(pa_threaded_mainloop
*m
) {
233 return pa_mainloop_get_retval(m
->real_mainloop
);
236 pa_mainloop_api
* pa_threaded_mainloop_get_api(pa_threaded_mainloop
*m
) {
239 return pa_mainloop_get_api(m
->real_mainloop
);
242 int pa_threaded_mainloop_in_thread(pa_threaded_mainloop
*m
) {
245 return m
->thread
&& pa_thread_self() == m
->thread
;