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 <[email protected]>
@jacobperron
Fix doc typo in CallbackGroup constructor (ros2#1582)
736550c 
Signed-off-by: Jacob Perron <[email protected]>
@ivanpauno
Document design decisions that were made for statically typed paramet…
e331050 
…ers (ros2#1568)

Signed-off-by: Ivan Santiago Paunovic <[email protected]>
@cottsay
7.0.0
7bfda87 
Signed-off-by: Scott K Logan <[email protected]>
@suab321321
Made 'Context::shutdown_reason' function a const function (ros2#1578)
f5afe38 
Signed-off-by: Abhinav Singh <[email protected]>
@fujitatomoya
get_parameters_service_ should return empty if allow_undeclared_ is f…
7505161 
…alse (ros2#1514)

Signed-off-by: Tomoya.Fujita <[email protected]>
@ivanpauno
Changelogs
cae3836 
Signed-off-by: Ivan Santiago Paunovic <[email protected]>
@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 <[email protected]>
@Karsten1987 @fujitatomoya
make rcl_lifecyle_com_interface optional in lifecycle nodes (ros2#1507)
052596c 
* make rcl_com_interface optional

Signed-off-by: Karsten Knese <[email protected]>

* Update rclcpp_lifecycle/test/mocking_utils/patch.hpp

Co-authored-by: Tomoya Fujita <[email protected]>

* line break

Signed-off-by: Karsten Knese <[email protected]>

* use state_machine_options

Signed-off-by: Karsten Knese <[email protected]>

Co-authored-by: Tomoya Fujita <[email protected]>
@clalancette
Changelog.
63fdf82 
Signed-off-by: Chris Lalancette <[email protected]>
@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 <[email protected]>
@jacobperron
Document misuse of parameters callback (ros2#1590)
0088e35 
* Document misuse of parameters callback

Related to ros2#1587

Signed-off-by: Jacob Perron <[email protected]>

* Remove bad example

Signed-off-by: Jacob Perron <[email protected]>
@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 <[email protected]>

* 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 <[email protected]>
@clalancette @ivanpauno
Remove rmw_connext_cpp references. (ros2#1595)
98a62f6 
* Remove rmw_connext_cpp references.

Signed-off-by: Chris Lalancette <[email protected]>
Co-authored-by: Ivan Santiago Paunovic <[email protected]>
@clalancette
Changelog.
06a4a56 
Signed-off-by: Chris Lalancette <[email protected]>
@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 <[email protected]>

* Fix typo

Signed-off-by: Brice <[email protected]>

* add option usage in test

Signed-off-by: Brice <[email protected]>

* Document parameter

Signed-off-by: Brice <[email protected]>
@ivanpauno
Delete debug messages (ros2#1602)
63e7922 
Signed-off-by: Ivan Santiago Paunovic <[email protected]>
@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 <[email protected]>

* fix line length

Signed-off-by: anaelle-sw <[email protected]>

* fix code style divergence

Signed-off-by: anaelle-sw <[email protected]>

* fix code style divergence

Signed-off-by: anaelle-sw <[email protected]>

* Initialize only once clock_callbackgroup

Signed-off-by: anaelle-sw <[email protected]>

* Check if thread joinable before start a new thread

Signed-off-by: anaelle-sw <[email protected]>

* Cancel executor and join thread in destroy_clock_sub

Signed-off-by: anaelle-sw <[email protected]>

* Check if clock_thread_ is joinable before cancel executor and join

Signed-off-by: anaelle-sw <[email protected]>

* Add use_clock_thread as an option

Signed-off-by: anaelle-sw <[email protected]>

* Fix code style divergence

Signed-off-by: anaelle-sw <[email protected]>

* Fix code style divergence

Signed-off-by: anaelle-sw <[email protected]>

* Fix code style divergence

Signed-off-by: anaelle-sw <[email protected]>

* Add TimeSource tests

Signed-off-by: anaelle-sw <[email protected]>

* update use_clock_thread value in function attachNode

Signed-off-by: anaelle <[email protected]>

* join clock thread in function detachNode

Signed-off-by: anaelle <[email protected]>

* TimeSource tests: fixes + comments + more tested cases

Signed-off-by: anaelle <[email protected]>

* clean destroy_clock_sub()

Signed-off-by: anaelle <[email protected]>

* flag to ensure clock_executor is cancelled

Signed-off-by: anaelle <[email protected]>

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

Signed-off-by: anaelle <[email protected]>

* spin_until_future_complete() to cleanly cancel executor

Signed-off-by: anaelle <[email protected]>

* fix tests warnings

Signed-off-by: anaelle <[email protected]>

* fix test error: cancel clock executor

Signed-off-by: anaelle <[email protected]>

* clean comments

Signed-off-by: anaelle <[email protected]>

* fix precision loss

Signed-off-by: anaelle <[email protected]>
@christophebedard
Namespace tracetools C++ functions (ros2#1603)
3ab6571 
Signed-off-by: Christophe Bedard <[email protected]>
@clalancette
Revert "Namespace tracetools C++ functions (ros2#1603)" (ros2#1607)
2562f71 
This reverts commit 3ab6571.

Signed-off-by: Chris Lalancette <[email protected]>
@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 <[email protected]>
@christophebedard
Namespace tracetools C++ functions (ros2#1608)
aa3a65d 
Signed-off-by: Christophe Bedard <[email protected]>
@ivanpauno
Initialize integers in test_parameter_event_handler.cpp to avoid unde…
51a4b21 
…fined behavior (ros2#1609)

Signed-off-by: Ivan Santiago Paunovic <[email protected]>
@clalancette
Changelog.
4747205 
Signed-off-by: Chris Lalancette <[email protected]>
@clalancette
8.2.0
e7e3504
@wjwwood
Add RMW listener APIs
f19633f 
Signed-off-by: Alberto Soragna <[email protected]>
@wjwwood
split long log into two lines
b94349c 
Signed-off-by: Alberto Soragna <[email protected]>
alsora and others added 29 commits April 23, 2021 15:18
@alsora
fix comments
01c2111 
Signed-off-by: Alberto Soragna <[email protected]>
@alsora
expose qos listener APIs from pub and sub; add unit-tests
476238b 
Signed-off-by: Alberto Soragna <[email protected]>
@alsora
add qos event unit-test for invalid callbacks
79dba0a 
Signed-off-by: Alberto Soragna <[email protected]>
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 <[email protected]>

* Add unit test for rclcpp action server deadlock

Signed-off-by: Kaven Yau <[email protected]>

* Update rclcpp_action/test/test_server.cpp

Co-authored-by: William Woodall <[email protected]>

Co-authored-by: Kaven Yau <[email protected]>
Co-authored-by: Jacob Perron <[email protected]>
Co-authored-by: William Woodall <[email protected]>
Use QoS depth to limit callbacks count
e4e56ef 
Signed-off-by: Mauro Passerino <[email protected]>
@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 <[email protected]>

* add test case for mismatched allocators

Signed-off-by: William Woodall <[email protected]>

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

Signed-off-by: William Woodall <[email protected]>

* style fixes

Signed-off-by: William Woodall <[email protected]>

* refactor to test message address and count, more DRY

Signed-off-by: William Woodall <[email protected]>

* update copyright

Signed-off-by: William Woodall <[email protected]>

* fix typo

Signed-off-by: William Woodall <[email protected]>

Co-authored-by: Michel Hidalgo <[email protected]>

Co-authored-by: Michel Hidalgo <[email protected]>
@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 <[email protected]>

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

Signed-off-by: Barry Xu <[email protected]>
@KavenYau
Returns CancelResponse::REJECT while goal handle failed to transit to…
d051b8a 
… CANCELING state (ros2#1641)

Signed-off-by: Kaven Yau <[email protected]>
@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 <[email protected]>
@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 <[email protected]>

* Avoid sizeof(void) in MyAllocator implementation.

Signed-off-by: Michel Hidalgo <[email protected]>

* Address peer review comment

Signed-off-by: Ivan Santiago Paunovic <[email protected]>

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

Signed-off-by: Ivan Santiago Paunovic <[email protected]>

Co-authored-by: Ivan Santiago Paunovic <[email protected]>
@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 <[email protected]>
@wjwwood @paudrow
[rclcpp] Type Adaptation feature (ros2#1557)
2e4c97a 
* initial version of type_adaptor.hpp

Signed-off-by: William Woodall <[email protected]>

* initial version of rclcpp::get_message_type_support_handle()

Signed-off-by: William Woodall <[email protected]>

* initial version of rclcpp::is_ros_compatible_type check

Signed-off-by: William Woodall <[email protected]>

* fixup include statement order in publisher.hpp

Signed-off-by: William Woodall <[email protected]>

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

Signed-off-by: William Woodall <[email protected]>

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

Signed-off-by: William Woodall <[email protected]>

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

Signed-off-by: William Woodall <[email protected]>

* fixes to TypeAdapter and adding new publish function signatures

Signed-off-by: William Woodall <[email protected]>

* bugfixes

Signed-off-by: William Woodall <[email protected]>

* more bugfixes

Signed-off-by: William Woodall <[email protected]>

* Add nullptr check

Signed-off-by: Audrow Nash <[email protected]>

* Remove public from struct inheritance

Signed-off-by: Audrow Nash <[email protected]>

* Add tests for publisher with type adapter

Signed-off-by: Audrow Nash <[email protected]>

* Update packages to C++17

Signed-off-by: Audrow Nash <[email protected]>

* Revert "Update packages to C++17"

This reverts commit 4585605.

Signed-off-by: William Woodall <[email protected]>

* Begin updating AnySubscriptionCallback to use the TypeAdapter

Signed-off-by: Audrow Nash <[email protected]>

* Use type adapter's custom type

Signed-off-by: Audrow Nash <[email protected]>

* Correct which AnySubscriptionCallbackHelper is selected

Signed-off-by: Audrow Nash <[email protected]>

* Setup dispatch function to work with adapted types

Signed-off-by: Audrow Nash <[email protected]>

* Improve template logic on dispatch methods

Signed-off-by: Audrow Nash <[email protected]>

* implement TypeAdapter for Subscription

Signed-off-by: William Woodall <[email protected]>

* Add intraprocess tests with all supported message types

Signed-off-by: Audrow Nash <[email protected]>

* Add intra process tests

Signed-off-by: Audrow Nash <[email protected]>

* Add tests for subscription with type adapter

Signed-off-by: Audrow Nash <[email protected]>

* Fix null allocator test

Signed-off-by: Audrow Nash <[email protected]>

* Handle serialized message correctly

Signed-off-by: Audrow Nash <[email protected]>

* Fix generic subscription

Signed-off-by: Audrow Nash <[email protected]>

* Fix trailing space

Signed-off-by: Audrow Nash <[email protected]>

* fix some issues found while testing type_adapter in demos

Signed-off-by: William Woodall <[email protected]>

* add more tests, WIP

Signed-off-by: William Woodall <[email protected]>

* Improve pub/sub tests

Signed-off-by: Audrow Nash <[email protected]>

* Apply uncrustify formatting

Signed-off-by: Audrow Nash <[email protected]>

* finish new tests for any subscription callback with type adapter

Signed-off-by: William Woodall <[email protected]>

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

Signed-off-by: William Woodall <[email protected]>

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

Signed-off-by: William Woodall <[email protected]>

* cpplint fix

Signed-off-by: William Woodall <[email protected]>

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

Signed-off-by: Audrow Nash <[email protected]>

* Fix intra process manager tests

Signed-off-by: Audrow Nash <[email protected]>

Co-authored-by: Audrow Nash <[email protected]>
@jacobperron
Fix doc typo (ros2#1663)
5dad229 
Signed-off-by: Jacob Perron <[email protected]>
@clalancette
Changelog.
a3383c3 
Signed-off-by: Chris Lalancette <[email protected]>
@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 <[email protected]>
@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 <[email protected]>
@wjwwood
fix syntax issue with gcc (ros2#1674)
18fcd91 
* fix syntax issue with gcc

Signed-off-by: William Woodall <[email protected]>

* uncrustify

Signed-off-by: William Woodall <[email protected]>
@cottsay
Fix destruction order in lifecycle benchmark (ros2#1675)
56f68f9 
Signed-off-by: Scott K Logan <[email protected]>
@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 <[email protected]>

* Remove assertion

Signed-off-by: Jacob Perron <[email protected]>

* Throw NoParameterOverrideProvided exception if accessed before initialized

Signed-off-by: Jacob Perron <[email protected]>

* Add test getting static parameter after it is set

Signed-off-by: Jacob Perron <[email protected]>

* Do not throw on access of uninitialized dynamically typed parameter

Signed-off-by: Jacob Perron <[email protected]>

* Rename exception type

Signed-off-by: Jacob Perron <[email protected]>

* Remove unused exception type

Signed-off-by: Jacob Perron <[email protected]>

* Uncrustify

Signed-off-by: Jacob Perron <[email protected]>
@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 <[email protected]>

* Take action_server_reentrant_mutex_ out of the sending result loop

Signed-off-by: Kaven Yau <[email protected]>

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

Signed-off-by: Kaven Yau <[email protected]>
Merge branch 'master' into mauro/add-rmw-listener-apis-merge-master
2ac2dc2 
Signed-off-by: Mauro Passerino <[email protected]>
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 <[email protected]>
Some fixes
394da52 
Signed-off-by: Mauro Passerino <[email protected]>
@mauropasse mauropasse force-pushed the mauro/add-events-executor branch from a191180 to 394da52 Compare August 11, 2021 15:55
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
Development

Successfully merging this pull request may close these issues.