Class GuardCondition

Class Documentation

class GuardCondition

A condition that can be waited on in a single wait set and asynchronously triggered.

Public Functions

explicit GuardCondition(rclcpp::Context::SharedPtr context = rclcpp::contexts::get_global_default_context(), rcl_guard_condition_options_t guard_condition_options = rcl_guard_condition_get_default_options())

Construct the guard condition, optionally specifying which Context to use.

Parameters:

  • context – [in] Optional custom context to be used. Defaults to using the global default context singleton. Shared ownership of the context is held with the guard condition until destruction.

  • guard_condition_options – [in] Optional guard condition options to be used. Defaults to using the default guard condition options.

Throws:

  • std::invalid_argument – if the context is nullptr.

  • rclcpp::exceptions::RCLError – based exceptions when underlying rcl functions fail.

virtual ~GuardCondition()
rclcpp::Context::SharedPtr get_context() const

Return the context used when creating this guard condition.

rcl_guard_condition_t &get_rcl_guard_condition()

Return the underlying rcl guard condition structure.

const rcl_guard_condition_t &get_rcl_guard_condition() const

Return the underlying rcl guard condition structure.

void trigger()

Signal that the condition has been met, notifying both the wait set and listeners, if any.

This function is thread-safe, and may be called concurrently with waiting on this guard condition in a wait set.

Throws:

rclcpp::exceptions::RCLError – based exceptions when underlying rcl functions fail.

bool exchange_in_use_by_wait_set_state(bool in_use_state)

Exchange the “in use by wait set” state for this guard condition.

This is used to ensure this guard condition is not used by multiple wait sets at the same time.

Parameters:

in_use_state – [in] the new state to exchange into the state, true indicates it is now in use by a wait set, and false is that it is no longer in use by a wait set.

Returns:

the previous state.

void add_to_wait_set(rcl_wait_set_t *wait_set)

Adds the guard condition to a waitset.

This function is thread-safe.

Parameters:

wait_set – [in] pointer to a wait set where to add the guard condition

void set_on_trigger_callback(std::function<void(size_t)> callback)

Set a callback to be called whenever the guard condition is triggered.

The callback receives a size_t which is the number of times the guard condition was triggered since the last time this callback was called. Normally this is 1, but can be > 1 if the guard condition was triggered before any callback was set.

Calling it again will clear any previously set callback.

This function is thread-safe.

If you want more information available in the callback, like the guard condition or other information, you may use a lambda with captures or std::bind.

Parameters:

callback – [in] functor to be called when the guard condition is triggered

Protected Attributes

rclcpp::Context::SharedPtr context_
rcl_guard_condition_t rcl_guard_condition_
std::atomic<bool> in_use_by_wait_set_ = {false}
std::recursive_mutex reentrant_mutex_
std::function<void(size_t)> on_trigger_callback_ = {nullptr}
size_t unread_count_ = {0}
rcl_wait_set_t *wait_set_ = {nullptr}