output_stream.h

Go to the documentation of this file.

// === output_stream.h =================================================================================================
//                                               Sen Infrastructure
//                   Released under the Apache License v2.0 (SPDX-License-Identifier Apache-2.0).
//                                    See the LICENSE.txt file for more information.
//                   © Airbus SAS, Airbus Helicopters, and Airbus Defence and Space SAU/GmbH/SAS.
// =====================================================================================================================
 
#ifndef SEN_CORE_IO_OUTPUT_STREAM_H
#define SEN_CORE_IO_OUTPUT_STREAM_H
 
// sen
#include "sen/core/base/numbers.h"
#include "sen/core/base/timestamp.h"
#include "sen/core/io/buffer_writer.h"
#include "sen/core/io/detail/serialization_traits.h"
 
// std
#include <cstring>
 
namespace sen
{

template <typename BufferEndian>
class OutputStreamTemplate final
{
  SEN_NOCOPY_NOMOVE(OutputStreamTemplate)
 
public:
  explicit OutputStreamTemplate(Writer& writer) noexcept: writer_(writer) {}
  ~OutputStreamTemplate() noexcept = default;
 
public:
  void writeBool(bool val) { writeBasic(impl::BoolTransportType {val ? uchar_t {1U} : uchar_t {0U}}); }
  void writeChar(char val) { writeBasic(val); }
  void writeUChar(unsigned char val) { writeBasic(val); }
  void writeInt8(int8_t val) { writeBasic(val); }
  void writeUInt8(uint8_t val) { writeBasic(val); }
  void writeInt16(int16_t val) { writeBasic(val); }
  void writeUInt16(uint16_t val) { writeBasic(val); }
  void writeInt32(int32_t val) { writeBasic(val); }
  void writeUInt32(uint32_t val) { writeBasic(val); }
  void writeInt64(int64_t val) { writeBasic(val); }
  void writeUInt64(uint64_t val) { writeBasic(val); }
  void writeFloat32(float32_t val) { writeBasic(val); }
  void writeFloat64(float64_t val) { writeBasic(val); }
  void writeString(std::string_view val);
  void writeTimestamp(TimeStamp val) { writeInt64(val.sinceEpoch().getNanoseconds()); }
 
public:
  [[nodiscard]] Writer& getWriter() noexcept { return writer_; }
  [[nodiscard]] const Writer& getWriter() const noexcept { return writer_; }
 
private:
  template <typename T>
  impl::IfBasic<T, void> writeBasic(T val);
 
private:
  Writer& writer_;
};
 
using OutputStream = OutputStreamTemplate<LittleEndian>;
 
//----------------------------------------------------------------------------------------------------------------------
// Inline implementation
//----------------------------------------------------------------------------------------------------------------------
 
template <typename BufferEndian>
inline void OutputStreamTemplate<BufferEndian>::writeString(std::string_view val)
{
  // write the size of the sequence
  auto size = static_cast<uint32_t>(val.size());
  writeUInt32(size);
 
  if (size == 0U)
  {
    return;
  }
 
  std::memcpy(writer_.advance(size), val.data(), size);
}
 
template <typename BufferEndian>
template <typename T>
inline impl::IfBasic<T, void> OutputStreamTemplate<BufferEndian>::writeBasic(T val)
{
  static_assert(std::is_trivially_copyable_v<T>);
  constexpr auto size = sizeof(T);
 
  ::sen::impl::swapBytesIfNeeded(val, BufferEndian {});
  std::memcpy(writer_.advance(size), &val, size);
}
 
}  // namespace sen
 
#endif  // SEN_CORE_IO_OUTPUT_STREAM_H