size_delimited_log_writer.h

Go to the documentation of this file.

// Copyright (c) Space-ng, inc. All rights reserved.
 
#pragma once
 
#include "sol3/core/stream_writer.h"
#include "sol3/cpp/filesystem.h"  // IWYU pragma: keep
 
#include <flatbuffers/flatbuffers.h>
 
#include <cstddef>
#include <cstdint>
#include <fstream>
 
namespace sol3::core {
class SizeDelimitedLogWriter : public IStreamWriter {
 public:
  explicit SizeDelimitedLogWriter(cpp::fs::path log_path);
  ~SizeDelimitedLogWriter();
 
  void open(cpp::fs::path log_path);
  void close();
  bool isOpen() const;
  cpp::fs::path const& logPath() const { return log_path_; }
 
  void writeSizePrefixed(flatbuffers::span<uint8_t const> frame);
 
  void commit(size_t message_count);
 
  void rollback();
 
  void writeNonSizePrefixedUnaligned(flatbuffers::span<uint8_t const> data);
 
  void rewriteSizePrefixed(
      size_t offset, flatbuffers::span<uint8_t const> frame);
 
  size_t currentOffset() const;
 
  void write(char const* data, size_t size) override;
 
 private:
  sol3::cpp::fs::path log_path_;
  std::fstream file_;
  size_t size_ = 0;
};
}  // namespace sol3::core