Method process_logs

modules/core/core/src/core/log/log_worker.cpp:217–247

}

void LogWorker::process_logs() SKR_NOEXCEPT
{
    LogManager::Get()->tscns_.calibrate();
    LogElement e;

    // try flush
    while (auto flush_tok = queue_->query_flushing())
    {
        SKR_ASSERT(flush_tok->query_status() == kFlushing);
        while (queue_->try_dequeue_from(flush_tok, e))
        {
            patternAndSink(e);
        }
        SKR_ASSERT(flush_tok->query_cnt() == 0);
        skr_atomic32_cas_relaxed(&flush_tok->flush_status_, kFlushing, kFlushed);
    }

    // normal polling    
    const uint32_t N = 16; // avoid too many logs in one cycle
    uint32_t n = 0;
    while (queue_->try_dequeue(e))
    {
        patternAndSink(e);

        n++;
        if (n >= N) break;
    }

    // flush sinks
    LogManager::Get()->FlushAllSinks();
}

void LogWorker::flush(SThreadID tid) SKR_NOEXCEPT
{