--- deliantra/server/common/logger.C 2006/08/29 08:01:35 1.3 +++ deliantra/server/common/logger.C 2018/11/17 23:40:00 1.31 @@ -1,82 +1,268 @@ /* - * 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 (©) 2017,2018 Marc Alexander Lehmann / the Deliantra team + * Copyright (©) 2005,2006,2007,2008,2009,2010,2011,2012,2013,2014,2015,2016 Marc Alexander Lehmann / Robin Redeker / the Deliantra team + * + * Deliantra is free software: you can redistribute it and/or modify it under + * the terms of the Affero 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 Affero GNU General Public License + * and 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; +}; + +typedef std::vector > logvector; + +static SMUTEX(mutex); +static SMUTEX(fdlock); +static SCOND(cond); +static int logfd = STDERR_FILENO; +static int logsync = 1; +static logvector queue; - The authors can be reached via e-mail at crossfire-devel@real-time.com -*/ +int log_setfd (int fd) +{ + SMUTEX_LOCK (fdlock); + int old = logfd; + logfd = fd < 0 ? STDERR_FILENO : fd; + SMUTEX_UNLOCK (fdlock); + return old; +} -#include -#include -#include +#define PREFIX_LEN sizeof ("0000-00-00 00:00:00.0000 L+") - 1 -/* - * 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. - */ +static void +log_sync (logline &line) +{ + static const char levelchar [16+1] = "EWIDt???????????"; + struct tm lt; + char pfx [PREFIX_LEN]; + + localtime_r (&line.tv.tv_sec, <); + + sprintf (pfx, "%04d-%02d-%02d %02d:%02d:%02d.%04d %c", + 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), + levelchar [line.flags & 15] + ); -void LOG (LogLevel logLevel, const char *format, ...) + 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; + + if (logsync != 2) + SMUTEX_LOCK (fdlock); + + 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] = '+'; + } + + if (logsync != 2) + SMUTEX_UNLOCK (fdlock); + + 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++]; - buf[0] = '\0'; - if (logLevel <= settings.debug) + // 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 ()) + { + if (idx < 32) + queue.clear (); + else + logvector ().swap (queue); // free memory, hopefully + + idx = 0; + } + + SMUTEX_UNLOCK (mutex); + + log_sync (line); + } +} + +void +log_cleanup () +{ + logsync = 1; + SMUTEX_UNLOCK (fdlock); + + for (;;) + { + int done; + + SMUTEX_LOCK (mutex); + done = queue.empty (); + SMUTEX_UNLOCK (mutex); + + if (done) + break; + + usleep (10000); + SMUTEX_LOCK (fdlock); + SMUTEX_UNLOCK (fdlock); + } +} + +static void +af_child () +{ + logsync = 2; +} + +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_utf8_string 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); + } +} + +static int suspended; + +void +log_suspend () +{ + if (!suspended++) + { + LOG (llevDebug, "logging suspended."); + SMUTEX_LOCK (fdlock); + } } + +void +log_resume () +{ + if (!--suspended) + { + SMUTEX_UNLOCK (fdlock); + LOG (llevDebug, "logging resumed."); + } +} +