Refs #22929. Avoid processing fake samples in PubSubReader.

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

Author: MiguelCompany

test/blackbox/api/dds-pim/PubSubReader.hpp

@@ -1785,7 +1785,10 @@ class PubSubReader
 
         if (eprosima::fastdds::dds::RETCODE_OK == datareader_->take(data_seq, info_seq))
         {
-            current_processed_count_++;
+            if (info_seq[0].sample_identity != eprosima::fastdds::rtps::SampleIdentity::unknown())
+            {
+                current_processed_count_++;
+            }
             return true;
         }
         return false;
@@ -1797,7 +1800,10 @@ class PubSubReader
         eprosima::fastdds::dds::SampleInfo dds_info;
         if (datareader_->take_next_sample(data, &dds_info) == eprosima::fastdds::dds::RETCODE_OK)
         {
-            current_processed_count_++;
+            if (dds_info.sample_identity != eprosima::fastdds::rtps::SampleIdentity::unknown())
+            {
+                current_processed_count_++;
+            }
             return true;
         }
         return false;
@@ -2017,7 +2023,8 @@ class PubSubReader
         ReturnCode_t success = take_ ?
                 datareader->take_next_sample((void*)&data, &info) :
                 datareader->read_next_sample((void*)&data, &info);
-        if (eprosima::fastdds::dds::RETCODE_OK == success)
+        if ((eprosima::fastdds::dds::RETCODE_OK == success) &&
+                (info.sample_identity != eprosima::fastdds::rtps::SampleIdentity::unknown()))
         {
             returnedValue = true;
 
@@ -2071,6 +2078,11 @@ class PubSubReader
             type& data = datas[i];
             eprosima::fastdds::dds::SampleInfo& info = infos[i];
 
+            if (info.sample_identity == eprosima::fastdds::rtps::SampleIdentity::unknown())
+            {
+                continue; // Skip unknown samples
+            }
+
             // Check order of changes.
             LastSeqInfo seq_info{ info.instance_handle, info.sample_identity.writer_guid() };
             ASSERT_LT(last_seq[seq_info], info.sample_identity.sequence_number());