41 return fwrite(str.data(), 1, str.size(), fp);
48 assert(m_fileout ==
nullptr);
58 setbuf(m_fileout,
nullptr);
67 while (!m_msgs_before_open.empty()) {
68 const std::string &s = m_msgs_before_open.front();
74 fwrite(s.data(), 1, s.size(), stdout);
76 for (
const auto &cb : m_print_callbacks) {
80 m_msgs_before_open.pop_front();
92 if (m_fileout !=
nullptr) {
96 m_print_callbacks.clear();
132 #ifdef DEBUG_LOCKCONTENTION
146 if (category_desc.category == str) {
147 flag = category_desc.flag;
159 std::sort(categories.begin(), categories.end(),
160 [](
auto a,
auto b) { return a.category < b.category; });
162 std::vector<LogCategory> ret;
169 catActive.
category = category_desc.category;
170 catActive.
active = WillLogCategory(category_desc.flag);
171 ret.push_back(catActive);
183 std::string strStamped;
185 if (!m_log_timestamps) {
189 if (m_started_new_line) {
192 if (m_log_time_micros) {
193 strStamped.pop_back();
194 strStamped +=
strprintf(
".%06dZ", nTimeMicros % 1000000);
198 strStamped +=
" (mocktime: " +
201 strStamped +=
' ' + str;
219 for (
char ch_in : str) {
220 uint8_t ch = (uint8_t)ch_in;
221 if ((ch >= 32 || ch ==
'\n') && ch !=
'\x7f') {
232 const std::string &logging_function,
233 const std::string &source_file,
234 const int source_line) {
238 if (m_log_sourcelocations && m_started_new_line) {
239 str_prefixed.insert(0,
"[" +
RemovePrefix(source_file,
"./") +
":" +
241 logging_function +
"] ");
244 if (m_log_threadnames && m_started_new_line) {
248 str_prefixed = LogTimestampStr(str_prefixed);
250 m_started_new_line = !str.empty() && str[str.size() - 1] ==
'\n';
254 m_msgs_before_open.push_back(str_prefixed);
258 if (m_print_to_console) {
260 fwrite(str_prefixed.data(), 1, str_prefixed.size(), stdout);
263 for (
const auto &cb : m_print_callbacks) {
266 if (m_print_to_file) {
267 assert(m_fileout !=
nullptr);
271 m_reopen_file =
false;
275 setbuf(m_fileout,
nullptr);
277 m_fileout = new_fileout;
286 constexpr
size_t RECENT_DEBUG_HISTORY_SIZE = 10 * 1000000;
288 assert(!m_file_path.empty());
296 log_size = fs::file_size(m_file_path);
297 }
catch (
const fs::filesystem_error &) {
302 if (file && log_size > 11 * (RECENT_DEBUG_HISTORY_SIZE / 10)) {
304 std::vector<char> vch(RECENT_DEBUG_HISTORY_SIZE, 0);
305 if (fseek(file, -((
long)vch.size()), SEEK_END)) {
306 LogPrintf(
"Failed to shrink debug log file: fseek(...) failed\n");
310 int nBytes = fread(vch.data(), 1, vch.size(), file);
315 fwrite(vch.data(), 1, nBytes, file);
318 }
else if (file !=
nullptr) {
324 m_categories |= category;
332 EnableCategory(flag);
337 m_categories &= ~category;
345 DisableCategory(flag);
353 LogPrintf(
"Error trying to log using a category mask instead of an "
354 "explicit category.\n");
358 return (m_categories.load(std::memory_order_relaxed) & category) != 0;
bool WillLogCategory(LogFlags category) const
Return true if log accepts specified category.
std::string LogTimestampStr(const std::string &str)
void DisconnectTestLogger()
Only for testing.
bool DefaultShrinkDebugFile() const
Default for whether ShrinkDebugFile should be run.
std::vector< LogCategory > LogCategoriesList() const
Returns a vector of the log categories in alphabetical order.
void DisableCategory(LogFlags category)
void EnableCategory(LogFlags category)
bool StartLogging()
Start logging (and flush all buffered messages)
void LogPrintStr(const std::string &str, const std::string &logging_function, const std::string &source_file, const int source_line)
Send a string to the log output.
const CLogCategoryDesc LogCategories[]
static int FileWriteStr(const std::string &str, FILE *fp)
bool GetLogCategory(BCLog::LogFlags &flag, const std::string &str)
Return true if str parses as a log category and set the flag.
const char *const DEFAULT_DEBUGLOGFILE
BCLog::Logger & LogInstance()
static const bool DEFAULT_LOGIPS
std::string LogEscapeMessage(const std::string &str)
Belts and suspenders: make sure outgoing log messages don't contain potentially suspicious characters...
FILE * fopen(const fs::path &p, const char *mode)
const std::string & ThreadGetInternalName()
Get the thread's internal (in-memory) name; used e.g.
std::string RemovePrefix(const std::string &str, const std::string &prefix)
std::string ToString(const T &t)
Locale-independent version of std::to_string.
int64_t GetTimeMicros()
Returns the system time (not mockable)
std::chrono::seconds GetMockTime()
For testing.
std::string FormatISO8601DateTime(int64_t nTime)
ISO 8601 formatting is preferred.
constexpr int64_t count_seconds(std::chrono::seconds t)
Helper to count the seconds of a duration.