TeaSpeak/spdlog
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

move discarded message handling to a dedicated function

Browse Source 
fix - formatter new discarded message
This commit is contained in:
Alexander Zilberkant 2017-05-13 00:53:57 +03:00
parent 0aeaf9e28e
commit 42258a1059
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
include/spdlog/details/async_log_helper.h
View File

@ -189,6 +189,9 @@ private:
// counter for messages discarded due to queue overflow // counter for messages discarded due to queue overflow
std::atomic<unsigned int> _discarded_msg_count; std::atomic<unsigned int> _discarded_msg_count;
// handle discarded messages
void handle_discarded_msg(const std::string& logger_name);
}; };
} }
} }
@ -319,16 +322,7 @@ inline bool spdlog::details::async_log_helper::process_next_msg(log_clock::time_
default: default:
#if defined(SPDLOG_ASYNC_COUNT_DISCARDED_MSG) #if defined(SPDLOG_ASYNC_COUNT_DISCARDED_MSG)
unsigned int num_of_discarded_messages = _discarded_msg_count.exchange(0); handle_discarded_msg(incoming_async_msg.logger_name);
if (num_of_discarded_messages)
{
log_msg discarded_warning_msg(&incoming_async_msg.logger_name, level::warn);
discarded_warning_msg.raw << "Dropped " << num_of_discarded_messages << " messages";
for (auto &s : _sinks)
{
s->log(discarded_warning_msg);
}
}
#endif #endif
log_msg incoming_log_msg; log_msg incoming_log_msg;
@ -415,5 +409,18 @@ inline void spdlog::details::async_log_helper::set_error_handler(spdlog::log_err
_err_handler = err_handler; _err_handler = err_handler;
} }
inline void spdlog::details::async_log_helper::handle_discarded_msg(const std::string& logger_name)
{
unsigned int num_of_discarded_messages = _discarded_msg_count.exchange(0);
if (num_of_discarded_messages)
{
log_msg discarded_warning_msg(&logger_name, level::warn);
discarded_warning_msg.raw << "Discarded " << num_of_discarded_messages << " messages - logger queue overflow";
_formatter->format(discarded_warning_msg);
for (auto &s : _sinks)
{
s->log(discarded_warning_msg);
}
}
}