worker_loop()

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

inlineprivate

Definition at line 309 of file Archivist.cpp.

    {
        using namespace std::chrono_literals;
 
        while (m_worker_running.load(std::memory_order_acquire)) {
            if (m_initialized) {
                drain_ring_buffer();
            }
            std::this_thread::sleep_for(10ms);
        }
 
        if (m_initialized) {
            drain_ring_buffer();
        }
    }

References drain_ring_buffer(), m_initialized, and m_worker_running.

Referenced by start_worker().

Here is the call graph for this function:

Here is the caller graph for this function: