From: Matt Birkholz <puck@birchwood-abbey.net>
Date: Thu, 23 Jul 2015 23:25:01 +0000 (-0700)
Subject: Serialize the outf functions.
X-Git-Url: https://birchwood-abbey.net/git?a=commitdiff_plain;h=1003c79eb3ace28a190f49d6078205eafb802d4d;p=mit-scheme.git

Serialize the outf functions.
---

diff --git a/src/microcode/outf.c b/src/microcode/outf.c
index 7ba856370..211a6c9fe 100644
--- a/src/microcode/outf.c
+++ b/src/microcode/outf.c
@@ -40,7 +40,7 @@ USA.
    Use outf where you would normally think of using fprintf and
    outf_flush where you would normally use fflush.  */
 
-#include "config.h"
+#include "scheme.h"
 #include "outf.h"
 
 #ifdef __WIN32__
@@ -245,48 +245,89 @@ outf_flush_fatal (void)
 
 #ifndef OUTF_VARIANTS_DEFINED
 
+#ifdef ENABLE_SMP
+static pthread_mutex_t stderr_mutex = MUTEX_INITIALIZER;
+static pthread_mutex_t stdout_mutex = MUTEX_INITIALIZER;
+#define LOCKN(which) mutex_lock_noerr (which)
+#define UNLOCKN(which) mutex_unlock_noerr (which)
+
+static void
+mutex_lock_noerr (pthread_mutex_t *m)
+{
+  int err = pthread_mutex_lock (m);
+  if (err)
+    outf_error_line (";%d outf mutex lock failed: %d", self->id, err);
+}
+
+static void
+mutex_unlock_noerr (pthread_mutex_t *m)
+{
+  int err = pthread_mutex_unlock (m);
+  if (err)
+    outf_error_line (";%d outf mutex unlock failed: %d", self->id, err);
+}
+
+#else
+#define LOCKN(which)
+#define UNLOCKN(which)
+#endif
+
 void
 voutf_console (const char * format, va_list args)
 {
+  LOCKN (&stdout_mutex);
   vfprintf (stdout, format, args);
+  UNLOCKN (&stdout_mutex);
 }
 
 void
 outf_flush_console (void)
 {
+  LOCKN (&stdout_mutex);
   fflush (stdout);
+  UNLOCKN (&stdout_mutex);
 }
 
 void
 voutf_error (const char * format, va_list args)
 {
+  LOCKN (&stderr_mutex);
   vfprintf (stderr, format, args);
+  UNLOCKN (&stderr_mutex);
 }
 
 void
 outf_flush_error (void)
 {
+  LOCKN (&stderr_mutex);
   fflush (stderr);
+  UNLOCKN (&stderr_mutex);
 }
 
 void
 voutf_error_line (const char * format, va_list args)
 {
+  LOCKN (&stderr_mutex);
   vfprintf (stderr, format, args);
   fputc ('\n', stderr);
   fflush (stderr);
+  UNLOCKN (&stderr_mutex);
 }
 
 void
 voutf_fatal (const char * format, va_list args)
 {
+  LOCKN (&stderr_mutex);
   vfprintf (stderr, format, args);
+  UNLOCKN (&stderr_mutex);
 }
 
 void
 outf_flush_fatal (void)
 {
+  LOCKN (&stderr_mutex);
   fflush (stderr);
+  UNLOCKN (&stderr_mutex);
 }
 
 #endif /* not OUTF_VARIANTS_DEFINED */