[core] Bugfix: descgate incorrectly locked with shared locks. (#1462) (…

…#1470)

Co-authored-by: Rex Schilasky <[email protected]>

ecal/core/src/ecal_descgate.cpp

@@ -53,7 +53,7 @@ namespace eCAL
 
   bool CDescGate::ApplyTopicDescription(const std::string& topic_name_, const SDataTypeInformation& topic_info_, const QualityFlags description_quality_)
   {
-    const std::unique_lock<std::shared_timed_mutex> lock(m_topic_info_map.sync);
+    const std::unique_lock<std::mutex> lock(m_topic_info_map.sync);
     m_topic_info_map.map->remove_deprecated();
 
     const auto topic_info_it = m_topic_info_map.map->find(topic_name_);
@@ -195,7 +195,7 @@ namespace eCAL
   {
     std::unordered_map<std::string, SDataTypeInformation> map;
 
-    const std::shared_lock<std::shared_timed_mutex> lock(m_topic_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_topic_info_map.sync);
     m_topic_info_map.map->remove_deprecated();
     map.reserve(m_topic_info_map.map->size());
 
@@ -210,7 +210,7 @@ namespace eCAL
   {
     topic_names_.clear();
 
-    const std::shared_lock<std::shared_timed_mutex> lock(m_topic_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_topic_info_map.sync);
     m_topic_info_map.map->remove_deprecated();
     topic_names_.reserve(m_topic_info_map.map->size());
 
@@ -224,7 +224,8 @@ namespace eCAL
   {
     if (topic_name_.empty()) return(false);
 
-    const std::shared_lock<std::shared_timed_mutex> lock(m_topic_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_topic_info_map.sync);
+    m_topic_info_map.map->remove_deprecated();
     const auto topic_info_it = m_topic_info_map.map->find(topic_name_);
 
     if (topic_info_it == m_topic_info_map.map->end()) return(false);
@@ -240,7 +241,7 @@ namespace eCAL
   {
     std::tuple<std::string, std::string> service_method_tuple = std::make_tuple(service_name_, method_name_);
 
-    const std::unique_lock<std::shared_timed_mutex> lock(m_service_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_service_info_map.sync);
     m_service_info_map.map->remove_deprecated();
 
     auto service_info_map_it = m_service_info_map.map->find(service_method_tuple);
@@ -276,7 +277,7 @@ namespace eCAL
   {
     std::map<std::tuple<std::string, std::string>, SServiceMethodInformation> map;
 
-    const std::shared_lock<std::shared_timed_mutex> lock(m_service_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_service_info_map.sync);
     m_service_info_map.map->remove_deprecated();
 
     for (const auto& service_info : (*m_service_info_map.map))
@@ -290,7 +291,7 @@ namespace eCAL
   {
     service_method_names_.clear();
 
-    const std::shared_lock<std::shared_timed_mutex> lock(m_service_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_service_info_map.sync);
     m_service_info_map.map->remove_deprecated();
     service_method_names_.reserve(m_service_info_map.map->size());
 
@@ -304,7 +305,8 @@ namespace eCAL
   {
     std::tuple<std::string, std::string> service_method_tuple = std::make_tuple(service_name_, method_name_);
 
-    const std::shared_lock<std::shared_timed_mutex> lock(m_service_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_service_info_map.sync);
+    m_service_info_map.map->remove_deprecated();
     auto service_info_map_it = m_service_info_map.map->find(service_method_tuple);
 
     if (service_info_map_it == m_service_info_map.map->end()) return false;
@@ -317,7 +319,8 @@ namespace eCAL
   {
     std::tuple<std::string, std::string> service_method_tuple = std::make_tuple(service_name_, method_name_);
 
-    const std::shared_lock<std::shared_timed_mutex> lock(m_service_info_map.sync);
+    const std::lock_guard<std::mutex> lock(m_service_info_map.sync);
+    m_service_info_map.map->remove_deprecated();
     auto service_info_map_it = m_service_info_map.map->find(service_method_tuple);
 
     if (service_info_map_it == m_service_info_map.map->end()) return false;

ecal/core/src/ecal_descgate.h

@@ -107,7 +107,7 @@ namespace eCAL
         map(std::make_unique<TopicInfoMap>(timeout_))
       {
       };
-      mutable std::shared_timed_mutex sync;                                        //!< Mutex protecting the map
+      mutable std::mutex              sync;                                        //!< Mutex protecting the map
       std::unique_ptr<TopicInfoMap>   map;                                         //!< Map containing information about each known topic
     };
     STopicInfoMap m_topic_info_map;
@@ -120,7 +120,7 @@ namespace eCAL
         map(std::make_unique<ServiceMethodInfoMap>(timeout_))
       {
       };
-      mutable std::shared_timed_mutex       sync;                                  //!< Mutex protecting the map
+      mutable std::mutex                    sync;                                  //!< Mutex protecting the map
       std::unique_ptr<ServiceMethodInfoMap> map;                                   //!< Map containing information about each known service
     };
     SServiceMethodInfoMap m_service_info_map;