MsgIdLayer.h

Go to the documentation of this file.

//
// Copyright 2014 - 2024 (C). Alex Robenko. All rights reserved.
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
 
#pragma once
 
#include <array>
#include <tuple>
#include <algorithm>
#include <utility>
#include <tuple>
#include <limits>
 
#include "comms/CompileControl.h"
#include "comms/Assert.h"
#include "comms/MessageBase.h"
#include "comms/MsgFactory.h"
#include "comms/details/tag.h"
#include "comms/protocol/details/ProtocolLayerBase.h"
#include "comms/protocol/details/MsgIdLayerOptionsParser.h"
#include "comms/protocol/details/ProtocolLayerExtendingClassHelper.h"
#include "comms/util/Tuple.h"
#include "comms/util/type_traits.h"
#include "comms/dispatch.h"
#include "comms/fields.h"
 
 
COMMS_MSVC_WARNING_PUSH
COMMS_MSVC_WARNING_DISABLE(4100) // Disable warning about unreferenced parameters
COMMS_MSVC_WARNING_DISABLE(4189) // Disable erroneous initialized but not referenced variable warning
 
namespace comms
{
 
namespace protocol
{
 
template <typename TField,
          typename TMessage,
          typename TAllMessages,
          typename TNextLayer,
          typename... TOptions>
class MsgIdLayer : public
        details::ProtocolLayerBase<
            TField,
            TNextLayer,
            details::ProtocolLayerExtendingClassT<
                MsgIdLayer<TField, TMessage, TAllMessages, TNextLayer, TOptions...>, 
                details::MsgIdLayerOptionsParser<TOptions...>
            >
        >
{
    static_assert(util::IsTuple<TAllMessages>::Value,
        "TAllMessages must be of std::tuple type");
 
    using BaseImpl =
        details::ProtocolLayerBase<
            TField,
            TNextLayer,
            details::ProtocolLayerExtendingClassT<
                MsgIdLayer<TField, TMessage, TAllMessages, TNextLayer, TOptions...>, 
                details::MsgIdLayerOptionsParser<TOptions...>
            >
        >;
 
    static_assert(TMessage::hasMsgIdType(),
        "Usage of MsgIdLayer requires support for ID type. "
        "Use comms::option::def::MsgIdType option in message interface type definition.");
 
    using ParsedOptionsInternal =  details::MsgIdLayerOptionsParser<TOptions...>;
 
public:
    // @brief Message factory class
    using MsgFactory = typename ParsedOptionsInternal::template MsgFactory<TMessage, TAllMessages>;
 
    using ExtendingClass = typename ParsedOptionsInternal::ExtendingClass;    
 
    using AllMessages = TAllMessages;
 
    using MsgPtr = typename MsgFactory::MsgPtr;
 
    using Message = TMessage;
 
    using MsgIdType = typename Message::MsgIdType;
 
    using MsgIdParamType = typename Message::MsgIdParamType;
 
    using Field = typename BaseImpl::Field;
 
    using CreateFailureReason = typename MsgFactory::CreateFailureReason;
 
    explicit MsgIdLayer() = default;
 
    MsgIdLayer(const MsgIdLayer&) = default;
 
    MsgIdLayer(MsgIdLayer&&) = default;
 
    MsgIdLayer& operator=(const MsgIdLayer&) = default;
 
    MsgIdLayer& operator=(MsgIdLayer&&) = default;
 
    ~MsgIdLayer() noexcept = default;
 
    static constexpr bool hasExtendingClass()
    {
        return ParsedOptionsInternal::HasExtendingClass;
    }     
 
    static constexpr bool hasMsgFactory()
    {
        return ParsedOptionsInternal::HasMsgFactory;
    }   
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus doRead(
        Field& field,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        TExtraValues... extraValues)
    {
        auto beforeReadIter = iter;
        auto& thisObj = BaseImpl::thisLayer();
        auto* msgPtr = BaseImpl::toMsgPtr(msg);
        auto es = thisObj.doReadField(msgPtr, field, iter, size);
        if (es == comms::ErrorStatus::NotEnoughData) {
            BaseImpl::updateMissingSize(field, size, extraValues...);
        }
 
        if (es != ErrorStatus::Success) {
            return es;
        }
 
        auto fieldLen = static_cast<std::size_t>(std::distance(beforeReadIter, iter));
 
        using Tag =
            typename comms::util::LazyShallowConditional<
                comms::isMessageBase<typename std::decay<decltype(msg)>::type>()
            >::template Type<
                DirectOpTag,
                PointerOpTag
            >;
 
        return
            doReadInternal(
                field,
                msg,
                iter,
                size - fieldLen,
                std::forward<TNextLayerReader>(nextLayerReader),
                Tag(),
                extraValues...);
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerWriter>
    ErrorStatus doWrite(
        Field& field,
        const TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerWriter&& nextLayerWriter) const
    {
        auto& thisObj = BaseImpl::thisLayer();
        using MsgType = typename std::decay<decltype(msg)>::type;
        thisObj.prepareFieldForWrite(
            getMsgId(msg, IdRetrieveTag<MsgType>()), 
            msg, 
            field);
 
        auto es = thisObj.doWriteField(&msg, field, iter, size);
        if (es != ErrorStatus::Success) {
            return es;
        }
 
        COMMS_ASSERT(field.length() <= size);
 
        using Tag =
            typename comms::util::LazyShallowConditional<
                comms::isMessageBase<MsgType>() || MsgType::hasWrite()
            >::template Type<
                DirectOpTag,
                StaticBinSearchOpTag
            >;
 
        return writeInternal(field, msg, iter, size - field.length(), std::forward<TNextLayerWriter>(nextLayerWriter), Tag());
    }
 
    MsgPtr createMsg(MsgIdParamType id, unsigned idx = 0, CreateFailureReason* reason = nullptr)
    {
        return factory_.createMsg(id, idx, reason);
    }
 
    static constexpr bool isDispatchPolymorphic()
    {
        return MsgFactory::isDispatchPolymorphic();
    }
 
    static constexpr bool isDispatchStaticBinSearch()
    {
        return MsgFactory::isDispatchStaticBinSearch();
    }
 
    static constexpr bool isDispatchLinearSwitch()
    {
        return MsgFactory::isDispatchLinearSwitch();
    }
 
protected:
 
    static MsgIdType getMsgIdFromField(const Field& field)
    {
        return static_cast<MsgIdType>(field.getValue());
    }
 
    template <typename TMsg>
    static void beforeRead(const Field& field, TMsg& msg)
    {
        static_cast<void>(field);
        static_cast<void>(msg);
    }
 
    template <typename TMsg>
    static void prepareFieldForWrite(MsgIdParamType id, const TMsg& msg, Field& field)
    {
        static_cast<void>(msg);
        static_cast<void>(field);
        field.setValue(id);
    }
 
private:
 
    template <typename... TParams>
    using PolymorphicOpTag = comms::details::tag::Tag1<>;
 
    template <typename... TParams>
    using DirectOpTag = comms::details::tag::Tag2<>;
 
    template <typename... TParams>
    using PointerOpTag = comms::details::tag::Tag3<>;
 
    template <typename... TParams>
    using StaticBinSearchOpTag = comms::details::tag::Tag4<>;         
 
    template <typename TMsg>
    using IdRetrieveTag =
        typename comms::util::LazyShallowConditional<
            details::protocolLayerHasDoGetId<TMsg>()
        >::template Type<
            DirectOpTag,
            PolymorphicOpTag
        >;
 
    template <typename... TParams>
    using IdParamAsIsTag = comms::details::tag::Tag5<>; 
 
    template <typename... TParams>
    using IdParamCastTag = comms::details::tag::Tag6<>;     
 
    template <typename TId>
    using IdParamTag =
        typename comms::util::LazyShallowConditional<
            std::is_base_of<MsgIdType, TId>::value
        >::template Type<
            IdParamAsIsTag,
            IdParamCastTag
        >;
 
    template <typename... TParams>
    using HasGenericMsgTag = comms::details::tag::Tag7<>; 
 
    template <typename... TParams>
    using NoGenericMsgTag = comms::details::tag::Tag8<>;     
 
    template <typename TIter, typename TNextLayerReader, typename... TExtraValues>
    class ReadRedirectionHandler
    {
    public:
        using RetType = comms::ErrorStatus;
 
        ReadRedirectionHandler(
            TIter& iter,
            std::size_t size,
            TNextLayerReader&& nextLayerReader,
            TExtraValues... extraValues)
          : m_iter(iter),
            m_size(size),
            m_nextLayerReader(std::forward<TNextLayerReader>(nextLayerReader)),
            m_extraValues(extraValues...)
        {
        }
 
        template <typename TMsg>
        RetType handle(TMsg& msg)
        {
            static_assert(comms::isMessageBase<TMsg>(), "Expected to be a valid message object");
            return handleInternal(msg, m_extraValues);
        }
 
        RetType handle(TMessage& msg)
        {
            static_cast<void>(msg);
            static constexpr bool Should_not_happen = false;
            static_cast<void>(Should_not_happen);
            COMMS_ASSERT(Should_not_happen);
            return comms::ErrorStatus::InvalidMsgId;
        }        
 
    private:
        template <typename TMsg>
        RetType handleInternal(TMsg& msg, std::tuple<>&)
        {
            return m_nextLayerReader.read(msg, m_iter, m_size);
        }
 
        template <typename TMsg, typename T0>
        RetType handleInternal(TMsg& msg, std::tuple<T0>& extraValues)
        {
            return m_nextLayerReader.read(msg, m_iter, m_size, std::get<0>(extraValues));
        }
 
        template <typename TMsg, typename T0, typename T1>
        RetType handleInternal(TMsg& msg, std::tuple<T0, T1>& extraValues)
        {
            return m_nextLayerReader.read(msg, m_iter, m_size, std::get<0>(extraValues), std::get<1>(extraValues));
        }
 
        template <typename TMsg, typename T0, typename T1, typename T2>
        RetType handleInternal(TMsg& msg, std::tuple<T0, T1, T2>& extraValues)
        {
            return
               m_nextLayerReader.read(
                    msg,
                    m_iter,
                    m_size,
                    std::get<0>(extraValues),
                    std::get<1>(extraValues),
                    std::get<2>(extraValues));
        }
 
        template <typename TMsg, typename T0, typename T1, typename T2, typename T3>
        RetType handleInternal(TMsg& msg, std::tuple<T0, T1, T2, T3>& extraValues)
        {
            return
               m_nextLayerReader.read(
                    msg,
                    m_iter,
                    m_size,
                    std::get<0>(extraValues),
                    std::get<1>(extraValues),
                    std::get<2>(extraValues),
                    std::get<3>(extraValues));
        }
 
        template <typename TMsg, typename T0, typename T1, typename T2, typename T3, typename T4>
        RetType handleInternal(TMsg& msg, std::tuple<T0, T1, T2, T3, T4>& extraValues)
        {
            return
               m_nextLayerReader.read(
                    msg,
                    m_iter,
                    m_size,
                    std::get<0>(extraValues),
                    std::get<1>(extraValues),
                    std::get<2>(extraValues),
                    std::get<3>(extraValues),
                    std::get<4>(extraValues));
        }
 
        template <typename TMsg, typename T0, typename T1, typename T2, typename T3, typename T4, typename T5>
        RetType handleInternal(TMsg& msg, std::tuple<T0, T1, T2, T3, T4, T5>& extraValues)
        {
            return
               m_nextLayerReader.read(
                    msg,
                    m_iter,
                    m_size,
                    std::get<0>(extraValues),
                    std::get<1>(extraValues),
                    std::get<2>(extraValues),
                    std::get<3>(extraValues),
                    std::get<4>(extraValues),
                    std::get<5>(extraValues));
        }
 
        TIter& m_iter;
        std::size_t m_size = 0U;
        TNextLayerReader&& m_nextLayerReader;
        std::tuple<TExtraValues...> m_extraValues;
    };
 
    template <typename TIter, typename TNextLayerReader, typename... TExtraValues>
    ReadRedirectionHandler<TIter, TNextLayerReader, TExtraValues...> makeReadRedirectionHandler(
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        TExtraValues... extraValues)
    {
        return ReadRedirectionHandler<TIter, TNextLayerReader, TExtraValues...>(iter, size, std::forward<TNextLayerReader>(nextLayerReader), extraValues...);
    }
 
    template <typename TIter, typename TNextLayerWriter>
    class WriteRedirectionHandler
    {
    public:
        using RetType = comms::ErrorStatus;
 
        WriteRedirectionHandler(
            TIter& iter,
            std::size_t size,
            TNextLayerWriter&& nextLayerWriter)
          : m_iter(iter),
            m_size(size),
            m_nextLayerWriter(std::forward<TNextLayerWriter>(nextLayerWriter))
        {
        }
 
        template <typename TMsg>
        RetType handle(const TMsg& msg)
        {
            static_assert(comms::isMessageBase<TMsg>(), "Expected to be a valid message object");
            return m_nextLayerWriter.write(msg, m_iter, m_size);
        }
        
        RetType handle(const TMessage& msg)
        {
            static_cast<void>(msg);
            static constexpr bool Should_not_happen = false;
            static_cast<void>(Should_not_happen);
            COMMS_ASSERT(Should_not_happen);
            return comms::ErrorStatus::InvalidMsgId;
        }   
 
    private:
        TIter& m_iter;
        std::size_t m_size = 0U;
        TNextLayerWriter&& m_nextLayerWriter;
    };
 
    template <typename TIter, typename TNextLayerWriter>
    WriteRedirectionHandler<TIter, TNextLayerWriter> makeWriteRedirectionHandler(
        TIter& iter,
        std::size_t size,
        TNextLayerWriter&& nextLayerWriter)
    {
        return WriteRedirectionHandler<TIter, TNextLayerWriter>(iter, size, std::forward<TNextLayerWriter>(nextLayerWriter));
    }
 
    template <typename TMsg, typename... TParams>
    static MsgIdParamType getMsgId(const TMsg& msg, PolymorphicOpTag<TParams...>)
    {
        using MsgType = typename std::decay<decltype(msg)>::type;
        static_assert(comms::isMessage<MsgType>(),
            "The message class is expected to inherit from comms::Message");
        static_assert(MsgType::hasGetId(),
            "The message interface class must expose polymorphic ID retrieval functionality, "
            "use comms::option::app::IdInfoInterface option to define it.");
 
        return msg.getId();
    }
 
    template <typename TMsg, typename... TParams>
    static constexpr MsgIdParamType getMsgId(const TMsg& msg, DirectOpTag<TParams...>)
    {
        return msg.doGetId();
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus doReadInternalDirect(
        Field& field,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        TExtraValues... extraValues)
    {
        using MsgType = typename std::decay<decltype(msg)>::type;
        static_assert(details::protocolLayerHasDoGetId<MsgType>(),
                "Explicit message type is expected to expose compile type message ID by "
                "using \"StaticNumIdImpl\" option");
 
        auto& thisObj = BaseImpl::thisLayer();
        auto id = thisObj.getMsgIdFromField(field);
        BaseImpl::setMsgId(id, extraValues...);
        if (id != MsgType::doGetId()) {
            return ErrorStatus::InvalidMsgId;
        }
 
        thisObj.beforeRead(field, msg);
        return nextLayerReader.read(msg, iter, size, extraValues...);
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus doReadInternal(
        MsgIdParamType id,
        unsigned idx,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        PolymorphicOpTag<>,
        TExtraValues... extraValues)
    {
        static_cast<void>(id);
        static_cast<void>(idx);
        return nextLayerReader.read(msg, iter, size, extraValues...);
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus doReadInternal(
        Field& field,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        DirectOpTag<>,
        TExtraValues... extraValues)
    {
        return
            doReadInternalDirect(
                field,
                msg,
                iter,
                size,
                std::forward<TNextLayerReader>(nextLayerReader),
                extraValues...);
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus doReadInternal(
        Field& field,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        PointerOpTag<>,
        TExtraValues... extraValues)
    {
        using MsgType = typename std::decay<decltype(msg)>::type;
        static_assert(comms::details::hasElementType<MsgType>(),
            "Unsupported type of message object, expected to be either message itself or smart pointer");
 
        using MsgElementType = typename MsgType::element_type;
 
//        static_assert(std::has_virtual_destructor<MsgElementType>::value,
//            "Message object is (dynamically) allocated and held by the pointer to the base class. "
//            "However, there is no virtual desctructor to perform proper destruction.");
 
        using Tag = 
            typename comms::util::LazyShallowConditional<
                MsgElementType::hasRead()
            >::template Type<
                PolymorphicOpTag,
                StaticBinSearchOpTag
            >;
 
        auto& thisObj = BaseImpl::thisLayer();
        const auto id = thisObj.getMsgIdFromField(field);
        BaseImpl::setMsgId(id, extraValues...);
 
        auto es = comms::ErrorStatus::InvalidMsgId;
        unsigned idx = 0;
        CreateFailureReason failureReason = CreateFailureReason::None;
        while (true) {
            COMMS_ASSERT(!msg);
            msg = createMsgInternal(id, idx, &failureReason);
            if (!msg) {
                break;
            }
 
            using IterType = typename std::decay<decltype(iter)>::type;
            static_assert(std::is_same<typename std::iterator_traits<IterType>::iterator_category, std::random_access_iterator_tag>::value,
                "Iterator used for reading is expected to be random access one");
            IterType readStart = iter;                
 
            thisObj.beforeRead(field, *msg);
            es = doReadInternal(id, idx, msg, iter, size, std::forward<TNextLayerReader>(nextLayerReader), Tag(), extraValues...);
            if (es == comms::ErrorStatus::Success) {
                BaseImpl::setMsgIndex(idx, extraValues...);
                return es;
            }
 
            msg.reset();
            iter = readStart;
            ++idx;
        }
 
        BaseImpl::setMsgIndex(idx, extraValues...);
        COMMS_ASSERT(!msg);
        if (failureReason == CreateFailureReason::AllocFailure) {
            return comms::ErrorStatus::MsgAllocFailure;
        }        
        
        COMMS_ASSERT(failureReason == CreateFailureReason::InvalidId);
        using GenericMsgTag = 
            typename comms::util::LazyShallowConditional<
                MsgFactory::hasGenericMessageSupport()
            >::template Type<
                HasGenericMsgTag,
                NoGenericMsgTag
            >;
 
        return createAndReadGenericMsgInternal(
            field, 
            idx,
            msg, 
            iter, 
            size, 
            std::forward<TNextLayerReader>(nextLayerReader), 
            es,
            GenericMsgTag(),
            extraValues...);
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus doReadInternal(
        MsgIdParamType id,
        unsigned idx,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        StaticBinSearchOpTag<>,
        TExtraValues... extraValues)
    {
        auto handler =
            makeReadRedirectionHandler(
                iter,
                size,
                std::forward<TNextLayerReader>(nextLayerReader),
                extraValues...);
        return comms::dispatchMsgStaticBinSearch<AllMessages>(id, idx, *msg, handler);
    }
 
    template <typename TId, typename... TParams>
    MsgPtr createMsgInternalTagged(TId&& id, unsigned idx, CreateFailureReason* reason, IdParamAsIsTag<TParams...>)
    {
        return createMsg(std::forward<TId>(id), idx, reason);
    }
 
    template <typename TId, typename... TParams>
    MsgPtr createMsgInternalTagged(TId&& id, unsigned idx, CreateFailureReason* reason, IdParamCastTag<TParams...>)
    {
        return createMsg(static_cast<MsgIdType>(id), idx, reason);
    }
 
    template <typename TId>
    MsgPtr createMsgInternal(TId&& id, unsigned idx, CreateFailureReason* reason)
    {
        using IdType = typename std::decay<decltype(id)>::type;
        return createMsgInternalTagged(std::forward<TId>(id), idx, reason, IdParamTag<IdType>());
    }
 
    template <typename TId, typename... TParams>
    MsgPtr createGenericMsgInternalTagged(TId&& id, unsigned idx, IdParamAsIsTag<TParams...>)
    {
        return factory_.createGenericMsg(std::forward<TId>(id), idx);
    }
 
    template <typename TId, typename... TParams>
    MsgPtr createGenericMsgInternalTagged(TId&& id, unsigned idx, IdParamCastTag<TParams...>)
    {
        return factory_.createGenericMsg(static_cast<MsgIdType>(id), idx);
    }
 
    template <typename TId>
    MsgPtr createGenericMsgInternal(TId&& id, unsigned idx)
    {
        using IdType = typename std::decay<decltype(id)>::type;
        return createGenericMsgInternalTagged(std::forward<TId>(id), idx, IdParamTag<IdType>());
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus createAndReadGenericMsgInternal(
        const Field& field,
        unsigned msgIdx,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        comms::ErrorStatus es,
        NoGenericMsgTag<>,
        TExtraValues...)
    {
        static_cast<void>(field);
        static_cast<void>(msgIdx);
        static_cast<void>(msg);
        static_cast<void>(iter);
        static_cast<void>(size);
        static_cast<void>(nextLayerReader);
        return es;
    }   
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus createAndReadGenericMsgInternal(
        const Field& field,
        unsigned msgIdx,
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        comms::ErrorStatus es,
        HasGenericMsgTag<>,
        TExtraValues... extraValues)
    {
        using GenericMsgType = typename MsgFactory::GenericMessage;
 
        auto& thisObj = BaseImpl::thisLayer();
        auto id = thisObj.getMsgIdFromField(field);
        msg = createGenericMsgInternal(id, msgIdx);
        if (!msg) {
            return es;
        }
 
        thisObj.beforeRead(field, *msg);
 
        using Tag = 
            typename comms::util::LazyShallowConditional<
                GenericMsgType::hasRead()
            >::template Type<
                PolymorphicOpTag,
                DirectOpTag
            >;
 
        return
            readGenericMsg(
                msg,
                iter,
                size,
                std::forward<TNextLayerReader>(nextLayerReader),
                Tag(),
                extraValues...);
    }  
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus readGenericMsg(
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        PolymorphicOpTag<>,
        TExtraValues... extraValues)
    {
        return nextLayerReader.read(msg, iter, size, extraValues...);
    }  
 
    template <typename TMsg, typename TIter, typename TNextLayerReader, typename... TExtraValues>
    comms::ErrorStatus readGenericMsg(
        TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerReader&& nextLayerReader,
        DirectOpTag<>,
        TExtraValues... extraValues)
    {
        using GenericMsgType = typename MsgFactory::GenericMessage;
        auto& castedMsgRef = static_cast<GenericMsgType&>(*msg);
        return nextLayerReader.read(castedMsgRef, iter, size, extraValues...);
    }               
 
    template <typename TId, typename... TParams>
    std::size_t msgCountInternalTagged(TId&& id, IdParamAsIsTag<TParams...>)
    {
        return factory_.msgCount(std::forward<TId>(id));
    }
 
    template <typename TId, typename... TParams>
    std::size_t msgCountInternalTagged(TId&& id, IdParamCastTag<TParams...>)
    {
        return factory_.msgCount(static_cast<MsgIdType>(id));
    }
 
 
    template <typename TId>
    std::size_t msgCountInternal(TId&& id)
    {
        using IdType = typename std::decay<decltype(id)>::type;
        return msgCountInternalTagged(std::forward<TId>(id), IdParamTag<IdType>());
    }
 
    template <typename TMsg, typename TIter, typename TNextLayerWriter, typename... TParams>
    ErrorStatus writeInternal(
        Field& field,
        const TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerWriter&& nextLayerWriter,
        DirectOpTag<TParams...>) const
    {
        static_cast<void>(field);
        return nextLayerWriter.write(msg, iter, size);
    }
 
 
    template <typename TMsg, typename TIter, typename TNextLayerWriter, typename... TParams>
    ErrorStatus writeInternal(
        Field& field,
        const TMsg& msg,
        TIter& iter,
        std::size_t size,
        TNextLayerWriter&& nextLayerWriter,
        StaticBinSearchOpTag<TParams...>) const
    {
        auto& thisObj = BaseImpl::thisLayer();
        auto handler = makeWriteRedirectionHandler(iter, size, std::forward<TNextLayerWriter>(nextLayerWriter));
        auto id = thisObj.getMsgIdFromField(field);
        return comms::dispatchMsgStaticBinSearch(id, msg, handler);
    }
 
    MsgFactory factory_;
};
 
 
namespace details
{
template <typename T>
struct MsgIdLayerCheckHelper
{
    static const bool Value = false;
};
 
template <typename TField,
          typename TMessage,
          typename TAllMessages,
          typename TNextLayer,
          typename... TOptions>
struct MsgIdLayerCheckHelper<MsgIdLayer<TField, TMessage, TAllMessages, TNextLayer, TOptions...> >
{
    static const bool Value = true;
};
 
} // namespace details
 
template <typename T>
constexpr bool isMsgIdLayer()
{
    return details::MsgIdLayerCheckHelper<T>::Value;
}
 
}  // namespace protocol
 
}  // namespace comms
 
COMMS_MSVC_WARNING_POP