summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--src/log.cpp83
-rw-r--r--src/log.h63
2 files changed, 89 insertions, 57 deletions
diff --git a/src/log.cpp b/src/log.cpp
index e15bed52a..7cae8b670 100644
--- a/src/log.cpp
+++ b/src/log.cpp
@@ -68,21 +68,6 @@ public:
void flush(const std::string &buffer);
};
-
-#ifdef __ANDROID__
-static unsigned int 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
-
-};
-#endif
-
////
//// Globals
////
@@ -124,6 +109,41 @@ 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)
+ {
+ assert(ARRLEN(g_level_to_android) == LL_MAX);
+ __android_log_print(g_level_to_android[lev],
+ PROJECT_NAME_C, "%s", line.c_str());
+ }
+};
+
+AndroidSystemLogOutput g_android_log_output;
+
+#endif
///////////////////////////////////////////////////////////////////////////////
@@ -232,11 +252,11 @@ void Logger::log(LogLevel lev, const std::string &text)
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 << getTimestamp() << ": " << label << "[" << thread_name << "]: " << text;
+ os << timestamp << ": " << label << "[" << thread_name << "]: " << text;
- logToSystem(lev, text);
- logToOutputs(lev, os.str());
+ logToOutputs(lev, os.str(), timestamp, thread_name, text);
}
void Logger::logRaw(LogLevel lev, const std::string &text)
@@ -244,24 +264,23 @@ void Logger::logRaw(LogLevel lev, const std::string &text)
if (m_silenced_levels[lev])
return;
- logToSystem(lev, text);
- logToOutputs(lev, text);
+ logToOutputsRaw(lev, text);
}
-void Logger::logToSystem(LogLevel lev, const std::string &text)
+void Logger::logToOutputsRaw(LogLevel lev, const std::string &line)
{
-#ifdef __ANDROID__
- assert(ARRLEN(level_to_android) == LL_MAX);
- __android_log_print(level_to_android[lev],
- PROJECT_NAME_C, "%s", text.c_str());
-#endif
+ 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 &text)
+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(text);
+ m_outputs[lev][i]->log(lev, combined, time, thread_name, payload_text);
}
@@ -271,11 +290,11 @@ void Logger::logToOutputs(LogLevel lev, const std::string &text)
void FileLogOutput::open(const std::string &filename)
{
- stream.open(filename.c_str(), std::ios::app | std::ios::ate);
- if (!stream.good())
+ 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));
- stream << "\n\n"
+ m_stream << "\n\n"
"-------------" << std::endl
<< " Separator" << std::endl
<< "-------------\n" << std::endl;
@@ -313,8 +332,6 @@ void StringBuffer::push_back(char c)
}
-
-
void LogBuffer::flush(const std::string &buffer)
{
logger.log(level, buffer);
diff --git a/src/log.h b/src/log.h
index 0e63041cc..f877f2f8a 100644
--- a/src/log.h
+++ b/src/log.h
@@ -57,12 +57,14 @@ public:
bool getTraceEnabled() { return m_trace_enabled; }
static LogLevel stringToLevel(const std::string &name);
+ static const std::string getLevelLabel(LogLevel lev);
private:
- void logToSystem(LogLevel, const std::string &text);
- void logToOutputs(LogLevel, const std::string &text);
+ void logToOutputsRaw(LogLevel, const std::string &line);
+ void logToOutputs(LogLevel, const std::string &combined,
+ const std::string &time, const std::string &thread_name,
+ const std::string &payload_text);
- const std::string getLevelLabel(LogLevel lev);
const std::string getThreadName();
std::vector<ILogOutput *> m_outputs[LL_MAX];
@@ -78,73 +80,86 @@ private:
class ILogOutput {
public:
- virtual void log(const std::string &line) = 0;
+ virtual void logRaw(LogLevel, const std::string &line) = 0;
+ virtual void log(LogLevel, const std::string &combined,
+ const std::string &time, const std::string &thread_name,
+ const std::string &payload_text) = 0;
};
-class StreamLogOutput : public ILogOutput {
+class ICombinedLogOutput : public ILogOutput {
+public:
+ void log(LogLevel lev, const std::string &combined,
+ const std::string &time, const std::string &thread_name,
+ const std::string &payload_text)
+ {
+ logRaw(lev, combined);
+ }
+};
+
+class StreamLogOutput : public ICombinedLogOutput {
public:
StreamLogOutput(std::ostream &stream) :
- stream(stream)
+ m_stream(stream)
{
}
- void log(const std::string &line)
+ void logRaw(LogLevel lev, const std::string &line)
{
- stream << line << std::endl;
+ m_stream << line << std::endl;
}
private:
- std::ostream &stream;
+ std::ostream &m_stream;
};
-class FileLogOutput : public ILogOutput {
+class FileLogOutput : public ICombinedLogOutput {
public:
void open(const std::string &filename);
- void log(const std::string &line)
+ void logRaw(LogLevel lev, const std::string &line)
{
- stream << line << std::endl;
+ m_stream << line << std::endl;
}
private:
- std::ofstream stream;
+ std::ofstream m_stream;
};
-class LogOutputBuffer : public ILogOutput {
+class LogOutputBuffer : public ICombinedLogOutput {
public:
LogOutputBuffer(Logger &logger, LogLevel lev) :
- logger(logger)
+ m_logger(logger)
{
- logger.addOutput(this, lev);
+ m_logger.addOutput(this, lev);
}
~LogOutputBuffer()
{
- logger.removeOutput(this);
+ m_logger.removeOutput(this);
}
- virtual void log(const std::string &line)
+ void logRaw(LogLevel lev, const std::string &line)
{
- buffer.push(line);
+ m_buffer.push(line);
}
bool empty()
{
- return buffer.empty();
+ return m_buffer.empty();
}
std::string get()
{
if (empty())
return "";
- std::string s = buffer.front();
- buffer.pop();
+ std::string s = m_buffer.front();
+ m_buffer.pop();
return s;
}
private:
- std::queue<std::string> buffer;
- Logger &logger;
+ std::queue<std::string> m_buffer;
+ Logger &m_logger;
};
generated by cgit v1.2.3 (git 2.25.1) at 2024-06-03 05:51:21 +0000