drain_ring_buffer()

void MayaFlux::Journal::Archivist::Impl::drain_ring_buffer ( )

inlineprivate

Definition at line 323 of file Archivist.cpp.

    {
        while (auto entry = m_ring_buffer.try_pop()) {
            std::lock_guard lock(m_mutex);
 
            if (m_sinks.empty()) {
                write_to_console(*entry);
            } else {
                write_to_sinks(*entry);
            }
        }
 
        auto dropped = m_dropped_messages.exchange(0, std::memory_order_acquire);
        if (dropped > 0) {
            std::lock_guard lock(m_mutex);
            std::cout << "[MayaFlux::Journal] WARNING: Dropped " << dropped
                      << " realtime log messages (buffer full)\n";
        }
    }

References m_dropped_messages, m_mutex, m_ring_buffer, m_sinks, write_to_console(), and write_to_sinks().

Referenced by shutdown(), stop_worker(), and worker_loop().

Here is the call graph for this function:

Here is the caller graph for this function: