DynamicPubSubType.hpp

// Copyright 2023 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.
 
#ifndef FASTDDS_DDS_XTYPES_DYNAMIC_TYPES__DYNAMICPUBSUBTYPE_HPP
#define FASTDDS_DDS_XTYPES_DYNAMIC_TYPES__DYNAMICPUBSUBTYPE_HPP
 
#include <fastdds/dds/core/ReturnCode.hpp>
#include <fastdds/dds/topic/TopicDataType.hpp>
#include <fastdds/dds/xtypes/dynamic_types/Types.hpp>
#include <fastdds/dds/xtypes/type_representation/TypeObject.hpp>
#include <fastdds/rtps/common/InstanceHandle.hpp>
#include <fastdds/rtps/common/SerializedPayload.hpp>
#include <fastdds/utils/md5.hpp>
 
namespace eprosima {
namespace fastdds {
namespace dds {
 
class DynamicType;
class DynamicData;
 
class DynamicPubSubType : public virtual eprosima::fastdds::dds::TopicDataType
{
    traits<DynamicType>::ref_type dynamic_type_;
 
    unsigned char* key_buffer_ {nullptr};
 
    MD5 md5_;
 
public:
 
    //{{{ Public functions
 
    FASTDDS_EXPORTED_API DynamicPubSubType() = default;
 
    FASTDDS_EXPORTED_API DynamicPubSubType(
            traits<DynamicType>::ref_type type);
 
    FASTDDS_EXPORTED_API DynamicPubSubType(
            traits<DynamicType>::ref_type type,
            const xtypes::TypeInformation& type_information);
 
    FASTDDS_EXPORTED_API virtual ~DynamicPubSubType();
 
    FASTDDS_EXPORTED_API void* create_data() override;
 
    FASTDDS_EXPORTED_API void delete_data(
            void* data) override;
 
    FASTDDS_EXPORTED_API bool deserialize(
            eprosima::fastdds::rtps::SerializedPayload_t& payload,
            void* data) override;
 
    FASTDDS_EXPORTED_API traits<DynamicType>::ref_type get_dynamic_type() const noexcept;
 
    FASTDDS_EXPORTED_API bool compute_key(
            eprosima::fastdds::rtps::SerializedPayload_t& payload,
            eprosima::fastdds::rtps::InstanceHandle_t& ihandle,
            bool force_md5 = false) override;
 
    FASTDDS_EXPORTED_API bool compute_key(
            const void* const data,
            eprosima::fastdds::rtps::InstanceHandle_t& ihandle,
            bool force_md5 = false) override;
 
    FASTDDS_EXPORTED_API uint32_t calculate_serialized_size(
            const void* const data,
            DataRepresentationId_t data_representation) override;
 
    FASTDDS_EXPORTED_API bool serialize(
            const void* const data,
            eprosima::fastdds::rtps::SerializedPayload_t& payload,
            fastdds::dds::DataRepresentationId_t data_representation) override;
 
    FASTDDS_EXPORTED_API ReturnCode_t set_dynamic_type(
            traits<DynamicType>::ref_type type);
 
    FASTDDS_EXPORTED_API void register_type_object_representation() override;
 
    //}}}
 
private:
 
    void update_dynamic_type();
};
 
} // namespace dds
} // namespace fastdds
} // namespace eprosima
 
#endif // FASTDDS_DDS_XTYPES_DYNAMIC_TYPES__DYNAMICPUBSUBTYPE_HPP