thread_safe_writer.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "base_writer.h"
 
#include <kcenon/logger/logger_export.h>
 
#include <mutex>
 
namespace kcenon::logger {
 
class LOGGER_SYSTEM_API thread_safe_writer : public base_writer {
public:
    explicit thread_safe_writer(std::unique_ptr<log_formatter_interface> formatter = nullptr);
 
    ~thread_safe_writer() override = default;
 
    // Non-copyable and non-movable (mutex cannot be copied or moved)
    thread_safe_writer(const thread_safe_writer&) = delete;
    thread_safe_writer& operator=(const thread_safe_writer&) = delete;
    thread_safe_writer(thread_safe_writer&&) = delete;
    thread_safe_writer& operator=(thread_safe_writer&&) = delete;
 
    common::VoidResult write(const log_entry& entry) final;
 
    common::VoidResult flush() final;
 
protected:
    virtual common::VoidResult write_entry_impl(const log_entry& entry) = 0;
 
    virtual common::VoidResult flush_impl() = 0;
 
    std::mutex& get_mutex() const { return write_mutex_; }
 
private:
    mutable std::mutex write_mutex_;
};
 
} // namespace kcenon::logger