[#24061] Finished IWriter 'update_topic_partitions()' implementation

Signed-off-by: danipiza <dpizarrogallego@gmail.com>

Author: Danipiza

ddspipe_core/include/ddspipe_core/core/DdsPipe.hpp

@@ -126,6 +126,10 @@ class DdsPipe
     DDSPIPE_CORE_DllAPI
     utils::ReturnCode disable() noexcept;
 
+    DDSPIPE_CORE_DllAPI
+    void update_filter(
+            const std::set<std::string> filter_partition_set);
+
     DDSPIPE_CORE_DllAPI
     void update_partitions(
             std::set<std::string> partitions_set);

ddspipe_core/src/cpp/communication/dds/DdsBridge.cpp

@@ -306,7 +306,6 @@ utils::Heritable<DistributedTopic> DdsBridge::create_topic_for_participant_nts_(
 {
     // Make a copy of the Topic to customize it according to the Participant's configured QoS.
     utils::Heritable<DistributedTopic> topic = topic_->copy();
-    std::cout << "\tDDSBRIDGE. create_topic" << topic_->partition_name.size() << "\n";
 
     // Impose the Topic QoS that have been pre-configured for the Bridge's topic.
     // set_qos only overwrites the Topic QoS that have been set with a lower FuzzyLevel.
@@ -349,7 +348,6 @@ void DdsBridge::add_partition_to_topic(
         std::string partition)
 {
     topic_->partition_name[guid] = partition;
-    std::cout << "\tDDSBRIDGE. add_partition_to_topic" << topic_->partition_name.size() << "\n";
 }
 
 } /* namespace core */

ddspipe_core/src/cpp/core/DdsPipe.cpp

@@ -322,7 +322,7 @@ void DdsPipe::discovered_endpoint_nts_(
                 }
             }
         }
-        update_partitions(filter_partition_);
+
         // update readers outside the lock
         if (!filter_partition_.empty())
         {
@@ -679,6 +679,15 @@ void DdsPipe::update_content_filter(
     }
 }
 
+void DdsPipe::update_filter(
+        const std::set<std::string> filter_partition_set)
+{
+    // Avoid possible datarace with partitions filter
+    std::lock_guard<std::mutex> lock(bridges_mutex_);
+
+    filter_partition_ = filter_partition_set;
+}
+
 } /* namespace core */
 } /* namespace ddspipe */
 } /* namespace eprosima */

ddspipe_participants/src/cpp/participant/rtps/CommonParticipant.cpp

@@ -573,7 +573,6 @@ bool CommonParticipant::add_topic_partition(
         const std::string& writer_guid,
         const std::string& partition)
 {
-    std::cout << "Writer guid: " << writer_guid << "\n";
     if (partition_names.find(topic_name) != partition_names.end())
     {
         // the topic exists

ddspipe_participants/src/cpp/reader/dds/CommonReader.cpp

@@ -143,8 +143,6 @@ void CommonReader::on_data_available(
     EPROSIMA_LOG_INFO(DDSPIPE_DDS_READER,
             "On data available in reader in " << participant_id_ << " for topic " << topic_ << ".");
 
-    //std::cout << "On data available in reader in " << participant_id_ << " for topic " << topic_ << "\n";
-
     // The CommonReader notifies the reception of a message to the Monitor when a on_data_available event is received.
     // An on_data_available event can be received with more than one message, but figuring out the number of messages
     // received is not possible with the current API. Thus, the Monitor will be notified once for each on_data_available