serializers/contiguous.hpp

Go to the documentation of this file.

#pragma once
 
#include "../exceptions.hpp"
#include "base.hpp"
#include <limits>
#include <string.h>
 
namespace jaffarCommon
{
 
namespace serializer
{
 
class Contiguous final : public serializer::Base
{
public:
  Contiguous(void* __restrict outputDataBuffer = nullptr, const size_t outputDataBufferSize = std::numeric_limits<uint32_t>::max())
      : serializer::Base(outputDataBuffer, outputDataBufferSize)
  {
  }
 
  ~Contiguous() = default;
 
  __JAFFAR_COMMON__INLINE__ void pushContiguous(const void* const __restrict inputDataBuffer = nullptr, const size_t inputDataSize = 0) override
  {
    // Making sure we do not exceed the maximum size estipulated
    if (_outputDataBufferPos + inputDataSize > _outputDataBufferSize)
      JAFFAR_THROW_RUNTIME("Maximum output data position (%lu) reached before contiguous serialization from pos (%lu) and input size (%lu)", _outputDataBufferSize,
                           _outputDataBufferPos, inputDataSize);
 
    // Only perform memcpy if the output block is not null
    if (_outputDataBuffer != nullptr && inputDataBuffer != nullptr) memcpy(&_outputDataBuffer[_outputDataBufferPos], inputDataBuffer, inputDataSize);
 
    // Moving output data pointer position
    _outputDataBufferPos += inputDataSize;
  }
 
  __JAFFAR_COMMON__INLINE__ void push(const void* const __restrict inputDataBuffer, const size_t inputDataSize) override { pushContiguous(inputDataBuffer, inputDataSize); }
};
 
} // namespace serializer
 
} // namespace jaffarCommon