Refs #23365. Add blackbox test.

Signed-off-by: Miguel Company <miguelcompany@eprosima.com>

Author: MiguelCompany

test/blackbox/common/DDSBlackboxTestsBasic.cpp

@@ -512,6 +512,127 @@ TEST(DDSBasic, PidRelatedSampleIdentity)
     ASSERT_EQ(related_sample_identity_, info.related_sample_identity);
 }
 
+/**
+ * Read a parameterList from a CDRMessage.
+ * Search for PID_RPC_MORE_REPLIES in msg.
+ * @param [in] msg Reference to the message.
+ * @param [out] exists_pid_rpc_more_replies True if the parameter is inside msg.
+ * @return true if parsing was correct, false otherwise.
+ */
+bool check_rpc_has_more_replies_field(
+        fastdds::rtps::CDRMessage_t& msg,
+        bool& exists_pid_rpc_more_replies)
+{
+    uint32_t qos_size = 0;
+
+    uint32_t original_pos = msg.pos;
+    bool is_sentinel = false;
+    while (!is_sentinel)
+    {
+        msg.pos = original_pos + qos_size;
+
+        ParameterId_t pid{PID_SENTINEL};
+        bool valid = true;
+        pid = (ParameterId_t)eprosima::fastdds::helpers::cdr_parse_u16(
+            (char*)&msg.buffer[msg.pos]);
+        msg.pos += 2;
+        uint16_t plength = eprosima::fastdds::helpers::cdr_parse_u16(
+            (char*)&msg.buffer[msg.pos]);
+        msg.pos += 2;
+
+        if (pid == PID_SENTINEL)
+        {
+            // PID_SENTINEL is always considered of length 0
+            plength = 0;
+            is_sentinel = true;
+        }
+
+        qos_size += (4 + plength);
+
+        // Align to 4 byte boundary and prepare for next iteration
+        qos_size = (qos_size + 3) & ~3;
+
+        if (!valid || ((msg.pos + plength) > msg.length))
+        {
+            return false;
+        }
+        else if (!is_sentinel)
+        {
+            if (PID_RPC_MORE_REPLIES == pid)
+            {
+                exists_pid_rpc_more_replies = true;
+            }
+        }
+    }
+    return true;
+}
+
+/**
+ * This test checks that PID_RPC_MORE_REPLIES is being sent as parameter when has_more_replies is
+ * specified in WriteParams, and that it is correctly passed into SampleInfo.
+ */
+TEST(DDSBasic, PidRpcMoreReplies)
+{
+    PubSubWriter<HelloWorldPubSubType> reliable_writer(TEST_TOPIC_NAME);
+    PubSubReader<HelloWorldPubSubType> reliable_reader(TEST_TOPIC_NAME);
+
+    // Test transport will be used in order to filter inlineQoS
+    auto test_transport = std::make_shared<eprosima::fastdds::rtps::test_UDPv4TransportDescriptor>();
+    bool exists_pid_rpc_more_replies = false;
+
+    test_transport->drop_data_messages_filter_ =
+            [&exists_pid_rpc_more_replies]
+                (eprosima::fastdds::rtps::CDRMessage_t& msg)-> bool
+            {
+                bool ret = check_rpc_has_more_replies_field(msg, exists_pid_rpc_more_replies);
+                EXPECT_TRUE(ret);
+                return false;
+            };
+
+    reliable_writer.reliability(eprosima::fastdds::dds::RELIABLE_RELIABILITY_QOS)
+            .disable_builtin_transport()
+            .add_user_transport_to_pparams(test_transport)
+            .init();
+    ASSERT_TRUE(reliable_writer.isInitialized());
+
+    reliable_reader.reliability(eprosima::fastdds::dds::RELIABLE_RELIABILITY_QOS)
+            .disable_builtin_transport()
+            .add_user_transport_to_pparams(test_transport)
+            .init();
+    ASSERT_TRUE(reliable_reader.isInitialized());
+
+    reliable_writer.wait_discovery();
+    reliable_reader.wait_discovery();
+
+    DataWriter& native_writer = reliable_writer.get_native_writer();
+
+    HelloWorld data;
+    // Send reply associating it with the client request.
+    eprosima::fastdds::rtps::WriteParams write_params;
+    write_params.has_more_replies(true);
+
+    // Publish the value with has_more_replies set to true
+    ReturnCode_t write_ret = native_writer.write((void*)&data, write_params);
+    ASSERT_EQ(RETCODE_OK, write_ret);
+
+    DataReader& native_reader = reliable_reader.get_native_reader();
+
+    HelloWorld read_data;
+    eprosima::fastdds::dds::SampleInfo info;
+    eprosima::fastdds::dds::Duration_t timeout;
+    timeout.seconds = 2;
+    while (!native_reader.wait_for_unread_message(timeout))
+    {
+    }
+
+    ASSERT_EQ(RETCODE_OK,
+            native_reader.take_next_sample((void*)&read_data, &info));
+
+    ASSERT_TRUE(exists_pid_rpc_more_replies);
+
+    ASSERT_TRUE(info.has_more_replies);
+}
+
 /**
  * This test checks that PID_RELATED_SAMPLE_IDENTITY and
  * PID_CUSTOM_RELATED_SAMPLE_IDENTITY are being sent as parameter,