Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Mauro/add events executor #63

Open
wants to merge 99 commits into
base: irobot/add-events-executor
Choose a base branch
from
Open

Mauro/add events executor #63

wants to merge 99 commits into from

Conversation

mauropasse
Copy link
Collaborator

@mauropasse mauropasse commented Apr 14, 2021 •
edited
Loading

Changes

  • Use rclcpp::GuardConditions 53cc25d
  • Todo: Use latest rclcpp::GuardConditions
  • Apply william's refactor to make callbacks type safe 56405fc
  • Use std::function as executor callbacks 1412e94
  • Add callback to rclcpp::GuardConditions 32aa3db
  • Add callback to rclcpp intra-process subscriptions 7cadae3
  • Limit intra-process subscription events to QoS depth size.
  • Limit nodes GuardConditions max events to one 41c8f8a
  • Todo: Fix tests

ivanpauno and others added 30 commits March 12, 2021 13:07
@ivanpauno
Enable qos parameter overrides for the /parameter_events topic (ros2#…
35c89c8 
…1532)

Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@jacobperron
Fix doc typo in CallbackGroup constructor (ros2#1582)
736550c 
Signed-off-by: Jacob Perron <jacob@openrobotics.org>
@ivanpauno
Document design decisions that were made for statically typed paramet…
e331050 
…ers (ros2#1568)

Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@cottsay
7.0.0
7bfda87 
Signed-off-by: Scott K Logan <logans@cottsay.net>
@suab321321
Made 'Context::shutdown_reason' function a const function (ros2#1578)
f5afe38 
Signed-off-by: Abhinav Singh <singhabhinav9051571833@gmail.com>
@fujitatomoya
get_parameters_service_ should return empty if allow_undeclared_ is f…
7505161 
…alse (ros2#1514)

Signed-off-by: Tomoya.Fujita <Tomoya.Fujita@sony.com>
@ivanpauno
Changelogs
cae3836 
Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@ivanpauno
7.0.1
59ad83a
@jacobperron
Guard against integer overflow in duration conversion (ros2#1584)
182ad38 
Guard against overflow when converting from rclcpp::Duration to builtin_interfaces::msg::Duration,
which is a unsigned to signed conversion.

Use non-std int types for consistency

Handle large negative values

Signed-off-by: Jacob Perron <jacob@openrobotics.org>
@Karsten1987 @fujitatomoya
make rcl_lifecyle_com_interface optional in lifecycle nodes (ros2#1507)
052596c 
* make rcl_com_interface optional

Signed-off-by: Karsten Knese <Karsten1987@users.noreply.github.com>

* Update rclcpp_lifecycle/test/mocking_utils/patch.hpp

Co-authored-by: Tomoya Fujita <Tomoya.Fujita@sony.com>

* line break

Signed-off-by: Karsten Knese <Karsten1987@users.noreply.github.com>

* use state_machine_options

Signed-off-by: Karsten Knese <Karsten1987@users.noreply.github.com>

Co-authored-by: Tomoya Fujita <Tomoya.Fujita@sony.com>
@clalancette
Changelog.
63fdf82 
Signed-off-by: Chris Lalancette <clalancette@openrobotics.org>
@clalancette
8.0.0
763c564
@Karsten1987
use const auto & to iterate over parameters (ros2#1593)
3fa511a 
Clang is complaining about the looping variable being referenced as `const val` but should rather be `const ref`.

```
/Users/karsten/workspace/ros2/ros2_master/src/ros2/rclcpp/rclcpp/src/rclcpp/parameter_service.cpp:46:25: error: loop variable 'param' of type 'const rclcpp::Parameter' creates a copy from type 'const rclcpp::Parameter' [-Werror,-Wrange-loop-construct]
        for (const auto param : parameters) {
                        ^
/Users/karsten/workspace/ros2/ros2_master/src/ros2/rclcpp/rclcpp/src/rclcpp/parameter_service.cpp:46:14: note: use reference type 'const rclcpp::Parameter &' to prevent copying
        for (const auto param : parameters) {
             ^~~~~~~~~~~~~~~~~~
                        &
1 error generated.
```

Signed-off-by: Karsten Knese <Karsten1987@users.noreply.github.com>
@jacobperron
Document misuse of parameters callback (ros2#1590)
0088e35 
* Document misuse of parameters callback

Related to ros2#1587

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Remove bad example

Signed-off-by: Jacob Perron <jacob@openrobotics.org>
@jacobperron
Add API for checking QoS profile compatibility (ros2#1554)
dbb4c35 
* Add API for checking QoS profile compatibility

Depends on ros2/rmw#299

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Refactor as free function

Returns a struct containing the compatibility enum value and string for the reason.

Updated tests to reflect behavior changes upstream.

Signed-off-by: Jacob Perron <jacob@openrobotics.org>
@clalancette @ivanpauno
Remove rmw_connext_cpp references. (ros2#1595)
98a62f6 
* Remove rmw_connext_cpp references.

Signed-off-by: Chris Lalancette <clalancette@openrobotics.org>
Co-authored-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@clalancette
Changelog.
06a4a56 
Signed-off-by: Chris Lalancette <clalancette@openrobotics.org>
@clalancette
8.1.0
a7ec7d9
@BriceRenaudeau
add automatically_add_executor_with_node option (ros2#1594)
92ece94 
* add automatically_add_executor_with_node option

Signed-off-by: Brice <brice.renaudeau@wyca.fr>

* Fix typo

Signed-off-by: Brice <brice.renaudeau@wyca.fr>

* add option usage in test

Signed-off-by: Brice <brice.renaudeau@wyca.fr>

* Document parameter

Signed-off-by: Brice <brice.renaudeau@wyca.fr>
@ivanpauno
Delete debug messages (ros2#1602)
63e7922 
Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@anaelle-sw
Clock subscription callback group spins in its own thread (ros2#1556)
bc8c71b 
* Clock subscription callback group spins in its own thread

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* fix line length

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* fix code style divergence

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* fix code style divergence

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Initialize only once clock_callbackgroup

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Check if thread joinable before start a new thread

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Cancel executor and join thread in destroy_clock_sub

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Check if clock_thread_ is joinable before cancel executor and join

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Add use_clock_thread as an option

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Fix code style divergence

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Fix code style divergence

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Fix code style divergence

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* Add TimeSource tests

Signed-off-by: anaelle-sw <anaelle.sarazin@wyca.fr>

* update use_clock_thread value in function attachNode

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* join clock thread in function detachNode

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* TimeSource tests: fixes + comments + more tested cases

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* clean destroy_clock_sub()

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* flag to ensure clock_executor is cancelled

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* Always re-init clock_callback_group when creating a new clock sub

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* spin_until_future_complete() to cleanly cancel executor

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* fix tests warnings

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* fix test error: cancel clock executor

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* clean comments

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>

* fix precision loss

Signed-off-by: anaelle <anaelle.sarazin@wyca.fr>
@christophebedard
Namespace tracetools C++ functions (ros2#1603)
3ab6571 
Signed-off-by: Christophe Bedard <bedard.christophe@gmail.com>
@clalancette
Revert "Namespace tracetools C++ functions (ros2#1603)" (ros2#1607)
2562f71 
This reverts commit 3ab6571.

Signed-off-by: Chris Lalancette <clalancette@openrobotics.org>
@jacobperron
Fix flaky lifecycle node tests (ros2#1606)
f986ca3 
Apparently, the topics and services that LifecycleNode provides are not
available immediately after creating a node.

Fix flaky tests by accounting for some delay between the LifecycleNode
constructor and queries about its topics and services.

Signed-off-by: Jacob Perron <jacob@openrobotics.org>
@christophebedard
Namespace tracetools C++ functions (ros2#1608)
aa3a65d 
Signed-off-by: Christophe Bedard <bedard.christophe@gmail.com>
@ivanpauno
Initialize integers in test_parameter_event_handler.cpp to avoid unde…
51a4b21 
…fined behavior (ros2#1609)

Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@clalancette
Changelog.
4747205 
Signed-off-by: Chris Lalancette <clalancette@openrobotics.org>
@clalancette
8.2.0
e7e3504
@wjwwood
Add RMW listener APIs
f19633f 
Signed-off-by: Alberto Soragna <asoragna@irobot.com>
@wjwwood
split long log into two lines
b94349c 
Signed-off-by: Alberto Soragna <asoragna@irobot.com>
alsora and others added 29 commits April 23, 2021 15:18
@alsora
fix comments
01c2111 
Signed-off-by: Alberto Soragna <alberto.soragna@gmail.com>
@alsora
expose qos listener APIs from pub and sub; add unit-tests
476238b 
Signed-off-by: Alberto Soragna <alberto.soragna@gmail.com>
@alsora
add qos event unit-test for invalid callbacks
79dba0a 
Signed-off-by: Alberto Soragna <alberto.soragna@gmail.com>
Merge pull request ros2#64 from alsora/asoragna/waitable-listeners
d4dbb64 
Complete support for rmw listener APIs
Merge remote-tracking branch 'upstream/master' into irobot/add-rmw-li…
b0ff053 
…stener-apis
@KavenYau @jacobperron @wjwwood
Fix action server deadlock issue that caused by other mutexes locked …
fba080c 
…in CancelCallback (ros2#1635)

* Fix deadlock issue that caused by other mutexes locked in CancelCallback

Signed-off-by: Kaven Yau <love29881460@qq.com>

* Add unit test for rclcpp action server deadlock

Signed-off-by: Kaven Yau <love29881460@qq.com>

* Update rclcpp_action/test/test_server.cpp

Co-authored-by: William Woodall <william+github@osrfoundation.org>

Co-authored-by: Kaven Yau <love29881460@qq.com>
Co-authored-by: Jacob Perron <jacob@openrobotics.org>
Co-authored-by: William Woodall <william+github@osrfoundation.org>
Use QoS depth to limit callbacks count
e4e56ef 
Signed-off-by: Mauro Passerino <mpasserino@irobot.com>
@alsora
Merge pull request ros2#65 from mauropasse/mauro/add-rmw-listener-apis
d760ba3 
Use QoS depth to limit callbacks count
@wjwwood @hidmic
use dynamic_pointer_cast to detect allocator mismatch in intra proces…
79c2dd8 
…s manager (ros2#1643)

* use dynamic_pointer_cast to detect allocator mismatch in intra process manager

Signed-off-by: William Woodall <william@osrfoundation.org>

* add test case for mismatched allocators

Signed-off-by: William Woodall <william@osrfoundation.org>

* forward template arguments to avoid mismatched types in intra process manager

Signed-off-by: William Woodall <william@osrfoundation.org>

* style fixes

Signed-off-by: William Woodall <william@osrfoundation.org>

* refactor to test message address and count, more DRY

Signed-off-by: William Woodall <william@osrfoundation.org>

* update copyright

Signed-off-by: William Woodall <william@osrfoundation.org>

* fix typo

Signed-off-by: William Woodall <william@osrfoundation.org>

Co-authored-by: Michel Hidalgo <michel@ekumenlabs.com>

Co-authored-by: Michel Hidalgo <michel@ekumenlabs.com>
@Barry-Xu-2018
Use OnShutdown callback handle instead of OnShutdown callback (ros2#1639
6806cdf 
)

1. Add remove_on_shutdown_callback() in rclcpp::Context

Signed-off-by: Barry Xu <barry.xu@sony.com>

2. Add add_on_shutdown_callback(), which returns a handle that can be removed by remove_on_shutdown_callback().

Signed-off-by: Barry Xu <barry.xu@sony.com>
@KavenYau
Returns CancelResponse::REJECT while goal handle failed to transit to…
d051b8a 
… CANCELING state (ros2#1641)

Signed-off-by: Kaven Yau <kavenyau@foxmail.com>
@hidmic
Fix get_publishers_subscriptions_info_by_topic test in test_node.cpp (r…
c15eb1e 
…os2#1648)

* Wait on graph guard condition for graph changes to propagate

Signed-off-by: Michel Hidalgo <michel@ekumenlabs.com>
@hidmic @ivanpauno
Keep custom allocator in publisher and subscription options alive. (r…
1fc2d58 
…os2#1647)

* Keep custom allocator in publisher and subscription options alive.

Also, enforce an allocator bound to void is used to avoid surprises.

Signed-off-by: Michel Hidalgo <michel@ekumenlabs.com>

* Avoid sizeof(void) in MyAllocator implementation.

Signed-off-by: Michel Hidalgo <michel@ekumenlabs.com>

* Address peer review comment

Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>

* Use a lazely initialized private field when 'allocator' is not initialized

Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>

Co-authored-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@hidmic
Do not attempt to use void allocators for memory allocation. (ros2#1657)
0659d82 
Keep a rebound allocator for byte-sized memory blocks around
for publisher and subscription options.

Follow-up after 1fc2d58

Signed-off-by: Michel Hidalgo <michel@ekumenlabs.com>
@wjwwood @paudrow
[rclcpp] Type Adaptation feature (ros2#1557)
2e4c97a 
* initial version of type_adaptor.hpp

Signed-off-by: William Woodall <william@osrfoundation.org>

* initial version of rclcpp::get_message_type_support_handle()

Signed-off-by: William Woodall <william@osrfoundation.org>

* initial version of rclcpp::is_ros_compatible_type check

Signed-off-by: William Woodall <william@osrfoundation.org>

* fixup include statement order in publisher.hpp

Signed-off-by: William Woodall <william@osrfoundation.org>

* use new rclcpp::get_message_type_support_handle() and check in Publisher

Signed-off-by: William Woodall <william@osrfoundation.org>

* update adaptor->adapter, update TypeAdapter to use two arguments, add implicit default

Signed-off-by: William Woodall <william@osrfoundation.org>

* move away from shared_ptr<allocator> to just allocator, like the STL

Signed-off-by: William Woodall <william@osrfoundation.org>

* fixes to TypeAdapter and adding new publish function signatures

Signed-off-by: William Woodall <william@osrfoundation.org>

* bugfixes

Signed-off-by: William Woodall <william@osrfoundation.org>

* more bugfixes

Signed-off-by: William Woodall <william@osrfoundation.org>

* Add nullptr check

Signed-off-by: Audrow Nash <audrow@hey.com>

* Remove public from struct inheritance

Signed-off-by: Audrow Nash <audrow@hey.com>

* Add tests for publisher with type adapter

Signed-off-by: Audrow Nash <audrow@hey.com>

* Update packages to C++17

Signed-off-by: Audrow Nash <audrow@hey.com>

* Revert "Update packages to C++17"

This reverts commit 4585605.

Signed-off-by: William Woodall <william@osrfoundation.org>

* Begin updating AnySubscriptionCallback to use the TypeAdapter

Signed-off-by: Audrow Nash <audrow@hey.com>

* Use type adapter's custom type

Signed-off-by: Audrow Nash <audrow@hey.com>

* Correct which AnySubscriptionCallbackHelper is selected

Signed-off-by: Audrow Nash <audrow@hey.com>

* Setup dispatch function to work with adapted types

Signed-off-by: Audrow Nash <audrow@hey.com>

* Improve template logic on dispatch methods

Signed-off-by: Audrow Nash <audrow@hey.com>

* implement TypeAdapter for Subscription

Signed-off-by: William Woodall <william@osrfoundation.org>

* Add intraprocess tests with all supported message types

Signed-off-by: Audrow Nash <audrow@hey.com>

* Add intra process tests

Signed-off-by: Audrow Nash <audrow@hey.com>

* Add tests for subscription with type adapter

Signed-off-by: Audrow Nash <audrow@hey.com>

* Fix null allocator test

Signed-off-by: Audrow Nash <audrow@hey.com>

* Handle serialized message correctly

Signed-off-by: Audrow Nash <audrow@hey.com>

* Fix generic subscription

Signed-off-by: Audrow Nash <audrow@hey.com>

* Fix trailing space

Signed-off-by: Audrow Nash <audrow@hey.com>

* fix some issues found while testing type_adapter in demos

Signed-off-by: William Woodall <william@osrfoundation.org>

* add more tests, WIP

Signed-off-by: William Woodall <william@osrfoundation.org>

* Improve pub/sub tests

Signed-off-by: Audrow Nash <audrow@hey.com>

* Apply uncrustify formatting

Signed-off-by: Audrow Nash <audrow@hey.com>

* finish new tests for any subscription callback with type adapter

Signed-off-by: William Woodall <william@osrfoundation.org>

* fix adapt_type<...>::as<...> syntax

Signed-off-by: William Woodall <william@osrfoundation.org>

* fix explicit template instantiation of create_subscription() in new test

Signed-off-by: William Woodall <william@osrfoundation.org>

* cpplint fix

Signed-off-by: William Woodall <william@osrfoundation.org>

* Fix bug by aligning allocator types on both sides of ipm

Signed-off-by: Audrow Nash <audrow@hey.com>

* Fix intra process manager tests

Signed-off-by: Audrow Nash <audrow@hey.com>

Co-authored-by: Audrow Nash <audrow@hey.com>
@jacobperron
Fix doc typo (ros2#1663)
5dad229 
Signed-off-by: Jacob Perron <jacob@openrobotics.org>
@clalancette
Changelog.
a3383c3 
Signed-off-by: Chris Lalancette <clalancette@openrobotics.org>
@clalancette
10.0.0
72443ff
@ivanpauno
[service] Don't use a weak_ptr to avoid leaking (ros2#1668)
d488535 
Signed-off-by: Ivan Santiago Paunovic <ivanpauno@ekumenlabs.com>
@cottsay
Bump the benchmark timeout for benchmark_action_client (ros2#1671)
f245b4c 
Pausing and resuming the measurement inside the timing loop can cause
the initial run duration calculation to underestimate how long the
benchmark is taking to run, which results in the recorded run taking a
lot longer than it should. This is a known issue in libbenchmark.

This test is affected by that behavior, and typically takes a bit longer
than the others. The easiest thing to do right now is to just bump the
timeout. My tests show that 180 seconds is typically sufficient for this
test, so 240 should be a safe point to conclude that the test is
malfunctioning.

Signed-off-by: Scott K Logan <logans@cottsay.net>
@wjwwood
fix syntax issue with gcc (ros2#1674)
18fcd91 
* fix syntax issue with gcc

Signed-off-by: William Woodall <william@osrfoundation.org>

* uncrustify

Signed-off-by: William Woodall <william@osrfoundation.org>
@cottsay
Fix destruction order in lifecycle benchmark (ros2#1675)
56f68f9 
Signed-off-by: Scott K Logan <logans@cottsay.net>
@jacobperron
Declare parameters uninitialized (ros2#1673)
07b6ea0 
* Declare parameters uninitialized

Fixes ros2#1649

Allow declaring parameters without an initial value or override.
This was possible prior to Galactic, but was made impossible since we started enforcing the types of parameters in Galactic.

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Remove assertion

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Throw NoParameterOverrideProvided exception if accessed before initialized

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Add test getting static parameter after it is set

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Do not throw on access of uninitialized dynamically typed parameter

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Rename exception type

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Remove unused exception type

Signed-off-by: Jacob Perron <jacob@openrobotics.org>

* Uncrustify

Signed-off-by: Jacob Perron <jacob@openrobotics.org>
@jacobperron
11.0.0
0251f70
@KavenYau
Fix occasionally missing goal result caused by race condition (ros2#1677
1c61751 
)

* Fix occasionally missing goal result caused by race condition

Signed-off-by: Kaven Yau <kavenyau@foxmail.com>

* Take action_server_reentrant_mutex_ out of the sending result loop

Signed-off-by: Kaven Yau <kavenyau@foxmail.com>

* add note for explaining the current locking order in server.cpp

Signed-off-by: Kaven Yau <kavenyau@foxmail.com>
Merge branch 'master' into mauro/add-rmw-listener-apis-merge-master
2ac2dc2 
Signed-off-by: Mauro Passerino <mpasserino@irobot.com>
Merge pull request ros2#66 from mauropasse/mauro/add-rmw-listener-api…
c9d3d11 
…s-merge-master

Merged master on irobot/add-rmw-listener-apis
Merge branch 'irobot/add-rmw-listener-apis' into mauro/add-events-exe…
558569f 
…cutor

Signed-off-by: Mauro Passerino <mpasserino@irobot.com>
Some fixes
394da52 
Signed-off-by: Mauro Passerino <mpasserino@irobot.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone