ThreadedLoggerBackend.h

Go to the documentation of this file.

// © 2019-2024 Diarkis Inc. All rights reserved.
 
#pragma once
 
#include <atomic>
#include <mutex>
#include <thread>
#include "diarkis/common.h"
#include "diarkis/results.autogen.h"
#include "diarkis/system/Component.h"
#include "diarkis/system/Thread.h"
#include "diarkis/system/result.h"
#include "logging/loggerBackends/LoggerBackend.h"
 
using namespace Diarkis::System;
 
class ThreadedLoggerBackend : public ILoggerBackend
{
    public:
        ThreadedLoggerBackend(std::shared_ptr<ILoggerBackend> loggerBackend, bool bDirect=false);
        virtual ~ThreadedLoggerBackend();
        void Stop();
 
        Result Log(const Diarkis::StdString& message, bool includeNewLine = true) override;
 
    private:
        struct LogInfo
        {
            Diarkis::StdString message;
            bool includeNewLine;
        };
 
        const std::shared_ptr<ILoggerBackend> loggerBackend_;
        std::shared_ptr<Diarkis::System::DiarkisThread> thread_;
        std::atomic<bool> isRunning_;
        std::mutex mutex_;
        Diarkis::StdQueue<LogInfo> messageQueueLog_;
 
        // Whether to output directly instead of storing in a queue.
        // This is for debugging and normally false.
        bool bDirectOutput_;
 
        void FlushLogs();
 
        static Diarkis::System::Result ThreadLoop(void*);
};