Method shutdown

src/core/AsyncLogWriter.cpp:167–197

}

void AsyncLogWriter::shutdown()
{
    std::shared_ptr<SyncPoint> sync;
    {
        std::lock_guard lock(m_mutex);
        if (!m_started)
            return;

        m_accepting = false;
        m_stopping = true;
        sync = std::make_shared<SyncPoint>();
        QueueItem item;
        item.kind = ItemKind::Stop;
        item.sync = sync;
        m_queue.push_back(std::move(item));
    }
    m_cv.notify_one();

    {
        std::unique_lock lock(sync->mutex);
        sync->cv.wait(lock, [&] { return sync->done; });
    }

    if (m_worker.joinable())
        m_worker.join();

    std::lock_guard lock(m_mutex);
    m_started = false;
    m_stopping = false;
    m_queue.clear();
}

bool AsyncLogWriter::isRunning() const
{