IPC Client/Service to match Subscription approach

Signed-off-by: Mauro Passerino <mpasserino@irobot.com>
ros2 · May 26, 2022 · b6245f2 · b6245f2
1 parent fa5d140
commit b6245f2
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 8 deletions.
diff --git a/rclcpp/include/rclcpp/client.hpp b/rclcpp/include/rclcpp/client.hpp
@@ -379,6 +379,9 @@ class ClientBase
     uint64_t intra_process_client_id,
     IntraProcessManagerWeakPtr weak_ipm);
 
+  std::shared_ptr<rclcpp::experimental::ClientIntraProcessBase> client_intra_process_;
+  std::atomic_uint ipc_sequence_number_{1};
+
   rclcpp::node_interfaces::NodeGraphInterface::WeakPtr node_graph_;
   std::shared_ptr<rcl_node_t> node_handle_;
   std::shared_ptr<rclcpp::Context> context_;
@@ -898,6 +901,8 @@ class Client : public ClientBase
     }
 
     // Create a ClientIntraProcess which will be given to the intra-process manager.
+    using ClientIntraProcessT = rclcpp::experimental::ClientIntraProcess<ServiceT>;
+
     client_intra_process_ = std::make_shared<ClientIntraProcessT>(
       context_,
       this->get_service_name(),
@@ -919,11 +924,6 @@ class Client : public ClientBase
       CallbackInfoVariant>>
   pending_requests_;
   std::mutex pending_requests_mutex_;
-
-private:
-  using ClientIntraProcessT = rclcpp::experimental::ClientIntraProcess<ServiceT>;
-  std::shared_ptr<ClientIntraProcessT> client_intra_process_;
-  std::atomic_uint ipc_sequence_number_{1};
 };
 
 }  // namespace rclcpp

diff --git a/rclcpp/include/rclcpp/service.hpp b/rclcpp/include/rclcpp/service.hpp
@@ -289,6 +289,8 @@ class ServiceBase
     uint64_t intra_process_service_id,
     IntraProcessManagerWeakPtr weak_ipm);
 
+  std::shared_ptr<rclcpp::experimental::ServiceIntraProcessBase> service_intra_process_;
+
   std::shared_ptr<rcl_node_t> node_handle_;
   std::shared_ptr<rclcpp::Context> context_;
 
@@ -552,6 +554,8 @@ class Service
     }
 
     // Create a ServiceIntraProcess which will be given to the intra-process manager.
+    using ServiceIntraProcessT = rclcpp::experimental::ServiceIntraProcess<ServiceT>;
+
     service_intra_process_ = std::make_shared<ServiceIntraProcessT>(
       any_callback_,
       context_,
@@ -568,9 +572,6 @@ class Service
   RCLCPP_DISABLE_COPY(Service)
 
   AnyServiceCallback<ServiceT> any_callback_;
-
-  using ServiceIntraProcessT = rclcpp::experimental::ServiceIntraProcess<ServiceT>;
-  std::shared_ptr<ServiceIntraProcessT> service_intra_process_;
 };
 
 }  // namespace rclcpp