Dnae adas/generic subscriber and publisher by DensoADAS · Pull Request #1077 · ros2/rclcpp

DensoADAS · 2020-04-21T13:10:10Z

using SerializedMessage and support in intraprocess manager to create a generic subscriber / publisher without previously known message type

DensoADAS · 2020-04-21T13:26:41Z

@Karsten1987 I did not create a spezialzation of Publisher for SerializedMessages as I disklike copying so much redudant code. I redesigned it so the changes to the Publisher are reduced. I hope it does not break to much with the current api. (But I have also a version with a spezialized publisher in backup)

DensoADAS · 2020-04-21T13:34:51Z

depends on #1076

ivanpauno · 2020-04-21T19:14:22Z

A few questions before reviewing, I'm probably missing some context from #973 discussion:

what's the goal of the "generic" publisher/subscription?
how they differ from Publisher/Subscription?

Thanks!

ivanpauno · 2020-04-21T21:24:52Z

+create_generic_publisher(
+  NodeT & node,
+  const std::string & topic_name,
+  const rosidl_message_type_support_t & type_support,


Why both MessageT template parameter and the type_support argument are needed?

Naming should also be more clear.
Maybe, just an override of create_publisher?

I think MessageT is used for the allocator

ivanpauno · 2020-04-21T21:27:59Z

-    if (RCL_RET_OK != status) {
-      rclcpp::exceptions::throw_from_rcl_error(status, "failed to publish message");
-    }
+    generic_publisher::do_inter_process_publish(publisher_handle_, msg);


I don't understand why the two new free functions are needed, and why a "normal" Publisher is calling the functions in generic_publisher namespace.
@DensoADAS can you expain?

for the SerializedMessage the original "do_inter_process_publish" will fail as it's no ROS message

can we just are an override for a serialized message in the Publisher class?

Karsten1987

Given that there is no generic publisher type, I would think it makes sense best to not mention this and keep the notation to publisher.

DensoADAS · 2020-04-22T04:26:12Z

A few questions before reviewing, I'm probably missing some context from #973 discussion:
* what's the goal of the "generic" publisher/subscription?

* how they differ from `Publisher`/`Subscription`?
Thanks!

The "generic" publisher/subscriber allows communication without knowing the message type to compile time. Therefore a serialized message can bei published or received and the endpoint has to handle the content itself. This is used for example in rosbag2.

This implementation supports now intraprocess communication when using the C++ version of serialized messages which make the memory handling more safe.

ivanpauno · 2020-04-22T14:26:36Z

The "generic" publisher/subscriber allows communication without knowing the message type to compile time. Therefore a serialized message can bei published or received and the endpoint has to handle the content itself. This is used for example in rosbag2.

Ah ok. So in those cases, you use MessageT=SerializedMessageBase, and you don't need to know the message type at compile time, right?

* implemented interface to deserialize a given serialized message to ros message Signed-off-by: Joshua Hampp <[email protected]>

* serialized publisher uses correct method to forward content to subscriber * non-serialized publisher can serialize message for serialized subscriber Signed-off-by: Joshua Hampp <[email protected]>

Signed-off-by: Joshua Hampp <[email protected]>

…cess_message Signed-off-by: Joshua Hampp <[email protected]>

…y needed for the next PR) Signed-off-by: Joshua Hampp <[email protected]>

Signed-off-by: Joshua Hampp <[email protected]>

Signed-off-by: Dirk Thomas <[email protected]>

* Reflect changes in rclcpp API Signed-off-by: Prajakta Gokhale <[email protected]> * Revert earlier fix made in rclcpp Signed-off-by: Prajakta Gokhale <[email protected]>

* added constructor with typesupport * added more generic do_inter_process_publish Signed-off-by: Joshua Hampp <[email protected]>

Signed-off-by: Joshua Hampp <[email protected]>

…d subscribers Signed-off-by: Joshua Hampp <[email protected]>

Signed-off-by: Joshua Hampp <[email protected]>

Karsten1987 · 2020-04-22T16:06:59Z

CI (build everything, test rclcpp):

Linux
Linux-aarch64
macOS
Windows

DensoADAS · 2020-04-22T18:43:45Z

Switching back to create_generic_... would solve this. Do you have another suggestion?

DensoADAS · 2020-04-24T14:39:01Z

@Karsten1987 I lost a little bit the track of the conversation. What's the current status?

Karsten1987 · 2020-04-24T15:57:16Z

In my opinion, #1076 (comment) this is where we stand. I think the intraprocess manager should be sorted out before pushing forward with this change.

* removed specialization to rclcpp::Serialization Signed-off-by: Joshua Hampp <[email protected]>

* allocate message * getter for serialization * provide untyped message Signed-off-by: Joshua Hampp <[email protected]>

Signed-off-by: Joshua Hampp <[email protected]>

* two extra subscription/publisher pairs (for serialized ones) * added methods for (de)serialization * added methods for messages without known allocator * splitted up publishing with same type and not matching message type Signed-off-by: Joshua Hampp <[email protected]>

Signed-off-by: Joshua Hampp <[email protected]>

Karsten1987 · 2020-04-29T18:03:47Z

Thanks @DensoADAS for iterating over this PR.

Unfortunately, we've passed API freeze for Foxy and after talking with @jacobperron (the Foxy lead), we've decided to table this for G-Turtle.

nyxaria · 2020-08-17T08:03:20Z

Is a generic subscriber available in Foxy? I don't think I can use ROS2 until it is in. :/

jacobperron · 2020-08-17T17:31:00Z

Is a generic subscriber available in Foxy?

Not in rclcpp. Unless something like this PR can be done in an ABI compatible way, I don't think we can expect it to land in Foxy.

As mentioned on ROS Answers, you can do this in Python and/or copy the C++ implementation from rosbag2 for your application.

ivanpauno reviewed Apr 21, 2020

View reviewed changes

Karsten1987 reviewed Apr 21, 2020

View reviewed changes

Comment thread rclcpp/include/rclcpp/create_publisher.hpp Outdated

Comment thread rclcpp/include/rclcpp/create_subscription.hpp Outdated

Comment thread rclcpp/include/rclcpp/publisher.hpp Outdated

Comment thread rclcpp/include/rclcpp/publisher.hpp Outdated

DensoADAS force-pushed the dnae_adas/generic_subscriber_and_publisher branch from e0fb512 to b5bce53 Compare April 22, 2020 07:13

Joshua Hampp and others added 18 commits April 22, 2020 17:03

* updated interface to SubscriptionIntraProcessBase

9d88f0e

* implemented interface to deserialize a given serialized message to ros message Signed-off-by: Joshua Hampp <[email protected]>

added support for SerializedMessage in Intraprocessmanger, so:

1dad3ad

* serialized publisher uses correct method to forward content to subscriber * non-serialized publisher can serialize message for serialized subscriber Signed-off-by: Joshua Hampp <[email protected]>

updated unit test for intraprocess manager to match new interface

c552c0b

Signed-off-by: Joshua Hampp <[email protected]>

updated is_serialized_message_class traits

2513cc2

Signed-off-by: Joshua Hampp <[email protected]>

renamed provide_serialized_intra_process_message to provide_intra_pro…

fd6a20e

…cess_message Signed-off-by: Joshua Hampp <[email protected]>

fixed Serialization class for non-supported type (yes this is actuall…

f0c8dd3

…y needed for the next PR) Signed-off-by: Joshua Hampp <[email protected]>

updated to (de)seriaizle method

facb43d

Signed-off-by: Joshua Hampp <[email protected]>

fix build regression (ros2#1078)

08a3251

Signed-off-by: Dirk Thomas <[email protected]>

Reflect changes in rclcpp API (ros2#1079)

0577f39

* Reflect changes in rclcpp API Signed-off-by: Prajakta Gokhale <[email protected]> * Revert earlier fix made in rclcpp Signed-off-by: Prajakta Gokhale <[email protected]>

extended publisher:

9ae2da1

* added constructor with typesupport * added more generic do_inter_process_publish Signed-off-by: Joshua Hampp <[email protected]>

added create_generic_subscription and create_generic_publisher

9490d9f

Signed-off-by: Joshua Hampp <[email protected]>

added test for intra process communication with generic publishers an…

3b430bf

…d subscribers Signed-off-by: Joshua Hampp <[email protected]>

fixed date

88a6927

Signed-off-by: Joshua Hampp <[email protected]>

fixed unintended change

63ad2fe

Signed-off-by: Joshua Hampp <[email protected]>

replaced generic_publisher

86f8ef9

Signed-off-by: Joshua Hampp <[email protected]>

removed unneeded template typename

62635ab

Signed-off-by: Joshua Hampp <[email protected]>

renamed create_generic_... to create_

d676d12

Signed-off-by: Joshua Hampp <[email protected]>

updated to new SerializedMessage

aeb69bf

Signed-off-by: Joshua Hampp <[email protected]>

DensoADAS force-pushed the dnae_adas/generic_subscriber_and_publisher branch from b5bce53 to aeb69bf Compare April 22, 2020 15:38

emersonknapp mentioned this pull request Apr 24, 2020

Export generic_subscription.hpp/cpp and generic_publisher.hpp/cpp for external use ros2/rosbag2#378

Closed

Joshua Hampp added 7 commits April 29, 2020 18:40

* added get_type_support_handle to rclcpp::Serialization

8d2de84

* removed specialization to rclcpp::Serialization Signed-off-by: Joshua Hampp <[email protected]>

extended subscription_intra_process(_base):

e2c19bb

* allocate message * getter for serialization * provide untyped message Signed-off-by: Joshua Hampp <[email protected]>

update unit test for subscription_intra_process(_base)

370061b

Signed-off-by: Joshua Hampp <[email protected]>

simplified code

2e5a7bd

Signed-off-by: Joshua Hampp <[email protected]>

fixed modifier

6b3d9c7

Signed-off-by: Joshua Hampp <[email protected]>

updated comments

f5c3362

Signed-off-by: Joshua Hampp <[email protected]>

Karsten1987 mentioned this pull request Aug 23, 2020

deserialize SerializedMessage into arbitrary message type on runtime? #1283

Closed

clalancette assigned wjwwood Mar 29, 2021

wjwwood removed their assignment Mar 29, 2021

clalancette added the backlog label Mar 28, 2022

audrow changed the base branch from master to rolling June 28, 2022 14:21

Uh oh!

Conversation

DensoADAS commented Apr 21, 2020

Uh oh!

DensoADAS commented Apr 21, 2020 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

DensoADAS commented Apr 21, 2020 • edited by ivanpauno Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

ivanpauno commented Apr 21, 2020 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

ivanpauno Apr 21, 2020

Choose a reason for hiding this comment

Uh oh!

ivanpauno Apr 21, 2020

Choose a reason for hiding this comment

Uh oh!

DensoADAS Apr 22, 2020

Choose a reason for hiding this comment

Uh oh!

Uh oh!

ivanpauno Apr 21, 2020

Choose a reason for hiding this comment

Uh oh!

DensoADAS Apr 22, 2020

Choose a reason for hiding this comment

Uh oh!

ivanpauno Apr 22, 2020

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Karsten1987 left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

DensoADAS commented Apr 22, 2020

Uh oh!

ivanpauno commented Apr 22, 2020

Uh oh!

Karsten1987 commented Apr 22, 2020 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

DensoADAS commented Apr 22, 2020

Uh oh!

DensoADAS commented Apr 24, 2020

Uh oh!

Karsten1987 commented Apr 24, 2020

Uh oh!

Karsten1987 commented Apr 29, 2020

Uh oh!

nyxaria commented Aug 17, 2020

Uh oh!

jacobperron commented Aug 17, 2020

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

8 participants

DensoADAS commented Apr 21, 2020 •

edited

Loading

DensoADAS commented Apr 21, 2020 •

edited by ivanpauno

Loading

ivanpauno commented Apr 21, 2020 •

edited

Loading

Karsten1987 commented Apr 22, 2020 •

edited

Loading