--- deliantra/server/common/logger.C 2006/08/29 08:01:35 1.3
+++ deliantra/server/common/logger.C 2008/04/30 06:40:28 1.18
@@ -1,82 +1,225 @@
/*
- * static char *rcsid_loger_c =
- * "$Id: logger.C,v 1.3 2006/08/29 08:01:35 root Exp $ ";
+ * This file is part of Deliantra, the Roguelike Realtime MMORPG.
+ *
+ * Copyright (©) 2005,2006,2007 Marc Alexander Lehmann / Robin Redeker / the Deliantra team
+ * Copyright (©) 2002,2007 Mark Wedel & Crossfire Development Team
+ * Copyright (©) 1992,2007 Frank Tore Johansen
+ *
+ * Deliantra 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 3 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, see .
+ *
+ * The authors can be reached via e-mail to
*/
-/*
- CrossFire, A Multiplayer game for X-windows
+#include
+#include
- Copyright (C) 2002 Mark Wedel & Crossfire Development Team
- Copyright (C) 1992 Frank Tore Johansen
+#include
- 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.
+#include
+#include
- 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.
+#include "global.h"
+#include "dynbuf.h"
+#include "util.h"
- 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., 675 Mass Ave, Cambridge, MA 02139, USA.
+struct logline
+{
+ struct timeval tv;
+ char *buf; // includes PREFIX_LEN garbage bytes
+ int len;
+ int flags;
+};
+
+static SMUTEX(mutex);
+static SCOND(cond);
+static int logfd = STDERR_FILENO;
+static int logsync = 1;
+static std::vector > queue;
- The authors can be reached via e-mail at crossfire-devel@real-time.com
-*/
+void set_logfd (int fd)
+{
+ SMUTEX_LOCK (mutex);
+ logfd = fd < 0 ? STDERR_FILENO : fd;
+ SMUTEX_UNLOCK (mutex);
+}
+#define PREFIX_LEN sizeof ("0000-00-00 00:00:00.0000+") - 1
-#include
-#include
-#include
+static void
+log_sync (logline &line)
+{
+ struct tm lt;
+ char pfx [PREFIX_LEN];
-/*
- * Logs a message to stderr, or to file, and/or even to socket.
- * Or discards the message if it is of no importanse, and none have
- * asked to hear messages of that logLevel.
- *
- * See include/logger.h for possible logLevels. Messages with llevInfo
- * and llevError are always printed, regardless of debug mode.
- */
+ localtime_r (&line.tv.tv_sec, <);
+
+ sprintf (pfx, "%04d-%02d-%02d %02d:%02d:%02d.%04d",
+ lt.tm_year + 1900,
+ lt.tm_mon + 1,
+ lt.tm_mday,
+ lt.tm_hour,
+ lt.tm_min,
+ lt.tm_sec,
+ (int)(line.tv.tv_usec / 100)
+ );
+
+ pfx [PREFIX_LEN - 1] = line.flags & logSync ? '=' : ' ';
+
+ struct iovec iov [2];
+
+ iov [0].iov_base = pfx;
+ iov [0].iov_len = PREFIX_LEN;
+
+ char *buf = line.buf;
-void LOG (LogLevel logLevel, const char *format, ...)
+ while (char *end = strchr (buf, '\n'))
+ {
+ iov [1].iov_base = buf;
+ iov [1].iov_len = end - buf + 1;
+
+ writev (STDERR_FILENO, iov, 2);
+ if (logfd != STDERR_FILENO)
+ writev (logfd, iov, 2);
+
+ buf = end + 1;
+
+ if (buf == line.buf + line.len)
+ break;
+
+ pfx [PREFIX_LEN - 1] = '+';
+ }
+
+ sfree (line.buf, line.len);
+}
+
+static void *
+logthread_proc (void *arg)
{
- char buf[20480]; /* This needs to be really really big - larger
- * than any other buffer, since that buffer may
- * need to be put in this one.
- */
- char tbuf[20480];
+ int idx = 0;
- time_t curtime = time (NULL);
- struct tm *ptime = localtime (&curtime);
+ for (;;)
+ {
+ logline line;
- strftime (tbuf, 256, "%Y-%m-%d %H:%M:%S ", ptime);
+ SMUTEX_LOCK (mutex);
- va_list ap;
- va_start(ap, format);
+ while (queue.empty ())
+ SCOND_WAIT (cond, mutex);
+
+ line = queue [idx++];
+
+ // this algorithm could result in an ever-increasing vector
+ // size if we log faster than we can write, but if that happens
+ // we have bigger problems.
+ if (idx == queue.size ())
+ {
+ queue.clear ();
+ idx = 0;
+ }
+
+ SMUTEX_UNLOCK (mutex);
- buf[0] = '\0';
- if (logLevel <= settings.debug)
+ log_sync (line);
+ }
+}
+
+void
+log_cleanup ()
+{
+ logsync = 1;
+
+ for (;;)
+ {
+ int done;
+
+ SMUTEX_LOCK (mutex);
+ done = queue.empty ();
+ SMUTEX_UNLOCK (mutex);
+
+ if (done)
+ break;
+
+ usleep (10000);
+ }
+}
+
+static void
+af_child ()
+{
+ logsync = 1;
+}
+
+static struct logthread : thread
+{
+ logthread ()
{
- vsnprintf(buf, sizeof (buf), format, ap);
- strncat(tbuf, buf, 20460);
-#ifdef WIN32 /* ---win32 change log handling for win32 */
- fputs(tbuf, logfile); /* wrote to file or stdout */
-#ifdef DEBUG /* if we have a debug version, we want see ALL output */
- fflush(logfile); /* so flush this! */
-#endif
- if(logfile != stderr) /* if was it a logfile wrote it to screen too */
- fputs(tbuf, stderr);
-#else
- fputs(tbuf, logfile);
-#endif
- }
- if (!exiting && !trying_emergency_save &&
- logLevel == llevError && ++nroferrors > MAX_ERRORS) {
- exiting = 1;
- if (!trying_emergency_save)
- emergency_save(0);
+ pthread_atfork (0, 0, af_child);
+ start (logthread_proc);
+ logsync = 0;
}
- va_end(ap);
+} logthread;
+
+void
+LOG (int flags, const char *format, ...)
+{
+ int level = flags & 15;
+
+ if (level > settings.debug)
+ return;
+
+ logline line;
+ gettimeofday (&line.tv, 0);
+
+ static dynbuf_text buf;
+
+ va_list ap;
+ va_start (ap, format);
+ buf.vprintf (format, ap);
+ va_end (ap);
+
+ buf << '\n';
+
+ line.buf = buf.linearise ();
+ line.len = buf.size ();
+
+ if (line.buf [line.len - 2] == '\n')
+ --line.len;
+
+ line.buf = salloc (line.len, line.buf);
+
+ buf.clear ();
+
+ if (logsync)
+ flags |= logSync;
+
+ if (flags & logBacktrace)
+ {
+ line.buf [line.len - 1] = 0;
+ log_backtrace (line.buf);
+ line.buf [line.len - 1] = '\n';
+ }
+
+ line.flags = flags;
+
+ if (line.flags & logSync)
+ log_sync (line);
+ else
+ {
+ SMUTEX_LOCK (mutex);
+ queue.push_back (line);
+ SMUTEX_UNLOCK (mutex);
+ SCOND_SIGNAL (cond);
+ }
}
+