MessageHolder.h

Go to the documentation of this file.

// Copyright Onix Solutions Limited [OnixS]. All rights reserved.
//
// This software owned by Onix Solutions Limited [OnixS] and is
// protected by copyright law and international copyright treaties.
//
// Access to and use of the software is governed by the terms of the applicable
// OnixS Software Services Agreement (the Agreement) and Customer end user license
// agreements granting a non-assignable, non-transferable and non-exclusive license
// to use the software for it's own data processing purposes under the terms defined
// in the Agreement.
//
// Except as otherwise granted within the terms of the Agreement, copying or
// reproduction of any part of this source code or associated reference material
// to any other location for further reproduction or redistribution, and any
// amendments to this copyright notice, are expressly prohibited.
//
// Any reproduction or redistribution for sale or hiring of the Software not in
// accordance with the terms of the Agreement is a violation of copyright law.
//
 
#pragma once
 
#include <vector>
 
#include <OnixS/CME/ConflatedTCP/messaging/MaxMessageSize.h>
#include <OnixS/CME/ConflatedTCP/messaging/SbeMessage.h>
#include <OnixS/CME/ConflatedTCP/messaging/SimpleOpenFramingHeader.h>
 
ONIXS_CONFLATEDTCP_MESSAGING_NAMESPACE_BEGIN

struct FieldsInitPolicy
{
    template <typename SbeMessageType>
    inline static SbeMessageType createMessage(
        void* data, MessageSize length, SchemaVersion version)
    {
        return SbeMessageType(data, length, version);
    }

    inline static const char* name() ONIXS_CONFLATEDTCP_NOTHROW
    {
        return "FieldsInitPolicy";
    }
};

struct FieldsNoInitPolicy
{
    template <typename SbeMessageType>
    inline static SbeMessageType createMessage(
        void* data, MessageSize length, SchemaVersion version)
    {
        return SbeMessageType(
            data, length, SbeMessage::NoFieldsInit(), version);
    }

    inline static const char* name() ONIXS_CONFLATEDTCP_NOTHROW
    {
        return "FieldsNoInitPolicy";
    }
};
 
template <typename MessageType>
struct HeldAdapter ONIXS_CONFLATEDTCP_FINAL
    : public MessageType
{
    ONIXS_CONFLATEDTCP_STATIC_ASSERT((
        IsBaseOf<SbeMessage, MessageType>::value));
 
    typedef MessageType SbeType;
 
    typedef typename
    SbeType::EncodedLength
        EncodedLength;
 
    HeldAdapter() ONIXS_CONFLATEDTCP_DEFAULT;
 
    HeldAdapter(
        void* data,
        EncodedLength length,
        SchemaVersion version)
        : MessageType(data, length, version)
    {
    }
 
    HeldAdapter(
        void* data,
        EncodedLength length,
        SbeMessage::NoFieldsInit,
        SchemaVersion version)
        : MessageType(data, length, version)
    {
    }
 
    HeldAdapter(
        void* data,
        EncodedLength length,
        SbeMessage::NoInit)
        : MessageType(data, length)
    {
    }
 
    HeldAdapter(
        void* data,
        EncodedLength length,
        SbeMessage::NoInit,
        SbeMessage::NoCheck)
    ONIXS_CONFLATEDTCP_NOTHROW
        : MessageType(
            data,
            length,
            SbeMessage::NoInit(),
            SbeMessage::NoCheck())
    {
    }
};

template <typename, size_t, typename>
class MessageHolder;
template <
    template <typename, size_t, typename> class HolderType,
    typename MsgType,
    size_t MaxMessageSize,
    typename MessageInitializer>
inline void toStr(
    std::string& str,
    const HolderType<MsgType, MaxMessageSize, MessageInitializer>& holder)
{
    str += "MessageHolder[";
 
    str += "BufferSize=";
    toStr(str, holder.BufferSize);
 
    str += ", MessageInitializer=";
    str += MessageInitializer::name();
 
    str += ", ";
    toStr(str, *holder.header());
 
    str += ", ";
    toStr(str, holder.message());
 
    str += "]";
}

ONIXS_CONFLATEDTCP_CONST_OR_CONSTEXPR char magicDebugValue = 0x5A;

ONIXS_CONFLATEDTCP_CONST_OR_CONSTEXPR UInt8 DefaultMaxGroupItems = 100;

template <
    typename MessageTypeT,
    size_t MaxMessageSize =
        GetMaxMessageSize<typename HeldAdapter<MessageTypeT>::SbeType, DefaultMaxGroupItems>::Size,
    typename MessageInitializer = FieldsInitPolicy>
class MessageHolder
{
    typedef typename HeldAdapter<MessageTypeT>::SbeType SbeType;
 
    ONIXS_CONFLATEDTCP_STATIC_ASSERT_MSG(
        (MaxMessageSize >= sizeof(MessageHeader)),
        "MaxMessageSize template parameter is too small");
 
    ONIXS_CONFLATEDTCP_STATIC_ASSERT_MSG(
        (MaxMessageSize >= GetMinMessageSize<SbeType>::Size),
        "The buffer can not fit the message");
 
    ONIXS_CONFLATEDTCP_STATIC_ASSERT_MSG(
        (MaxMessageSize <= MaxConflatedTcpMessageSize),
        "The buffer is too large.");
 
public:
    typedef HeldAdapter<MessageTypeT> MessageType;

