mirror of
https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git
synced 2025-10-29 05:40:23 -04:00
* split pa_cstrerror() into its own file polypcore/core-error.[ch]
* fix building of padsp * remove a warning when compiling padsp.c git-svn-id: file:///home/lennart/svn/public/pulseaudio/trunk@972 fefdeb5f-60dc-0310-8127-8f9354f1896f
This commit is contained in:
parent
f8aa55c5ac
commit
4413b89d7a
49 changed files with 324 additions and 255 deletions
2
doc/todo
2
doc/todo
|
|
@ -2,8 +2,6 @@
|
|||
|
||||
Pre 0.9.0
|
||||
- add API to query the bufferattrs after stream creation
|
||||
- add proper padsp script that makes $PADSP_xxx env vars from the command line arguments, just like esddsp does
|
||||
- move pa_cstrerror() to polypcore/core-error.h
|
||||
|
||||
Post 0.9.0:
|
||||
- alsa mmap driver
|
||||
|
|
|
|||
|
|
@ -402,6 +402,7 @@ libpolyp_la_SOURCES += \
|
|||
polypcore/strbuf.c polypcore/strbuf.h \
|
||||
polypcore/strlist.c polypcore/strlist.h \
|
||||
polypcore/tagstruct.c polypcore/tagstruct.h \
|
||||
polypcore/core-error.c polypcore/core-error.h \
|
||||
polypcore/winsock.h
|
||||
|
||||
if OS_IS_WIN32
|
||||
|
|
@ -574,7 +575,8 @@ libpolypcore_la_SOURCES += \
|
|||
polypcore/source-output.c polypcore/source-output.h \
|
||||
polypcore/strbuf.c polypcore/strbuf.h \
|
||||
polypcore/tokenizer.c polypcore/tokenizer.h \
|
||||
polypcore/winsock.h
|
||||
polypcore/winsock.h \
|
||||
polypcore/core-error.c polypcore/core-error.h
|
||||
|
||||
if OS_IS_WIN32
|
||||
libpolypcore_la_SOURCES += \
|
||||
|
|
@ -1186,3 +1188,5 @@ install-exec-hook:
|
|||
chmod u+s $(DESTDIR)$(bindir)/polypaudio
|
||||
ln -sf pacat $(DESTDIR)$(bindir)/parec
|
||||
rm -f $(DESTDIR)$(modlibexecdir)/*.a
|
||||
|
||||
.PHONY: utils/padsp
|
||||
|
|
|
|||
|
|
@ -32,7 +32,7 @@
|
|||
#include <sys/capability.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polypcore/core-error.h>
|
||||
|
||||
#include <polypcore/log.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,9 @@
|
|||
#include <assert.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/strbuf.h>
|
||||
#include <polypcore/conf-parser.h>
|
||||
|
|
|
|||
|
|
@ -50,11 +50,11 @@
|
|||
|
||||
#include "../polypcore/winsock.h"
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/mainloop.h>
|
||||
#include <polyp/mainloop-signal.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core.h>
|
||||
#include <polypcore/memblock.h>
|
||||
#include <polypcore/module.h>
|
||||
|
|
|
|||
|
|
@ -34,9 +34,9 @@
|
|||
|
||||
#include <asoundlib.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/memchunk.h>
|
||||
|
|
|
|||
|
|
@ -33,9 +33,9 @@
|
|||
#include <sys/types.h>
|
||||
#include <sys/stat.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/modargs.h>
|
||||
#include <polypcore/log.h>
|
||||
|
|
|
|||
|
|
@ -28,8 +28,7 @@
|
|||
#include <string.h>
|
||||
#include <errno.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/modargs.h>
|
||||
#include <polypcore/core-util.h>
|
||||
|
|
|
|||
|
|
@ -28,8 +28,7 @@
|
|||
#include <errno.h>
|
||||
#include <signal.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/modargs.h>
|
||||
|
|
|
|||
|
|
@ -33,9 +33,9 @@
|
|||
#include <unistd.h>
|
||||
#include <limits.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/iochannel.h>
|
||||
#include <polypcore/sink.h>
|
||||
#include <polypcore/module.h>
|
||||
|
|
|
|||
|
|
@ -36,9 +36,9 @@
|
|||
|
||||
#include <jack/jack.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/iochannel.h>
|
||||
#include <polypcore/sink.h>
|
||||
#include <polypcore/module.h>
|
||||
|
|
|
|||
|
|
@ -36,9 +36,9 @@
|
|||
|
||||
#include <jack/jack.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/iochannel.h>
|
||||
#include <polypcore/source.h>
|
||||
#include <polypcore/module.h>
|
||||
|
|
|
|||
|
|
@ -32,9 +32,9 @@
|
|||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/modargs.h>
|
||||
|
|
|
|||
|
|
@ -33,9 +33,9 @@
|
|||
|
||||
#include <linux/input.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/namereg.h>
|
||||
|
|
|
|||
|
|
@ -36,9 +36,9 @@
|
|||
#include <limits.h>
|
||||
#include <sys/mman.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/iochannel.h>
|
||||
#include <polypcore/sink.h>
|
||||
#include <polypcore/source.h>
|
||||
|
|
|
|||
|
|
@ -35,9 +35,9 @@
|
|||
#include <unistd.h>
|
||||
#include <limits.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/iochannel.h>
|
||||
#include <polypcore/sink.h>
|
||||
#include <polypcore/source.h>
|
||||
|
|
|
|||
|
|
@ -33,9 +33,9 @@
|
|||
#include <unistd.h>
|
||||
#include <limits.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/iochannel.h>
|
||||
#include <polypcore/sink.h>
|
||||
#include <polypcore/module.h>
|
||||
|
|
|
|||
|
|
@ -33,9 +33,9 @@
|
|||
#include <unistd.h>
|
||||
#include <limits.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/iochannel.h>
|
||||
#include <polypcore/source.h>
|
||||
#include <polypcore/module.h>
|
||||
|
|
|
|||
|
|
@ -42,9 +42,9 @@
|
|||
|
||||
#include "../polypcore/winsock.h"
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/socket-server.h>
|
||||
#include <polypcore/socket-util.h>
|
||||
|
|
|
|||
|
|
@ -32,9 +32,9 @@
|
|||
#include <stdlib.h>
|
||||
#include <ctype.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/modargs.h>
|
||||
|
|
|
|||
|
|
@ -34,8 +34,7 @@
|
|||
#include <sys/stat.h>
|
||||
#include <fcntl.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -31,10 +31,10 @@
|
|||
#include <string.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/timeval.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/llist.h>
|
||||
#include <polypcore/sink.h>
|
||||
|
|
|
|||
|
|
@ -32,11 +32,11 @@
|
|||
#include <string.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/timeval.h>
|
||||
#include <polyp/util.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/module.h>
|
||||
#include <polypcore/llist.h>
|
||||
#include <polypcore/source.h>
|
||||
|
|
|
|||
|
|
@ -36,8 +36,7 @@
|
|||
#include <sys/filio.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/error.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/log.h>
|
||||
|
||||
#include "rtp.h"
|
||||
|
|
|
|||
|
|
@ -38,9 +38,9 @@
|
|||
#include <sys/filio.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -29,7 +29,7 @@
|
|||
#include <errno.h>
|
||||
#include <string.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/log.h>
|
||||
|
|
|
|||
|
|
@ -47,7 +47,7 @@
|
|||
|
||||
#include "../polypcore/winsock.h"
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polyp/version.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -28,15 +28,6 @@
|
|||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
#include <pthread.h>
|
||||
#endif
|
||||
|
||||
#ifdef HAVE_WINDOWS_H
|
||||
#include <windows.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/utf8.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-util.h>
|
||||
|
|
@ -44,191 +35,32 @@
|
|||
|
||||
#include "error.h"
|
||||
|
||||
static const char* const errortab[PA_ERR_MAX] = {
|
||||
[PA_OK] = "OK",
|
||||
[PA_ERR_ACCESS] = "Access denied",
|
||||
[PA_ERR_COMMAND] = "Unknown command",
|
||||
[PA_ERR_INVALID] = "Invalid argument",
|
||||
[PA_ERR_EXIST] = "Entity exists",
|
||||
[PA_ERR_NOENTITY] = "No such entity",
|
||||
[PA_ERR_CONNECTIONREFUSED] = "Connection refused",
|
||||
[PA_ERR_PROTOCOL] = "Protocol error",
|
||||
[PA_ERR_TIMEOUT] = "Timeout",
|
||||
[PA_ERR_AUTHKEY] = "No authorization key",
|
||||
[PA_ERR_INTERNAL] = "Internal error",
|
||||
[PA_ERR_CONNECTIONTERMINATED] = "Connection terminated",
|
||||
[PA_ERR_KILLED] = "Entity killed",
|
||||
[PA_ERR_INVALIDSERVER] = "Invalid server",
|
||||
[PA_ERR_MODINITFAILED] = "Module initalization failed",
|
||||
[PA_ERR_BADSTATE] = "Bad state",
|
||||
[PA_ERR_NODATA] = "No data",
|
||||
[PA_ERR_VERSION] = "Incompatible protocol version",
|
||||
[PA_ERR_TOOLARGE] = "Too large"
|
||||
};
|
||||
|
||||
const char*pa_strerror(int error) {
|
||||
|
||||
static const char* const errortab[PA_ERR_MAX] = {
|
||||
[PA_OK] = "OK",
|
||||
[PA_ERR_ACCESS] = "Access denied",
|
||||
[PA_ERR_COMMAND] = "Unknown command",
|
||||
[PA_ERR_INVALID] = "Invalid argument",
|
||||
[PA_ERR_EXIST] = "Entity exists",
|
||||
[PA_ERR_NOENTITY] = "No such entity",
|
||||
[PA_ERR_CONNECTIONREFUSED] = "Connection refused",
|
||||
[PA_ERR_PROTOCOL] = "Protocol error",
|
||||
[PA_ERR_TIMEOUT] = "Timeout",
|
||||
[PA_ERR_AUTHKEY] = "No authorization key",
|
||||
[PA_ERR_INTERNAL] = "Internal error",
|
||||
[PA_ERR_CONNECTIONTERMINATED] = "Connection terminated",
|
||||
[PA_ERR_KILLED] = "Entity killed",
|
||||
[PA_ERR_INVALIDSERVER] = "Invalid server",
|
||||
[PA_ERR_MODINITFAILED] = "Module initalization failed",
|
||||
[PA_ERR_BADSTATE] = "Bad state",
|
||||
[PA_ERR_NODATA] = "No data",
|
||||
[PA_ERR_VERSION] = "Incompatible protocol version",
|
||||
[PA_ERR_TOOLARGE] = "Too large"
|
||||
};
|
||||
|
||||
if (error < 0 || error >= PA_ERR_MAX)
|
||||
return NULL;
|
||||
|
||||
return errortab[error];
|
||||
}
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
|
||||
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, "polypaudio%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 *origbuf;
|
||||
|
||||
#ifdef HAVE_STRERROR_R
|
||||
char errbuf[128];
|
||||
#endif
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
char *tlsstr;
|
||||
|
||||
pthread_once(&cstrerror_once, inittls);
|
||||
|
||||
tlsstr = pthread_getspecific(tlsstr_key);
|
||||
#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) {
|
||||
origbuf = errbuf;
|
||||
errbuf[sizeof(errbuf) - 1] = '\0';
|
||||
} else
|
||||
origbuf = "";
|
||||
#endif
|
||||
|
||||
#else
|
||||
/* This might not be thread safe, but we hope for the best */
|
||||
origbuf = strerror(errnum);
|
||||
#endif
|
||||
|
||||
tlsstr = pa_locale_to_utf8(origbuf);
|
||||
if (!tlsstr) {
|
||||
fprintf(stderr, "Unable to convert, filtering\n");
|
||||
tlsstr = pa_utf8_filter(origbuf);
|
||||
}
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
pthread_setspecific(tlsstr_key, tlsstr);
|
||||
#elif defined(HAVE_WINDOWS_H)
|
||||
TlsSetValue(tlsstr_key, tlsstr);
|
||||
data->data = tlsstr;
|
||||
#endif
|
||||
|
||||
return tlsstr;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -33,12 +33,6 @@ PA_C_DECL_BEGIN
|
|||
/** Return a human readable error message for the specified numeric error code */
|
||||
const char* pa_strerror(int error);
|
||||
|
||||
/** A wrapper around the standard strerror() function that converts the
|
||||
* string to UTF-8. The function is thread safe but the returned string is
|
||||
* only guaranteed to exist until the thread exits or pa_cstrerror() is
|
||||
* called again from the same thread. */
|
||||
const char* pa_cstrerror(int errnum);
|
||||
|
||||
PA_C_DECL_END
|
||||
|
||||
#endif
|
||||
|
|
|
|||
|
|
@ -36,7 +36,7 @@
|
|||
#include <windows.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-util.h>
|
||||
|
|
|
|||
|
|
@ -44,7 +44,7 @@
|
|||
#include "../polypcore/pipe.h"
|
||||
#endif
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polyp/timeval.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -51,8 +51,7 @@
|
|||
|
||||
#include "../polypcore/winsock.h"
|
||||
|
||||
#include <polyp/error.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/core-util.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -35,8 +35,8 @@
|
|||
#include <limits.h>
|
||||
#include <sys/stat.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/util.h>
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/random.h>
|
||||
|
|
|
|||
|
|
@ -29,7 +29,6 @@
|
|||
#include <stdlib.h>
|
||||
#include <errno.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/module.h>
|
||||
|
|
@ -50,6 +49,7 @@
|
|||
#include <polypcore/sound-file-stream.h>
|
||||
#include <polypcore/props.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/core-error.h>
|
||||
|
||||
#include "cli-command.h"
|
||||
|
||||
|
|
|
|||
|
|
@ -28,9 +28,9 @@
|
|||
#include <stdio.h>
|
||||
#include <errno.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/core-util.h>
|
||||
|
||||
|
|
|
|||
205
src/polypcore/core-error.c
Normal file
205
src/polypcore/core-error.c
Normal file
|
|
@ -0,0 +1,205 @@
|
|||
/* $Id$ */
|
||||
|
||||
/***
|
||||
This file is part of polypaudio.
|
||||
|
||||
polypaudio is free software; you can redistribute it and/or modify
|
||||
it under the terms of the GNU Lesser General Public License as published
|
||||
by the Free Software Foundation; either version 2 of the License,
|
||||
or (at your option) any later version.
|
||||
|
||||
polypaudio is distributed in the hope that it will be useful, but
|
||||
WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU Lesser General Public License
|
||||
along with polypaudio; if not, write to the Free Software
|
||||
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
|
||||
USA.
|
||||
***/
|
||||
|
||||
#ifdef HAVE_CONFIG_H
|
||||
#include <config.h>
|
||||
#endif
|
||||
|
||||
#include <errno.h>
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
#include <pthread.h>
|
||||
#endif
|
||||
|
||||
#ifdef HAVE_WINDOWS_H
|
||||
#include <windows.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/utf8.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/native-common.h>
|
||||
|
||||
#include "core-error.h"
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
|
||||
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, "polypaudio%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 *origbuf;
|
||||
|
||||
#ifdef HAVE_STRERROR_R
|
||||
char errbuf[128];
|
||||
#endif
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
char *tlsstr;
|
||||
|
||||
pthread_once(&cstrerror_once, inittls);
|
||||
|
||||
tlsstr = pthread_getspecific(tlsstr_key);
|
||||
#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) {
|
||||
origbuf = errbuf;
|
||||
errbuf[sizeof(errbuf) - 1] = '\0';
|
||||
} else
|
||||
origbuf = "";
|
||||
#endif
|
||||
|
||||
#else
|
||||
/* This might not be thread safe, but we hope for the best */
|
||||
origbuf = strerror(errnum);
|
||||
#endif
|
||||
|
||||
tlsstr = pa_locale_to_utf8(origbuf);
|
||||
if (!tlsstr) {
|
||||
fprintf(stderr, "Unable to convert, filtering\n");
|
||||
tlsstr = pa_utf8_filter(origbuf);
|
||||
}
|
||||
|
||||
#ifdef HAVE_PTHREAD
|
||||
pthread_setspecific(tlsstr_key, tlsstr);
|
||||
#elif defined(HAVE_WINDOWS_H)
|
||||
TlsSetValue(tlsstr_key, tlsstr);
|
||||
data->data = tlsstr;
|
||||
#endif
|
||||
|
||||
return tlsstr;
|
||||
}
|
||||
41
src/polypcore/core-error.h
Normal file
41
src/polypcore/core-error.h
Normal file
|
|
@ -0,0 +1,41 @@
|
|||
#ifndef foocoreerrorhfoo
|
||||
#define foocoreerrorhfoo
|
||||
|
||||
/* $Id$ */
|
||||
|
||||
/***
|
||||
This file is part of polypaudio.
|
||||
|
||||
polypaudio is free software; you can redistribute it and/or modify
|
||||
it under the terms of the GNU Lesser General Public License as published
|
||||
by the Free Software Foundation; either version 2 of the License,
|
||||
or (at your option) any later version.
|
||||
|
||||
polypaudio is distributed in the hope that it will be useful, but
|
||||
WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU Lesser General Public License
|
||||
along with polypaudio; if not, write to the Free Software
|
||||
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
|
||||
USA.
|
||||
***/
|
||||
|
||||
#include <inttypes.h>
|
||||
#include <polyp/cdecl.h>
|
||||
|
||||
/** \file
|
||||
* Error management */
|
||||
|
||||
PA_C_DECL_BEGIN
|
||||
|
||||
/** A wrapper around the standard strerror() function that converts the
|
||||
* string to UTF-8. The function is thread safe but the returned string is
|
||||
* only guaranteed to exist until the thread exits or pa_cstrerror() is
|
||||
* called again from the same thread. */
|
||||
const char* pa_cstrerror(int errnum);
|
||||
|
||||
PA_C_DECL_END
|
||||
|
||||
#endif
|
||||
|
|
@ -41,7 +41,6 @@
|
|||
#include <windows.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/mainloop.h>
|
||||
#include <polyp/channelmap.h>
|
||||
#include <polyp/timeval.h>
|
||||
|
|
@ -57,6 +56,7 @@
|
|||
#include <polypcore/sound-file.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/core-error.h>
|
||||
|
||||
#include "core-scache.h"
|
||||
|
||||
|
|
|
|||
|
|
@ -69,10 +69,10 @@
|
|||
|
||||
#include <samplerate.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
#include <polyp/util.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/winsock.h>
|
||||
#include <polypcore/log.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -38,9 +38,9 @@
|
|||
|
||||
#include "winsock.h"
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/socket-util.h>
|
||||
#include <polypcore/log.h>
|
||||
|
|
|
|||
|
|
@ -29,9 +29,9 @@
|
|||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/log.h>
|
||||
|
||||
#include "ioline.h"
|
||||
|
|
|
|||
|
|
@ -39,9 +39,9 @@
|
|||
#include <windows.h>
|
||||
#endif
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -30,7 +30,6 @@
|
|||
#include <stdlib.h>
|
||||
#include <limits.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/sample.h>
|
||||
#include <polyp/timeval.h>
|
||||
#include <polyp/utf8.h>
|
||||
|
|
@ -49,6 +48,7 @@
|
|||
#include <polypcore/namereg.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/core-error.h>
|
||||
|
||||
#include "endianmacros.h"
|
||||
|
||||
|
|
|
|||
|
|
@ -30,7 +30,6 @@
|
|||
#include <errno.h>
|
||||
#include <string.h>
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/sink-input.h>
|
||||
|
|
@ -39,6 +38,7 @@
|
|||
#include <polypcore/sample-util.h>
|
||||
#include <polypcore/namereg.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/core-error.h>
|
||||
|
||||
#include "protocol-simple.h"
|
||||
|
||||
|
|
|
|||
|
|
@ -54,10 +54,10 @@
|
|||
|
||||
#include "winsock.h"
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/timeval.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/socket-util.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
|
|
|
|||
|
|
@ -64,11 +64,11 @@
|
|||
|
||||
#include <polyp/xmalloc.h>
|
||||
#include <polyp/util.h>
|
||||
#include <polyp/error.h>
|
||||
|
||||
#include <polypcore/socket-util.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
#include <polypcore/core-error.h>
|
||||
|
||||
#include "socket-server.h"
|
||||
|
||||
|
|
|
|||
|
|
@ -59,9 +59,9 @@
|
|||
|
||||
#include "winsock.h"
|
||||
|
||||
#include <polyp/error.h>
|
||||
#include <polyp/xmalloc.h>
|
||||
|
||||
#include <polypcore/core-error.h>
|
||||
#include <polypcore/core-util.h>
|
||||
#include <polypcore/log.h>
|
||||
|
||||
|
|
|
|||
|
|
@ -54,7 +54,7 @@ int main(PA_GCC_UNUSED int argc, PA_GCC_UNUSED char*argv[]) {
|
|||
}
|
||||
|
||||
if ((fd = socket(PF_UNIX, SOCK_STREAM, 0)) < 0) {
|
||||
pa_log(__FILE__": socket(PF_UNIX, SOCK_STREAM, 0): %s", pa_cstrerror(errno));
|
||||
pa_log(__FILE__": socket(PF_UNIX, SOCK_STREAM, 0): %s", strerror(errno));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
|
@ -66,7 +66,7 @@ int main(PA_GCC_UNUSED int argc, PA_GCC_UNUSED char*argv[]) {
|
|||
int r;
|
||||
|
||||
if ((r = connect(fd, (struct sockaddr*) &sa, sizeof(sa))) < 0 && (errno != ECONNREFUSED && errno != ENOENT)) {
|
||||
pa_log(__FILE__": connect(): %s", pa_cstrerror(errno));
|
||||
pa_log(__FILE__": connect(): %s", strerror(errno));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
|
@ -97,7 +97,7 @@ int main(PA_GCC_UNUSED int argc, PA_GCC_UNUSED char*argv[]) {
|
|||
|
||||
for (;;) {
|
||||
if (select(FD_SETSIZE, &ifds, &ofds, NULL, NULL) < 0) {
|
||||
pa_log(__FILE__": select(): %s", pa_cstrerror(errno));
|
||||
pa_log(__FILE__": select(): %s", strerror(errno));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
|
@ -109,7 +109,7 @@ int main(PA_GCC_UNUSED int argc, PA_GCC_UNUSED char*argv[]) {
|
|||
if (r == 0)
|
||||
break;
|
||||
|
||||
pa_log(__FILE__": read(): %s", pa_cstrerror(errno));
|
||||
pa_log(__FILE__": read(): %s", strerror(errno));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
|
@ -125,7 +125,7 @@ int main(PA_GCC_UNUSED int argc, PA_GCC_UNUSED char*argv[]) {
|
|||
if (r == 0)
|
||||
break;
|
||||
|
||||
pa_log(__FILE__": read(): %s", pa_cstrerror(errno));
|
||||
pa_log(__FILE__": read(): %s", strerror(errno));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
|
@ -138,7 +138,7 @@ int main(PA_GCC_UNUSED int argc, PA_GCC_UNUSED char*argv[]) {
|
|||
assert(obuf_length);
|
||||
|
||||
if ((r = write(1, obuf + obuf_index, obuf_length)) < 0) {
|
||||
pa_log(__FILE__": write(): %s", pa_cstrerror(errno));
|
||||
pa_log(__FILE__": write(): %s", strerror(errno));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
|
@ -152,7 +152,7 @@ int main(PA_GCC_UNUSED int argc, PA_GCC_UNUSED char*argv[]) {
|
|||
assert(ibuf_length);
|
||||
|
||||
if ((r = write(fd, ibuf + ibuf_index, ibuf_length)) < 0) {
|
||||
pa_log(__FILE__": write(): %s", pa_cstrerror(errno));
|
||||
pa_log(__FILE__": write(): %s", strerror(errno));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -361,7 +361,7 @@ static void reset_params(fd_info *i) {
|
|||
i->n_fragments = 0;
|
||||
}
|
||||
|
||||
static char *client_name(char *buf, size_t n) {
|
||||
static const char *client_name(char *buf, size_t n) {
|
||||
char p[PATH_MAX];
|
||||
const char *e;
|
||||
|
||||
|
|
@ -376,7 +376,7 @@ static char *client_name(char *buf, size_t n) {
|
|||
return buf;
|
||||
}
|
||||
|
||||
static char *stream_name(void) {
|
||||
static const char *stream_name(void) {
|
||||
const char *e;
|
||||
|
||||
if ((e = getenv("PADSP_STREAM_NAME")))
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue