Cdr.cpp

Go to the documentation of this file.

// Copyright 2016 Proyectos y Sistemas de Mantenimiento SL (eProsima).
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#include <cstring>
#include <limits>
 
#include <fastcdr/Cdr.h>
 
namespace eprosima {
namespace fastcdr {
 
using namespace exception;
 
#if FASTCDR_IS_BIG_ENDIAN_TARGET
const Cdr::Endianness Cdr::DEFAULT_ENDIAN = BIG_ENDIANNESS;
#else
const Cdr::Endianness Cdr::DEFAULT_ENDIAN = LITTLE_ENDIANNESS;
#endif // if FASTCDR_IS_BIG_ENDIAN_TARGET
 
constexpr uint16_t PID_EXTENDED = 0x3F01;
constexpr uint16_t PID_EXTENDED_LENGTH = 0x8;
constexpr uint16_t PID_SENTINEL = 0x3F02;
constexpr uint16_t PID_SENTINEL_LENGTH = 0x0;
 
constexpr uint8_t operator ""_8u(
        unsigned long long int value)
{
    return static_cast<uint8_t>(value);
}
 
inline size_t alignment_on_state(
        const FastBuffer::iterator& origin,
        const FastBuffer::iterator& offset,
        size_t data_size)
{
    return (data_size - ((offset - origin) % data_size)) & (data_size - 1);
}
 
inline uint32_t Cdr::get_long_lc(
        SerializedMemberSizeForNextInt serialized_member_size)
{
    uint32_t lc = 0x40000000;
 
    switch (serialized_member_size)
    {
        case SERIALIZED_MEMBER_SIZE_8:
            lc =  0x70000000;
            break;
        case SERIALIZED_MEMBER_SIZE_4:
            lc =  0x60000000;
            break;
        case SERIALIZED_MEMBER_SIZE:
            lc = 0x50000000;
            break;
        default:
            break;
    }
 
    return lc;
}
 
inline uint32_t Cdr::get_short_lc(
        size_t member_serialized_size)
{
    uint32_t lc = 0x0;
    switch (member_serialized_size)
    {
        case 2:
            lc = 0x10000000;
            break;
        case 4:
            lc = 0x20000000;
            break;
        case 8:
            lc = 0x30000000;
            break;
        default:
            break;
    }
 
    return lc;
}
 
Cdr::state::state(
        const Cdr& cdr)
    : offset_(cdr.offset_)
    , origin_(cdr.origin_)
    , swap_bytes_(cdr.swap_bytes_)
    , last_data_size_(cdr.last_data_size_)
    , next_member_id_(cdr.next_member_id_)
    , previous_encoding_(cdr.current_encoding_)
{
}
 
Cdr::state::state(
        const state& current_state)
    : offset_(current_state.offset_)
    , origin_(current_state.origin_)
    , swap_bytes_(current_state.swap_bytes_)
    , last_data_size_(current_state.last_data_size_)
    , next_member_id_(current_state.next_member_id_)
    , previous_encoding_(current_state.previous_encoding_)
{
}
 
bool Cdr::state::operator ==(
        const Cdr::state& other_state) const
{
    return
        other_state.offset_ == offset_ &&
        other_state.origin_ == origin_ &&
        other_state.swap_bytes_ == swap_bytes_ &&
        (0 == other_state.last_data_size_ ||
        0 == last_data_size_ ||
        other_state.last_data_size_ == last_data_size_
        );
}
 
Cdr::Cdr(
        FastBuffer& cdr_buffer,
        const Endianness endianness,
        const CdrVersion cdr_version)
    : cdr_buffer_(cdr_buffer)
    , cdr_version_(cdr_version)
    , endianness_(endianness)
    , swap_bytes_(endianness == DEFAULT_ENDIAN ? false : true)
    , offset_(cdr_buffer.begin())
    , origin_(cdr_buffer.begin())
    , end_(cdr_buffer.end())
{
    switch (cdr_version_)
    {
        case CdrVersion::XCDRv2:
            break;
        case CdrVersion::XCDRv1:
            align64_ = 8;
            encoding_flag_ = EncodingAlgorithmFlag::PLAIN_CDR;
            current_encoding_ = EncodingAlgorithmFlag::PLAIN_CDR;
            break;
        default:
            align64_ = 8;
            encoding_flag_ = EncodingAlgorithmFlag::PLAIN_CDR;
            current_encoding_ = EncodingAlgorithmFlag::PLAIN_CDR;
            break;
    }
    reset_callbacks();
}
 
void Cdr::reset_callbacks()
{
    switch (cdr_version_)
    {
        case CdrVersion::XCDRv2:
            begin_serialize_member_ = &Cdr::xcdr2_begin_serialize_member;
            end_serialize_member_ = &Cdr::xcdr2_end_serialize_member;
            begin_serialize_opt_member_ = &Cdr::xcdr2_begin_serialize_member;
            end_serialize_opt_member_ = &Cdr::xcdr2_end_serialize_member;
            begin_serialize_type_ = &Cdr::xcdr2_begin_serialize_type;
            end_serialize_type_ = &Cdr::xcdr2_end_serialize_type;
            deserialize_type_ = &Cdr::xcdr2_deserialize_type;
            break;
        case CdrVersion::XCDRv1:
            begin_serialize_member_ = &Cdr::xcdr1_begin_serialize_member;
            end_serialize_member_ = &Cdr::xcdr1_end_serialize_member;
            begin_serialize_opt_member_ = &Cdr::xcdr1_begin_serialize_opt_member;
            end_serialize_opt_member_ = &Cdr::xcdr1_end_serialize_opt_member;
            begin_serialize_type_ = &Cdr::xcdr1_begin_serialize_type;
            end_serialize_type_ = &Cdr::xcdr1_end_serialize_type;
            deserialize_type_ = &Cdr::xcdr1_deserialize_type;
            break;
        default:
            begin_serialize_member_ = &Cdr::cdr_begin_serialize_member;
            end_serialize_member_ = &Cdr::cdr_end_serialize_member;
            begin_serialize_opt_member_ = &Cdr::cdr_begin_serialize_member;
            end_serialize_opt_member_ = &Cdr::cdr_end_serialize_member;
            begin_serialize_type_ = &Cdr::cdr_begin_serialize_type;
            end_serialize_type_ = &Cdr::cdr_end_serialize_type;
            deserialize_type_ = &Cdr::cdr_deserialize_type;
            break;
    }
}
 
Cdr& Cdr::read_encapsulation()
{
    uint8_t dummy {0};
    uint8_t encapsulation {0};
    state state_before_error(*this);
 
    try
    {
        // If it is DDS_CDR, the first step is to get the dummy byte.
        if (CdrVersion::CORBA_CDR < cdr_version_)
        {
            (*this) >> dummy;
            if (0 != dummy)
            {
                throw BadParamException("Unexpected non-zero initial byte received in Cdr::read_encapsulation");
            }
        }
 
        // Get the ecampsulation byte.
        (*this) >> encapsulation;
 
 
        // If it is a different endianness, make changes.
        const uint8_t endianness = encapsulation & 0x1_8u;
        if (endianness_ != endianness)
        {
            swap_bytes_ = !swap_bytes_;
            endianness_ = endianness;
        }
 
        // Check encapsulationKind correctness
        const uint8_t encoding_flag = encapsulation & static_cast<uint8_t>(~0x1);
        switch (encoding_flag)
        {
            case EncodingAlgorithmFlag::PLAIN_CDR2:
            case EncodingAlgorithmFlag::DELIMIT_CDR2:
            case EncodingAlgorithmFlag::PL_CDR2:
                if (CdrVersion::XCDRv1 <= cdr_version_)
                {
                    cdr_version_ = CdrVersion::XCDRv2;
                    align64_ = 4;
                }
                else
                {
                    throw BadParamException(
                              "Unexpected encoding algorithm received in Cdr::read_encapsulation. XCDRv2 should be selected.");
                }
                break;
            case EncodingAlgorithmFlag::PL_CDR:
                if (CdrVersion::XCDRv1 <= cdr_version_)
                {
                    cdr_version_ = CdrVersion::XCDRv1;
                    align64_ = 8;
                }
                else
                {
                    throw BadParamException(
                              "Unexpected encoding algorithm received in Cdr::read_encapsulation. XCDRv1 should be selected");
                }
                break;
            case EncodingAlgorithmFlag::PLAIN_CDR:
                if (CdrVersion::XCDRv1 <= cdr_version_)
                {
                    cdr_version_ = CdrVersion::XCDRv1;
                    align64_ = 8;
                }
                break;
            default:
                throw BadParamException("Unexpected encoding algorithm received in Cdr::read_encapsulation for DDS CDR");
        }
        reset_callbacks();
 
        encoding_flag_ = static_cast<EncodingAlgorithmFlag>(encoding_flag);
        current_encoding_ = encoding_flag_;
 
        if (CdrVersion::CORBA_CDR < cdr_version_)
        {
            deserialize(options_);
        }
    }
    catch (Exception& ex)
    {
        set_state(state_before_error);
        ex.raise();
    }
 
    reset_alignment();
    return *this;
}
 
Cdr& Cdr::serialize_encapsulation()
{
    uint8_t dummy = 0;
    uint8_t encapsulation = 0;
    state state_before_error(*this);
 
    try
    {
        // If it is DDS_CDR, the first step is to serialize the dummy byte.
        if (CdrVersion::CORBA_CDR < cdr_version_)
        {
            (*this) << dummy;
        }
 
        // Construct encapsulation byte.
        encapsulation = (encoding_flag_ | endianness_);
 
        // Serialize the encapsulation byte.
        (*this) << encapsulation;
 
        current_encoding_ = encoding_flag_;
    }
    catch (Exception& ex)
    {
        set_state(state_before_error);
        ex.raise();
    }
 
    try
    {
        if (CdrVersion::CORBA_CDR < cdr_version_)
        {
            serialize(options_);
        }
    }
    catch (Exception& ex)
    {
        set_state(state_before_error);
        ex.raise();
    }
 
    reset_alignment();
    return *this;
}
 
CdrVersion Cdr::get_cdr_version() const
{
    return cdr_version_;
}
 
EncodingAlgorithmFlag Cdr::get_encoding_flag() const
{
    return encoding_flag_;
}
 
bool Cdr::set_encoding_flag(
        EncodingAlgorithmFlag encoding_flag)
{
    bool ret_value = false;
 
    if (CdrVersion::CORBA_CDR != cdr_version_)
    {
        if (offset_ == cdr_buffer_.begin())
        {
            encoding_flag_ = encoding_flag;
            ret_value = true;
        }
    }
 
    return ret_value;
}
 
std::array<uint8_t, 2> Cdr::get_dds_cdr_options() const
{
    return options_;
}
 
void Cdr::set_dds_cdr_options(
        const std::array<uint8_t, 2>& options)
{
    options_ = options;
}
 
void Cdr::change_endianness(
        Endianness endianness)
{
    if (endianness_ != endianness)
    {
        swap_bytes_ = !swap_bytes_;
        endianness_ = endianness;
    }
}
 
Cdr::Endianness Cdr::endianness() const
{
    return static_cast<Endianness>(endianness_);
}
 
bool Cdr::jump(
        size_t num_bytes)
{
    bool ret_value = false;
 
    if (((end_ - offset_) >= num_bytes) || resize(num_bytes))
    {
        offset_ += num_bytes;
        last_data_size_ = 0;
        ret_value = true;
    }
 
    return ret_value;
}
 
char* Cdr::get_buffer_pointer()
{
    return cdr_buffer_.getBuffer();
}
 
char* Cdr::get_current_position()
{
    return &offset_;
}
 
size_t Cdr::get_serialized_data_length() const
{
    return offset_ - cdr_buffer_.begin();
}
 
Cdr::state Cdr::get_state() const
{
    return Cdr::state(*this);
}
 
void Cdr::set_state(
        const state& current_state)
{
    offset_ >> current_state.offset_;
    origin_ >> current_state.origin_;
    swap_bytes_ = current_state.swap_bytes_;
    last_data_size_ = current_state.last_data_size_;
    next_member_id_ = current_state.next_member_id_;
}
 
void Cdr::reset()
{
    offset_ = cdr_buffer_.begin();
    origin_ = cdr_buffer_.begin();
    swap_bytes_ = endianness_ == DEFAULT_ENDIAN ? false : true;
    last_data_size_ = 0;
    encoding_flag_ = CdrVersion::XCDRv2 ==
            cdr_version_ ? EncodingAlgorithmFlag::PLAIN_CDR2 : EncodingAlgorithmFlag::PLAIN_CDR;
    current_encoding_ = encoding_flag_;
    next_member_id_ = MEMBER_ID_INVALID;
    options_ = {0, 0};
}
 
bool Cdr::move_alignment_forward(
        size_t num_bytes)
{
    bool ret_value = false;
 
    if (((end_ - origin_) >= num_bytes) || resize(num_bytes))
    {
        origin_ += num_bytes;
        last_data_size_ = 0;
        ret_value = true;
    }
 
    return ret_value;
}
 
bool Cdr::resize(
        size_t min_size_inc)
{
    if (cdr_buffer_.resize(min_size_inc))
    {
        offset_ << cdr_buffer_.begin();
        origin_ << cdr_buffer_.begin();
        end_ = cdr_buffer_.end();
        return true;
    }
 
    return false;
}
 
Cdr& Cdr::serialize(
        const char char_t)
{
    if (((end_ - offset_) >= sizeof(char_t)) || resize(sizeof(char_t)))
    {
        // Save last datasize.
        last_data_size_ = sizeof(char_t);
 
        offset_++ << char_t;
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const int16_t short_t)
{
    size_t align = alignment(sizeof(short_t));
    size_t size_aligned = sizeof(short_t) + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = sizeof(short_t);
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(&short_t);
 
            offset_++ << dst[1];
            offset_++ << dst[0];
        }
        else
        {
            offset_ << short_t;
            offset_ += sizeof(short_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const int32_t long_t)
{
    size_t align = alignment(sizeof(long_t));
    size_t size_aligned = sizeof(long_t) + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = sizeof(long_t);
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(&long_t);
 
            offset_++ << dst[3];
            offset_++ << dst[2];
            offset_++ << dst[1];
            offset_++ << dst[0];
        }
        else
        {
            offset_ << long_t;
            offset_ += sizeof(long_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const int64_t longlong_t)
{
    size_t align = alignment(align64_);
    size_t size_aligned = sizeof(longlong_t) + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(&longlong_t);
 
            offset_++ << dst[7];
            offset_++ << dst[6];
            offset_++ << dst[5];
            offset_++ << dst[4];
            offset_++ << dst[3];
            offset_++ << dst[2];
            offset_++ << dst[1];
            offset_++ << dst[0];
        }
        else
        {
            offset_ << longlong_t;
            offset_ += sizeof(longlong_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const float float_t)
{
    size_t align = alignment(sizeof(float_t));
    size_t size_aligned = sizeof(float_t) + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = sizeof(float_t);
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(&float_t);
 
            offset_++ << dst[3];
            offset_++ << dst[2];
            offset_++ << dst[1];
            offset_++ << dst[0];
        }
        else
        {
            offset_ << float_t;
            offset_ += sizeof(float_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const double double_t)
{
    size_t align = alignment(align64_);
    size_t size_aligned = sizeof(double_t) + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(&double_t);
 
            offset_++ << dst[7];
            offset_++ << dst[6];
            offset_++ << dst[5];
            offset_++ << dst[4];
            offset_++ << dst[3];
            offset_++ << dst[2];
            offset_++ << dst[1];
            offset_++ << dst[0];
        }
        else
        {
            offset_ << double_t;
            offset_ += sizeof(double_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const long double ldouble_t)
{
    size_t align = alignment(align64_);
    size_t size_aligned = sizeof(ldouble_t) + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
#if FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
            __float128 tmp = ldouble_t;
            const char* dst = reinterpret_cast<const char*>(&tmp);
#else
            const char* dst = reinterpret_cast<const char*>(&ldouble_t);
#endif // FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
#if FASTCDR_HAVE_FLOAT128 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
            offset_++ << dst[15];
            offset_++ << dst[14];
            offset_++ << dst[13];
            offset_++ << dst[12];
            offset_++ << dst[11];
            offset_++ << dst[10];
            offset_++ << dst[9];
            offset_++ << dst[8];
            offset_++ << dst[7];
            offset_++ << dst[6];
            offset_++ << dst[5];
            offset_++ << dst[4];
            offset_++ << dst[3];
            offset_++ << dst[2];
            offset_++ << dst[1];
            offset_++ << dst[0];
#else
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8
            // Filled with 0's.
            offset_++ << static_cast<char>(0);
            offset_++ << static_cast<char>(0);
            offset_++ << static_cast<char>(0);
            offset_++ << static_cast<char>(0);
            offset_++ << static_cast<char>(0);
            offset_++ << static_cast<char>(0);
            offset_++ << static_cast<char>(0);
            offset_++ << static_cast<char>(0);
            offset_++ << dst[7];
            offset_++ << dst[6];
            offset_++ << dst[5];
            offset_++ << dst[4];
            offset_++ << dst[3];
            offset_++ << dst[2];
            offset_++ << dst[1];
            offset_++ << dst[0];
#else
#error unsupported long double type and no __float128 available
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8
#endif // FASTCDR_HAVE_FLOAT128 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
        }
        else
        {
#if FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
            __float128 tmp = ldouble_t;
            offset_ << tmp;
            offset_ += 16;
#else
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8
            offset_ << static_cast<long double>(0);
            offset_ += sizeof(ldouble_t);
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
            offset_ << ldouble_t;
            offset_ += sizeof(ldouble_t);
#else
#error unsupported long double type and no __float128 available
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
#endif // FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const bool bool_t)
{
    if (((end_ - offset_) >= sizeof(uint8_t)) || resize(sizeof(uint8_t)))
    {
        // Save last datasize.
        last_data_size_ = sizeof(uint8_t);
 
        if (bool_t)
        {
            offset_++ << static_cast<uint8_t>(1);
        }
        else
        {
            offset_++ << static_cast<uint8_t>(0);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize(
        const char* string_t)
{
    uint32_t length = 0;
 
    if (string_t != nullptr)
    {
        length = size_to_uint32(strlen(string_t)) + 1;
    }
 
    if (length > 0)
    {
        Cdr::state state_before_error(*this);
        serialize(length);
 
        if (((end_ - offset_) >= length) || resize(length))
        {
            // Save last datasize.
            last_data_size_ = sizeof(uint8_t);
 
            offset_.memcopy(string_t, length);
            offset_ += length;
        }
        else
        {
            set_state(state_before_error);
            throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
        }
    }
    else
    {
        serialize(length);
    }
 
    serialized_member_size_ = SERIALIZED_MEMBER_SIZE;
 
    return *this;
}
 
Cdr& Cdr::serialize(
        const wchar_t* string_t)
{
    uint32_t bytes_length = 0;
    size_t wstrlen = 0;
 
    if (string_t != nullptr)
    {
        wstrlen = wcslen(string_t);
        bytes_length = size_to_uint32(wstrlen * 2);
    }
 
    if (bytes_length > 0)
    {
        Cdr::state state_(*this);
        serialize(size_to_uint32(wstrlen));
 
        if (((end_ - offset_) >= bytes_length) || resize(bytes_length))
        {
            serialize_array(string_t, wstrlen);
        }
        else
        {
            set_state(state_);
            throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
        }
    }
    else
    {
        serialize(bytes_length);
    }
 
    return *this;
}
 
Cdr& Cdr::serialize_array(
        const bool* bool_t,
        size_t num_elements)
{
    size_t total_size = sizeof(*bool_t) * num_elements;
 
    if (((end_ - offset_) >= total_size) || resize(total_size))
    {
        // Save last datasize.
        last_data_size_ = sizeof(*bool_t);
 
        for (size_t count = 0; count < num_elements; ++count)
        {
            uint8_t value = 0;
 
            if (bool_t[count])
            {
                value = 1;
            }
            offset_++ << value;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_array(
        const char* char_t,
        size_t num_elements)
{
    size_t total_size = sizeof(*char_t) * num_elements;
 
    if (((end_ - offset_) >= total_size) || resize(total_size))
    {
        // Save last datasize.
        last_data_size_ = sizeof(*char_t);
 
        offset_.memcopy(char_t, total_size);
        offset_ += total_size;
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_array(
        const int16_t* short_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(sizeof(*short_t));
    size_t total_size = sizeof(*short_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = sizeof(*short_t);
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(short_t);
            const char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*short_t))
            {
                offset_++ << dst[1];
                offset_++ << dst[0];
            }
        }
        else
        {
            offset_.memcopy(short_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_array(
        const int32_t* long_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(sizeof(*long_t));
    size_t total_size = sizeof(*long_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = sizeof(*long_t);
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(long_t);
            const char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*long_t))
            {
                offset_++ << dst[3];
                offset_++ << dst[2];
                offset_++ << dst[1];
                offset_++ << dst[0];
            }
        }
        else
        {
            offset_.memcopy(long_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_array(
        const wchar_t* wchar,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    for (size_t count = 0; count < num_elements; ++count)
    {
        serialize(wchar[count]);
    }
    return *this;
}
 
Cdr& Cdr::serialize_array(
        const int64_t* longlong_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(align64_);
    size_t total_size = sizeof(*longlong_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(longlong_t);
            const char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*longlong_t))
            {
                offset_++ << dst[7];
                offset_++ << dst[6];
                offset_++ << dst[5];
                offset_++ << dst[4];
                offset_++ << dst[3];
                offset_++ << dst[2];
                offset_++ << dst[1];
                offset_++ << dst[0];
            }
        }
        else
        {
            offset_.memcopy(longlong_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_array(
        const float* float_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(sizeof(*float_t));
    size_t total_size = sizeof(*float_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = sizeof(*float_t);
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(float_t);
            const char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*float_t))
            {
                offset_++ << dst[3];
                offset_++ << dst[2];
                offset_++ << dst[1];
                offset_++ << dst[0];
            }
        }
        else
        {
            offset_.memcopy(float_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_array(
        const double* double_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(align64_);
    size_t total_size = sizeof(*double_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(double_t);
            const char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*double_t))
            {
                offset_++ << dst[7];
                offset_++ << dst[6];
                offset_++ << dst[5];
                offset_++ << dst[4];
                offset_++ << dst[3];
                offset_++ << dst[2];
                offset_++ << dst[1];
                offset_++ << dst[0];
            }
        }
        else
        {
            offset_.memcopy(double_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_array(
        const long double* ldouble_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(align64_);
    // Fix for Windows ( long doubles only store 8 bytes )
    size_t total_size = 16 * num_elements; // sizeof(*ldouble_t)
    size_t size_aligned = total_size + align;
 
    if (((end_ - offset_) >= size_aligned) || resize(size_aligned))
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
#if FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
        if (swap_bytes_)
        {
            for (size_t i = 0; i < num_elements; ++i, ++ldouble_t)
            {
                __float128 tmp = *ldouble_t;
                const char* dst = reinterpret_cast<const char*>(&tmp);
                offset_++ << dst[15];
                offset_++ << dst[14];
                offset_++ << dst[13];
                offset_++ << dst[12];
                offset_++ << dst[11];
                offset_++ << dst[10];
                offset_++ << dst[9];
                offset_++ << dst[8];
                offset_++ << dst[7];
                offset_++ << dst[6];
                offset_++ << dst[5];
                offset_++ << dst[4];
                offset_++ << dst[3];
                offset_++ << dst[2];
                offset_++ << dst[1];
                offset_++ << dst[0];
            }
        }
        else
        {
            for (size_t i = 0; i < num_elements; ++i, ++ldouble_t)
            {
                __float128 tmp = *ldouble_t;
                offset_ << tmp;
                offset_ += 16;
            }
        }
#else
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
        if (swap_bytes_)
        {
            const char* dst = reinterpret_cast<const char*>(ldouble_t);
            const char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*ldouble_t))
            {
#if FASTCDR_SIZEOF_LONG_DOUBLE == 16
                offset_++ << dst[15];
                offset_++ << dst[14];
                offset_++ << dst[13];
                offset_++ << dst[12];
                offset_++ << dst[11];
                offset_++ << dst[10];
                offset_++ << dst[9];
                offset_++ << dst[8];
#else
                offset_++ << static_cast<char>(0);
                offset_++ << static_cast<char>(0);
                offset_++ << static_cast<char>(0);
                offset_++ << static_cast<char>(0);
                offset_++ << static_cast<char>(0);
                offset_++ << static_cast<char>(0);
                offset_++ << static_cast<char>(0);
                offset_++ << static_cast<char>(0);
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 16
                offset_++ << dst[7];
                offset_++ << dst[6];
                offset_++ << dst[5];
                offset_++ << dst[4];
                offset_++ << dst[3];
                offset_++ << dst[2];
                offset_++ << dst[1];
                offset_++ << dst[0];
            }
        }
        else
        {
#if FASTCDR_SIZEOF_LONG_DOUBLE == 16
            offset_.memcopy(ldouble_t, total_size);
            offset_ += total_size;
#else
            for (size_t i = 0; i < num_elements; ++i)
            {
                offset_ << static_cast<long double>(0);
                offset_ += 8;
                offset_ << ldouble_t[i];
                offset_ += 8;
            }
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 16
        }
#else
#error unsupported long double type and no __float128 available
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
#endif // FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        char& char_t)
{
    if ((end_ - offset_) >= sizeof(char_t))
    {
        // Save last datasize.
        last_data_size_ = sizeof(char_t);
 
        offset_++ >> char_t;
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        int16_t& short_t)
{
    size_t align = alignment(sizeof(short_t));
    size_t size_aligned = sizeof(short_t) + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = sizeof(short_t);
 
        // Align
        make_alignment(align);
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(&short_t);
 
            offset_++ >> dst[1];
            offset_++ >> dst[0];
        }
        else
        {
            offset_ >> short_t;
            offset_ += sizeof(short_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        int32_t& long_t)
{
    size_t align = alignment(sizeof(long_t));
    size_t size_aligned = sizeof(long_t) + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = sizeof(long_t);
 
        // Align
        make_alignment(align);
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(&long_t);
 
            offset_++ >> dst[3];
            offset_++ >> dst[2];
            offset_++ >> dst[1];
            offset_++ >> dst[0];
        }
        else
        {
            offset_ >> long_t;
            offset_ += sizeof(long_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        int64_t& longlong_t)
{
    size_t align = alignment(align64_);
    size_t size_aligned = sizeof(longlong_t) + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(&longlong_t);
 
            offset_++ >> dst[7];
            offset_++ >> dst[6];
            offset_++ >> dst[5];
            offset_++ >> dst[4];
            offset_++ >> dst[3];
            offset_++ >> dst[2];
            offset_++ >> dst[1];
            offset_++ >> dst[0];
        }
        else
        {
            offset_ >> longlong_t;
            offset_ += sizeof(longlong_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        float& float_t)
{
    size_t align = alignment(sizeof(float_t));
    size_t size_aligned = sizeof(float_t) + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = sizeof(float_t);
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(&float_t);
 
            offset_++ >> dst[3];
            offset_++ >> dst[2];
            offset_++ >> dst[1];
            offset_++ >> dst[0];
        }
        else
        {
            offset_ >> float_t;
            offset_ += sizeof(float_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        double& double_t)
{
    size_t align = alignment(align64_);
    size_t size_aligned = sizeof(double_t) + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(&double_t);
 
            offset_++ >> dst[7];
            offset_++ >> dst[6];
            offset_++ >> dst[5];
            offset_++ >> dst[4];
            offset_++ >> dst[3];
            offset_++ >> dst[2];
            offset_++ >> dst[1];
            offset_++ >> dst[0];
        }
        else
        {
            offset_ >> double_t;
            offset_ += sizeof(double_t);
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        long double& ldouble_t)
{
    size_t align = alignment(align64_);
    size_t size_aligned = sizeof(ldouble_t) + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align.
        make_alignment(align);
 
        if (swap_bytes_)
        {
#if FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
            __float128 tmp = ldouble_t;
            char* dst = reinterpret_cast<char*>(&tmp);
#else
            char* dst = reinterpret_cast<char*>(&ldouble_t);
#endif // FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
#if FASTCDR_HAVE_FLOAT128 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
            offset_++ >> dst[15];
            offset_++ >> dst[14];
            offset_++ >> dst[13];
            offset_++ >> dst[12];
            offset_++ >> dst[11];
            offset_++ >> dst[10];
            offset_++ >> dst[9];
            offset_++ >> dst[8];
            offset_++ >> dst[7];
            offset_++ >> dst[6];
            offset_++ >> dst[5];
            offset_++ >> dst[4];
            offset_++ >> dst[3];
            offset_++ >> dst[2];
            offset_++ >> dst[1];
            offset_++ >> dst[0];
#if FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
            ldouble_t = static_cast<long double>(tmp);
#endif // FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
#else
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8
            offset_ += 8;
            offset_++ >> dst[7];
            offset_++ >> dst[6];
            offset_++ >> dst[5];
            offset_++ >> dst[4];
            offset_++ >> dst[3];
            offset_++ >> dst[2];
            offset_++ >> dst[1];
            offset_++ >> dst[0];
#else
#error unsupported long double type and no __float128 available
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8
#endif // FASTCDR_HAVE_FLOAT128 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
        }
        else
        {
#if FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
            __float128 tmp;
            offset_ >> tmp;
            offset_ += 16;
            ldouble_t = static_cast<long double>(tmp);
#else
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8
            offset_ += 8;
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8
            offset_ >> ldouble_t;
            offset_ += sizeof(ldouble_t);
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
#endif // FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        bool& bool_t)
{
    uint8_t value = 0;
 
    if ((end_ - offset_) >= sizeof(uint8_t))
    {
        // Save last datasize.
        last_data_size_ = sizeof(uint8_t);
 
        offset_++ >> value;
 
        if (value == 1)
        {
            bool_t = true;
            return *this;
        }
        else if (value == 0)
        {
            bool_t = false;
            return *this;
        }
 
        throw BadParamException("Unexpected byte value in Cdr::deserialize(bool), expected 0 or 1");
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        char*& string_t)
{
    uint32_t length = 0;
    Cdr::state state_before_error(*this);
 
    deserialize(length);
 
    if (length == 0)
    {
        string_t = nullptr;
        return *this;
    }
    else if ((end_ - offset_) >= length)
    {
        // Save last datasize.
        last_data_size_ = sizeof(uint8_t);
 
        // Allocate memory.
        string_t =
                reinterpret_cast<char*>(calloc(length + ((&offset_)[length - 1] == '\0' ? 0 : 1),
                sizeof(char)));
        memcpy(string_t, &offset_, length);
        offset_ += length;
        return *this;
    }
 
    set_state(state_before_error);
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize(
        wchar_t*& string_t)
{
    uint32_t length = 0;
    Cdr::state state_before_error(*this);
 
    deserialize(length);
 
    if (length == 0)
    {
        string_t = nullptr;
        return *this;
    }
    else if ((end_ - offset_) >= (length * 2))
    {
        // Save last datasize.
        last_data_size_ = sizeof(uint16_t);
        // Allocate memory.
        string_t = reinterpret_cast<wchar_t*>(calloc(length + 1, sizeof(wchar_t))); // WStrings never serialize terminating zero
 
        deserialize_array(string_t, length);
 
        return *this;
    }
 
    set_state(state_before_error);
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
const char* Cdr::read_string(
        uint32_t& length)
{
    const char* ret_value = "";
    state state_before_error(*this);
 
    *this >> length;
 
    if (length == 0)
    {
        return ret_value;
    }
    else if ((end_ - offset_) >= length)
    {
        // Save last datasize.
        last_data_size_ = sizeof(uint8_t);
 
        ret_value = &offset_;
        offset_ += length;
        if (ret_value[length - 1] == '\0')
        {
            --length;
        }
        return ret_value;
    }
 
    set_state(state_before_error);
    throw exception::NotEnoughMemoryException(
              exception::NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
const std::wstring Cdr::read_wstring(
        uint32_t& length)
{
    std::wstring ret_value = L"";
    state state_(*this);
 
    *this >> length;
    uint32_t bytes_length = length * 2;
 
    if (bytes_length == 0)
    {
        return ret_value;
    }
    else if ((end_ - offset_) >= bytes_length)
    {
        // Save last datasize.
        last_data_size_ = sizeof(uint16_t);
 
        ret_value.resize(length);
        deserialize_array(const_cast<wchar_t*>(ret_value.c_str()), length);
        if (ret_value[length - 1] == L'\0')
        {
            --length;
            ret_value.erase(length);
        }
        return ret_value;
    }
 
    set_state(state_);
    throw exception::NotEnoughMemoryException(
              exception::NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        bool* bool_t,
        size_t num_elements)
{
    size_t total_size = sizeof(*bool_t) * num_elements;
 
    if ((end_ - offset_) >= total_size)
    {
        // Save last datasize.
        last_data_size_ = sizeof(*bool_t);
 
        for (size_t count = 0; count < num_elements; ++count)
        {
            uint8_t value = 0;
            offset_++ >> value;
 
            if (value == 1)
            {
                bool_t[count] = true;
            }
            else if (value == 0)
            {
                bool_t[count] = false;
            }
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        char* char_t,
        size_t num_elements)
{
    size_t total_size = sizeof(*char_t) * num_elements;
 
    if ((end_ - offset_) >= total_size)
    {
        // Save last datasize.
        last_data_size_ = sizeof(*char_t);
 
        offset_.rmemcopy(char_t, total_size);
        offset_ += total_size;
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        int16_t* short_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(sizeof(*short_t));
    size_t total_size = sizeof(*short_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = sizeof(*short_t);
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(short_t);
            char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*short_t))
            {
                offset_++ >> dst[1];
                offset_++ >> dst[0];
            }
        }
        else
        {
            offset_.rmemcopy(short_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        int32_t* long_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(sizeof(*long_t));
    size_t total_size = sizeof(*long_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = sizeof(*long_t);
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(long_t);
            char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*long_t))
            {
                offset_++ >> dst[3];
                offset_++ >> dst[2];
                offset_++ >> dst[1];
                offset_++ >> dst[0];
            }
        }
        else
        {
            offset_.rmemcopy(long_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        wchar_t* wchar,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    uint16_t value;
    for (size_t count = 0; count < num_elements; ++count)
    {
        deserialize(value);
        wchar[count] = static_cast<wchar_t>(value);
    }
    return *this;
}
 
Cdr& Cdr::deserialize_array(
        int64_t* longlong_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(align64_);
    size_t total_size = sizeof(*longlong_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(longlong_t);
            char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*longlong_t))
            {
                offset_++ >> dst[7];
                offset_++ >> dst[6];
                offset_++ >> dst[5];
                offset_++ >> dst[4];
                offset_++ >> dst[3];
                offset_++ >> dst[2];
                offset_++ >> dst[1];
                offset_++ >> dst[0];
            }
        }
        else
        {
            offset_.rmemcopy(longlong_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        float* float_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(sizeof(*float_t));
    size_t total_size = sizeof(*float_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = sizeof(*float_t);
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(float_t);
            char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*float_t))
            {
                offset_++ >> dst[3];
                offset_++ >> dst[2];
                offset_++ >> dst[1];
                offset_++ >> dst[0];
            }
        }
        else
        {
            offset_.rmemcopy(float_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        double* double_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(align64_);
    size_t total_size = sizeof(*double_t) * num_elements;
    size_t size_aligned = total_size + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(double_t);
            char* end = dst + total_size;
 
            for (; dst < end; dst += sizeof(*double_t))
            {
                offset_++ >> dst[7];
                offset_++ >> dst[6];
                offset_++ >> dst[5];
                offset_++ >> dst[4];
                offset_++ >> dst[3];
                offset_++ >> dst[2];
                offset_++ >> dst[1];
                offset_++ >> dst[0];
            }
        }
        else
        {
            offset_.rmemcopy(double_t, total_size);
            offset_ += total_size;
        }
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::deserialize_array(
        long double* ldouble_t,
        size_t num_elements)
{
    if (num_elements == 0)
    {
        return *this;
    }
 
    size_t align = alignment(align64_);
    // Fix for Windows ( long doubles only store 8 bytes )
    size_t total_size = 16 * num_elements;
    size_t size_aligned = total_size + align;
 
    if ((end_ - offset_) >= size_aligned)
    {
        // Save last datasize.
        last_data_size_ = align64_;
 
        // Align if there are any elements
        if (num_elements)
        {
            make_alignment(align);
        }
 
#if FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
        if (swap_bytes_)
        {
            for (size_t i = 0; i < num_elements; ++i)
            {
                __float128 tmp;
                char* dst = reinterpret_cast<char*>(&tmp);
                offset_++ >> dst[15];
                offset_++ >> dst[14];
                offset_++ >> dst[13];
                offset_++ >> dst[12];
                offset_++ >> dst[11];
                offset_++ >> dst[10];
                offset_++ >> dst[9];
                offset_++ >> dst[8];
                offset_++ >> dst[7];
                offset_++ >> dst[6];
                offset_++ >> dst[5];
                offset_++ >> dst[4];
                offset_++ >> dst[3];
                offset_++ >> dst[2];
                offset_++ >> dst[1];
                offset_++ >> dst[0];
                ldouble_t[i] = static_cast<long double>(tmp);
            }
        }
        else
        {
            for (size_t i = 0; i < num_elements; ++i)
            {
                __float128 tmp;
                offset_ >> tmp;
                offset_ += 16;
                ldouble_t[i] = static_cast<long double>(tmp);
            }
        }
#else
#if FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
        if (swap_bytes_)
        {
            char* dst = reinterpret_cast<char*>(ldouble_t);
            char* end = dst + num_elements * sizeof(*ldouble_t);
 
            for (; dst < end; dst += sizeof(*ldouble_t))
            {
#if FASTCDR_SIZEOF_LONG_DOUBLE == 16
                offset_++ >> dst[15];
                offset_++ >> dst[14];
                offset_++ >> dst[13];
                offset_++ >> dst[12];
                offset_++ >> dst[11];
                offset_++ >> dst[10];
                offset_++ >> dst[9];
                offset_++ >> dst[8];
#else
                offset_ += 8;
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 16
                offset_++ >> dst[7];
                offset_++ >> dst[6];
                offset_++ >> dst[5];
                offset_++ >> dst[4];
                offset_++ >> dst[3];
                offset_++ >> dst[2];
                offset_++ >> dst[1];
                offset_++ >> dst[0];
            }
        }
        else
        {
#if FASTCDR_SIZEOF_LONG_DOUBLE == 16
            offset_.rmemcopy(ldouble_t, total_size);
            offset_ += total_size;
#else
            for (size_t i = 0; i < num_elements; ++i)
            {
                offset_ += 8; // ignore first 8 bytes
                offset_ >> ldouble_t[i];
                offset_ += 8;
            }
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 16
        }
#endif // FASTCDR_SIZEOF_LONG_DOUBLE == 8 || FASTCDR_SIZEOF_LONG_DOUBLE == 16
#endif // FASTCDR_HAVE_FLOAT128 && FASTCDR_SIZEOF_LONG_DOUBLE < 16
 
        return *this;
    }
 
    throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
}
 
Cdr& Cdr::serialize_bool_array(
        const std::vector<bool>& vector_t)
{
    state state_before_error(*this);
 
    size_t total_size = vector_t.size() * sizeof(bool);
 
    if (((end_ - offset_) >= total_size) || resize(total_size))
    {
        // Save last datasize.
        last_data_size_ = sizeof(bool);
 
        for (size_t count = 0; count < vector_t.size(); ++count)
        {
            uint8_t value = 0;
            std::vector<bool>::const_reference ref = vector_t[count];
 
            if (ref)
            {
                value = 1;
            }
            offset_++ << value;
        }
    }
    else
    {
        set_state(state_before_error);
        throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
    }
 
    if (CdrVersion::XCDRv2 == cdr_version_)
    {
        serialized_member_size_ = SERIALIZED_MEMBER_SIZE;
    }
 
    return *this;
}
 
Cdr& Cdr::serialize_bool_sequence(
        const std::vector<bool>& vector_t)
{
    state state_before_error(*this);
 
    *this << static_cast<int32_t>(vector_t.size());
 
    size_t total_size = vector_t.size() * sizeof(bool);
 
    if (((end_ - offset_) >= total_size) || resize(total_size))
    {
        // Save last datasize.
        last_data_size_ = sizeof(bool);
 
        for (size_t count = 0; count < vector_t.size(); ++count)
        {
            uint8_t value = 0;
            std::vector<bool>::const_reference ref = vector_t[count];
 
            if (ref)
            {
                value = 1;
            }
            offset_++ << value;
        }
    }
    else
    {
        set_state(state_before_error);
        throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
    }
 
    if (CdrVersion::XCDRv2 == cdr_version_)
    {
        serialized_member_size_ = SERIALIZED_MEMBER_SIZE;
    }
 
    return *this;
}
 
Cdr& Cdr::deserialize_bool_array(
        std::vector<bool>& vector_t)
{
    state state_before_error(*this);
 
    size_t total_size = vector_t.size() * sizeof(bool);
 
    if ((end_ - offset_) >= total_size)
    {
        // Save last datasize.
        last_data_size_ = sizeof(bool);
 
        for (uint32_t count = 0; count < vector_t.size(); ++count)
        {
            uint8_t value = 0;
            offset_++ >> value;
 
            if (value == 1)
            {
                vector_t[count] = true;
            }
            else if (value == 0)
            {
                vector_t[count] = false;
            }
            else
            {
                throw BadParamException("Unexpected byte value in Cdr::deserialize_bool_sequence, expected 0 or 1");
            }
        }
    }
    else
    {
        set_state(state_before_error);
        throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
    }
 
    return *this;
}
 
Cdr& Cdr::deserialize_bool_sequence(
        std::vector<bool>& vector_t)
{
    uint32_t sequence_length {0};
    state state_before_error(*this);
 
    *this >> sequence_length;
 
    size_t total_size = sequence_length * sizeof(bool);
 
    if ((end_ - offset_) >= total_size)
    {
        vector_t.resize(sequence_length);
        // Save last datasize.
        last_data_size_ = sizeof(bool);
 
        for (uint32_t count = 0; count < sequence_length; ++count)
        {
            uint8_t value = 0;
            offset_++ >> value;
 
            if (value == 1)
            {
                vector_t[count] = true;
            }
            else if (value == 0)
            {
                vector_t[count] = false;
            }
            else
            {
                throw BadParamException("Unexpected byte value in Cdr::deserialize_bool_sequence, expected 0 or 1");
            }
        }
    }
    else
    {
        set_state(state_before_error);
        throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
    }
 
    return *this;
}
 
Cdr& Cdr::deserialize_string_sequence(
        std::string*& sequence_t,
        size_t& num_elements)
{
    uint32_t sequence_length {0};
 
    if (CdrVersion::XCDRv2 == cdr_version_)
    {
        uint32_t dheader {0};
        deserialize(dheader);
 
        auto offset = offset_;
 
        deserialize(sequence_length);
 
        try
        {
            sequence_t = new std::string[sequence_length];
 
            uint32_t count {0};
            while (offset_ - offset < dheader && count < sequence_length)
            {
                deserialize(sequence_t[count]);
                ++count;
            }
 
            if (offset_ - offset != dheader)
            {
                throw BadParamException("Member size greater than size specified by DHEADER");
            }
        }
        catch (exception::Exception& ex)
        {
            delete [] sequence_t;
            sequence_t = nullptr;
            ex.raise();
        }
    }
    else
    {
        state state_before_error(*this);
 
        deserialize(sequence_length);
 
        try
        {
            sequence_t = new std::string[sequence_length];
            deserialize_array(sequence_t, sequence_length);
        }
        catch (exception::Exception& ex)
        {
            delete [] sequence_t;
            sequence_t = nullptr;
            set_state(state_before_error);
            ex.raise();
        }
    }
 
    num_elements = sequence_length;
    return *this;
}
 
Cdr& Cdr::deserialize_wstring_sequence(
        std::wstring*& sequence_t,
        size_t& num_elements)
{
    uint32_t sequence_length {0};
 
    if (CdrVersion::XCDRv2 == cdr_version_)
    {
        uint32_t dheader {0};
        deserialize(dheader);
 
        auto offset = offset_;
 
        deserialize(sequence_length);
 
        try
        {
            sequence_t = new std::wstring[sequence_length];
 
            uint32_t count {0};
            while (offset_ - offset < dheader && count < sequence_length)
            {
                deserialize(sequence_t[count]);
                ++count;
            }
 
            if (offset_ - offset != dheader)
            {
                throw BadParamException("Member size greater than size specified by DHEADER");
            }
        }
        catch (exception::Exception& ex)
        {
            delete [] sequence_t;
            sequence_t = nullptr;
            ex.raise();
        }
    }
    else
    {
        state state_before_error(*this);
 
        deserialize(sequence_length);
 
        try
        {
            sequence_t = new std::wstring[sequence_length];
            deserialize_array(sequence_t, sequence_length);
        }
        catch (exception::Exception& ex)
        {
            delete [] sequence_t;
            sequence_t = nullptr;
            set_state(state_before_error);
            ex.raise();
        }
    }
 
    num_elements = sequence_length;
    return *this;
}
 
void Cdr::xcdr1_serialize_short_member_header(
        const MemberId& member_id)
{
    assert(0x3F00 >= member_id.id);
 
    make_alignment(alignment(4));
 
    uint16_t flags_and_member_id = static_cast<uint16_t>(member_id.must_understand ? 0x4000 : 0x0) |
            static_cast<uint16_t>(member_id.id);
    serialize(flags_and_member_id);
    uint16_t size = 0;
    serialize(size);
    reset_alignment();
}
 
void Cdr::xcdr1_end_short_member_header(
        const MemberId& member_id,
        size_t member_serialized_size)
{
    static_cast<void>(member_id);
    assert(0x3F00 >= member_id.id);
    assert(std::numeric_limits<uint16_t>::max() >= member_serialized_size );
    make_alignment(alignment(4));
    jump(sizeof(uint16_t));
    uint16_t size = static_cast<uint16_t>(member_serialized_size);
    serialize(size);
}
 
void Cdr::xcdr1_serialize_long_member_header(
        const MemberId& member_id)
{
    make_alignment(alignment(4));
 
    uint16_t flags_and_extended_pid = static_cast<uint16_t>(member_id.must_understand ? 0x4000 : 0x0) |
            static_cast<uint16_t>(PID_EXTENDED);
    serialize(flags_and_extended_pid);
    uint16_t size = PID_EXTENDED_LENGTH;
    serialize(size);
    uint32_t id = member_id.id;
    serialize(id);
    uint32_t msize = 0;
    serialize(msize);
    reset_alignment();
}
 
void Cdr::xcdr1_end_long_member_header(
        const MemberId&,
        size_t member_serialized_size)
{
    jump(sizeof(uint16_t) + sizeof(uint16_t) + sizeof(uint32_t));
    uint32_t msize = static_cast<uint32_t>(member_serialized_size);
    serialize(msize);
}
 
void Cdr::xcdr1_change_to_short_member_header(
        const MemberId& member_id,
        size_t member_serialized_size)
{
    assert(0x3F00 >= member_id.id);
    assert(std::numeric_limits<uint16_t>::max() >= member_serialized_size );
 
    uint16_t flags_and_member_id = static_cast<uint16_t>(member_id.must_understand ? 0x4000 : 0x0) |
            static_cast<uint16_t>(member_id.id);
    serialize(flags_and_member_id);
    uint16_t size = static_cast<uint16_t>(member_serialized_size);
    serialize(size);
    memmove(&offset_, &offset_ + 8, member_serialized_size);
}
 
void Cdr::xcdr1_change_to_long_member_header(
        const MemberId& member_id,
        size_t member_serialized_size)
{
    if (0 < (end_ - offset_ - member_serialized_size - 11))
    {
        memmove(&offset_ + 12, &offset_ + 4, member_serialized_size);
    }
    else
    {
        throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
    }
    uint16_t flags_and_extended_pid = static_cast<uint16_t>(member_id.must_understand ? 0x4000 : 0x0) |
            static_cast<uint16_t>(PID_EXTENDED);
    serialize(flags_and_extended_pid);
    uint16_t size = PID_EXTENDED_LENGTH;
    serialize(size);
    uint32_t id = member_id.id;
    serialize(id);
    uint32_t msize = static_cast<uint32_t>(member_serialized_size);
    serialize(msize);
}
 
bool Cdr::xcdr1_deserialize_member_header(
        MemberId& member_id,
        Cdr::state& current_state)
{
    bool ret_value = true;
    make_alignment(alignment(4));
    uint16_t flags_and_member_id = 0;
    deserialize(flags_and_member_id);
    member_id.must_understand = (flags_and_member_id & 0x4000);
    uint16_t id = (flags_and_member_id & 0x3FFF);
 
 
    if (PID_EXTENDED > id)
    {
        member_id.id = id;
        uint16_t size = 0;
        deserialize(size);
        current_state.member_size_ = size;
        current_state.header_serialized_ = XCdrHeaderSelection::SHORT_HEADER;
        reset_alignment();
    }
    else if (PID_EXTENDED == id) // PID_EXTENDED
    {
        uint16_t size = 0;
        deserialize(size);
        if (PID_EXTENDED_LENGTH != size)
        {
            throw BadParamException("PID_EXTENDED comes with a size different than 8");
        }
        uint32_t mid = 0;
        deserialize(mid);
        member_id.id = mid;
        deserialize(current_state.member_size_);
        current_state.header_serialized_ = XCdrHeaderSelection::LONG_HEADER;
        reset_alignment();
    }
    else if (PID_SENTINEL == id) // PID_SENTINEL
    {
        uint16_t size = 0;
        deserialize(size);
        if (0 != size)
        {
            throw BadParamException("PID_SENTINEL comes with a size different than 0");
        }
        current_state.member_size_ = size;
        ret_value = false;
    }
 
    return ret_value;
}
 
void Cdr::xcdr2_serialize_short_member_header(
        const MemberId& member_id)
{
    assert(0x10000000 > member_id.id);
 
    uint32_t flags_and_member_id = (member_id.must_understand ? 0x80000000 : 0x0) | member_id.id;
    serialize(flags_and_member_id);
}
 
void Cdr::xcdr2_end_short_member_header(
        const MemberId& member_id,
        size_t member_serialized_size)
{
    assert(0x10000000 > member_id.id);
    assert(8 >= member_serialized_size);
 
    uint32_t lc = get_short_lc(member_serialized_size);
    uint32_t flags_and_member_id = (member_id.must_understand ? 0x80000000 : 0x0) | lc | member_id.id;
    serialize(flags_and_member_id);
}
 
void Cdr::xcdr2_serialize_long_member_header(
        const MemberId& member_id)
{
    assert(0x10000000 > member_id.id);
 
    uint32_t flags_and_member_id = (member_id.must_understand ? 0x80000000 : 0x0) | member_id.id;
    serialize(flags_and_member_id);
    uint32_t size = 0;
    serialize(size);
}
 
void Cdr::xcdr2_end_long_member_header(
        const MemberId& member_id,
        size_t member_serialized_size)
{
    assert(0x10000000 > member_id.id);
 
    uint32_t lc = 0 == member_serialized_size ? get_long_lc(serialized_member_size_) : 0x40000000;
    uint32_t flags_and_member_id = (member_id.must_understand ? 0x80000000 : 0x0) | lc | member_id.id;
    serialize(flags_and_member_id);
    if (0 < member_serialized_size)
    {
        uint32_t size = static_cast<uint32_t>(member_serialized_size);
        serialize(size);
    }
}
 
void Cdr::xcdr2_change_to_short_member_header(
        const MemberId& member_id,
        size_t member_serialized_size)
{
    assert(0x10000000 > member_id.id);
    assert(8 >= member_serialized_size);
 
    uint32_t lc = get_short_lc(member_serialized_size);
    uint32_t flags_and_member_id = (member_id.must_understand ? 0x80000000 : 0x0) | lc | member_id.id;
    serialize(flags_and_member_id);
    memmove(&offset_, &offset_ + 4, member_serialized_size);
}
 
void Cdr::xcdr2_change_to_long_member_header(
        const MemberId& member_id,
        size_t member_serialized_size)
{
    assert(0x10000000 > member_id.id);
 
    if (0 < (end_ - offset_ - member_serialized_size - 7))
    {
        memmove(&offset_ + 8, &offset_ + 4, member_serialized_size);
    }
    else
    {
        throw NotEnoughMemoryException(NotEnoughMemoryException::NOT_ENOUGH_MEMORY_MESSAGE_DEFAULT);
    }
    uint32_t lc = get_long_lc(serialized_member_size_);
    uint32_t flags_and_member_id = (member_id.must_understand ? 0x80000000 : 0x0) | lc | member_id.id;
    serialize(flags_and_member_id);
    uint32_t size = static_cast<uint32_t>(member_serialized_size);
    serialize(size);
}
 
void Cdr::xcdr2_shrink_to_long_member_header(
        const MemberId& member_id,
        const FastBuffer::iterator& offset)
{
    assert(0x10000000 > member_id.id);
 
    memmove(&offset_ + 4, &offset_ + 8, offset - offset_ - 8);
    uint32_t lc = get_long_lc(serialized_member_size_);
    uint32_t flags_and_member_id = (member_id.must_understand ? 0x80000000 : 0x0) | lc | member_id.id;
    serialize(flags_and_member_id);
}
 
Cdr& Cdr::xcdr1_begin_serialize_member(
        const MemberId& member_id,
        bool is_present,
        Cdr::state& current_state,
        Cdr::XCdrHeaderSelection header_selection)
{
    static_cast<void>(is_present);
    assert(is_present);
    assert(MEMBER_ID_INVALID != member_id);
    assert(MEMBER_ID_INVALID == next_member_id_ || member_id == next_member_id_);
    assert(current_state == Cdr::state(*this));
    assert(EncodingAlgorithmFlag::PLAIN_CDR == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR == current_encoding_);
 
    if (EncodingAlgorithmFlag::PL_CDR == current_encoding_)
    {
        if (0x3F00 >= member_id.id)
        {
            switch (header_selection)
            {
                case XCdrHeaderSelection::AUTO_WITH_SHORT_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::SHORT_HEADER:
                    xcdr1_serialize_short_member_header(member_id);
                    current_state.header_serialized_ = XCdrHeaderSelection::SHORT_HEADER;
                    break;
                case XCdrHeaderSelection::AUTO_WITH_LONG_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::LONG_HEADER:
                    xcdr1_serialize_long_member_header(member_id);
                    current_state.header_serialized_ = XCdrHeaderSelection::LONG_HEADER;
                    break;
            }
        }
        else
        {
            switch (header_selection)
            {
                case XCdrHeaderSelection::AUTO_WITH_SHORT_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::AUTO_WITH_LONG_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::LONG_HEADER:
                    xcdr1_serialize_long_member_header(member_id);
                    current_state.header_serialized_ = XCdrHeaderSelection::LONG_HEADER;
                    break;
                default:
                    throw BadParamException(
                              "Cannot encode XCDRv1 ShortMemberHeader when member_id is bigger than 0x3F00");
            }
        }
        current_state.header_selection_ = header_selection;
    }
    current_state.next_member_id_ = member_id;
    next_member_id_ = MEMBER_ID_INVALID;
 
    return *this;
}
 
Cdr& Cdr::xcdr1_end_serialize_member(
        const Cdr::state& current_state)
{
    assert(MEMBER_ID_INVALID != current_state.next_member_id_);
    assert(EncodingAlgorithmFlag::PLAIN_CDR == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR == current_encoding_);
 
    if (EncodingAlgorithmFlag::PL_CDR == current_encoding_)
    {
        auto last_offset = offset_;
        auto member_origin = origin_;
        set_state(current_state);
        make_alignment(alignment(4));
        const size_t member_serialized_size = last_offset - offset_ -
                (current_state.header_serialized_ == XCdrHeaderSelection::SHORT_HEADER ? 4 : 12);
        if (member_serialized_size > std::numeric_limits<uint16_t>::max())
        {
            switch (current_state.header_serialized_)
            {
                case XCdrHeaderSelection::SHORT_HEADER:
                    if (AUTO_WITH_SHORT_HEADER_BY_DEFAULT == current_state.header_selection_)
                    {
                        xcdr1_change_to_long_member_header(current_state.next_member_id_, member_serialized_size);
                        member_origin += 8;
                    }
                    else
                    {
                        throw BadParamException(
                                  "Cannot encode XCDRv1 ShortMemberHeader when serialized member size is greater than 0xFFFF");
                    }
                    break;
                case XCdrHeaderSelection::LONG_HEADER:
                    xcdr1_end_long_member_header(current_state.next_member_id_, member_serialized_size);
                    break;
                default:
                    assert(false); // header_serialized_ must have only SHORT_HEADER or LONG_HEADER
            }
        }
        else
        {
            switch (current_state.header_serialized_)
            {
                case XCdrHeaderSelection::SHORT_HEADER:
                    xcdr1_end_short_member_header(current_state.next_member_id_, member_serialized_size);
                    break;
                case XCdrHeaderSelection::LONG_HEADER:
                    if (LONG_HEADER == current_state.header_selection_ ||
                            0x3F00 < current_state.next_member_id_.id)
                    {
                        xcdr1_end_long_member_header(current_state.next_member_id_, member_serialized_size);
                    }
                    else if (AUTO_WITH_LONG_HEADER_BY_DEFAULT == current_state.header_selection_)
                    {
                        xcdr1_change_to_short_member_header(current_state.next_member_id_, member_serialized_size);
                        member_origin -= 8;
                    }
                    break;
                default:
                    assert(false); // header_serialized_ must have only SHORT_HEADER or LONG_HEADER
            }
        }
        origin_ = member_origin; // Don't POP(origin)
        jump(member_serialized_size);
    }
 
    next_member_id_ = MEMBER_ID_INVALID;
 
    return *this;
}
 
Cdr& Cdr::xcdr1_begin_serialize_opt_member(
        const MemberId& member_id,
        bool is_present,
        Cdr::state& current_state,
        Cdr::XCdrHeaderSelection header_selection)
{
    assert(MEMBER_ID_INVALID != member_id);
    assert(MEMBER_ID_INVALID == next_member_id_ || member_id == next_member_id_);
    assert(current_state == Cdr::state(*this));
    assert(EncodingAlgorithmFlag::PLAIN_CDR == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR == current_encoding_);
 
    if (is_present || EncodingAlgorithmFlag::PL_CDR != current_encoding_)
    {
        if (0x3F00 >= member_id.id)
        {
            switch (header_selection)
            {
                case XCdrHeaderSelection::AUTO_WITH_SHORT_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::SHORT_HEADER:
                    xcdr1_serialize_short_member_header(member_id);
                    current_state.header_serialized_ = XCdrHeaderSelection::SHORT_HEADER;
                    break;
                case XCdrHeaderSelection::AUTO_WITH_LONG_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::LONG_HEADER:
                    xcdr1_serialize_long_member_header(member_id);
                    current_state.header_serialized_ = XCdrHeaderSelection::LONG_HEADER;
                    break;
            }
        }
        else
        {
            switch (header_selection)
            {
                case XCdrHeaderSelection::AUTO_WITH_SHORT_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::AUTO_WITH_LONG_HEADER_BY_DEFAULT:
                case XCdrHeaderSelection::LONG_HEADER:
                    xcdr1_serialize_long_member_header(member_id);
                    current_state.header_serialized_ = XCdrHeaderSelection::LONG_HEADER;
                    break;
                default:
                    throw BadParamException(
                              "Cannot encode XCDRv1 ShortMemberHeader when member_id is bigger than 0x3F00");
            }
        }
        current_state.header_selection_ = header_selection;
    }
    current_state.member_size_ = is_present ? 1 : 0;
    current_state.next_member_id_ = member_id;
    next_member_id_ = MEMBER_ID_INVALID;
 
    return *this;
}
 
Cdr& Cdr::xcdr1_end_serialize_opt_member(
        const Cdr::state& current_state)
{
    assert(MEMBER_ID_INVALID != current_state.next_member_id_);
    assert(EncodingAlgorithmFlag::PLAIN_CDR == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR == current_encoding_);
 
    if (0 < current_state.member_size_)
    {
        auto last_offset = offset_;
        auto member_origin = origin_;
        set_state(current_state);
        make_alignment(alignment(4));
        const size_t member_serialized_size = last_offset - offset_ -
                (current_state.header_serialized_ == XCdrHeaderSelection::SHORT_HEADER ? 4 : 12);
        if (member_serialized_size > std::numeric_limits<uint16_t>::max())
        {
            switch (current_state.header_serialized_)
            {
                case XCdrHeaderSelection::SHORT_HEADER:
                    if (AUTO_WITH_SHORT_HEADER_BY_DEFAULT == current_state.header_selection_)
                    {
                        xcdr1_change_to_long_member_header(current_state.next_member_id_, member_serialized_size);
                        member_origin += 8;
                    }
                    else
                    {
                        throw BadParamException(
                                  "Cannot encode XCDRv1 ShortMemberHeader when serialized member size is greater than 0xFFFF");
                    }
                    break;
                case XCdrHeaderSelection::LONG_HEADER:
                    xcdr1_end_long_member_header(current_state.next_member_id_, member_serialized_size);
                    break;
                default:
                    assert(false); // header_serialized_ must have only SHORT_HEADER or LONG_HEADER
            }
        }
        else
        {
            switch (current_state.header_serialized_)
            {
                case XCdrHeaderSelection::SHORT_HEADER:
                    xcdr1_end_short_member_header(current_state.next_member_id_, member_serialized_size);
                    break;
                case XCdrHeaderSelection::LONG_HEADER:
                    if (LONG_HEADER == current_state.header_selection_ ||
                            0x3F00 < current_state.next_member_id_.id)
                    {
                        xcdr1_end_long_member_header(current_state.next_member_id_, member_serialized_size);
                    }
                    else if (AUTO_WITH_LONG_HEADER_BY_DEFAULT == current_state.header_selection_)
                    {
                        xcdr1_change_to_short_member_header(current_state.next_member_id_, member_serialized_size);
                        member_origin -= 8;
                    }
                    break;
                default:
                    assert(false); // header_serialized_ must have only SHORT_HEADER or LONG_HEADER
            }
        }
        origin_ = member_origin; // Don't POP(origin)
        jump(member_serialized_size);
    }
 
    next_member_id_ = MEMBER_ID_INVALID;
 
    return *this;
}
 
Cdr& Cdr::xcdr2_begin_serialize_member(
        const MemberId& member_id,
        bool is_present,
        Cdr::state& current_state,
        XCdrHeaderSelection header_selection)
{
    assert(MEMBER_ID_INVALID != member_id);
    assert(MEMBER_ID_INVALID == next_member_id_ || member_id == next_member_id_);
    assert(current_state == Cdr::state(*this));
    assert(EncodingAlgorithmFlag::PLAIN_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::DELIMIT_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR2 == current_encoding_);
 
    if (is_present && EncodingAlgorithmFlag::PL_CDR2 == current_encoding_)
    {
        if (0x10000000 <= member_id.id)
        {
            throw BadParamException("Cannot serialize a member identifier equal or greater than 0x10000000");
        }
 
        switch (header_selection)
        {
            case XCdrHeaderSelection::SHORT_HEADER:
            case XCdrHeaderSelection::AUTO_WITH_SHORT_HEADER_BY_DEFAULT:
                xcdr2_serialize_short_member_header(member_id);
                current_state.header_serialized_ = XCdrHeaderSelection::SHORT_HEADER;
                break;
            case XCdrHeaderSelection::LONG_HEADER:
            case XCdrHeaderSelection::AUTO_WITH_LONG_HEADER_BY_DEFAULT:
                xcdr2_serialize_long_member_header(member_id);
                current_state.header_serialized_ = XCdrHeaderSelection::LONG_HEADER;
                break;
        }
        current_state.header_selection_ = header_selection;
    }
 
    current_state.member_size_ = is_present ? 1 : 0;
    current_state.next_member_id_ = member_id;
    next_member_id_ = MEMBER_ID_INVALID;
 
    return *this;
}
 
Cdr& Cdr::xcdr2_end_serialize_member(
        const Cdr::state& current_state)
{
    assert(MEMBER_ID_INVALID != current_state.next_member_id_);
    assert(EncodingAlgorithmFlag::PLAIN_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::DELIMIT_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR2 == current_encoding_);
 
    if (0 < current_state.member_size_ && EncodingAlgorithmFlag::PL_CDR2 == current_encoding_)
    {
        auto last_offset = offset_;
        set_state(current_state);
        make_alignment(alignment(sizeof(uint32_t)));
        if (NO_SERIALIZED_MEMBER_SIZE == serialized_member_size_)
        {
            const size_t member_serialized_size = last_offset - offset_ -
                    (current_state.header_serialized_ == XCdrHeaderSelection::SHORT_HEADER ? 4 : 8);
            if (8 < member_serialized_size)
            {
                switch (current_state.header_serialized_)
                {
                    case XCdrHeaderSelection::SHORT_HEADER:
                        if (AUTO_WITH_SHORT_HEADER_BY_DEFAULT == current_state.header_selection_)
                        {
                            xcdr2_change_to_long_member_header(current_state.next_member_id_, member_serialized_size);
                        }
                        else
                        {
                            throw BadParamException("Cannot encode XCDRv2 LongMemberHeader");
                        }
                        break;
                    case XCdrHeaderSelection::LONG_HEADER:
                        xcdr2_end_long_member_header(current_state.next_member_id_, member_serialized_size);
                        break;
                    default:
                        assert(false); // header_serialized_ must have only SHORT_HEADER or LONG_HEADER
                }
            }
            else
            {
                switch (current_state.header_serialized_)
                {
                    case XCdrHeaderSelection::SHORT_HEADER:
                        xcdr2_end_short_member_header(current_state.next_member_id_, member_serialized_size);
                        break;
                    case XCdrHeaderSelection::LONG_HEADER:
                        if (AUTO_WITH_LONG_HEADER_BY_DEFAULT == current_state.header_selection_)
                        {
                            xcdr2_change_to_short_member_header(current_state.next_member_id_, member_serialized_size);
                        }
                        else
                        {
                            xcdr2_end_long_member_header(current_state.next_member_id_, member_serialized_size);
                        }
                        break;
                    default:
                        assert(false); // header_serialized_ must have only SHORT_HEADER or LONG_HEADER
                }
            }
 
            jump(member_serialized_size);
        }
        else
        {
            // Use inner type DHEADER as NEXTINT
            switch (current_state.header_serialized_)
            {
                case XCdrHeaderSelection::SHORT_HEADER:
                    if (AUTO_WITH_SHORT_HEADER_BY_DEFAULT == current_state.header_selection_)
                    {
                        xcdr2_end_long_member_header(current_state.next_member_id_, 0);
                        offset_ = last_offset;
                    }
                    else
                    {
                        throw BadParamException("Cannot encode XCDRv2 LongMemberHeader");
                    }
                    break;
                case XCdrHeaderSelection::LONG_HEADER:
                    xcdr2_shrink_to_long_member_header(current_state.next_member_id_, last_offset);
                    offset_ = last_offset;
                    offset_ -= sizeof(uint32_t);
                    break;
                default:
                    assert(false); // header_serialized_ must have only SHORT_HEADER or LONG_HEADER
            }
 
            last_data_size_ = 0;
        }
    }
 
    next_member_id_ = MEMBER_ID_INVALID;
    serialized_member_size_ = NO_SERIALIZED_MEMBER_SIZE;
 
    return *this;
}
 
void Cdr::xcdr2_deserialize_member_header(
        MemberId& member_id,
        Cdr::state& current_state)
{
    uint32_t flags_and_member_id = 0;
    deserialize(flags_and_member_id);
    member_id.must_understand = (flags_and_member_id & 0x80000000);
    uint32_t mid = (flags_and_member_id & 0x0FFFFFFF);
    uint32_t lc = (flags_and_member_id & 0x70000000) >> 28;
 
    member_id.id = mid;
 
    if (4 > lc)
    {
        switch (lc)
        {
            case 0:
                current_state.member_size_ = 1;
                break;
            case 1:
                current_state.member_size_ = 2;
                break;
            case 2:
                current_state.member_size_ = 4;
                break;
            case 3:
                current_state.member_size_ = 8;
                break;
            default:
                break;
        }
        current_state.header_serialized_ = XCdrHeaderSelection::SHORT_HEADER;
    }
    else if (4 == lc)
    {
        uint32_t size = 0;
        deserialize(size);
        current_state.member_size_ = size;
        current_state.header_serialized_ = XCdrHeaderSelection::LONG_HEADER;
    }
    else
    {
        uint32_t size = 0;
        deserialize(size);
        current_state.member_size_ = 4 + (size * (5 == lc ? 1 : (6 == lc ? 4 : 8)));
        current_state.header_serialized_ = XCdrHeaderSelection::SHORT_HEADER; // Avoid take into account DHEADER after.
        offset_ -= sizeof(uint32_t);
    }
}
 
Cdr& Cdr::xcdr1_begin_serialize_type(
        Cdr::state& current_state,
        EncodingAlgorithmFlag type_encoding) noexcept
{
    assert(current_state == Cdr::state(*this));
    assert(EncodingAlgorithmFlag::PLAIN_CDR == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR == current_encoding_);
    assert(EncodingAlgorithmFlag::PLAIN_CDR == type_encoding ||
            EncodingAlgorithmFlag::PL_CDR == type_encoding);
    current_state.previous_encoding_ = current_encoding_;
    current_encoding_ = type_encoding;
    return *this;
}
 
Cdr& Cdr::xcdr1_end_serialize_type(
        const Cdr::state& current_state)
{
    assert(EncodingAlgorithmFlag::PLAIN_CDR == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR == current_encoding_);
 
    if (EncodingAlgorithmFlag::PL_CDR == current_encoding_)
    {
        make_alignment(alignment(4));
        serialize(PID_SENTINEL);
        serialize(PID_SENTINEL_LENGTH);
    }
 
    current_encoding_ = current_state.previous_encoding_;
 
    return *this;
}
 
Cdr& Cdr::xcdr2_begin_serialize_type(
        Cdr::state& current_state,
        EncodingAlgorithmFlag type_encoding)
{
    assert(current_state == Cdr::state(*this));
    assert(EncodingAlgorithmFlag::PLAIN_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::DELIMIT_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR2 == current_encoding_);
    assert(EncodingAlgorithmFlag::PLAIN_CDR2 == type_encoding ||
            EncodingAlgorithmFlag::DELIMIT_CDR2 == type_encoding ||
            EncodingAlgorithmFlag::PL_CDR2 == type_encoding);
    if (EncodingAlgorithmFlag::PLAIN_CDR2 != type_encoding)
    {
        uint32_t dheader {0};
        serialize(dheader);
    }
    serialized_member_size_ = NO_SERIALIZED_MEMBER_SIZE; // Avoid error when serializing arrays, sequences, etc..
    current_state.previous_encoding_ = current_encoding_;
    current_encoding_ = type_encoding;
    return *this;
}
 
Cdr& Cdr::xcdr2_end_serialize_type(
        const Cdr::state& current_state)
{
    assert(EncodingAlgorithmFlag::PLAIN_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::DELIMIT_CDR2 == current_encoding_ ||
            EncodingAlgorithmFlag::PL_CDR2 == current_encoding_);
    if (EncodingAlgorithmFlag::PLAIN_CDR2 != current_encoding_)
    {
        auto last_offset = offset_;
        set_state(current_state);
        const size_t member_serialized_size = last_offset - offset_ /*DHEADER ->*/ - 4 - alignment(4);
        serialize(static_cast<uint32_t>(member_serialized_size));
        jump(member_serialized_size);
        serialized_member_size_ = SERIALIZED_MEMBER_SIZE;
    }
    current_encoding_ = current_state.previous_encoding_;
    return *this;
}
 
Cdr& Cdr::xcdr1_deserialize_type(
        EncodingAlgorithmFlag type_encoding,
        std::function<bool (Cdr&, const MemberId&)> functor)
{
    assert(EncodingAlgorithmFlag::PLAIN_CDR == type_encoding ||
            EncodingAlgorithmFlag::PL_CDR == type_encoding);
    Cdr::state current_state(*this);
 
    if (EncodingAlgorithmFlag::PL_CDR == type_encoding)
    {
        while (xcdr1_deserialize_member_header(next_member_id_, current_state))
        {
            auto prev_offset = offset_;
            bool deser_value = functor(*this, next_member_id_);
 
            if (!deser_value)
            {
                if (next_member_id_.must_understand)
                {
                    throw BadParamException("Cannot deserialize a member with flag must_understand");
                }
                else
                {
                    jump(current_state.member_size_);
                }
            }
 
            if (current_state.member_size_ != offset_ - prev_offset)
            {
                throw BadParamException(
                          "Member size provided by member header is not equal to the real decoded member size");
            }
        }
    }
    else
    {
        next_member_id_ = MemberId(0);
 
        while (offset_ != end_ && functor(*this, next_member_id_))
        {
            ++next_member_id_.id;
        }
    }
 
    next_member_id_ = current_state.next_member_id_;
 
    return *this;
}
 
Cdr& Cdr::xcdr2_deserialize_type(
        EncodingAlgorithmFlag type_encoding,
        std::function<bool (Cdr&, const MemberId&)> functor)
{
    assert(EncodingAlgorithmFlag::PLAIN_CDR2 == type_encoding ||
            EncodingAlgorithmFlag::DELIMIT_CDR2 == type_encoding ||
            EncodingAlgorithmFlag::PL_CDR2 == type_encoding);
 
 
    if (EncodingAlgorithmFlag::PLAIN_CDR2 != type_encoding)
    {
        uint32_t dheader {0};
        deserialize(dheader);
 
        Cdr::state current_state(*this);
 
        if (EncodingAlgorithmFlag::PL_CDR2 == type_encoding)
        {
            while (offset_ - current_state.offset_ != dheader)
            {
                if (offset_ - current_state.offset_ > dheader)
                {
                    throw BadParamException("Member size greater than size specified by DHEADER");
                }
 
                auto offset = offset_;
 
                xcdr2_deserialize_member_header(next_member_id_, current_state);
                bool deser_value = functor(*this, next_member_id_);
                if (!deser_value)
                {
                    if (next_member_id_.must_understand)
                    {
                        throw BadParamException("Cannot deserialize a member with flag must_understand");
                    }
                    else
                    {
                        jump(current_state.member_size_);
                    }
                }
 
                if (!(0 == current_state.member_size_ &&
                        0 == offset_ - offset) &&
                        !(0 < current_state.member_size_ &&
                        current_state.member_size_ == offset_ - offset -
                        alignment_on_state(current_state.origin_, offset, sizeof(uint32_t)) -
                        (XCdrHeaderSelection::SHORT_HEADER == current_state.header_serialized_ ? 4 : 8)))
                {
                    throw BadParamException(
                              "Member size provided by member header is not equal to the real decoded size");
                }
            }
 
            next_member_id_ = current_state.next_member_id_;
        }
        else
        {
            next_member_id_ = MemberId(0);
 
            while (offset_ - current_state.offset_ < dheader && functor(*this, next_member_id_))
            {
                ++next_member_id_.id;
            }
            size_t jump_size = dheader - (offset_ - current_state.offset_);
            jump(jump_size);
 
            next_member_id_ = current_state.next_member_id_;
        }
    }
    else
    {
        Cdr::state current_state(*this);
        next_member_id_ = MemberId(0);
 
        while (offset_ != end_ && functor(*this, next_member_id_))
        {
            ++next_member_id_.id;
        }
 
        next_member_id_ = current_state.next_member_id_;
    }
 
    return *this;
}
 
Cdr& Cdr::cdr_begin_serialize_member(
        const MemberId&,
        bool,
        Cdr::state&,
        XCdrHeaderSelection )
{
    next_member_id_ = MEMBER_ID_INVALID;
    return *this;
}
 
Cdr& Cdr::cdr_end_serialize_member(
        const Cdr::state&)
{
    next_member_id_ = MEMBER_ID_INVALID;
    return *this;
}
 
Cdr& Cdr::cdr_begin_serialize_type(
        Cdr::state& current_state,
        EncodingAlgorithmFlag type_encoding)
{
    static_cast<void>(type_encoding);
    assert(EncodingAlgorithmFlag::PLAIN_CDR == type_encoding);
    current_state.previous_encoding_ = current_encoding_;
    current_encoding_ = type_encoding;
    return *this;
}
 
Cdr& Cdr::cdr_end_serialize_type(
        const Cdr::state& current_state)
{
    current_encoding_ = current_state.previous_encoding_;
    return *this;
}
 
Cdr& Cdr::cdr_deserialize_type(
        EncodingAlgorithmFlag type_encoding,
        std::function<bool (Cdr&, const MemberId&)> functor)
{
    static_cast<void>(type_encoding);
    assert(EncodingAlgorithmFlag::PLAIN_CDR == type_encoding);
 
    Cdr::state current_state(*this);
    next_member_id_ = MemberId(0);
 
    while (offset_ != end_ && functor(*this, next_member_id_))
    {
        ++next_member_id_.id;
    }
 
    next_member_id_ = current_state.next_member_id_;
    return *this;
}
 
Cdr::state Cdr::allocate_xcdrv2_dheader()
{
    Cdr::state dheader_state(*this);
 
    if (CdrVersion::XCDRv2 == cdr_version_)
    {
        // Serialize DHEADER
        uint32_t dheader {0};
        serialize(dheader);
    }
 
    return dheader_state;
}
 
void Cdr::set_xcdrv2_dheader(
        const Cdr::state& dheader_state)
{
    if (CdrVersion::XCDRv2 == cdr_version_)
    {
        auto offset = offset_;
        Cdr::state state_after(*this);
        set_state(dheader_state);
        size_t dheader = offset - offset_ - (4 + alignment(sizeof(uint32_t)));    /* DHEADER */
        serialize(static_cast<uint32_t>(dheader));
        set_state(state_after);
        serialized_member_size_ = SERIALIZED_MEMBER_SIZE;
    }
}
 
} // namespace fastcdr
} // namespace eprosima