1.5.1

Signed-off-by: Pablo Garrido <pablogs9@gmail.com>

.github/workflows/ci.yml

@@ -3,35 +3,36 @@ name: CI micro-ROS Agent
 on:
     pull_request:
       branches:
-        - 'humble'
+        - '**'
-    schedule:
-      - cron: '33 6 * * *'
 
 jobs:
 
     microros_agent_ci:
-      runs-on: ubuntu-latest
+        runs-on: ubuntu-20.04
-      strategy:
+        container: microros/base:foxy
-        fail-fast: false
+
-        matrix:
+        steps:
-          os: [ ubuntu-20.04 ]
+        - uses: actions/checkout@v2
-          ros_distribution: [ humble ]
+          with:
-          include:
+            path: urosagent
-            - docker_image: ubuntu:jammy
+
-              ros_distribution: humble
+        - name: Download dependencies
-      container:
+          run: |
-        image: ubuntu:jammy
+            apt update
-      steps:
+            cd /uros_ws
-      - uses: actions/checkout@v2
+            . /opt/ros/$ROS_DISTRO/setup.sh
-      - uses: ros-tooling/setup-ros@0.3.2
+            . install/local_setup.sh
-        with:
+            rosdep update --rosdistro=$ROS_DISTRO
-          use-ros2-testing: false
+            ros2 run micro_ros_setup create_agent_ws.sh
-          required-ros-distributions: ${{ matrix.ros_distribution }}
+
-      - name : Download and install dependencies
+        - name: Patch branch
-        run: |
+          run: |
-          apt-get install ros-${{ matrix.ros_distribution }}-micro-ros-msgs
+            rm -rf /uros_ws/src/uros/micro-ROS-Agent/*
-          apt-get install ros-${{ matrix.ros_distribution }}-rmw-fastrtps-cpp
+            cp -R urosagent/* /uros_ws/src/uros/micro-ROS-Agent/
-      - uses : ros-tooling/action-ros-ci@0.2.5
+
-        with:
+        - name: Build
-          package-name: "micro_ros_agent"
+          run:  |
-          target-ros2-distro: ${{ matrix.ros_distribution }}
+            cd /uros_ws
+            . /opt/ros/$ROS_DISTRO/setup.sh
+            . install/local_setup.sh
+            ros2 run micro_ros_setup build_agent.sh

README.md

@@ -55,4 +55,3 @@ see the file [3rd-party-licenses.txt](3rd-party-licenses.txt).
 Please notice the following issues/limitations:
 
 * There is an unknown issue when dealing with serial ports shared with the micro-ROS agent running inside a Docker. Sometimes it works with a remarkable packet loss.
-* There is an known issues with serial port communication on micro-ros-agent snap version. It is recommended to use the dockerized version or build it from source.

micro_ros_agent/CHANGELOG.rst

@@ -2,31 +2,16 @@
 Changelog for package micro-ros_agent
 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
 
-3.0.4 (2022-09-28)
+1.5.1 (2022-03-25)
 ------------------
-* Fix Datawriter destruction (`#169 <https://github.com/micro-ROS/micro-ROS-Agent/issues/169>`_)
+* Add services to graph manager (backport `#127 <https://github.com/micro-ROS/micro-ROS-Agent/issues/127>`_) (`#128 <https://github.com/micro-ROS/micro-ROS-Agent/issues/128>`_)
-* Synchronise predicate (`#160 <https://github.com/micro-ROS/micro-ROS-Agent/issues/160>`_)
+* Add used missing includes (`#116 <https://github.com/micro-ROS/micro-ROS-Agent/issues/116>`_)
+* Add system logger flag (`#118 <https://github.com/micro-ROS/micro-ROS-Agent/issues/118>`_) (`#120 <https://github.com/micro-ROS/micro-ROS-Agent/issues/120>`_)
+* Add condition variable include (`#113 <https://github.com/micro-ROS/micro-ROS-Agent/issues/113>`_) (`#115 <https://github.com/micro-ROS/micro-ROS-Agent/issues/115>`_)
+* pass system name to xrceagent (`#110 <https://github.com/micro-ROS/micro-ROS-Agent/issues/110>`_) (`#111 <https://github.com/micro-ROS/micro-ROS-Agent/issues/111>`_)
+* Fix memory leak in FastDDS datawriter (`#107 <https://github.com/micro-ROS/micro-ROS-Agent/issues/107>`_) (`#108 <https://github.com/micro-ROS/micro-ROS-Agent/issues/108>`_)
 
-3.0.3 (2022-06-13)
+1.5.0 (2021-09-13)
-------------------
-* Fix memory leak in graph manager (`#147 <https://github.com/micro-ROS/micro-ROS-Agent/issues/147>`_)
-
-3.0.2 (2022-05-25)
-------------------
-
-3.0.1 (2022-03-25)
-------------------
-* Add services to graph manager (`#127 <https://github.com/micro-ROS/micro-ROS-Agent/issues/127>`_) (`#129 <https://github.com/micro-ROS/micro-ROS-Agent/issues/129>`_)
-* Add used missing includes (`#116 <https://github.com/micro-ROS/micro-ROS-Agent/issues/116>`_) (`#124 <https://github.com/micro-ROS/micro-ROS-Agent/issues/124>`_)
-* Add system logger flag (`#118 <https://github.com/micro-ROS/micro-ROS-Agent/issues/118>`_) (`#119 <https://github.com/micro-ROS/micro-ROS-Agent/issues/119>`_)
-* Add condition variable include (`#113 <https://github.com/micro-ROS/micro-ROS-Agent/issues/113>`_) (`#114 <https://github.com/micro-ROS/micro-ROS-Agent/issues/114>`_)
-* pass system name to xrceagent (`#110 <https://github.com/micro-ROS/micro-ROS-Agent/issues/110>`_) (`#112 <https://github.com/micro-ROS/micro-ROS-Agent/issues/112>`_)
-* Fix memory leak in FastDDS datawriter (`#107 <https://github.com/micro-ROS/micro-ROS-Agent/issues/107>`_) (`#109 <https://github.com/micro-ROS/micro-ROS-Agent/issues/109>`_)
-
-3.0.0 (2021-09-13)
-------------------
-
-1.0.1 (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>`_)

micro_ros_agent/include/agent/graph_manager/graph_manager.hpp

@@ -111,12 +111,6 @@ public:
         const eprosima::fastdds::dds::DomainParticipant* participant,
         bool from_microros = true);
 
-    /**
-     * @brief   Getter for the graph cache.
-     * @return  Reference to inner graph cache
-     */
-    rmw_dds_common::GraphCache& get_graph_cache() { return graphCache_; }
-
     /**
      * @brief   Adds a DDS datawriter to the graph tree.
      * @param   datawriter_guid rtps::GUID_t of the datawriter to be added.
@@ -143,6 +137,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.
@@ -176,6 +185,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.
@@ -305,7 +329,7 @@ private:
     // 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/package.xml

@@ -2,7 +2,7 @@
 <?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>3.0.4</version>
+  <version>1.5.1</version>
   <description>micro-ROS Agent package</description>
   <maintainer email="pablogarrido@eprosima.com">Pablo Garrido</maintainer>
   <maintainer email="antoniocuadros@eprosima.com">Antonio Cuadros</maintainer>

micro_ros_agent/src/agent/Agent.cpp

@@ -79,9 +79,14 @@ bool Agent::create(
             {
                 auto graph_manager_ = find_or_create_graph_manager(participant->get_domain_id());
 
-                graph_manager_->add_datawriter(datawriter->guid(), participant, datawriter);
+                // TODO(jamoralp): Workaround for Fast-DDS bug #9977. Remove when fixed
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle =
+                    datawriter->get_instance_handle();
+                const eprosima::fastrtps::rtps::GUID_t datawriter_guid =
+                    iHandle2GUID(instance_handle);
+                graph_manager_->add_datawriter(datawriter_guid, participant, datawriter);
                 graph_manager_->associate_entity(
-                    datawriter->guid(), participant, dds::xrce::OBJK_DATAWRITER);
+                    datawriter_guid, participant, dds::xrce::OBJK_DATAWRITER);
             });
         xrce_dds_agent_instance_.add_middleware_callback(
             eprosima::uxr::Middleware::Kind::FASTDDS,
@@ -101,7 +106,12 @@ bool Agent::create(
 
                 auto graph_manager_ = find_or_create_graph_manager(participant->get_domain_id());
 
-                graph_manager_->remove_datawriter(datawriter->guid());
+                // TODO(jamoralp): Workaround for Fast-DDS bug #9977. Remove when fixed
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle =
+                    datawriter->get_instance_handle();
+                const eprosima::fastrtps::rtps::GUID_t datawriter_guid =
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle);
+                graph_manager_->remove_datawriter(datawriter_guid);
             });
 
         xrce_dds_agent_instance_.add_middleware_callback(
@@ -174,15 +184,21 @@ bool Agent::create(
             {
                 auto graph_manager_ = find_or_create_graph_manager(participant->get_domain_id());
 
-                graph_manager_->add_datawriter(datawriter->guid(), participant, datawriter);
+                // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dw =
+                    datawriter->get_instance_handle();
+                const eprosima::fastrtps::rtps::GUID_t datawriter_guid =
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dw);
+
+                graph_manager_->add_datawriter(datawriter_guid, participant, datawriter);
                 graph_manager_->associate_entity(
-                    datawriter->guid(), participant, dds::xrce::OBJK_DATAWRITER);
+                    datawriter_guid, participant, dds::xrce::OBJK_DATAWRITER);
 
                 // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
-                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle =
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dr =
                     datareader->get_instance_handle();
                 const eprosima::fastrtps::rtps::GUID_t datareader_guid =
-                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle);
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dr);
                 graph_manager_->add_datareader(datareader_guid, participant, datareader);
                 graph_manager_->associate_entity(
                     datareader_guid, participant, dds::xrce::OBJK_DATAREADER);
@@ -206,13 +222,18 @@ bool Agent::create(
             {
                 auto graph_manager_ = find_or_create_graph_manager(participant->get_domain_id());
 
-                graph_manager_->remove_datawriter(datawriter->guid());
+                // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dw =
+                    datawriter->get_instance_handle();
+                const eprosima::fastrtps::rtps::GUID_t datawriter_guid =
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dw);
+                graph_manager_->remove_datawriter(datawriter_guid);
 
                 // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
-                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle =
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dr =
                     datareader->get_instance_handle();
                 const eprosima::fastrtps::rtps::GUID_t datareader_guid =
-                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle);
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dr);
                 graph_manager_->remove_datareader(datareader_guid);
             });
 
@@ -235,15 +256,20 @@ bool Agent::create(
             {
                 auto graph_manager_ = find_or_create_graph_manager(participant->get_domain_id());
 
-                graph_manager_->add_datawriter(datawriter->guid(), participant, datawriter);
+                // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dw =
+                    datawriter->get_instance_handle();
+                const eprosima::fastrtps::rtps::GUID_t datawriter_guid =
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dw);
+                graph_manager_->add_datawriter(datawriter_guid, participant, datawriter);
                 graph_manager_->associate_entity(
-                    datawriter->guid(), participant, dds::xrce::OBJK_DATAWRITER);
+                    datawriter_guid, participant, dds::xrce::OBJK_DATAWRITER);
 
                 // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
-                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle =
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dr =
                     datareader->get_instance_handle();
                 const eprosima::fastrtps::rtps::GUID_t datareader_guid =
-                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle);
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dr);
                 graph_manager_->add_datareader(datareader_guid, participant, datareader);
                 graph_manager_->associate_entity(
                     datareader_guid, participant, dds::xrce::OBJK_DATAREADER);
@@ -267,13 +293,18 @@ bool Agent::create(
             {
                 auto graph_manager_ = find_or_create_graph_manager(participant->get_domain_id());
 
-                graph_manager_->remove_datawriter(datawriter->guid());
+                // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dw =
+                    datawriter->get_instance_handle();
+                const eprosima::fastrtps::rtps::GUID_t datawriter_guid =
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dw);
+                graph_manager_->remove_datawriter(datawriter_guid);
 
                 // TODO(pablogs): Workaround for Fast-DDS bug #9977. Remove when fixed
-                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle =
+                const eprosima::fastrtps::rtps::InstanceHandle_t instance_handle_dr =
                     datareader->get_instance_handle();
                 const eprosima::fastrtps::rtps::GUID_t datareader_guid =
-                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle);
+                    eprosima::fastrtps::rtps::iHandle2GUID(instance_handle_dr);
                 graph_manager_->remove_datareader(datareader_guid);
             });
 

micro_ros_agent/src/agent/graph_manager/graph_manager.cpp

@@ -126,10 +126,8 @@ GraphManager::GraphManager(eprosima::fastdds::dds::DomainId_t domain_id)
     // Set graph cache on change callback function
     graphCache_.set_on_change_callback([this]()
     {
-        {
+        std::unique_lock<std::mutex> lock(this->mtx_);
-            std::unique_lock<std::mutex> lock(this->mtx_);
+        this->graph_changed_ = true;
-            this->graph_changed_ = true;
-        }
         this->cv_.notify_one();
     });
 
@@ -146,7 +144,6 @@ inline void GraphManager::publish_microros_graph()
             {
                 return this->graph_changed_;
             });
-            graph_changed_ = false;
         }
 
         if (display_on_change_)
@@ -154,6 +151,7 @@ inline void GraphManager::publish_microros_graph()
             std::cout << "Updated uros Graph: graph changed" << std::endl;
             std::cout << graphCache_ << std::endl;
         }
+        graph_changed_ = false;
 
         micro_ros_msgs::msg::Graph graph_message;
 
@@ -322,10 +320,11 @@ void GraphManager::add_participant(
         if (it == micro_ros_graph_datawriters_.end())
         {
             // Create datawriter
-            eprosima::fastdds::dds::DataWriter * datawriter = publisher_->create_datawriter(ros_discovery_topic_.get(), datawriter_qos_);
+            std::unique_ptr<eprosima::fastdds::dds::DataWriter> datawriter;
+            datawriter.reset(publisher_->create_datawriter(ros_discovery_topic_.get(), datawriter_qos_));
 
             it = micro_ros_graph_datawriters_.insert(
-                std::make_pair(participant, datawriter)).first;
+                std::make_pair(participant, std::move(datawriter))).first;
         }
 
         it->second->write(static_cast<void *>(&info));
@@ -345,9 +344,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(
@@ -378,6 +376,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)
 {
@@ -415,6 +431,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)
 {
@@ -547,7 +581,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);
         }
@@ -599,7 +633,7 @@ GraphManager::ParticipantListener::ParticipantListener(
 }
 
 void GraphManager::ParticipantListener::on_participant_discovery(
-        eprosima::fastdds::dds::DomainParticipant* /* participant */,
+        eprosima::fastdds::dds::DomainParticipant* participant,
         eprosima::fastrtps::rtps::ParticipantDiscoveryInfo&& info)
 {
     switch (info.status)
@@ -616,15 +650,13 @@ void GraphManager::ParticipantListener::on_participant_discovery(
             const std::string enclave =
                 std::string(name_found->second.begin(), name_found->second.end());
 
-            const rmw_gid_t gid = rmw_fastrtps_shared_cpp::create_rmw_gid("rmw_fastrtps_cpp", info.info.m_guid);
+            graphManager_from_->add_participant(participant, false, enclave);
-            graphManager_from_->get_graph_cache().add_participant(gid, enclave);
             break;
         }
         case eprosima::fastrtps::rtps::ParticipantDiscoveryInfo::REMOVED_PARTICIPANT:
         case eprosima::fastrtps::rtps::ParticipantDiscoveryInfo::DROPPED_PARTICIPANT:
         {
-            const rmw_gid_t gid = rmw_fastrtps_shared_cpp::create_rmw_gid("rmw_fastrtps_cpp", info.info.m_guid);
+            graphManager_from_->remove_participant(participant, false);
-            graphManager_from_->get_graph_cache().remove_participant(gid);
             break;
         }
         default:
@@ -634,52 +666,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)
@@ -696,7 +682,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:
@@ -723,7 +709,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:
@@ -765,4 +751,4 @@ void GraphManager::DatareaderListener::on_data_available(
 }  // namespace agent
 }  // namespace uros
 
-#endif  // _UROS_AGENT_GRAPH_MANAGER_CPP
+#endif  // _UROS_AGENT_GRAPH_MANAGER_CPP

micro_ros_agent/src/agent/graph_manager/graph_typesupport.cpp

@@ -43,7 +43,7 @@ ParticipantEntitiesInfoTypeSupport::ParticipantEntitiesInfoTypeSupport()
     ss << "dds_::" << message_name << "_";
     this->setName(ss.str().c_str());
 
-    char full_bounded;
+    bool full_bounded = true;
     m_typeSize = 4 + callbacks_->max_serialized_size(full_bounded);
 }
 
@@ -135,7 +135,7 @@ MicrorosGraphInfoTypeSupport::MicrorosGraphInfoTypeSupport()
     ss << "dds_::" << message_name << "_";
     this->setName(ss.str().c_str());
 
-    char full_bounded;
+    bool full_bounded = true;
     m_typeSize = 4 + callbacks_->max_serialized_size(full_bounded);
 }
 

snap/hooks/configure

@@ -101,4 +101,4 @@ case "$daemon" in
 		echo "'$daemon' is not a valid boolean for daemon" >&2
 		return 1
 		;;
-esac
+esac

snap/local/fastdds_no_shared_memory.xml

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8" ?>
-    <profiles xmlns="http://www.eprosima.com/XMLSchemas/fastRTPS_Profiles" >
-        <transport_descriptors>
-            <transport_descriptor>
-                <transport_id>CustomUdpTransport</transport_id>
-                <type>UDPv4</type>
-            </transport_descriptor>
-        </transport_descriptors>
-
-        <participant profile_name="participant_profile" is_default_profile="true">
-            <rtps>
-                <userTransports>
-                    <transport_id>CustomUdpTransport</transport_id>
-                </userTransports>
-
-                <useBuiltinTransports>false</useBuiltinTransports>
-            </rtps>
-        </participant>
-    </profiles>

