1.5.0

Update package info

Update

Fix xrceagent paths

Update

Revert "Bump version"

This reverts commit 7b6b713041405a21d701952ef1eb2e8faab2802e.

Initial

(cherry picked from commit ceb1a1436c)

Co-authored-by: Pablo Garrido <pablogs9@gmail.com>

.github/workflows/ci.yml

@@ -9,7 +9,7 @@ jobs:
 
     microros_agent_ci:
         runs-on: ubuntu-20.04
-        container: microros/base:rolling
+        container: microros/base:foxy
 
         steps:
         - uses: actions/checkout@v2

micro_ros_agent/CHANGELOG.rst

@@ -2,6 +2,22 @@
 Changelog for package micro-ros_agent
 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
 
+1.5.0 (2021-09-13)
+------------------
+* Remove XRCE dependency and add superbuild (`#97 <https://github.com/micro-ROS/micro-ROS-Agent/issues/97>`_)
+* Fixed launch file by using a list for arguments. Ensures order of items is kept. (`#93 <https://github.com/micro-ROS/micro-ROS-Agent/issues/93>`_) (`#94 <https://github.com/micro-ROS/micro-ROS-Agent/issues/94>`_)
+* Modify argument type (`#91 <https://github.com/micro-ROS/micro-ROS-Agent/issues/91>`_)
+* Fix graph manager datawriters behaviour (`#84 <https://github.com/micro-ROS/micro-ROS-Agent/issues/84>`_)
+* Graph manager: Fix participant mask for listener callbacks (`#81 <https://github.com/micro-ROS/micro-ROS-Agent/issues/81>`_)
+* Fix agent launch (`#78 <https://github.com/micro-ROS/micro-ROS-Agent/issues/78>`_)
+* Fix graph manager node namespaces (`#75 <https://github.com/micro-ROS/micro-ROS-Agent/issues/75>`_)
+* Fix Rolling agent (`#61 <https://github.com/micro-ROS/micro-ROS-Agent/issues/61>`_)
+* Add multi domain graph manager (`#69 <https://github.com/micro-ROS/micro-ROS-Agent/issues/69>`_)
+* Add ros2 launch capabilities and example launch file (`#47 <https://github.com/micro-ROS/micro-ROS-Agent/issues/47>`_)
+* Snap build for the micro-ROS-Agent (`#43 <https://github.com/micro-ROS/micro-ROS-Agent/issues/43>`_)
+* Create graph manager after checking passed CLI arguments and launch xrce-dds server (`#41 <https://github.com/micro-ROS/micro-ROS-Agent/issues/41>`_)
+* Contributors: Antonio Cuadros, Jose Antonio Moral, Pablo Garrido, mergify[bot]
+
 0.0.1 (2019-04-24)
 -----------------
 * Initial release

micro_ros_agent/CMakeLists.txt

@@ -14,15 +14,20 @@
 
 cmake_minimum_required(VERSION 3.5)
 
-option(BUILD_SHARED_LIBS "Control shared/static building." ON)
-option(UBUILD_AGENT_EXECUTABLE "Control shared/static building." ON)
-
 option(UROSAGENT_GENERATE_PROFILE
   "Generates agent.refs according to the .msgs provided in the .repos" OFF
   )
 set(CMAKE_C_CLANG_TIDY clang-tidy -checks=*)
 
+option(MICROROSAGENT_SUPERBUILD "Enable superbuild compilation." ON)
+
+if(NOT MICROROSAGENT_SUPERBUILD)
     project(micro_ros_agent LANGUAGES CXX)
+else()
+    project(uagent_superbuild NONE)
+    include(${PROJECT_SOURCE_DIR}/cmake/SuperBuild.cmake)
+    return()
+endif()
 
 find_package(ament_cmake REQUIRED)
 find_package(microxrcedds_agent REQUIRED)
@@ -44,26 +49,15 @@ find_package(ament_cmake_gtest REQUIRED)
 
 find_package(micro_ros_msgs REQUIRED)
 
