123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370 |
- /*
- Minetest
- Copyright (C) 2013 celeron55, Perttu Ahola <celeron55@gmail.com>
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU Lesser General Public License as published by
- the Free Software Foundation; either version 2.1 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 Lesser General Public License for more details.
- You should have received a copy of the GNU Lesser General Public License along
- with this program; if not, write to the Free Software Foundation, Inc.,
- 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
- */
- #include "log.h"
- #include "threading/mutex_auto_lock.h"
- #include "debug.h"
- #include "gettime.h"
- #include "porting.h"
- #include "config.h"
- #include "exceptions.h"
- #include "util/numeric.h"
- #include "log.h"
- #include <sstream>
- #include <iostream>
- #include <algorithm>
- #include <cerrno>
- #include <cstring>
- const int BUFFER_LENGTH = 256;
- class StringBuffer : public std::streambuf {
- public:
- StringBuffer() {
- buffer_index = 0;
- }
- int overflow(int c);
- virtual void flush(const std::string &buf) = 0;
- std::streamsize xsputn(const char *s, std::streamsize n);
- void push_back(char c);
- private:
- char buffer[BUFFER_LENGTH];
- int buffer_index;
- };
- class LogBuffer : public StringBuffer {
- public:
- LogBuffer(Logger &logger, LogLevel lev) :
- logger(logger),
- level(lev)
- {}
- void flush(const std::string &buffer);
- private:
- Logger &logger;
- LogLevel level;
- };
- class RawLogBuffer : public StringBuffer {
- public:
- void flush(const std::string &buffer);
- };
- ////
- //// Globals
- ////
- Logger g_logger;
- StreamLogOutput stdout_output(std::cout);
- StreamLogOutput stderr_output(std::cerr);
- std::ostream null_stream(NULL);
- RawLogBuffer raw_buf;
- LogBuffer none_buf(g_logger, LL_NONE);
- LogBuffer error_buf(g_logger, LL_ERROR);
- LogBuffer warning_buf(g_logger, LL_WARNING);
- LogBuffer action_buf(g_logger, LL_ACTION);
- LogBuffer info_buf(g_logger, LL_INFO);
- LogBuffer verbose_buf(g_logger, LL_VERBOSE);
- // Connection
- std::ostream *dout_con_ptr = &null_stream;
- std::ostream *derr_con_ptr = &verbosestream;
- // Server
- std::ostream *dout_server_ptr = &infostream;
- std::ostream *derr_server_ptr = &errorstream;
- #ifndef SERVER
- // Client
- std::ostream *dout_client_ptr = &infostream;
- std::ostream *derr_client_ptr = &errorstream;
- #endif
- std::ostream rawstream(&raw_buf);
- std::ostream dstream(&none_buf);
- std::ostream errorstream(&error_buf);
- std::ostream warningstream(&warning_buf);
- std::ostream actionstream(&action_buf);
- std::ostream infostream(&info_buf);
- std::ostream verbosestream(&verbose_buf);
- // Android
- #ifdef __ANDROID__
- static unsigned int g_level_to_android[] = {
- ANDROID_LOG_INFO, // LL_NONE
- //ANDROID_LOG_FATAL,
- ANDROID_LOG_ERROR, // LL_ERROR
- ANDROID_LOG_WARN, // LL_WARNING
- ANDROID_LOG_WARN, // LL_ACTION
- //ANDROID_LOG_INFO,
- ANDROID_LOG_DEBUG, // LL_INFO
- ANDROID_LOG_VERBOSE, // LL_VERBOSE
- };
- class AndroidSystemLogOutput : public ICombinedLogOutput {
- public:
- AndroidSystemLogOutput()
- {
- g_logger.addOutput(this);
- }
- ~AndroidSystemLogOutput()
- {
- g_logger.removeOutput(this);
- }
- void logRaw(LogLevel lev, const std::string &line)
- {
- STATIC_ASSERT(ARRLEN(g_level_to_android) == LL_MAX,
- mismatch_between_android_and_internal_loglevels);
- __android_log_print(g_level_to_android[lev],
- PROJECT_NAME_C, "%s", line.c_str());
- }
- };
- AndroidSystemLogOutput g_android_log_output;
- #endif
- ///////////////////////////////////////////////////////////////////////////////
- ////
- //// Logger
- ////
- LogLevel Logger::stringToLevel(const std::string &name)
- {
- if (name == "none")
- return LL_NONE;
- else if (name == "error")
- return LL_ERROR;
- else if (name == "warning")
- return LL_WARNING;
- else if (name == "action")
- return LL_ACTION;
- else if (name == "info")
- return LL_INFO;
- else if (name == "verbose")
- return LL_VERBOSE;
- else
- return LL_MAX;
- }
- void Logger::addOutput(ILogOutput *out)
- {
- addOutputMaxLevel(out, (LogLevel)(LL_MAX - 1));
- }
- void Logger::addOutput(ILogOutput *out, LogLevel lev)
- {
- m_outputs[lev].push_back(out);
- }
- void Logger::addOutputMasked(ILogOutput *out, LogLevelMask mask)
- {
- for (size_t i = 0; i < LL_MAX; i++) {
- if (mask & LOGLEVEL_TO_MASKLEVEL(i))
- m_outputs[i].push_back(out);
- }
- }
- void Logger::addOutputMaxLevel(ILogOutput *out, LogLevel lev)
- {
- assert(lev < LL_MAX);
- for (size_t i = 0; i <= lev; i++)
- m_outputs[i].push_back(out);
- }
- LogLevelMask Logger::removeOutput(ILogOutput *out)
- {
- LogLevelMask ret_mask = 0;
- for (size_t i = 0; i < LL_MAX; i++) {
- std::vector<ILogOutput *>::iterator it;
- it = std::find(m_outputs[i].begin(), m_outputs[i].end(), out);
- if (it != m_outputs[i].end()) {
- ret_mask |= LOGLEVEL_TO_MASKLEVEL(i);
- m_outputs[i].erase(it);
- }
- }
- return ret_mask;
- }
- void Logger::setLevelSilenced(LogLevel lev, bool silenced)
- {
- m_silenced_levels[lev] = silenced;
- }
- void Logger::registerThread(const std::string &name)
- {
- std::thread::id id = std::this_thread::get_id();
- MutexAutoLock lock(m_mutex);
- m_thread_names[id] = name;
- }
- void Logger::deregisterThread()
- {
- std::thread::id id = std::this_thread::get_id();
- MutexAutoLock lock(m_mutex);
- m_thread_names.erase(id);
- }
- const std::string Logger::getLevelLabel(LogLevel lev)
- {
- static const std::string names[] = {
- "",
- "ERROR",
- "WARNING",
- "ACTION",
- "INFO",
- "VERBOSE",
- };
- assert(lev < LL_MAX && lev >= 0);
- STATIC_ASSERT(ARRLEN(names) == LL_MAX,
- mismatch_between_loglevel_names_and_enum);
- return names[lev];
- }
- const std::string Logger::getThreadName()
- {
- std::map<std::thread::id, std::string>::const_iterator it;
- std::thread::id id = std::this_thread::get_id();
- it = m_thread_names.find(id);
- if (it != m_thread_names.end())
- return it->second;
- std::ostringstream os;
- os << "#0x" << std::hex << id;
- return os.str();
- }
- void Logger::log(LogLevel lev, const std::string &text)
- {
- if (m_silenced_levels[lev])
- return;
- const std::string thread_name = getThreadName();
- const std::string label = getLevelLabel(lev);
- const std::string timestamp = getTimestamp();
- std::ostringstream os(std::ios_base::binary);
- os << timestamp << ": " << label << "[" << thread_name << "]: " << text;
- logToOutputs(lev, os.str(), timestamp, thread_name, text);
- }
- void Logger::logRaw(LogLevel lev, const std::string &text)
- {
- if (m_silenced_levels[lev])
- return;
- logToOutputsRaw(lev, text);
- }
- void Logger::logToOutputsRaw(LogLevel lev, const std::string &line)
- {
- MutexAutoLock lock(m_mutex);
- for (size_t i = 0; i != m_outputs[lev].size(); i++)
- m_outputs[lev][i]->logRaw(lev, line);
- }
- void Logger::logToOutputs(LogLevel lev, const std::string &combined,
- const std::string &time, const std::string &thread_name,
- const std::string &payload_text)
- {
- MutexAutoLock lock(m_mutex);
- for (size_t i = 0; i != m_outputs[lev].size(); i++)
- m_outputs[lev][i]->log(lev, combined, time, thread_name, payload_text);
- }
- ////
- //// *LogOutput methods
- ////
- void FileLogOutput::open(const std::string &filename)
- {
- m_stream.open(filename.c_str(), std::ios::app | std::ios::ate);
- if (!m_stream.good())
- throw FileNotGoodException("Failed to open log file " +
- filename + ": " + strerror(errno));
- m_stream << "\n\n"
- "-------------" << std::endl
- << " Separator" << std::endl
- << "-------------\n" << std::endl;
- }
- ////
- //// *Buffer methods
- ////
- int StringBuffer::overflow(int c)
- {
- push_back(c);
- return c;
- }
- std::streamsize StringBuffer::xsputn(const char *s, std::streamsize n)
- {
- for (int i = 0; i < n; ++i)
- push_back(s[i]);
- return n;
- }
- void StringBuffer::push_back(char c)
- {
- if (c == '\n' || c == '\r') {
- if (buffer_index)
- flush(std::string(buffer, buffer_index));
- buffer_index = 0;
- } else {
- int index = buffer_index;
- buffer[index++] = c;
- if (index >= BUFFER_LENGTH) {
- flush(std::string(buffer, buffer_index));
- buffer_index = 0;
- } else {
- buffer_index = index;
- }
- }
- }
- void LogBuffer::flush(const std::string &buffer)
- {
- logger.log(level, buffer);
- }
- void RawLogBuffer::flush(const std::string &buffer)
- {
- g_logger.logRaw(LL_NONE, buffer);
- }
|