Refs 12051. Notification can be file shared too

Signed-off-by: Iker Luengo <ikerluengo@eprosima.com>
eProsima · Aug 31, 2021 · add6067 · add6067
1 parent 2800cb2
commit add6067
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 7 deletions.
diff --git a/src/cpp/rtps/DataSharing/DataSharingNotification.cpp b/src/cpp/rtps/DataSharing/DataSharingNotification.cpp
@@ -54,16 +54,32 @@ bool DataSharingNotification::create_and_init_notification(
         const GUID_t& reader_guid,
         const std::string& shared_dir)
 {
-    return create_and_init_shared_segment_notification<fastdds::rtps::SharedMemSegment>(reader_guid,
-                        shared_dir);
+    if (shared_dir.empty())
+    {
+        return create_and_init_shared_segment_notification<fastdds::rtps::SharedMemSegment>(reader_guid,
+                       shared_dir);
+    }
+    else
+    {
+        return create_and_init_shared_segment_notification<fastdds::rtps::SharedFileSegment>(reader_guid,
+                       shared_dir);
+    }
 }
 
 bool DataSharingNotification::open_and_init_notification(
         const GUID_t& reader_guid,
         const std::string& shared_dir)
 {
-    return open_and_init_shared_segment_notification<fastdds::rtps::SharedMemSegment>(reader_guid,
-                        shared_dir);
+    if (shared_dir.empty())
+    {
+        return open_and_init_shared_segment_notification<fastdds::rtps::SharedMemSegment>(reader_guid,
+                       shared_dir);
+    }
+    else
+    {
+        return open_and_init_shared_segment_notification<fastdds::rtps::SharedFileSegment>(reader_guid,
+                       shared_dir);
+    }
 }
 
 void DataSharingNotification::destroy()

diff --git a/src/cpp/rtps/DataSharing/DataSharingNotification.hpp b/src/cpp/rtps/DataSharing/DataSharingNotification.hpp
@@ -152,7 +152,7 @@ class DataSharingNotification
         catch (const std::exception& e)
         {
             logError(HISTORY_DATASHARING_LISTENER, "Failed to create segment " << segment_name_
-                                                                                << ": " << e.what());
+                                                                               << ": " << e.what());
             return false;
         }
 
@@ -167,7 +167,7 @@ class DataSharingNotification
             T::remove(segment_name_);
 
             logError(HISTORY_DATASHARING_LISTENER, "Failed to create listener queue " << segment_name_
-                                                                                        << ": " << e.what());
+                                                                                      << ": " << e.what());
             return false;
         }
 
@@ -195,7 +195,7 @@ class DataSharingNotification
         catch (const std::exception& e)
         {
             logError(HISTORY_DATASHARING_LISTENER, "Failed to open segment " << segment_name_
-                                                                                << ": " << e.what());
+                                                                             << ": " << e.what());
             return false;
         }