Use new Blueberry v2.0.3 feature request-response and its discovery

.github/workflows/main.yml

@@ -3,7 +3,7 @@ name: Integration build rmw_iceoryx
 on:
   push:
     branches:
-      - master
+      - humble
   pull_request:
 
 jobs:
@@ -12,18 +12,17 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-          os: [ubuntu-20.04]
+          os: [ubuntu-22.04]
     steps:
       - uses: actions/checkout@v2
       - name: Setup ROS
         uses: ros-tooling/setup-ros@master
+        with:
+          required-ros-distributions: humble
       - name: Install Iceoryx Dependencies
         run: sudo apt-get update && sudo apt-get install -y cmake libacl1-dev libncurses5-dev pkg-config
       - name: Build & Test
         uses: ros-tooling/action-ros-ci@master
         with:
           package-name: rmw_iceoryx_cpp
-          target-ros2-distro: rolling
-          vcs-repo-file-url: |
-            https://raw.githubusercontent.com/ros2/ros2/master/ros2.repos
-            ${{ github.workspace }}/.github/workflows/custom_repos.repos
+          target-ros2-distro: humble

README.md

@@ -15,26 +15,13 @@ To install rmw_iceoryx in a ROS 2 workspace with the latest ROS version, just ex
 ```bash
 mkdir -p ~/iceoryx_ws/src
 cd $_
-# LATEST_ROS_VERSION could be e.g. galactic
+# LATEST_ROS_VERSION could be e.g. humble
 git clone --branch LATEST_ROS_VERSION https://github.com/ros2/rmw_iceoryx.git
 ```
 
 For alternative installation instructions and more details about iceoryx's internals, please see [iceoryx's GitHub repo](https://github.com/eclipse/iceoryx).
 
 rmw_iceoryx is compatible with ROS 2 starting with Eloquent release.
-
-If you want to use ROS 2 rolling, you need to checkout the `master` branch of both rmw_iceoryx and iceoryx:
-
-```bash
-cd ~/iceoryx_ws/
-wget https://raw.githubusercontent.com/ros2/ros2/master/ros2.repos
-# Change the line of Eclipse iceoryx to "version: master"
-vcs import src < ros2.repos
-
-cd ~/iceoryx_ws/src
-git clone --branch master https://github.com/ros2/rmw_iceoryx.git
-```
-
 Assuming you have ROS 2 installed correctly, you can compile the iceoryx workspace with colcon:
 
 ```bash
@@ -47,7 +34,7 @@ colcon build
 colcon build --symlink-install --cmake-args -DCMAKE_BUILD_TYPE=Release -DBUILD_TESTING=OFF
 ```
 
-That's it! You've installed rmw_iceoryx and are ready to rumble.
+That's it! You've installed iceoryx and are ready to rumble.
 
 Working with rmw_iceoryx_cpp
 ============================
@@ -154,8 +141,8 @@ Unfortunately, not all features are yet fully fleshed out.
 | `ros2 node list`      | :heavy_check_mark:                 |
 | `ros2 node info`      | :heavy_check_mark:                 |
 | `ros2 interface *`    | :heavy_check_mark:                 |
-| `ros2 service *`      | :x: (coming with iceoryx v2.0)     |
-| `ros2 param list`     | :x: (coming with iceoryx v2.0)     |
+| `ros2 service *`      | :heavy_check_mark:                 |
+| `ros2 param list`     | :x:                                |
 | `rqt_graph`           | :heavy_check_mark:                 |
 | `rqt_top`             | :heavy_check_mark:                 |
 | `rqt_console`         | :heavy_check_mark:                 |

rmw_iceoryx_cpp/include/rmw_iceoryx_cpp/iceoryx_deserialize.hpp

@@ -1,4 +1,5 @@
 // Copyright (c) 2019 by Robert Bosch GmbH. All rights reserved.
+// Copyright (c) 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -16,6 +17,7 @@
 #define RMW_ICEORYX_CPP__ICEORYX_DESERIALIZE_HPP_
 
 struct rosidl_message_type_support_t;
+struct rosidl_service_type_support_t;
 
 namespace rmw_iceoryx_cpp
 {
@@ -26,5 +28,15 @@ void deserialize(
   const rosidl_message_type_support_t * type_supports,
   void * ros_message);
 
+void deserializeRequest(
+  const char * serialized_msg,
+  const rosidl_service_type_support_t * type_supports,
+  void * ros_message);
+
+void deserializeResponse(
+  const char * serialized_msg,
+  const rosidl_service_type_support_t * type_supports,
+  void * ros_message);
+
 }  // namespace rmw_iceoryx_cpp
 #endif  // RMW_ICEORYX_CPP__ICEORYX_DESERIALIZE_HPP_

rmw_iceoryx_cpp/include/rmw_iceoryx_cpp/iceoryx_name_conversion.hpp

@@ -1,5 +1,6 @@
 // Copyright (c) 2019 by Robert Bosch GmbH. All rights reserved.
 // Copyright (c) 2021 by ZhenshengLee. All rights reserved.
+// Copyright (c) 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -23,6 +24,7 @@
 #include "iceoryx_hoofs/cxx/string.hpp"
 
 struct rosidl_message_type_support_t;
+struct rosidl_service_type_support_t;
 
 namespace rmw_iceoryx_cpp
 {
@@ -71,5 +73,10 @@ get_iceoryx_service_description(
   const std::string & topic,
   const rosidl_message_type_support_t * type_supports);
 
+iox::capro::ServiceDescription
+get_iceoryx_service_description(
+  const std::string & topic,
+  const rosidl_service_type_support_t * type_supports);
+
 }  // namespace rmw_iceoryx_cpp
 #endif  // RMW_ICEORYX_CPP__ICEORYX_NAME_CONVERSION_HPP_

rmw_iceoryx_cpp/include/rmw_iceoryx_cpp/iceoryx_serialize.hpp

@@ -1,4 +1,5 @@
 // Copyright (c) 2019 by Robert Bosch GmbH. All rights reserved.
+// Copyright (c) 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -18,6 +19,7 @@
 #include <vector>
 
 struct rosidl_message_type_support_t;
+struct rosidl_service_type_support_t;
 
 namespace rmw_iceoryx_cpp
 {
@@ -27,5 +29,15 @@ void serialize(
   const rosidl_message_type_support_t * type_supports,
   std::vector<char> & payload_vector);
 
+void serializeRequest(
+  const void * ros_message,
+  const rosidl_service_type_support_t * type_supports,
+  std::vector<char> & payload_vector);
+
+void serializeResponse(
+  const void * ros_message,
+  const rosidl_service_type_support_t * type_supports,
+  std::vector<char> & payload_vector);
+
 }  // namespace rmw_iceoryx_cpp
 #endif  // RMW_ICEORYX_CPP__ICEORYX_SERIALIZE_HPP_

rmw_iceoryx_cpp/include/rmw_iceoryx_cpp/iceoryx_topic_names_and_types.hpp

@@ -1,4 +1,5 @@
 // Copyright (c) 2019 by Robert Bosch GmbH. All rights reserved.
+// Copyright (c) 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -35,6 +36,7 @@ void fill_topic_containers(
   std::map<std::string, std::vector<std::string>> & topic_publishers_);
 
 std::map<std::string, std::string> get_topic_names_and_types();
+std::map<std::string, std::string> get_service_names_and_types();
 
 std::map<std::string, std::vector<std::string>> get_nodes_and_publishers();
 

rmw_iceoryx_cpp/include/rmw_iceoryx_cpp/iceoryx_type_info_introspection.hpp

@@ -1,5 +1,5 @@
 // Copyright (c) 2019 by Robert Bosch GmbH. All rights reserved.
-// Copyright (c) 2021 by Apex.AI Inc. All rights reserved.
+// Copyright (c) 2021 - 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -20,6 +20,7 @@
 #include <utility>
 
 struct rosidl_message_type_support_t;
+struct rosidl_service_type_support_t;
 
 namespace rmw_iceoryx_cpp
 {
@@ -35,15 +36,26 @@ enum class TypeSupportLanguage
 const std::pair<TypeSupportLanguage, const rosidl_message_type_support_t *> get_type_support(
   const rosidl_message_type_support_t * type_supports);
 
+/// @brief Wraps get_service_typesupport_handle() and does error handling
+/// @return std::pair containing enum TypeSupportLanguage and handle to the type support
+const std::pair<TypeSupportLanguage, const rosidl_service_type_support_t *> get_type_support(
+  const rosidl_service_type_support_t * type_supports);
+
 bool iceoryx_is_fixed_size(const rosidl_message_type_support_t * type_supports);
+bool iceoryx_is_fixed_size(const rosidl_service_type_support_t * type_supports);
 
 bool iceoryx_is_valid_type_support(const rosidl_message_type_support_t * type_supports);
+bool iceoryx_is_valid_type_support(const rosidl_service_type_support_t * type_supports);
 
 size_t iceoryx_get_message_size(const rosidl_message_type_support_t * type_supports);
+size_t iceoryx_get_request_size(const rosidl_service_type_support_t * type_supports);
+size_t iceoryx_get_response_size(const rosidl_service_type_support_t * type_supports);
 
 std::string iceoryx_get_message_name(const rosidl_message_type_support_t * type_supports);
+std::string iceoryx_get_service_name(const rosidl_service_type_support_t * type_supports);
 
 std::string iceoryx_get_message_namespace(const rosidl_message_type_support_t * type_supports);
+std::string iceoryx_get_service_namespace(const rosidl_service_type_support_t * type_supports);
 
 void iceoryx_init_message(
   const rosidl_message_type_support_t * type_supports,

rmw_iceoryx_cpp/package.xml

@@ -2,7 +2,7 @@
 <?xml-model href="http://download.ros.org/schema/package_format2.xsd" schematypens="http://www.w3.org/2001/XMLSchema"?>
 <package format="2">
   <name>rmw_iceoryx_cpp</name>
-  <version>1.0.1</version>
+  <version>2.0.3</version>
   <description>rmw implementation for Bosch's zero copy middleware iceoryx</description>
   <maintainer email="[email protected]">Karsten Knese</maintainer>
   <license>Apache License 2.0</license>

rmw_iceoryx_cpp/src/internal/iceoryx_deserialize.cpp

@@ -1,5 +1,5 @@
 // Copyright (c) 2019 by Robert Bosch GmbH. All rights reserved.
-// Copyright (c) 2021 by Apex.AI Inc. All rights reserved.
+// Copyright (c) 2021 - 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -17,6 +17,7 @@
 
 #include "rosidl_typesupport_introspection_c/identifier.h"
 #include "rosidl_typesupport_introspection_c/message_introspection.h"
+#include "rosidl_typesupport_introspection_c/service_introspection.h"
 
 #include "rosidl_typesupport_introspection_cpp/identifier.hpp"
 #include "rosidl_typesupport_introspection_cpp/message_introspection.hpp"
@@ -50,4 +51,40 @@ void deserialize(
   }
 }
 
+void deserializeRequest(
+  const char * serialized_msg,
+  const rosidl_service_type_support_t * type_supports,
+  void * ros_message)
+{
+  auto ts = get_type_support(type_supports);
+
+  if (ts.first == TypeSupportLanguage::CPP) {
+    auto members_cpp =
+      static_cast<const rosidl_typesupport_introspection_cpp::ServiceMembers *>(ts.second->data);
+    rmw_iceoryx_cpp::details_cpp::deserializeRequest(serialized_msg, members_cpp, ros_message);
+  } else if (ts.first == TypeSupportLanguage::C) {
+    auto members_c =
+      static_cast<const rosidl_typesupport_introspection_c__ServiceMembers *>(ts.second->data);
+    rmw_iceoryx_cpp::details_c::deserializeRequest(serialized_msg, members_c, ros_message);
+  }
+}
+
+void deserializeResponse(
+  const char * serialized_msg,
+  const rosidl_service_type_support_t * type_supports,
+  void * ros_message)
+{
+  auto ts = get_type_support(type_supports);
+
+  if (ts.first == TypeSupportLanguage::CPP) {
+    auto members_cpp =
+      static_cast<const rosidl_typesupport_introspection_cpp::ServiceMembers *>(ts.second->data);
+    rmw_iceoryx_cpp::details_cpp::deserializeResponse(serialized_msg, members_cpp, ros_message);
+  } else if (ts.first == TypeSupportLanguage::C) {
+    auto members_c =
+      static_cast<const rosidl_typesupport_introspection_c__ServiceMembers *>(ts.second->data);
+    rmw_iceoryx_cpp::details_c::deserializeResponse(serialized_msg, members_c, ros_message);
+  }
+}
+
 }  // namespace rmw_iceoryx_cpp

rmw_iceoryx_cpp/src/internal/iceoryx_deserialize_typesupport_c.hpp

@@ -1,4 +1,5 @@
 // Copyright (c) 2020 by Robert Bosch GmbH. All rights reserved.
+// Copyright (c) 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -27,6 +28,7 @@
 
 #include "rosidl_typesupport_introspection_c/field_types.h"
 #include "rosidl_typesupport_introspection_c/message_introspection.h"
+#include "rosidl_typesupport_introspection_c/service_introspection.h"
 
 #include "./iceoryx_serialization_common.hpp"
 
@@ -239,6 +241,22 @@ const char * deserialize(
   return serialized_msg;
 }
 
+const char * deserializeResponse(
+  const char * serialized_msg,
+  const rosidl_typesupport_introspection_c__ServiceMembers * service_members,
+  void * ros_message)
+{
+  return deserialize(serialized_msg, service_members->response_members_, ros_message);
+}
+
+const char * deserializeRequest(
+  const char * serialized_msg,
+  const rosidl_typesupport_introspection_c__ServiceMembers * service_members,
+  void * ros_message)
+{
+  return deserialize(serialized_msg, service_members->request_members_, ros_message);
+}
+
 }  // namespace details_c
 }  // namespace rmw_iceoryx_cpp
 #endif  // INTERNAL__ICEORYX_DESERIALIZE_TYPESUPPORT_C_HPP_

