drain_ring_buffer()

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

inline

Drain all pending ring buffer entries to sinks or console.

Lock-free. Safe to call from any thread. The worker calls this on its normal cadence; error() and fatal() call it synchronously before propagating exceptions or aborting to guarantee visibility.

Definition at line 109 of file Archivist.cpp.

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

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

Referenced by shutdown(), and worker_loop().

Here is the call graph for this function:

Here is the caller graph for this function: