From a4b6d58b24481a2f3e6a80d22a8141c53718fc05 Mon Sep 17 00:00:00 2001
From: Deomid Ryabkov <rojer@rojer.me>
Date: Fri, 28 Aug 2020 20:29:13 +0100
Subject: [PATCH] Add cs_log_{lock,unlock}

In implementatiosn that have preemptive scheduelrs these can be implemented
to ensure logging from different threads is properly serialized.
---
 mongoose.c          | 11 +++++++++++
 src/common/cs_dbg.c | 11 +++++++++++
 2 files changed, 22 insertions(+)

diff --git a/mongoose.c b/mongoose.c
index 71986b3c..93dd5fc7 100644
--- a/mongoose.c
+++ b/mongoose.c
@@ -578,6 +578,15 @@ double cs_log_ts WEAK;
 
 enum cs_log_level cs_log_cur_msg_level WEAK = LL_NONE;
 
+/* In implementations that require locking, these can be overridden. */
+void cs_log_lock(void) WEAK;
+void cs_log_lock(void) {
+}
+
+void cs_log_unlock(void) WEAK;
+void cs_log_unlock(void) {
+}
+
 void cs_log_set_file_level(const char *file_level) {
   char *fl = s_file_level;
   if (file_level != NULL) {
@@ -631,6 +640,7 @@ int cs_log_print_prefix(enum cs_log_level level, const char *file, int ln) {
     if (level > pll) return 0;
   }
 
+  cs_log_lock();
   if (cs_log_file == NULL) cs_log_file = stderr;
   cs_log_cur_msg_level = level;
   fwrite(prefix, 1, sizeof(prefix), cs_log_file);
@@ -653,6 +663,7 @@ void cs_log_printf(const char *fmt, ...) {
   fputc('\n', cs_log_file);
   fflush(cs_log_file);
   cs_log_cur_msg_level = LL_NONE;
+  cs_log_unlock();
 }
 
 void cs_log_set_file(FILE *file) WEAK;
diff --git a/src/common/cs_dbg.c b/src/common/cs_dbg.c
index c221e1f5..5368c2dc 100644
--- a/src/common/cs_dbg.c
+++ b/src/common/cs_dbg.c
@@ -28,6 +28,15 @@ double cs_log_ts WEAK;
 
 enum cs_log_level cs_log_cur_msg_level WEAK = LL_NONE;
 
+/* In implementations that require locking, these can be overridden. */
+void cs_log_lock(void) WEAK;
+void cs_log_lock(void) {
+}
+
+void cs_log_unlock(void) WEAK;
+void cs_log_unlock(void) {
+}
+
 void cs_log_set_file_level(const char *file_level) {
   char *fl = s_file_level;
   if (file_level != NULL) {
@@ -81,6 +90,7 @@ int cs_log_print_prefix(enum cs_log_level level, const char *file, int ln) {
     if (level > pll) return 0;
   }
 
+  cs_log_lock();
   if (cs_log_file == NULL) cs_log_file = stderr;
   cs_log_cur_msg_level = level;
   fwrite(prefix, 1, sizeof(prefix), cs_log_file);
@@ -103,6 +113,7 @@ void cs_log_printf(const char *fmt, ...) {
   fputc('\n', cs_log_file);
   fflush(cs_log_file);
   cs_log_cur_msg_level = LL_NONE;
+  cs_log_unlock();
 }
 
 void cs_log_set_file(FILE *file) WEAK;