rmw_iceoryx_cpp/src/internal/iceoryx_deserialize_typesupport_cpp.hpp

@@ -1,4 +1,5 @@
 // Copyright (c) 2020 by Robert Bosch GmbH. All rights reserved.
+// Copyright (c) 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -24,7 +25,7 @@
 #include <vector>
 
 #include "rosidl_typesupport_introspection_cpp/field_types.hpp"
-#include "rosidl_typesupport_introspection_cpp/message_introspection.hpp"
+#include "rosidl_typesupport_introspection_cpp/service_introspection.hpp"
 
 #include "./iceoryx_serialization_common.hpp"
 
@@ -309,6 +310,22 @@ const char * deserialize(
   return serialized_msg;
 }
 
+const char * deserializeResponse(
+  const char * serialized_msg,
+  const rosidl_typesupport_introspection_cpp::ServiceMembers * service_members,
+  void * ros_message)
+{
+  return deserialize(serialized_msg, service_members->response_members_, ros_message);
+}
+
+const char * deserializeRequest(
+  const char * serialized_msg,
+  const rosidl_typesupport_introspection_cpp::ServiceMembers * service_members,
+  void * ros_message)
+{
+  return deserialize(serialized_msg, service_members->request_members_, ros_message);
+}
+
 }  // namespace details_cpp
 }  // namespace rmw_iceoryx_cpp
 #endif  // INTERNAL__ICEORYX_DESERIALIZE_TYPESUPPORT_CPP_HPP_

rmw_iceoryx_cpp/src/internal/iceoryx_get_topic_endpoint_info.cpp

@@ -1,4 +1,5 @@
 // Copyright (c) 2021 by ZhenshengLee. All rights reserved.
+// Copyright (c) 2023 by Apex.AI Inc. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -117,7 +118,7 @@ fill_rmw_publisher_end_info(
 
   int i = 0;
   // store all data in rmw_topic_endpoint_info_array_t
-  for (const auto node_full_name : full_name_array) {
+  for (const auto & node_full_name : full_name_array) {
     auto name_n_space = get_name_n_space_from_node_full_name(node_full_name);
     auto rmw_topic_endpoint_info = rmw_get_zero_initialized_topic_endpoint_info();
     // duplicate and store the topic_name
@@ -204,7 +205,7 @@ fill_rmw_subscriber_end_info(
 
   int i = 0;
   // store all data in rmw_topic_endpoint_info_array_t
-  for (const auto node_full_name : full_name_array) {
+  for (const auto & node_full_name : full_name_array) {
     auto name_n_space = get_name_n_space_from_node_full_name(node_full_name);
     auto rmw_topic_endpoint_info = rmw_get_zero_initialized_topic_endpoint_info();
     // duplicate and store the topic_name