    enum
    {
        BufferSize = MaxMessageSize + sizeof(SimpleOpenFramingHeader)
    };
 
    explicit MessageHolder(SchemaVersion version = SbeType::Schema::Version)
    {
#ifdef ONIXS_CONFLATEDTCP_MEMCHECK_DEBUG
        std::memset(buffer_, magicDebugValue, BufferSize);
#endif
        messageSize(0);
 
        message_ = MessageInitializer::template createMessage<MessageType>(
            buffer_ + sizeof(SimpleOpenFramingHeader), MaxMessageSize, version);
    }
 
    MessageHolder(const MessageHolder& r)
    {
        copyFrom(r);
    }
 
    MessageHolder& operator=(const MessageHolder& r)
    {
        copyFrom(r);
        return *this;
    }

    const unsigned char* buffer() const ONIXS_CONFLATEDTCP_NOTHROW
    {
        return buffer_;
    }

    UInt16 bufferSize() const ONIXS_CONFLATEDTCP_NOTHROW
    {
        return header()->size();
    }

    MessageType& message() ONIXS_CONFLATEDTCP_NOTHROW
    {
        return message_;
    }

    const MessageType& message() const ONIXS_CONFLATEDTCP_NOTHROW
    {
        return message_;
    }

    UInt16 messageSize() const ONIXS_CONFLATEDTCP_NOTHROW
    {
        return bufferSize() - sizeof(SimpleOpenFramingHeader);
    }
 
    MessageType* operator->() ONIXS_CONFLATEDTCP_NOTHROW
    {
        return &message();
    }
 
    const MessageType* operator->() const ONIXS_CONFLATEDTCP_NOTHROW
    {
        return &message();
    }
 
    const MessageType& operator* () const ONIXS_CONFLATEDTCP_NOTHROW
    {
        return message();
    }
 
    MessageType& operator* () ONIXS_CONFLATEDTCP_NOTHROW
    {
        return message();
    }

    const SimpleOpenFramingHeader* header() const ONIXS_CONFLATEDTCP_NOTHROW
    {
        return reinterpret_cast<const SimpleOpenFramingHeader*>(buffer_);
    }

    SimpleOpenFramingHeader* header() ONIXS_CONFLATEDTCP_NOTHROW
    {
        return reinterpret_cast<SimpleOpenFramingHeader*>(buffer_);
    }

    MessageSize setHeader() ONIXS_CONFLATEDTCP_NOTHROW
    {
        const MessageSize calculatedMessageSize =
            message().calculateBinarySize();
 
        assert(calculatedMessageSize <= MaxMessageSize);
 
        assert(
            calculatedMessageSize >=
            SbeType::blockLength(message().version()) +
            MessageHeaderBuilder::Size +
            SbeType::getMinimalVariableFieldsSize(message().version()));
 
        messageSize(calculatedMessageSize);
        return calculatedMessageSize;
    }

    ONIXS_CONFLATEDTCP_NODISCARD
    std::string toString() const
    {
        return toStr(*this);
    }
 
private:
    void messageSize(UInt16 size) ONIXS_CONFLATEDTCP_NOTHROW
    {
        header()->setup(size + 2); //size contains only 2 bytes (message size) from SimpleOpenFramingHeader
    }
 
    void copyFrom(const MessageHolder& r)
    {
#ifdef ONIXS_CONFLATEDTCP_MEMCHECK_DEBUG
        std::memset(buffer_, magicDebugValue, BufferSize);
#endif
 
        const size_t sizeToCopy = r.message_.MessageType::calculateBinarySize() + sizeof(SimpleOpenFramingHeader);
 
        assert(r.message_.calculateBinarySize() <= MaxMessageSize);
 
        std::memcpy(
            buffer_,
            r.buffer_,
            sizeToCopy);
 
        message_ =
            MessageType(
                buffer_ + sizeof(SimpleOpenFramingHeader),
                MaxMessageSize,
                SbeMessage::NoInit(),
                SbeMessage::NoCheck());
    }
 
private:
    MessageType message_;
    unsigned char buffer_[BufferSize];
};
 
template <
    template <typename, size_t, typename> class HolderType,
    typename MsgType,
    size_t MaxMessageSize,
    typename MessageInitializer>
inline std::string toStr(
    const HolderType<MsgType, MaxMessageSize, MessageInitializer>& holder)
{
    std::string res;
    toStr(res, holder);
    return res;
}
 
template <
    template <typename, size_t, typename> class HolderType,
    typename MsgType,
    size_t MaxMessageSize,
    typename MessageInitializer>
std::ostream& operator<<(
    std::ostream& stream,
    const HolderType<MsgType, MaxMessageSize, MessageInitializer>& rhs)
{
    return stream << toStr(rhs);
}
 
#if defined(ONIXS_CONFLATEDTCP_CXX11)
 
template <
    typename MessageTypeT,
    size_t MaxMessageSize =
        GetMaxMessageSize<typename HeldAdapter<MessageTypeT>::SbeType, DefaultMaxGroupItems>::Size,
    typename MessageInitializer = FieldsInitPolicy>
using MessageHolders = std::vector<MessageHolder<MessageTypeT, MaxMessageSize, MessageInitializer> >;
 
#endif
 
ONIXS_CONFLATEDTCP_MESSAGING_NAMESPACE_END