summaryrefslogtreecommitdiffstats
path: root/src/libdebug/debug.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/libdebug/debug.c')
-rw-r--r--src/libdebug/debug.c23
1 files changed, 20 insertions, 3 deletions
diff --git a/src/libdebug/debug.c b/src/libdebug/debug.c
index 5becb02..67ba00c 100644
--- a/src/libdebug/debug.c
+++ b/src/libdebug/debug.c
@@ -25,6 +25,7 @@
#include <errno.h>
#include <math.h>
#include <time.h>
+#include <pthread.h>
#include <sys/ioctl.h>
#include <sys/time.h>
#include "debug.h"
@@ -55,6 +56,7 @@ struct debug_cat {
{ "mpt1327", "\033[1;34m" },
{ "jollycom", "\033[1;34m" },
{ "eurosignal", "\033[1;34m" },
+ { "pocsag", "\033[1;34m" },
{ "frame", "\033[0;36m" },
{ "call", "\033[0;37m" },
{ "cc", "\033[1;32m" },
@@ -100,6 +102,9 @@ void (*print_console_text)(void) = NULL;
int debug_limit_scroll = 0;
+static int lock_initialized = 0;
+static pthread_mutex_t debug_mutex;
+
void get_win_size(int *w, int *h)
{
struct winsize win;
@@ -123,10 +128,22 @@ void _printdebug(const char *file, const char __attribute__((unused)) *function,
const char *p;
va_list args;
int w, h;
+ int rc;
if (debuglevel > level)
return;
+ if (!(debug_mask & ((uint64_t)1 << cat)))
+ return;
+
+ if (!lock_initialized) {
+ rc = pthread_mutex_init(&debug_mutex, NULL);
+ if (rc == 0)
+ lock_initialized = 1;
+ }
+ if (lock_initialized)
+ pthread_mutex_lock(&debug_mutex);
+
buffer[sizeof(buffer) - 1] = '\0';
/* if kanal is used, prefix the channel number */
@@ -136,9 +153,6 @@ void _printdebug(const char *file, const char __attribute__((unused)) *function,
s -= strlen(buffer);
}
- if (!(debug_mask & ((uint64_t)1 << cat)))
- return;
-
va_start(args, fmt);
vsnprintf(b, s, fmt, args);
va_end(args);
@@ -166,6 +180,9 @@ void _printdebug(const char *file, const char __attribute__((unused)) *function,
if (print_console_text)
print_console_text();
fflush(stdout);
+
+ if (lock_initialized)
+ pthread_mutex_unlock(&debug_mutex);
}
const char *debug_amplitude(double level)