mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-12 13:30:10 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Rework core-error.c on top of PA_STATIC_TLS_DECLARE, the windows specific parts need to be moved to thread-win32.c

Browse source 
git-svn-id: file:///home/lennart/svn/public/pulseaudio/branches/lennart@1808 fefdeb5f-60dc-0310-8127-8f9354f1896f
This commit is contained in:
Lennart Poettering 2007-09-11 15:27:32 +00:00
parent abb18d9c4c
commit 2988c3d9fb
1 changed files with 26 additions and 154 deletions
Download patch file Download diff file Expand all files Collapse all files

178
src/pulsecore/core-error.c
View file

@ -31,178 +31,50 @@
#include <stdlib.h> #include <stdlib.h>
#include <string.h> #include <string.h>
#ifdef HAVE_PTHREAD
#include <pthread.h>
#endif
#ifdef HAVE_WINDOWS_H
#include <windows.h>
#endif
#include <pulse/utf8.h> #include <pulse/utf8.h>
#include <pulse/xmalloc.h> #include <pulse/xmalloc.h>
#include <pulsecore/core-util.h> #include <pulsecore/core-util.h>
#include <pulsecore/native-common.h> #include <pulsecore/native-common.h>
#include <pulsecore/thread.h>
#include <pulsecore/macro.h>
#include <pulsecore/log.h>
#include "core-error.h" #include "core-error.h"
#ifdef HAVE_PTHREAD PA_STATIC_TLS_DECLARE(cstrerror, pa_xfree);
static pthread_once_t cstrerror_once = PTHREAD_ONCE_INIT;
static pthread_key_t tlsstr_key;
static void inittls(void) {
int ret;
ret = pthread_key_create(&tlsstr_key, pa_xfree);
if (ret) {
fprintf(stderr, __FILE__ ": CRITICAL: Unable to allocate TLS key (%d)\n", errno);
exit(-1);
}
}
#elif HAVE_WINDOWS_H
static DWORD tlsstr_key = TLS_OUT_OF_INDEXES;
static DWORD monitor_key = TLS_OUT_OF_INDEXES;
static void inittls(void) {
HANDLE mutex;
char name[64];
sprintf(name, "pulse%d", (int)GetCurrentProcessId());
mutex = CreateMutex(NULL, FALSE, name);
if (!mutex) {
fprintf(stderr, __FILE__ ": CRITICAL: Unable to create named mutex (%d)\n", (int)GetLastError());
exit(-1);
}
WaitForSingleObject(mutex, INFINITE);
if (tlsstr_key == TLS_OUT_OF_INDEXES) {
tlsstr_key = TlsAlloc();
monitor_key = TlsAlloc();
if ((tlsstr_key == TLS_OUT_OF_INDEXES) || (monitor_key == TLS_OUT_OF_INDEXES)) {
fprintf(stderr, __FILE__ ": CRITICAL: Unable to allocate TLS key (%d)\n", (int)GetLastError());
exit(-1);
}
}
ReleaseMutex(mutex);
CloseHandle(mutex);
}
/*
* This is incredibly brain dead, but this is necessary when dealing with
* the hell that is Win32.
*/
struct monitor_data {
HANDLE thread;
void *data;
};
static DWORD WINAPI monitor_thread(LPVOID param) {
struct monitor_data *data;
data = (struct monitor_data*)param;
assert(data);
WaitForSingleObject(data->thread, INFINITE);
CloseHandle(data->thread);
pa_xfree(data->data);
pa_xfree(data);
return 0;
}
static void start_monitor(void) {
HANDLE thread;
struct monitor_data *data;
data = pa_xnew(struct monitor_data, 1);
assert(data);
DuplicateHandle(GetCurrentProcess(), GetCurrentThread(),
GetCurrentProcess(), &data->thread, 0, FALSE, DUPLICATE_SAME_ACCESS);
thread = CreateThread(NULL, 0, monitor_thread, data, 0, NULL);
assert(thread);
TlsSetValue(monitor_key, data);
CloseHandle(thread);
}
#else
/* Unsafe, but we have no choice */
static char *tlsstr;
#endif
const char* pa_cstrerror(int errnum) { const char* pa_cstrerror(int errnum) {
const char *origbuf; const char *original = NULL;
char *translated, *t;
#ifdef HAVE_STRERROR_R
char errbuf[128]; char errbuf[128];
#endif
#ifdef HAVE_PTHREAD if ((t = PA_STATIC_TLS_GET(cstrerror)))
char *tlsstr; pa_xfree(t);
pthread_once(&cstrerror_once, inittls); #if defined(HAVE_STRERROR_R) && defined(__GLIBC__)
original = strerror_r(errnum, errbuf, sizeof(errbuf));
tlsstr = pthread_getspecific(tlsstr_key); #elif defined(HAVE_STRERROR_R)
#elif defined(HAVE_WINDOWS_H)
char *tlsstr;
struct monitor_data *data;
inittls();
tlsstr = TlsGetValue(tlsstr_key);
if (!tlsstr)
start_monitor();
data = TlsGetValue(monitor_key);
#endif
if (tlsstr)
pa_xfree(tlsstr);
#ifdef HAVE_STRERROR_R
#ifdef __GLIBC__
origbuf = strerror_r(errnum, errbuf, sizeof(errbuf));
if (origbuf == NULL)
origbuf = "";
#else
if (strerror_r(errnum, errbuf, sizeof(errbuf)) == 0) { if (strerror_r(errnum, errbuf, sizeof(errbuf)) == 0) {
origbuf = errbuf; errbuf[sizeof(errbuf) - 1] = 0;
errbuf[sizeof(errbuf) - 1] = '\0'; original = errbuf;
} else }
origbuf = "";
#endif
#else #else
/* This might not be thread safe, but we hope for the best */ /* This might not be thread safe, but we hope for the best */
origbuf = strerror(errnum); original = strerror(errnum);
#endif #endif
tlsstr = pa_locale_to_utf8(origbuf); if (!original) {
if (!tlsstr) { pa_snprintf(errbuf, sizeof(errbuf), "Unknown error %i", errnum);
fprintf(stderr, "Unable to convert, filtering\n"); original = errbuf;
tlsstr = pa_utf8_filter(origbuf);
} }
#ifdef HAVE_PTHREAD if (!(translated = pa_locale_to_utf8(original))) {
pthread_setspecific(tlsstr_key, tlsstr); pa_log_warn("Unable to convert error string to locale, filtering.");
#elif defined(HAVE_WINDOWS_H) translated = pa_utf8_filter(original);
TlsSetValue(tlsstr_key, tlsstr); }
data->data = tlsstr;
#endif
return tlsstr; PA_STATIC_TLS_SET(cstrerror, translated);
return translated;
} }