First stab at porting mplex

Original commit message from CVS:
First stab at porting mplex

1 files changed, 239 insertions, 0 deletions

diff --git a/ext/mplex/mjpeg_logging.cc b/ext/mplex/mjpeg_logging.cc
new file mode 100644
index 00000000..db4b0c07
--- /dev/null
+++ b/ext/mplex/mjpeg_logging.cc
@@ -0,0 +1,239 @@
+/*
+    $Id$
+
+    Copyright (C) 2000 Herbert Valerio Riedel <hvr@gnu.org>
+
+    This program is free software; you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation; either version 2 of the License, or
+    (at your option) any later version.
+
+    This program 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 General Public License
+    along with this program; 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 <stdlib.h>
+#include <stdarg.h>
+#include <stdio.h>
+#include <assert.h>
+#include <string.h>
+
+extern int fred;
+
+#include "mjpeg_logging.h"
+
+static const char _rcsid[] = "$Id: ";
+
+#define MAX_DEFAULT_ID_SIZE 16
+#define DEFAULT_DEFAULT_ID "???"
+
+#ifdef HAVE___PROGNAME
+extern const char *__progname;
+#endif
+
+static log_level_t mjpeg_log_verbosity = (log_level_t) 0;
+static char default_handler_id[MAX_DEFAULT_ID_SIZE];
+static char default_handler_id_is_set = 0;
+
+static int
+default_mjpeg_log_filter (log_level_t level)
+{
+  int verb_from_env;
+
+  if (mjpeg_log_verbosity == 0) {
+    char *mjpeg_verb_env = getenv ("MJPEG_VERBOSITY");
+
+    if (mjpeg_verb_env != NULL) {
+      verb_from_env = LOG_WARN - atoi (mjpeg_verb_env);
+      if (verb_from_env >= LOG_DEBUG && verb_from_env <= LOG_ERROR)
+	mjpeg_log_verbosity = (log_level_t) verb_from_env;
+    }
+  }
+  return (level < LOG_WARN && level < mjpeg_log_verbosity);
+}
+
+static mjpeg_log_filter_t _filter = default_mjpeg_log_filter;
+
+static void
+default_mjpeg_log_handler (log_level_t level, const char message[])
+{
+  const char *ids;
+
+  if ((*_filter) (level))
+    return;
+  if (default_handler_id_is_set) {
+    ids = default_handler_id;
+  } else {
+#ifdef HAVE___PROGNAME
+    ids = __progname;
+#else
+    ids = DEFAULT_DEFAULT_ID;
+#endif
+  }
+  switch (level) {
+    case LOG_ERROR:
+      fprintf (stderr, "**ERROR: [%s] %s\n", ids, message);
+      break;
+    case LOG_DEBUG:
+      fprintf (stderr, "--DEBUG: [%s] %s\n", ids, message);
+      break;
+    case LOG_WARN:
+      fprintf (stderr, "++ WARN: [%s] %s\n", ids, message);
+      break;
+    case LOG_INFO:
+      fprintf (stderr, "   INFO: [%s] %s\n", ids, message);
+      break;
+    default:
+      assert (0);
+  }
+}
+
+static mjpeg_log_handler_t _handler = default_mjpeg_log_handler;
+
+
+mjpeg_log_handler_t
+mjpeg_log_set_handler (mjpeg_log_handler_t new_handler)
+{
+  mjpeg_log_handler_t old_handler = _handler;
+
+  _handler = new_handler;
+
+  return old_handler;
+}
+
+/***************
+ *
+ * Set default log handlers degree of verboseity.
+ * 0 = quiet, 1 = info, 2 = debug
+ *
+ *************/
+
+int
+mjpeg_default_handler_verbosity (int verbosity)
+{
+  int prev_verb = mjpeg_log_verbosity;
+
+  mjpeg_log_verbosity = (log_level_t) (LOG_WARN - (log_level_t) verbosity);
+  return prev_verb;
+}
+
+/*
+ * Set identifier string used by default handler
+ *
+ */
+int
+mjpeg_default_handler_identifier (const char *new_id)
+{
+  const char *s;
+
+  if (new_id == NULL) {
+    default_handler_id_is_set = 0;
+    return 0;
+  }
+  /* find basename of new_id (remove any directory prefix) */
+  if ((s = strrchr (new_id, '/')) == NULL)
+    s = new_id;
+  else
+    s = s + 1;
+  strncpy (default_handler_id, s, MAX_DEFAULT_ID_SIZE);
+  default_handler_id[MAX_DEFAULT_ID_SIZE - 1] = '\0';
+  default_handler_id_is_set = 1;
+  return 0;
+}
+
+
+static void
+mjpeg_logv (log_level_t level, const char format[], va_list args)
+{
+  char buf[1024] = { 0, };
+
+  /* TODO: Original had a re-entrancy error trap to assist bug
+     finding.  To make this work with multi-threaded applications a
+     lock is needed hence delete.
+   */
+
+
+  vsnprintf (buf, sizeof (buf) - 1, format, args);
+
+  _handler (level, buf);
+}
+
+void
+mjpeg_log (log_level_t level, const char format[], ...)
+{
+  va_list args;
+
+  va_start (args, format);
+  mjpeg_logv (level, format, args);
+  va_end (args);
+}
+
+void
+mjpeg_debug (const char format[], ...)
+{
+  va_list args;
+
+  va_start (args, format);
+  mjpeg_logv (LOG_DEBUG, format, args);
+  va_end (args);
+}
+
+void
+mjpeg_info (const char format[], ...)
+{
+  va_list args;
+
+  va_start (args, format);
+  mjpeg_logv (LOG_INFO, format, args);
+  va_end (args);
+}
+
+void
+mjpeg_warn (const char format[], ...)
+{
+  va_list args;
+
+  va_start (args, format);
+  mjpeg_logv (LOG_WARN, format, args);
+  va_end (args);
+}
+
+void
+mjpeg_error (const char format[], ...)
+{
+  va_list args;
+
+  va_start (args, format);
+  mjpeg_logv (LOG_ERROR, format, args);
+  va_end (args);
+}
+
+void
+mjpeg_error_exit1 (const char format[], ...)
+{
+  va_list args;
+
+  va_start (args, format);
+  mjpeg_logv (LOG_ERROR, format, args);
+  va_end (args);
+  exit (EXIT_FAILURE);
+}
+
+
+/* 
+ * Local variables:
+ *  c-file-style: "gnu"
+ *  tab-width: 8
+ *  indent-tabs-mode: nil
+ * End:
+ */