LoggerThread.hpp

Go to the documentation of this file.

// Copyright (c) 2023 Sapphire's Suite. All Rights Reserved.
 
#pragma once
 
#ifndef SAPPHIRE_LOGGER_LOGGER_THREAD_GUARD
#define SAPPHIRE_LOGGER_LOGGER_THREAD_GUARD
 
#include <SA/Logger/LoggerBase.hpp>
 
#include <SA/Logger/Misc/RingBuffer.hpp>
 
#include <mutex>
#include <thread>
 
namespace SA
{
    class LoggerThread : public LoggerBase
    {
        std::atomic<uint32_t> mFrameNum = 0u;
 
    //{ Thread
 
        std::thread mThread;
 
        std::atomic<bool> mIsRunning = true;
 
        RingBuffer<SA::Log> mRingBuffer;
 
        void ThreadLoop();
 
    //}
 
    //{ Streams
    
        std::mutex mStreamMutex;
 
        void ProcessLog(const SA::Log& _log, bool _bForce = false) override final;
 
        void RegisterStream(ALogStream* _stream) override final;
        bool UnregisterStream(ALogStream* _stream) override final;
 
    //}
 
    public:
        LoggerThread(uint32_t _ringBufferSize = 32) noexcept;
 
        ~LoggerThread();
 
        void Log(SA::Log _log) override final;
 
    //{ Streams
 
        void ClearStreams(bool _bFlush = true) override final;
 
 
        void Flush() override final;
 
 
        void EnableLogLevel(LogLevel _level) override final;
 
        void DisableLogLevel(LogLevel _level) override final;
 
 
        void EnableLogChannel(const std::wstring& _channel) override final;
 
        void DisableLogChannel(const std::wstring& _channel) override final;
 
    //}
 
 
    //{ Frame Num
 
        void IncrementFrameNum() override final;
 
        uint32_t GetFrameNum() const override final;
    //}
    };
}
 
 
#endif // GUARD