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 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 void pa_threaded_mainloop_signal(pa_threaded_mainloop
*m
, int wait_for_accept
) {
191 pa_cond_signal(m
->cond
, 1);
193 if (wait_for_accept
) {
194 m
->n_waiting_for_accept
++;
196 while (m
->n_waiting_for_accept
> 0)
197 pa_cond_wait(m
->accept_cond
, m
->mutex
);
201 void pa_threaded_mainloop_wait(pa_threaded_mainloop
*m
) {
204 /* Make sure that this function is not called from the helper thread */
205 pa_assert(!m
->thread
|| !pa_thread_is_running(m
->thread
) || !in_worker(m
));
209 pa_cond_wait(m
->cond
, m
->mutex
);
211 pa_assert(m
->n_waiting
> 0);
215 void pa_threaded_mainloop_accept(pa_threaded_mainloop
*m
) {
218 /* Make sure that this function is not called from the helper thread */
219 pa_assert(!m
->thread
|| !pa_thread_is_running(m
->thread
) || !in_worker(m
));
221 pa_assert(m
->n_waiting_for_accept
> 0);
222 m
->n_waiting_for_accept
--;
224 pa_cond_signal(m
->accept_cond
, 0);
227 int pa_threaded_mainloop_get_retval(pa_threaded_mainloop
*m
) {
230 return pa_mainloop_get_retval(m
->real_mainloop
);
233 pa_mainloop_api
* pa_threaded_mainloop_get_api(pa_threaded_mainloop
*m
) {
236 return pa_mainloop_get_api(m
->real_mainloop
);
239 int pa_threaded_mainloop_in_thread(pa_threaded_mainloop
*m
) {
242 return m
->thread
&& pa_thread_self() == m
->thread
;