diff options
author | Anthony Towns <aj@erisian.com.au> | 2018-05-03 11:09:28 +1000 |
---|---|---|
committer | MarcoFalke <falke.marco@gmail.com> | 2019-05-28 14:26:42 -0400 |
commit | 0b282f9b00da08734e2381477aad32d64b933745 (patch) | |
tree | ecc2d8957a556773296dbde794f5f330c4d3f5cb /src/logging.cpp | |
parent | 412987430c98e78ccda033ab1cf7a176a4c0b835 (diff) |
Log early messages with -printtoconsole
This ensures log messages prior to StartLogging() are replayed to
the console as well as to the debug log file.
Diffstat (limited to 'src/logging.cpp')
-rw-r--r-- | src/logging.cpp | 63 |
1 files changed, 38 insertions, 25 deletions
diff --git a/src/logging.cpp b/src/logging.cpp index f9d9d9c56b..268614065a 100644 --- a/src/logging.cpp +++ b/src/logging.cpp @@ -42,22 +42,35 @@ static int FileWriteStr(const std::string &str, FILE *fp) bool BCLog::Logger::StartLogging() { std::lock_guard<std::mutex> scoped_lock(m_file_mutex); - if (!m_print_to_file) return true; + assert(m_buffering); assert(m_fileout == nullptr); - assert(!m_file_path.empty()); - m_fileout = fsbridge::fopen(m_file_path, "a"); - if (!m_fileout) { - return false; + if (m_print_to_file) { + assert(!m_file_path.empty()); + m_fileout = fsbridge::fopen(m_file_path, "a"); + if (!m_fileout) { + return false; + } + + setbuf(m_fileout, nullptr); // unbuffered + + // Add newlines to the logfile to distinguish this execution from the + // last one. + FileWriteStr("\n\n\n\n\n", m_fileout); } - setbuf(m_fileout, nullptr); // unbuffered // dump buffered messages from before we opened the log + m_buffering = false; while (!m_msgs_before_open.empty()) { - FileWriteStr(m_msgs_before_open.front(), m_fileout); + const std::string& s = m_msgs_before_open.front(); + + if (m_print_to_file) FileWriteStr(s, m_fileout); + if (m_print_to_console) fwrite(s.data(), 1, s.size(), stdout); + m_msgs_before_open.pop_front(); } + if (m_print_to_console) fflush(stdout); return true; } @@ -205,6 +218,7 @@ std::string BCLog::Logger::LogTimestampStr(const std::string& str) void BCLog::Logger::LogPrintStr(const std::string &str) { + std::lock_guard<std::mutex> scoped_lock(m_file_mutex); std::string str_prefixed = str; if (m_log_threadnames && m_started_new_line) { @@ -215,32 +229,31 @@ void BCLog::Logger::LogPrintStr(const std::string &str) m_started_new_line = !str.empty() && str[str.size()-1] == '\n'; + if (m_buffering) { + // buffer if we haven't started logging yet + m_msgs_before_open.push_back(str_prefixed); + return; + } + if (m_print_to_console) { // print to console fwrite(str_prefixed.data(), 1, str_prefixed.size(), stdout); fflush(stdout); } if (m_print_to_file) { - std::lock_guard<std::mutex> scoped_lock(m_file_mutex); - - // buffer if we haven't opened the log yet - if (m_fileout == nullptr) { - m_msgs_before_open.push_back(str_prefixed); - } - else - { - // reopen the log file, if requested - if (m_reopen_file) { - m_reopen_file = false; - FILE* new_fileout = fsbridge::fopen(m_file_path, "a"); - if (new_fileout) { - setbuf(new_fileout, nullptr); // unbuffered - fclose(m_fileout); - m_fileout = new_fileout; - } + assert(m_fileout != nullptr); + + // reopen the log file, if requested + if (m_reopen_file) { + m_reopen_file = false; + FILE* new_fileout = fsbridge::fopen(m_file_path, "a"); + if (new_fileout) { + setbuf(new_fileout, nullptr); // unbuffered + fclose(m_fileout); + m_fileout = new_fileout; } - FileWriteStr(str_prefixed, m_fileout); } + FileWriteStr(str_prefixed, m_fileout); } } |