logger.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "generated/logging.pb.h"
 
#include <asio.hpp>
#include <atomic>
#include <cassert>
#include <cstdint>
#include <deque>
#include <memory>
#include <mutex>
#include <string_view>
#include <vector>
 
namespace logging {
 
class Logger {
  inline static Logger* instance = nullptr;
 
  struct {
    asio::io_context io_ctx;
    asio::ip::tcp::socket socket {io_ctx};
 
    std::deque<proto::logging::LogData> log_queue;
    std::mutex queue_mutex;

    std::atomic<bool> drain_pending = false;

    std::atomic<bool> connected = false;

    std::atomic<bool> unavailable = false;
  } m;
 
  static constexpr uint16_t port = 12800;                
  static constexpr bool auto_spawn_log_server = true;    
  static constexpr bool show_server_logs = false;        
 
public:
  static auto create() noexcept -> std::unique_ptr<Logger>;

  ~Logger() noexcept;
 
  // Copying a global logger doesn't make sense
  Logger(const Logger&) = delete;
  Logger(Logger&&) = delete;
  auto operator=(const Logger&) -> Logger& = delete;
  auto operator=(Logger&&) -> Logger& = delete;

  static void log(std::string_view file, unsigned line, char severity, std::string_view sink, std::string_view message);
 
private:
  Logger() = default;
 
  void initNetworkRetry();    
  void stop();                
  void drain();               
  auto collectQueue() -> std::vector<uint8_t>;    
  void flushSync();    
};
 
}