snap/local/micro-ros-agent-daemon

@@ -24,4 +24,4 @@ if [ -n "$p2p_port" ]; then
 	set -- --p2p "$p2p_port" "$@"
 fi
 
-exec "$SNAP/opt/ros/snap/lib/micro_ros_agent/micro_ros_agent" "$transport" "$@"
+exec "$SNAP/lib/micro_ros_agent/micro_ros_agent" "$transport" "$@"

snap/snapcraft.yaml

@@ -71,6 +71,16 @@ description: |
 
         $ snap set micro-ros-agent device="device path"
 
+  If connecting the micro-ROS Agent using an IP based connection mode,
+  that is, `udp4`, `udp6`, `tcp4` or `tcp6`, care must be taken to
+  connect first the `micro-ros-agent-shm-netplug` plug.
+  This is due to the fact that ROS 2 Foxy is using Fast-DDS as the
+  default DDS middleware, and Fast-DDS comes with *shared memory transport*.
+  Thus, this plugin must be enabled, in order to gain access to the
+  `/dev/shm` folder from the snap image, prior to running it:
+
+      $ sudo snap connect micro-ros-agent:micro-ros-agent-shm-netplug
+
   When using the snap with a serial device, some steps need to be taken
   in order to establish a successful connection:
 
@@ -110,59 +120,49 @@ architectures:
   - build-on: armhf
   - build-on: ppc64el
 
