RemoteObjectTemplate.h

Go to the documentation of this file.

// (c) IMT - Information Management Technology AG, CH-9470 Buchs, www.imt.ch.
 
#ifndef IMT_BASE_LIB_REMOTING_REMOTEOBJECTTEMPLATE_H
#define IMT_BASE_LIB_REMOTING_REMOTEOBJECTTEMPLATE_H
 
#include <Imt.Base.Core.Diagnostics/Diagnostics.h>
#include <Imt.Base.Core.Platform/Platform.h>
#include <Imt.Base.Core.Serialization/SerializableSenderIfc.h>
#include <Imt.Base.Lib.Remoting/RemoteObjectAbs.h>
 
namespace imt {
namespace base {
namespace lib {
namespace remoting {
 
template<class ProtocolType, uint16_t PROTOCOL_ID>
class RemoteObjectTemplate final : public RemoteObjectAbs {
 
public:
 
    RemoteObjectTemplate() = default;
 
    explicit RemoteObjectTemplate(RemotingSendServiceIfc* const pRemotingSendService,
        RemotingServiceIfc* const pRemotingReceiveService = nullptr,
        ::imt::base::core::serialization::SerializableSenderIfc* const portOut = nullptr) :
        RemoteObjectAbs {static_cast<int32_t>(PROTOCOL_ID), pRemotingSendService, pRemotingReceiveService},
        m_pPortOut {portOut},
        m_pDataToSend {nullptr} {
    }
 
    void deserialize(::imt::base::core::serialization::Deserializer& buffer) final {
        if (m_pPortOut == nullptr) {
            ASSERT_DEBUG1(false, "Output port not set, did you forget to pass the port in the constructor?");
            return;
        }
 
        ProtocolType const message {buffer};
        m_pPortOut->write(PROTOCOL_ID, &message, static_cast<size_t>(buffer.getBufferPos()));
    }
 
    void serialize(::imt::base::core::serialization::Serializer& buffer) const final {
        if (m_pDataToSend != nullptr) {
            m_pDataToSend->serialize(buffer);
        }
        else {
            // did you forget to set the pointer of the data to send?
            ASSERT_DEBUG(false);
        }
    }
 
    void setDataToSend(ProtocolType const* const protocolData) {
        // Because remoting is invoked via send() without parameters, the data to be sent needs to be set
        m_pDataToSend = protocolData;
    }
 
private:
 
    ::imt::base::core::serialization::SerializableSenderIfc* const m_pPortOut;
    // Pointer to the protocol which contains the values which have to be sent
    ProtocolType const* m_pDataToSend; // AXIVION Line AutosarC++19_03-A12.1.3: All data members initialized in custom constructor
};
 
} // namespace remoting
} // namespace lib
} // namespace base
} // namespace imt
 
#endif // IMT_BASE_LIB_REMOTING_REMOTEOBJECTTEMPLATE_H