Refs #21349. Apply suggestions

Signed-off-by: Ricardo González Moreno <ricardo@richiware.dev>
eProsima · Jul 15, 2024 · 3759961 · 3759961
1 parent 3984949
commit 3759961
Show file tree

Hide file tree

Showing 138 changed files with 25,725 additions and 2,737 deletions.
diff --git a/examples/cpp/configuration/ConfigurationPubSubTypes.cxx b/examples/cpp/configuration/ConfigurationPubSubTypes.cxx
@@ -148,6 +148,25 @@ void ConfigurationPubSubType::delete_data(
     delete(reinterpret_cast<Configuration*>(data));
 }
 
+bool ConfigurationPubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    Configuration data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool ConfigurationPubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/configuration/ConfigurationPubSubTypes.hpp b/examples/cpp/configuration/ConfigurationPubSubTypes.hpp
@@ -65,6 +65,11 @@ class ConfigurationPubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/content_filter/HelloWorldPubSubTypes.cxx b/examples/cpp/content_filter/HelloWorldPubSubTypes.cxx
@@ -148,6 +148,25 @@ void HelloWorldPubSubType::delete_data(
     delete(reinterpret_cast<HelloWorld*>(data));
 }
 
+bool HelloWorldPubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    HelloWorld data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool HelloWorldPubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/content_filter/HelloWorldPubSubTypes.hpp b/examples/cpp/content_filter/HelloWorldPubSubTypes.hpp
@@ -65,6 +65,11 @@ class HelloWorldPubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/custom_payload_pool/HelloWorldPubSubTypes.cxx b/examples/cpp/custom_payload_pool/HelloWorldPubSubTypes.cxx
@@ -148,6 +148,25 @@ void HelloWorldPubSubType::delete_data(
     delete(reinterpret_cast<HelloWorld*>(data));
 }
 
+bool HelloWorldPubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    HelloWorld data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool HelloWorldPubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/custom_payload_pool/HelloWorldPubSubTypes.hpp b/examples/cpp/custom_payload_pool/HelloWorldPubSubTypes.hpp
@@ -65,6 +65,11 @@ class HelloWorldPubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/dds/FlowControlExample/FlowControlExamplePubSubTypes.cxx b/examples/cpp/dds/FlowControlExample/FlowControlExamplePubSubTypes.cxx
@@ -148,6 +148,25 @@ void FlowControlExamplePubSubType::delete_data(
     delete(reinterpret_cast<FlowControlExample*>(data));
 }
 
+bool FlowControlExamplePubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    FlowControlExample data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool FlowControlExamplePubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/dds/FlowControlExample/FlowControlExamplePubSubTypes.hpp b/examples/cpp/dds/FlowControlExample/FlowControlExamplePubSubTypes.hpp
@@ -65,6 +65,11 @@ class FlowControlExamplePubSubType : public eprosima::fastdds::dds::TopicDataTyp
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/dds/HelloWorldExampleDataSharing/HelloWorldPubSubTypes.cxx b/examples/cpp/dds/HelloWorldExampleDataSharing/HelloWorldPubSubTypes.cxx
@@ -148,6 +148,25 @@ void HelloWorldPubSubType::delete_data(
     delete(reinterpret_cast<HelloWorld*>(data));
 }
 
+bool HelloWorldPubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    HelloWorld data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool HelloWorldPubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/dds/HelloWorldExampleDataSharing/HelloWorldPubSubTypes.hpp b/examples/cpp/dds/HelloWorldExampleDataSharing/HelloWorldPubSubTypes.hpp
@@ -65,6 +65,11 @@ class HelloWorldPubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/dds/HelloWorldExampleSharedMem/HelloWorldPubSubTypes.cxx b/examples/cpp/dds/HelloWorldExampleSharedMem/HelloWorldPubSubTypes.cxx
@@ -148,6 +148,25 @@ void HelloWorldPubSubType::delete_data(
     delete(reinterpret_cast<HelloWorld*>(data));
 }
 
+bool HelloWorldPubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    HelloWorld data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool HelloWorldPubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/dds/HelloWorldExampleSharedMem/HelloWorldPubSubTypes.hpp b/examples/cpp/dds/HelloWorldExampleSharedMem/HelloWorldPubSubTypes.hpp
@@ -65,6 +65,11 @@ class HelloWorldPubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/dds/HelloWorldExampleTCP/HelloWorldPubSubTypes.cxx b/examples/cpp/dds/HelloWorldExampleTCP/HelloWorldPubSubTypes.cxx
@@ -148,6 +148,25 @@ void HelloWorldPubSubType::delete_data(
     delete(reinterpret_cast<HelloWorld*>(data));
 }
 
+bool HelloWorldPubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    HelloWorld data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool HelloWorldPubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/dds/HelloWorldExampleTCP/HelloWorldPubSubTypes.hpp b/examples/cpp/dds/HelloWorldExampleTCP/HelloWorldPubSubTypes.hpp
@@ -65,6 +65,11 @@ class HelloWorldPubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/dds/Keys/samplePubSubTypes.cxx b/examples/cpp/dds/Keys/samplePubSubTypes.cxx
@@ -148,6 +148,25 @@ void samplePubSubType::delete_data(
     delete(reinterpret_cast<sample*>(data));
 }
 
+bool samplePubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    sample data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool samplePubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/dds/Keys/samplePubSubTypes.hpp b/examples/cpp/dds/Keys/samplePubSubTypes.hpp
@@ -65,6 +65,11 @@ class samplePubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,

diff --git a/examples/cpp/dds/RequestReplyExample/CalculatorPubSubTypes.cxx b/examples/cpp/dds/RequestReplyExample/CalculatorPubSubTypes.cxx
@@ -148,6 +148,25 @@ void RequestTypePubSubType::delete_data(
     delete(reinterpret_cast<RequestType*>(data));
 }
 
+bool RequestTypePubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    RequestType data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool RequestTypePubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,
@@ -309,6 +328,25 @@ void ReplyTypePubSubType::delete_data(
     delete(reinterpret_cast<ReplyType*>(data));
 }
 
+bool ReplyTypePubSubType::compute_key(
+        SerializedPayload_t* payload,
+        InstanceHandle_t* handle,
+        bool force_md5)
+{
+    if (!is_compute_key_provided)
+    {
+        return false;
+    }
+
+    ReplyType data;
+    if (deserialize(payload, static_cast<void*>(&data)))
+    {
+        return compute_key(static_cast<void*>(&data), handle, force_md5);
+    }
+
+    return false;
+}
+
 bool ReplyTypePubSubType::compute_key(
         const void* const data,
         InstanceHandle_t* handle,

diff --git a/examples/cpp/dds/RequestReplyExample/CalculatorPubSubTypes.hpp b/examples/cpp/dds/RequestReplyExample/CalculatorPubSubTypes.hpp
@@ -65,6 +65,11 @@ class RequestTypePubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
@@ -139,6 +144,11 @@ class ReplyTypePubSubType : public eprosima::fastdds::dds::TopicDataType
             const void* const data,
             eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
 
+    eProsima_user_DllExport bool compute_key(
+            eprosima::fastdds::rtps::SerializedPayload_t* payload,
+            eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
+            bool force_md5 = false) override;
+
     eProsima_user_DllExport bool compute_key(
             const void* const data,
             eprosima::fastdds::rtps::InstanceHandle_t* ihandle,