4 This file is part of PulseAudio.
6 PulseAudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as published
8 by the Free Software Foundation; either version 2 of the License,
9 or (at your option) any later version.
11 PulseAudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public License
17 along with PulseAudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
30 #include <pulse/xmalloc.h>
31 #include <pulsecore/log.h>
37 pa_thread_func_t thread_func
;
43 pa_free_cb_t free_func
;
46 struct pa_tls_monitor
{
48 pa_free_cb_t free_func
;
52 static pa_tls
*thread_tls
;
53 static pa_thread_once_t thread_tls_once
= PA_THREAD_ONCE_INIT
;
54 static pa_tls
*monitor_tls
;
55 static pa_thread_once_t monitor_tls_once
= PA_THREAD_ONCE_INIT
;
57 static void thread_tls_once_func(void) {
58 thread_tls
= pa_tls_new(NULL
);
62 static DWORD WINAPI
internal_thread_func(LPVOID param
) {
66 pa_thread_once(&thread_tls_once
, thread_tls_once_func
);
67 pa_tls_set(thread_tls
, t
);
69 t
->thread_func(t
->userdata
);
74 pa_thread
* pa_thread_new(pa_thread_func_t thread_func
, void *userdata
) {
79 t
= pa_xnew(pa_thread
, 1);
80 t
->thread_func
= thread_func
;
81 t
->userdata
= userdata
;
83 t
->thread
= CreateThread(NULL
, 0, internal_thread_func
, t
, 0, NULL
);
93 int pa_thread_is_running(pa_thread
*t
) {
98 if (!GetExitCodeThread(t
->thread
, &code
))
101 return code
== STILL_ACTIVE
;
104 void pa_thread_free(pa_thread
*t
) {
108 CloseHandle(t
->thread
);
112 int pa_thread_join(pa_thread
*t
) {
115 if (WaitForSingleObject(t
->thread
, INFINITE
) == WAIT_FAILED
)
121 pa_thread
* pa_thread_self(void) {
122 pa_thread_once(&thread_tls_once
, thread_tls_once_func
);
123 return pa_tls_get(thread_tls
);
126 void pa_thread_yield(void) {
130 void pa_thread_once(pa_thread_once_t
*control
, pa_thread_once_func_t once_func
) {
137 sprintf(name
, "pulse%d", (int)GetCurrentProcessId());
139 mutex
= CreateMutex(NULL
, FALSE
, name
);
142 WaitForSingleObject(mutex
, INFINITE
);
144 if (*control
== PA_THREAD_ONCE_INIT
) {
145 *control
= ~PA_THREAD_ONCE_INIT
;
154 static void monitor_tls_once_func(void) {
155 monitor_tls
= pa_tls_new(NULL
);
157 pa_tls_set(monitor_tls
, NULL
);
160 static DWORD WINAPI
monitor_thread_func(LPVOID param
) {
161 struct pa_tls_monitor
*m
= param
;
164 WaitForSingleObject(m
->thread
, INFINITE
);
166 CloseHandle(m
->thread
);
168 m
->free_func(m
->data
);
175 pa_tls
* pa_tls_new(pa_free_cb_t free_cb
) {
178 t
= pa_xnew(pa_tls
, 1);
179 t
->index
= TlsAlloc();
180 t
->free_func
= free_cb
;
182 if (t
->index
== TLS_OUT_OF_INDEXES
) {
190 void pa_tls_free(pa_tls
*t
) {
197 void *pa_tls_get(pa_tls
*t
) {
200 return TlsGetValue(t
->index
);
203 void *pa_tls_set(pa_tls
*t
, void *userdata
) {
208 r
= TlsGetValue(t
->index
);
210 TlsSetValue(t
->index
, userdata
);
213 struct pa_tls_monitor
*m
;
215 pa_thread_once(&monitor_tls_once
, monitor_tls_once_func
);
217 m
= pa_tls_get(monitor_tls
);
221 m
= pa_xnew(struct pa_tls_monitor
, 1);
223 DuplicateHandle(GetCurrentProcess(), GetCurrentThread(),
224 GetCurrentProcess(), &m
->thread
, 0, FALSE
,
225 DUPLICATE_SAME_ACCESS
);
227 m
->free_func
= t
->free_func
;
229 pa_tls_set(monitor_tls
, m
);
231 thread
= CreateThread(NULL
, 0, monitor_thread_func
, m
, 0, NULL
);