-package-repositories:
-- components: [main]
-  formats: [deb]
-  key-id: C1CF6E31E6BADE8868B172B4F42ED6FBAB17C654
-  key-server: keyserver.ubuntu.com
-  suites: [focal]
-  type: apt
-  url: http://repo.ros2.org/ubuntu/main
-
 parts:
-  ros2-foxy-extension:
-    build-packages: [ros-foxy-ros-core]
-    override-build: install -D -m 0755 launch ${SNAPCRAFT_PART_INSTALL}/snap/command-chain/ros2-launch
-    plugin: nil
-    source: $SNAPCRAFT_EXTENSIONS_DIR/ros2
 
   uros-agent:
     plugin: colcon
     source: .
-    colcon-cmake-args:
+    override-build: |
-      - -DMICROROSAGENT_SUPERBUILD=ON
+        set +u
-      - --cmake-force-configure
+        git clone https://github.com/eProsima/Micro-XRCE-DDS-Agent.git -b $ROS_DISTRO
-    override-pull: |
+        git clone https://github.com/eProsima/Micro-CDR.git -b $ROS_DISTRO
-        snapcraftctl pull
+        git clone https://github.com/micro-ROS/micro_ros_msgs.git -b $ROS_DISTRO
-
+        git clone https://github.com/micro-ROS/rosidl_typesupport_microxrcedds.git -b $ROS_DISTRO
-        version="$(git describe --always --tags| sed -e 's/^v//;s/-/+git/;y/-/./')"
+        git clone https://github.com/micro-ROS/rmw-microxrcedds.git -b $ROS_DISTRO
-        [ -n "$(echo $version | grep "+git")" ] && grade=devel || grade=stable
+        git clone https://github.com/micro-ROS/micro-ROS-Agent.git -b $ROS_DISTRO
-        snapcraftctl set-version "$version"
+        . /opt/ros/$ROS_DISTRO/setup.sh
-        snapcraftctl set-grade "$grade"
+        colcon build --merge-install --install-base $SNAPCRAFT_PRIME --cmake-args "-DUAGENT_BUILD_EXECUTABLE=OFF -DUAGENT_USE_SYSTEM_FASTDDS=ON" --packages-up-to micro_ros_agent
-
+        set -u
     build-packages: [make, gcc, g++]
     stage-packages: [ros-foxy-ros2launch]
