From 4e398e34bf140baf73fe8dceaf81078fb343f65a Mon Sep 17 00:00:00 2001
From: Ondrej Zajicek <santiago@crfreenet.org>
Date: Fri, 7 Feb 2014 13:09:55 +0100
Subject: [PATCH] Workaround thread-unsafeness of cli_echo().

---
 sysdep/unix/log.c  | 12 ++++++++++--
 sysdep/unix/main.c |  2 ++
 sysdep/unix/unix.h |  1 +
 3 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/sysdep/unix/log.c b/sysdep/unix/log.c
index 0f4c06e9..66a5581c 100644
--- a/sysdep/unix/log.c
+++ b/sysdep/unix/log.c
@@ -39,14 +39,21 @@ static const int rate_limit_count = 5;
 #ifdef USE_PTHREADS
 
 #include <pthread.h>
+
 static pthread_mutex_t log_mutex;
 static inline void log_lock(void) { pthread_mutex_lock(&log_mutex); }
 static inline void log_unlock(void) { pthread_mutex_unlock(&log_mutex); }
 
+static pthread_t main_thread;
+void main_thread_init(void) { main_thread = pthread_self(); }
+static int main_thread_self(void) { return pthread_equal(pthread_self(), main_thread); }
+
 #else
 
 static inline void log_lock(void) {  }
 static inline void log_unlock(void) {  }
+void main_thread_init(void) { }
+static int main_thread_self(void) { return 1; }
 
 #endif
 
@@ -128,8 +135,9 @@ log_commit(int class, buffer *buf)
     }
   log_unlock();
 
-  /* FIXME: cli_echo is not thread-safe */
-  cli_echo(class, buf->start);
+  /* cli_echo is not thread-safe, so call it just from the main thread */
+  if (main_thread_self())
+    cli_echo(class, buf->start);
 
   buf->pos = buf->start;
 }
diff --git a/sysdep/unix/main.c b/sysdep/unix/main.c
index 7a945826..e9217bc9 100644
--- a/sysdep/unix/main.c
+++ b/sysdep/unix/main.c
@@ -797,6 +797,8 @@ main(int argc, char **argv)
       dup2(0, 2);
     }
 
+  main_thread_init();
+
   write_pid_file();
 
   signal_init();
diff --git a/sysdep/unix/unix.h b/sysdep/unix/unix.h
index 1fc26db2..346adcf2 100644
--- a/sysdep/unix/unix.h
+++ b/sysdep/unix/unix.h
@@ -67,6 +67,7 @@ void krt_io_init(void);
 
 /* log.c */
 
+void main_thread_init(void);
 void log_init_debug(char *);		/* Initialize debug dump to given file (NULL=stderr, ""=off) */
 void log_switch(int debug, list *l, char *); /* Use l=NULL for initial switch */