-include(GNUInstallDirs)
+add_executable(${PROJECT_NAME}
-set(BIN_INSTALL_DIR     ${CMAKE_INSTALL_BINDIR}     CACHE PATH "Installation directory for binaries")
+  src/main.cpp
-set(INCLUDE_INSTALL_DIR ${CMAKE_INSTALL_INCLUDEDIR} CACHE PATH "Installation directory for C headers")
-set(LIB_INSTALL_DIR     ${CMAKE_INSTALL_LIBDIR}     CACHE PATH "Installation directory for libraries")
-set(DATA_INSTALL_DIR    ${CMAKE_INSTALL_DATADIR}    CACHE PATH "Installation directory for data")
-
-# Set source files
-set(SRCS
   src/agent/Agent.cpp
   src/agent/graph_manager/graph_manager.cpp
   src/agent/graph_manager/graph_typesupport.cpp
   src/agent/utils/demangle.cpp
   )
 
-# Library
+target_include_directories(${PROJECT_NAME}
-add_library(${PROJECT_NAME} ${SRCS})
-
-target_include_directories(${PROJECT_NAME} BEFORE
-  PUBLIC
-    $<INSTALL_INTERFACE:${INCLUDE_INSTALL_DIR}>
   PRIVATE
     include
   )
@@ -90,9 +84,9 @@ target_link_libraries(${PROJECT_NAME}
 
 target_compile_options(${PROJECT_NAME}
   PRIVATE
-    $<$<OR:$<CXX_COMPILER_ID:GNU>,$<CXX_COMPILER_ID:Clang>>:-Wall>
+    $<$<C_COMPILER_ID:GNU>:-Wall>
-    $<$<OR:$<CXX_COMPILER_ID:GNU>,$<CXX_COMPILER_ID:Clang>>:-Wextra>
+    $<$<C_COMPILER_ID:GNU>:-Wextra>
-    $<$<OR:$<CXX_COMPILER_ID:GNU>,$<CXX_COMPILER_ID:Clang>>:-Wpedantic>
+    $<$<C_COMPILER_ID:GNU>:-pedantic>
   )
 
 set_target_properties(${PROJECT_NAME} PROPERTIES
@@ -102,82 +96,27 @@ set_target_properties(${PROJECT_NAME} PROPERTIES
     YES
   )
 
-# Install agent lib
+set_target_properties(${PROJECT_NAME} PROPERTIES
+  CXX_STANDARD
+    14
+  CXX_STANDARD_REQUIRED
+    YES
+  )
+
+target_compile_options(${PROJECT_NAME}
+  PRIVATE
+    $<$<OR:$<CXX_COMPILER_ID:GNU>,$<CXX_COMPILER_ID:Clang>>:-Wall>
+    $<$<OR:$<CXX_COMPILER_ID:GNU>,$<CXX_COMPILER_ID:Clang>>:-Wextra>
+    $<$<OR:$<CXX_COMPILER_ID:GNU>,$<CXX_COMPILER_ID:Clang>>:-Wpedantic>
+  )
+
+ament_export_dependencies(microxrcedds_agent)
+
+ament_package()
+
 install(
   TARGETS
     ${PROJECT_NAME}
-    EXPORT
-        ${PROJECT_NAME}Targets
-    RUNTIME DESTINATION
-        ${BIN_INSTALL_DIR}
-    LIBRARY DESTINATION
-        ${LIB_INSTALL_DIR}
-    ARCHIVE DESTINATION
-        ${LIB_INSTALL_DIR}
-    COMPONENT
-        libraries
-    )
-
-# Install includes
-install(
-    DIRECTORY
-        ${PROJECT_SOURCE_DIR}/include/agent
-    DESTINATION
-        ${INCLUDE_INSTALL_DIR}
-    FILES_MATCHING
-        PATTERN "*.hpp"
-        PATTERN "*.h"
-    )
-
-# Export library
-install(
-  EXPORT
-      ${PROJECT_NAME}Targets
-  DESTINATION
-      ${DATA_INSTALL_DIR}/${PROJECT_NAME}/cmake
-  )
-
-# Package configuration
-include(CMakePackageConfigHelpers)
-
-configure_package_config_file(
-      ${PROJECT_SOURCE_DIR}/cmake/Config.cmake.in
-        ${PROJECT_BINARY_DIR}/cmake/config/${PROJECT_NAME}Config.cmake
-    INSTALL_DESTINATION
-        ${DATA_INSTALL_DIR}/${PROJECT_NAME}/cmake
-    PATH_VARS
-        BIN_INSTALL_DIR
-        INCLUDE_INSTALL_DIR
-        LIB_INSTALL_DIR
-        DATA_INSTALL_DIR
-    )
-
-install(
-  FILES
-      ${PROJECT_BINARY_DIR}/cmake/config/${PROJECT_NAME}Config.cmake
-  DESTINATION
-      ${DATA_INSTALL_DIR}/${PROJECT_NAME}/cmake
-  )
-
-if(UBUILD_AGENT_EXECUTABLE)
-  add_executable(micro_ros_agent_bin
-    ${SRCS}
-    src/main.cpp
-    )
-
-  target_include_directories(micro_ros_agent_bin
-    PRIVATE
-      $<BUILD_INTERFACE:${PROJECT_SOURCE_DIR}/include>
-    )
-
-  target_link_libraries(micro_ros_agent_bin ${PROJECT_NAME})
-
-  set_target_properties(micro_ros_agent_bin
-      PROPERTIES OUTPUT_NAME ${PROJECT_NAME})
-
-  install(
-    TARGETS
-      micro_ros_agent_bin
   DESTINATION
     lib/${PROJECT_NAME}
   )
@@ -188,11 +127,6 @@ if(UBUILD_AGENT_EXECUTABLE)
   DESTINATION
     share/${PROJECT_NAME}
   )
-endif()
-
-ament_export_dependencies(microxrcedds_agent)
-
-ament_package()
 
 if(UROSAGENT_GENERATE_PROFILE)
   set(_OUTPUT_PATH "${CMAKE_CURRENT_BINARY_DIR}/python")

micro_ros_agent/cmake/Config.cmake.in

@@ -1,32 +0,0 @@
-# Copyright 2016 Proyectos y Sistemas de Mantenimiento SL (eProsima).
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-set(@PROJECT_NAME@_VERSION @PROJECT_VERSION@)
-
-@PACKAGE_INIT@
-
-if(MSVC OR MSVC_IDE)
-    set_and_check(@PROJECT_NAME@_BIN_DIR "@PACKAGE_BIN_INSTALL_DIR@")
-endif()
-set_and_check(@PROJECT_NAME@_INCLUDE_DIR "@PACKAGE_INCLUDE_INSTALL_DIR@")
-set_and_check(@PROJECT_NAME@_LIB_DIR "@PACKAGE_LIB_INSTALL_DIR@")
-set_and_check(@PROJECT_NAME@_DATA_DIR "@PACKAGE_DATA_INSTALL_DIR@")
-
-foreach(d @_deps@)
-    list(GET d 0 _name)
-    list(GET d 1 _version)
-    find_package(${_name} ${_version} REQUIRED)
-endforeach()
-
-include(${@PROJECT_NAME@_DATA_DIR}/@PROJECT_NAME@/cmake/@PROJECT_NAME@Targets.cmake)

micro_ros_agent/cmake/SuperBuild.cmake

@@ -0,0 +1,66 @@
+# Copyright 2019 Proyectos y Sistemas de Mantenimiento SL (eProsima).
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+include(ExternalProject)
+
+unset(_deps)
+
+enable_language(C)
+enable_language(CXX)
+
+unset(xrceagent_DIR CACHE)
+find_package(xrceagent 2 EXACT QUIET)
+if(NOT xrceagent_FOUND)
+    ExternalProject_Add(xrceagent
+            GIT_REPOSITORY
+                https://github.com/eProsima/Micro-XRCE-DDS-Agent.git
+            GIT_TAG
+                ros2
+            PREFIX
+                ${PROJECT_BINARY_DIR}/agent
+            INSTALL_DIR
+                ${CMAKE_INSTALL_PREFIX}
+            CMAKE_CACHE_ARGS
+                -DCMAKE_CXX_COMPILER:FILEPATH=${CMAKE_CXX_COMPILER}
+                -DCMAKE_C_COMPILER:FILEPATH=${CMAKE_C_COMPILER}
+                -DCMAKE_BUILD_TYPE:STRING=${CMAKE_BUILD_TYPE}
+                -DCMAKE_C_FLAGS:STRING=${CMAKE_C_FLAGS}
+                -DCMAKE_CXX_FLAGS:STRING=${CMAKE_CXX_FLAGS}
+                -DCMAKE_EXE_LINKER_FLAGS:STRING=${CMAKE_EXE_LINKER_FLAGS}
+                -DCMAKE_SHARED_LINKER_FLAGS:STRING=${CMAKE_SHARED_LINKER_FLAGS}
+                -DCMAKE_INSTALL_PREFIX:PATH=<INSTALL_DIR>
+                -DCMAKE_BUILD_TYPE:STRING=${CMAKE_BUILD_TYPE}
+                -DCMAKE_PREFIX_PATH:PATH=<INSTALL_DIR>
+                -DUAGENT_USE_SYSTEM_FASTDDS:BOOL=ON
+                -DUAGENT_USE_SYSTEM_FASTCDR:BOOL=ON
+                -DUAGENT_CED_PROFILE:BOOL=OFF
+                -DUAGENT_P2P_PROFILE:BOOL=OFF
+                -DUAGENT_BUILD_EXECUTABLE:BOOL=OFF
+                -DUAGENT_ISOLATED_INSTALL:BOOL=OFF
+            )
+endif()
+
+# Main project.
+ExternalProject_Add(micro_ros_agent
+    SOURCE_DIR
+        ${PROJECT_SOURCE_DIR}
+    BINARY_DIR
+        ${CMAKE_CURRENT_BINARY_DIR}
+    CMAKE_CACHE_ARGS
+        -DMICROROSAGENT_SUPERBUILD:BOOL=OFF
+    INSTALL_COMMAND
+        ""
+    DEPENDS
+        xrceagent
+    )

micro_ros_agent/include/agent/Agent.hpp

@@ -26,26 +26,11 @@ namespace agent {
 
 class Agent
 {
-private:
+public:
+
     Agent();
 
-    ~Agent()
+    ~Agent() = default;
-    {
-        stop();
-    }
-    
-    Agent(const Agent &) = delete;
-
-    Agent(Agent &&) = delete;
-
-    Agent& operator =(
-            const Agent &) = delete;
-
-    Agent& operator =(
-            Agent &&) = delete;
-
-public:
-    static Agent& getInstance();
 
     bool create(
             int argc,
@@ -53,14 +38,12 @@ public:
 
     void run();
 
-    void stop();
-
 private:
-    bool initialized = false;
-    eprosima::uxr::AgentInstance& xrce_dds_agent_instance_;
-    std::map<eprosima::fastdds::dds::DomainId_t, graph_manager::GraphManager> graph_manager_map_;
 
-    graph_manager::GraphManager* find_or_create_graph_manager(eprosima::fastdds::dds::DomainId_t domain_id);
+    eprosima::uxr::AgentInstance& xrce_dds_agent_instance_;
+    std::map<eprosima::fastdds::dds::DomainId_t, std::shared_ptr<graph_manager::GraphManager>> graph_manager_map_;
+
+    std::shared_ptr<graph_manager::GraphManager> find_or_create_graph_manager(eprosima::fastdds::dds::DomainId_t domain_id);
 };
 
 }  // namespace agent

micro_ros_agent/include/agent/graph_manager/graph_manager.hpp

@@ -82,28 +82,6 @@ public:
      */
     ~GraphManager() = default;
 
-	void stop()
-	{
-		if (microros_graph_publisher_.joinable())
-		{
-			exit = true;
-        	cv_.notify_one();
-			microros_graph_publisher_.join();
-		}
-
-        subscriber_->delete_datareader(ros_discovery_datareader_);
-		publisher_->delete_datawriter(ros_to_microros_graph_datawriter_);
-
-		participant_->delete_subscriber(subscriber_);
-		participant_->delete_publisher(publisher_);
-
-		// Delete topics
-		participant_->delete_topic(ros_discovery_topic_);
-		participant_->delete_topic(ros_to_microros_graph_topic_);
-
-		eprosima::fastdds::dds::DomainParticipantFactory::get_instance()->delete_participant(participant_);
-	}
-
     /**
      * @brief   Implementation of the notification logic that updates the micro-ROS graph.
      */
@@ -154,6 +132,21 @@ public:
             const eprosima::fastrtps::rtps::GUID_t& participant_guid,
             const eprosima::fastdds::dds::DataWriterQos& writer_qos);
 
+    /**
+     * @brief   Adds a DDS datawriter to the graph tree.
+     * @param   datawriter_guid rtps::GUID_t of the datawriter to be added.
+     * @param   topic_name Name of the topic to which the datawriter sends information to.
+     * @param   type_name Type name of the sent topic.
+     * @param   participant_guid rtps::GUID_t of the participant which owns this datawriter.
+     * @param   writer_qos QOS of the datawriter to be included into the graph tree.
+     */
+    void add_datawriter(
+            const eprosima::fastrtps::rtps::GUID_t& datawriter_guid,
+            const std::string& topic_name,
+            const std::string& type_name,
+            const eprosima::fastrtps::rtps::GUID_t& participant_guid,
+            const eprosima::fastdds::dds::WriterQos& writer_qos);
+
     /**
      * @brief   Removes a DDS datawriter from the graph tree.
      * @param   datawriter_guid rtps::GUID_t of the datawriter to be removed.
@@ -187,6 +180,21 @@ public:
             const eprosima::fastrtps::rtps::GUID_t& participant_guid,
             const eprosima::fastdds::dds::DataReaderQos& reader_qos);
 
+    /**
+     * @brief   Adds a DDS datareader to the graph tree.
+     * @param   datareader_guid rtps::GUID_t of the datareader to be added.
+     * @param   topic_name Name of the topic to which the datareader sends information to.
+     * @param   type_name Type name of the sent topic.
+     * @param   participant_guid rtps::GUID_t of the participant which owns this datareader.
+     * @param   writer_qos QOS of the datareader to be included into the graph tree.
+     */
+    void add_datareader(
+            const eprosima::fastrtps::rtps::GUID_t& datareader_guid,
+            const std::string& topic_name,
+            const std::string& type_name,
+            const eprosima::fastrtps::rtps::GUID_t& participant_guid,
+            const eprosima::fastdds::dds::ReaderQos& reader_qos);
+
     /**
      * @brief   Removes a DDS datareader from the graph tree.
      * @param   datareader_guid rtps::GUID_t of the datareader to be removed.
@@ -296,28 +304,27 @@ private:
     std::thread microros_graph_publisher_;
     std::mutex mtx_;
     std::condition_variable cv_;
-    volatile bool exit = false;
 
     eprosima::fastdds::dds::DataWriterQos datawriter_qos_;
 
     rmw_dds_common::GraphCache graphCache_;
+    std::unique_ptr<ParticipantListener> participant_listener_;
+    std::unique_ptr<DatareaderListener> datareader_listener_;
 
-    ParticipantListener participant_listener_;
+    std::unique_ptr<eprosima::fastdds::dds::TypeSupport> participant_info_typesupport_;
-    DatareaderListener datareader_listener_;
+    std::unique_ptr<eprosima::fastdds::dds::TypeSupport> microros_graph_info_typesupport_;
+    std::unique_ptr<eprosima::fastdds::dds::DomainParticipant> participant_;
+    std::unique_ptr<eprosima::fastdds::dds::Publisher> publisher_;
+    std::unique_ptr<eprosima::fastdds::dds::Subscriber> subscriber_;
+    std::unique_ptr<eprosima::fastdds::dds::Topic> ros_discovery_topic_;
+    std::unique_ptr<eprosima::fastdds::dds::Topic> ros_to_microros_graph_topic_;
+    std::unique_ptr<eprosima::fastdds::dds::DataWriter> ros_to_microros_graph_datawriter_;
+    std::unique_ptr<eprosima::fastdds::dds::DataReader> ros_discovery_datareader_;
 
-    eprosima::fastdds::dds::TypeSupport participant_info_typesupport_;
-    eprosima::fastdds::dds::TypeSupport microros_graph_info_typesupport_;
-    eprosima::fastdds::dds::DomainParticipant* participant_;
-    eprosima::fastdds::dds::Publisher* publisher_;
-    eprosima::fastdds::dds::Subscriber* subscriber_;
-    eprosima::fastdds::dds::Topic* ros_discovery_topic_;
-    eprosima::fastdds::dds::Topic* ros_to_microros_graph_topic_;
-    eprosima::fastdds::dds::DataWriter* ros_to_microros_graph_datawriter_;
-    eprosima::fastdds::dds::DataReader* ros_discovery_datareader_;
     // Store a auxiliary publishers and datawriter for each participant created in micro-ROS
     std::map<
         const eprosima::fastdds::dds::DomainParticipant*,
-        eprosima::fastdds::dds::DataWriter*
+        std::unique_ptr<eprosima::fastdds::dds::DataWriter>
     > micro_ros_graph_datawriters_;
 };
 

micro_ros_agent/launch/micro_ros_agent_launch.py

@@ -7,6 +7,6 @@ def generate_launch_description():
             package='micro_ros_agent',
             executable='micro_ros_agent',
             name='micro_ros_agent',
-            arguments={"udp4", "-p", "8888", "-v6"}
+            arguments=["udp4", "-p", "8888", "-v6"]
         )
     ])

micro_ros_agent/package.xml

@@ -2,9 +2,10 @@
 <?xml-model href="http://download.ros.org/schema/package_format3.xsd" schematypens="http://www.w3.org/2001/XMLSchema"?>
 <package format="3">
   <name>micro_ros_agent</name>
-  <version>0.0.1</version>
+  <version>1.5.0</version>
-  <description>DDS-XCRE agent implementation </description>
+  <description>micro-ROS Agent package</description>
-  <maintainer email="borjaouterelo@eprosima.com">Borja Outerelo</maintainer>
+  <maintainer email="pablogarrido@eprosima.com">Pablo Garrido</maintainer>
+  <maintainer email="antoniocuadros@eprosima.com">Antonio Cuadros</maintainer>
   <license>Apache License 2.0</license>
 
   <buildtool_depend>ament_cmake</buildtool_depend>
@@ -14,7 +15,6 @@
   <test_depend>ament_lint_auto</test_depend>
   <test_depend>ament_lint_common</test_depend>
 
-  <depend>microxrcedds_agent</depend>
   <depend>rmw</depend>
   <depend>rcutils</depend>
   <depend>rmw_fastrtps_shared_cpp</depend>

micro_ros_agent/src/agent/Agent.cpp

@@ -25,22 +25,13 @@ Agent::Agent()
 {
 }
 
-Agent& Agent::getInstance()
-{
-    static Agent instance;
-    return instance;
-}
-
 bool Agent::create(
         int argc,
         char** argv)
 {
     bool result = xrce_dds_agent_instance_.create(argc, argv);
-
+    if (result)
-    if (result && !initialized)
     {
-        initialized = true;
-
         /**
          * Add CREATE_PARTICIPANT callback.
          */
@@ -182,29 +173,23 @@ bool Agent::create(
 
 void Agent::run()
 {
-    xrce_dds_agent_instance_.run();
+    return xrce_dds_agent_instance_.run();
 }
 
-void Agent::stop()
+std::shared_ptr<graph_manager::GraphManager> Agent::find_or_create_graph_manager(eprosima::fastdds::dds::DomainId_t domain_id)
 {
-    xrce_dds_agent_instance_.stop();
 
-    for (auto & element : graph_manager_map_)
-    {
-        element.second.stop();
-    }
-
-    graph_manager_map_.clear();
-}
-
-graph_manager::GraphManager* Agent::find_or_create_graph_manager(eprosima::fastdds::dds::DomainId_t domain_id)
-{
 auto it = graph_manager_map_.find(domain_id);
 
     if (it != graph_manager_map_.end()) {
-        return &it->second;
+        return it->second;
     }else{
-        return &graph_manager_map_.emplace(domain_id, domain_id).first->second;
+        return graph_manager_map_.insert(
+            std::make_pair(
+                domain_id,
+                std::make_shared<graph_manager::GraphManager>(domain_id)
+            )
+        ).first->second;
     }
 }
 

micro_ros_agent/src/agent/graph_manager/graph_manager.cpp

@@ -28,16 +28,15 @@ GraphManager::GraphManager(eprosima::fastdds::dds::DomainId_t domain_id)
     , mtx_()
     , cv_()
     , graphCache_()
-    , participant_listener_(this)
+    , participant_listener_(std::make_unique<ParticipantListener>(this))
-    , datareader_listener_(this)
+    , datareader_listener_(std::make_unique<DatareaderListener>(this))
-    , participant_info_typesupport_()
+    , participant_info_typesupport_(std::make_unique<
-    , microros_graph_info_typesupport_()
+        eprosima::fastdds::dds::TypeSupport>(new graph_manager::ParticipantEntitiesInfoTypeSupport()))
+    , microros_graph_info_typesupport_(std::make_unique<
+        eprosima::fastdds::dds::TypeSupport>(new graph_manager::MicrorosGraphInfoTypeSupport()))
 {
     eprosima::fastdds::dds::DomainParticipantFactory::get_instance()->load_profiles();
 
-    participant_info_typesupport_ = (eprosima::fastdds::dds::TypeSupport) new graph_manager::ParticipantEntitiesInfoTypeSupport();
-    microros_graph_info_typesupport_ = (eprosima::fastdds::dds::TypeSupport) new graph_manager::MicrorosGraphInfoTypeSupport();
-
     // Create DomainParticipant
     eprosima::fastdds::dds::DomainParticipantQos participant_qos =
         eprosima::fastdds::dds::DomainParticipantFactory::get_instance()->get_default_participant_qos();
@@ -55,30 +54,29 @@ GraphManager::GraphManager(eprosima::fastdds::dds::DomainId_t domain_id)
         eprosima::fastrtps::rtps::PREALLOCATED_WITH_REALLOC_MEMORY_MODE;
 
     eprosima::fastdds::dds::StatusMask par_mask = eprosima::fastdds::dds::StatusMask::none();
-
+    participant_.reset(eprosima::fastdds::dds::DomainParticipantFactory::get_instance()->
-    participant_ = eprosima::fastdds::dds::DomainParticipantFactory::get_instance()->
+        create_participant(domain_id_, participant_qos, participant_listener_.get(), par_mask));
-        create_participant(domain_id_, participant_qos, &participant_listener_, par_mask);
 
     // Register participant within typesupport
-    participant_->register_type(participant_info_typesupport_);
+    participant_->register_type(*participant_info_typesupport_);
-    participant_->register_type(microros_graph_info_typesupport_);
+    participant_->register_type(*microros_graph_info_typesupport_);
 
     // Create publisher
-    publisher_ = participant_->create_publisher(
+    publisher_.reset(participant_->create_publisher(
-        eprosima::fastdds::dds::PUBLISHER_QOS_DEFAULT);
+        eprosima::fastdds::dds::PUBLISHER_QOS_DEFAULT));
 
     // Create subscriber
-    subscriber_ = participant_->create_subscriber(
+    subscriber_.reset(participant_->create_subscriber(
-        eprosima::fastdds::dds::SUBSCRIBER_QOS_DEFAULT);
+        eprosima::fastdds::dds::SUBSCRIBER_QOS_DEFAULT));
 
     // Create topics
-    ros_discovery_topic_ = participant_->create_topic("ros_discovery_info",
+    ros_discovery_topic_.reset(participant_->create_topic("ros_discovery_info",
-        participant_info_typesupport_.get_type_name(),
+        participant_info_typesupport_->get_type_name(),
-        eprosima::fastdds::dds::TOPIC_QOS_DEFAULT);
+        eprosima::fastdds::dds::TOPIC_QOS_DEFAULT));
 
-    ros_to_microros_graph_topic_ = participant_->create_topic("ros_to_microros_graph",
+    ros_to_microros_graph_topic_.reset(participant_->create_topic("ros_to_microros_graph",
-        microros_graph_info_typesupport_.get_type_name(),
+        microros_graph_info_typesupport_->get_type_name(),
-        eprosima::fastdds::dds::TOPIC_QOS_DEFAULT);
+        eprosima::fastdds::dds::TOPIC_QOS_DEFAULT));
 
     // Create datawriters
     datawriter_qos_ =
@@ -99,9 +97,8 @@ GraphManager::GraphManager(eprosima::fastdds::dds::DomainId_t domain_id)
     eprosima::fastdds::dds::DataWriterQos ros_to_microros_datawriter_qos_ = datawriter_qos_;
     ros_to_microros_datawriter_qos_.history().kind =
         eprosima::fastdds::dds::HistoryQosPolicyKind::KEEP_ALL_HISTORY_QOS;
-
+    ros_to_microros_graph_datawriter_.reset(
-    ros_to_microros_graph_datawriter_ = 
+        publisher_->create_datawriter(ros_to_microros_graph_topic_.get(), ros_to_microros_datawriter_qos_));
-        publisher_->create_datawriter(ros_to_microros_graph_topic_, ros_to_microros_datawriter_qos_);
 
     // Create datareaders
 
@@ -117,9 +114,9 @@ GraphManager::GraphManager(eprosima::fastdds::dds::DomainId_t domain_id)
     datareader_qos.durability().kind =
         eprosima::fastdds::dds::DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS;
 
-    ros_discovery_datareader_ = 
+    ros_discovery_datareader_.reset(
-        subscriber_->create_datareader(ros_discovery_topic_,
+        subscriber_->create_datareader(ros_discovery_topic_.get(),
-            datareader_qos, &datareader_listener_);
+            datareader_qos, datareader_listener_.get()));
 
     // Set graph cache on change callback function
     graphCache_.set_on_change_callback([this]()
@@ -140,15 +137,10 @@ inline void GraphManager::publish_microros_graph()
             std::unique_lock<std::mutex> lock(mtx_);
             cv_.wait(lock, [this]()
             {
-                return this->graph_changed_ || exit;
+                return this->graph_changed_;
             });
         }
 
-        if (exit)
-        {
-            break;
-        }
-
         if (display_on_change_)
         {
             std::cout << "Updated uros Graph: graph changed" << std::endl;
@@ -323,8 +315,8 @@ void GraphManager::add_participant(
         if (it == micro_ros_graph_datawriters_.end())
         {
             // Create datawriter
-            eprosima::fastdds::dds::DataWriter* datawriter;
+            std::unique_ptr<eprosima::fastdds::dds::DataWriter> datawriter;
-            datawriter = publisher_->create_datawriter(ros_discovery_topic_, datawriter_qos_);
+            datawriter.reset(publisher_->create_datawriter(ros_discovery_topic_.get(), datawriter_qos_));
 
             it = micro_ros_graph_datawriters_.insert(
                 std::make_pair(participant, std::move(datawriter))).first;
@@ -347,10 +339,8 @@ void GraphManager::remove_participant(
         rmw_dds_common::convert_gid_to_msg(&gid, &info.gid);
         auto it = micro_ros_graph_datawriters_.find(participant);
         it->second->write(static_cast<void *>(&info));
-
-        publisher_->delete_datawriter(it->second);
-        micro_ros_graph_datawriters_.erase(participant);
     }
+    micro_ros_graph_datawriters_.erase(participant);
 }
 
 void GraphManager::add_datawriter(
@@ -381,6 +371,24 @@ void GraphManager::add_datawriter(
         type_name, participant_gid, qos_profile, false);
 }
 
+void GraphManager::add_datawriter(
+        const eprosima::fastrtps::rtps::GUID_t& datawriter_guid,
+        const std::string& topic_name,
+        const std::string& type_name,
+        const eprosima::fastrtps::rtps::GUID_t& participant_guid,
+        const eprosima::fastdds::dds::WriterQos& writer_qos)
+{
+    const rmw_gid_t datawriter_gid = rmw_fastrtps_shared_cpp::create_rmw_gid(
+        "rmw_fastrtps_cpp", datawriter_guid);
+    const rmw_gid_t participant_gid = rmw_fastrtps_shared_cpp::create_rmw_gid(
+        "rmw_fastrtps_cpp", participant_guid);
+    rmw_qos_profile_t qos_profile = rmw_qos_profile_unknown;
+    dds_qos_to_rmw_qos(writer_qos, &qos_profile);
+
+    graphCache_.add_entity(datawriter_gid, topic_name,
+        type_name, participant_gid, qos_profile, false);
+}
+
 void GraphManager::remove_datawriter(
         const eprosima::fastrtps::rtps::GUID_t& datawriter_guid)
 {
@@ -418,6 +426,24 @@ void GraphManager::add_datareader(
         type_name, participant_gid, qos_profile, true);
 }
 
+void GraphManager::add_datareader(
+        const eprosima::fastrtps::rtps::GUID_t& datareader_guid,
+        const std::string& topic_name,
+        const std::string& type_name,
+        const eprosima::fastrtps::rtps::GUID_t& participant_guid,
+        const eprosima::fastdds::dds::ReaderQos& reader_qos)
+{
+    const rmw_gid_t datareader_gid = rmw_fastrtps_shared_cpp::create_rmw_gid(
+        "rmw_fastrtps_cpp", datareader_guid);
+    const rmw_gid_t participant_gid = rmw_fastrtps_shared_cpp::create_rmw_gid(
+        "rmw_fastrtps_cpp", participant_guid);
+    rmw_qos_profile_t qos_profile = rmw_qos_profile_unknown;
+    dds_qos_to_rmw_qos(reader_qos, &qos_profile);
+
+    graphCache_.add_entity(datareader_gid, topic_name,
+        type_name, participant_gid, qos_profile, true);
+}
+
 void GraphManager::remove_datareader(
         const eprosima::fastrtps::rtps::GUID_t& datareader_guid)
 {
@@ -550,7 +576,7 @@ void GraphManager::update_node_entities_info()
     if (ros_discovery_datareader_->take_next_sample(&entities_info, &sample_info) ==
         eprosima::fastrtps::types::ReturnCode_t::RETCODE_OK)
     {
-        if (sample_info.instance_state == eprosima::fastdds::dds::InstanceStateKind::ALIVE_INSTANCE_STATE)
+        if (sample_info.instance_state == eprosima::fastdds::dds::InstanceStateKind::ALIVE)
         {
             graphCache_.update_participant_entities(entities_info);
         }
@@ -635,52 +661,6 @@ void GraphManager::ParticipantListener::on_participant_discovery(
     }
 }
 
-static eprosima::fastdds::dds::DataWriterQos writer_qos_conversion(
-    const eprosima::fastdds::dds::WriterQos& writer_qos)
-{
-    eprosima::fastdds::dds::DataWriterQos datawriter_qos;
-    datawriter_qos.durability(writer_qos.m_durability);
-    datawriter_qos.durability_service(writer_qos.m_durabilityService);
-    datawriter_qos.deadline(writer_qos.m_deadline);
-    datawriter_qos.latency_budget(writer_qos.m_latencyBudget);
-    datawriter_qos.liveliness(writer_qos.m_liveliness);
-    datawriter_qos.reliability(writer_qos.m_reliability);
-    datawriter_qos.destination_order(writer_qos.m_destinationOrder);
-    datawriter_qos.lifespan(writer_qos.m_lifespan);
-    datawriter_qos.user_data(writer_qos.m_userData);
-    datawriter_qos.ownership(writer_qos.m_ownership);
-    datawriter_qos.ownership_strength(writer_qos.m_ownershipStrength);
-    datawriter_qos.publish_mode(writer_qos.m_publishMode);
-    datawriter_qos.representation(writer_qos.representation);
-    datawriter_qos.data_sharing(writer_qos.data_sharing);
-
-    return datawriter_qos;
-}
-
-static eprosima::fastdds::dds::DataReaderQos reader_qos_conversion(
-    const eprosima::fastdds::dds::ReaderQos& reader_qos)
-{
-    eprosima::fastdds::dds::DataReaderQos datareader_qos;
-
-    datareader_qos.durability(reader_qos.m_durability);
-    datareader_qos.deadline(reader_qos.m_deadline);
-    datareader_qos.latency_budget(reader_qos.m_latencyBudget);
-    datareader_qos.liveliness(reader_qos.m_liveliness);
-    datareader_qos.reliability(reader_qos.m_reliability);
-    datareader_qos.destination_order(reader_qos.m_destinationOrder);
-    datareader_qos.user_data(reader_qos.m_userData);
-    datareader_qos.ownership(reader_qos.m_ownership);
-    datareader_qos.time_based_filter(reader_qos.m_timeBasedFilter);
-    datareader_qos.lifespan(reader_qos.m_lifespan);
-    datareader_qos.durability_service(reader_qos.m_durabilityService);
-    eprosima::fastdds::dds::TypeConsistencyQos consistency;
-    consistency.type_consistency = reader_qos.type_consistency;
-    datareader_qos.type_consistency(consistency);
-    datareader_qos.data_sharing(reader_qos.data_sharing);
-
-    return datareader_qos;
-}
-
 template <>
 void GraphManager::ParticipantListener::process_discovery_info<eprosima::fastrtps::rtps::ReaderDiscoveryInfo>(
         const eprosima::fastrtps::rtps::ReaderDiscoveryInfo& reader_info)
@@ -697,7 +677,7 @@ void GraphManager::ParticipantListener::process_discovery_info<eprosima::fastrtp
             const std::string type_name = reader_info.info.typeName().to_string();
 
             graphManager_from_->add_datareader(reader_info.info.guid(), topic_name, type_name,
-                iHandle2GUID(reader_info.info.RTPSParticipantKey()), reader_qos_conversion(reader_info.info.m_qos));
+                iHandle2GUID(reader_info.info.RTPSParticipantKey()), reader_info.info.m_qos);
             break;
         }
         default:
@@ -724,7 +704,7 @@ void GraphManager::ParticipantListener::process_discovery_info<eprosima::fastrtp
             const std::string type_name = writer_info.info.typeName().to_string();
 
             graphManager_from_->add_datawriter(writer_info.info.guid(), topic_name, type_name,
-                iHandle2GUID(writer_info.info.RTPSParticipantKey()), writer_qos_conversion(writer_info.info.m_qos));
+                iHandle2GUID(writer_info.info.RTPSParticipantKey()), writer_info.info.m_qos);
             break;
         }
         default:

micro_ros_agent/src/main.cpp

@@ -16,7 +16,7 @@
 
 int main(int argc, char** argv)
 {
-    uros::agent::Agent& micro_ros_agent = micro_ros_agent.getInstance();
+    uros::agent::Agent micro_ros_agent;
 
     /** Bypass '--ros-args' flag, as we use our own CLI parser.
       * As a workaround for launch files, arguments will be passed from