|
|
@ -98,24 +98,20 @@ bool SPDLOG_INLINE thread_pool::process_next_msg_()
|
|
|
|
|
|
|
|
|
|
|
|
switch (incoming_async_msg.msg_type)
|
|
|
|
switch (incoming_async_msg.msg_type)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
case async_msg_type::log:
|
|
|
|
case async_msg_type::log: {
|
|
|
|
{
|
|
|
|
|
|
|
|
incoming_async_msg.worker_ptr->backend_sink_it_(incoming_async_msg);
|
|
|
|
incoming_async_msg.worker_ptr->backend_sink_it_(incoming_async_msg);
|
|
|
|
return true;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
case async_msg_type::flush:
|
|
|
|
case async_msg_type::flush: {
|
|
|
|
{
|
|
|
|
|
|
|
|
incoming_async_msg.worker_ptr->backend_flush_();
|
|
|
|
incoming_async_msg.worker_ptr->backend_flush_();
|
|
|
|
return true;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
case async_msg_type::terminate:
|
|
|
|
case async_msg_type::terminate: {
|
|
|
|
{
|
|
|
|
|
|
|
|
return false;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
default:
|
|
|
|
default: {
|
|
|
|
{
|
|
|
|
|
|
|
|
assert(false && "Unexpected async_msg_type");
|
|
|
|
assert(false && "Unexpected async_msg_type");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|