-    build-environment:
-    - ROS_VERSION: '2'
-    - ROS_DISTRO: foxy
 
   runner:
     plugin: dump
     source: snap/local/
     organize:
-      'micro-ros-agent-daemon': usr/bin/
+      '*': usr/bin/
-      'fastdds_no_shared_memory.xml': usr/share/
+
+plugs:
+  micro-ros-agent-shm-netplug:
+    interface: system-files
+    allow-auto-connection: true
+    write:
+      - /dev/shm
 
 apps:
   micro-ros-agent:
-    command: opt/ros/snap/lib/micro_ros_agent/micro_ros_agent
+    command: lib/micro_ros_agent/micro_ros_agent
     environment:
-        FASTRTPS_DEFAULT_PROFILES_FILE: ${SNAP}/usr/share/fastdds_no_shared_memory.xml
+        LD_LIBRARY_PATH: "$LD_LIBRARY_PATH:$SNAP/lib"
-    plugs: [network, network-bind, serial-port]
+    plugs: [network, network-bind, serial-port, micro-ros-agent-shm-netplug]
+    extensions: [ros2-foxy]
 
   daemon:
     command: usr/bin/micro-ros-agent-daemon
     environment:
-        FASTRTPS_DEFAULT_PROFILES_FILE: ${SNAP}/usr/share/fastdds_no_shared_memory.xml
+        LD_LIBRARY_PATH: "$LD_LIBRARY_PATH:$SNAP/lib"
     daemon: simple
-    plugs: [network, network-bind, serial-port]
+    plugs: [network, network-bind, serial-port, micro-ros-agent-shm-netplug]