Executor runner class. More...

#include "get_capability_specs_runner.hpp"

Inheritance diagram for capabilities2_runner::GetCapabilitySpecsRunner:

Collaboration diagram for capabilities2_runner::GetCapabilitySpecsRunner:

Public Member Functions
	GetCapabilitySpecsRunner ()

virtual void	start (rclcpp::Node::SharedPtr node, const runner_opts &run_config, const std::string &bond_id) override
	Starter function for starting the action runner.

Public Member Functions inherited from capabilities2_runner::ServiceRunner< capabilities2_msgs::srv::GetCapabilitySpecs >
	ServiceRunner ()
	Constructor which needs to be empty due to plugin semantics.

virtual void	init_service (rclcpp::Node::SharedPtr node, const runner_opts &run_config, const std::string &service_name)
	Initializer function for initializing the service runner in place of constructor due to plugin semantics.

virtual void	stop (const std::string &bond_id, const std::string &instance_id="") override
	stop function to cease functionality and shutdown

Public Member Functions inherited from capabilities2_runner::ThreadTriggerRunner
	ThreadTriggerRunner ()

	~ThreadTriggerRunner ()

virtual void	trigger (capabilities2_events::EventParameters &parameters, const std::string &bond_id, const std::string &instance_id) override
	Trigger the runner.

Public Member Functions inherited from capabilities2_runner::RunnerBase
	RunnerBase ()

	~RunnerBase ()=default

void	init_base (rclcpp::Node::SharedPtr node, const runner_opts &run_config)
	Initializer function for initializing the base runner in place of constructor due to plugin semantics.

void	enable_events (std::shared_ptr< capabilities2_events::EventBase > events)
	enable events system for this runner

void	add_connection (const std::string &connection_id, const capabilities2_msgs::msg::CapabilityEventCode &type, const capabilities2_msgs::msg::Capability &target, std::function< void(const std::string &, const std::string &, const std::string &, capabilities2_events::EventParameters)> callback)
	make EventNode::add_connection public method on runner api.

const std::string	get_package_name ()
	get the package name to which the runner belong to.

const std::string &	get_interface () const
	get the interface of the runner.

const std::string &	get_provider () const
	get the provider of the runner.

const std::string &	get_started_by () const
	get the starter of the runner.

const std::string &	get_pid () const
	get the pid of the runner.

Public Member Functions inherited from capabilities2_events::EventNode
	EventNode (std::shared_ptr< EventBase > event_emitter=nullptr)

virtual	~EventNode ()=default

void	emit_event (const std::string &bond_id, const std::string &instance_id, const uint8_t &event_type, capabilities2_events::EventParameters parameters=capabilities2_events::EventParameters())
	emit an event from this event node to all matching connections

Protected Member Functions
virtual capabilities2_msgs::srv::GetCapabilitySpecs::Request	generate_request (capabilities2_events::EventParameters &parameters) override
	This generate goal function overrides the generate_goal() function from ActionRunner()

virtual capabilities2_events::EventParameters	param_on_success () override
	This function overrides the param_on_success() function from RunnerBase to provide specific implementation for the GetCapabilitySpecsRunner.

virtual void	process_response (typename capabilities2_msgs::srv::GetCapabilitySpecs::Response::SharedPtr response) override

Protected Member Functions inherited from capabilities2_runner::ServiceRunner< capabilities2_msgs::srv::GetCapabilitySpecs >
virtual void	execution (capabilities2_events::EventParameters parameters, const std::string &thread_id) override
	Trigger process to be executed.

virtual void	process_response (typename ServiceT::Response::SharedPtr)
	Process the reponse and print data as required.

Protected Member Functions inherited from capabilities2_runner::RunnerBase
virtual capabilities2_events::EventParameters	param_on_started ()
	Update on_started event parameters with new data if available.

virtual capabilities2_events::EventParameters	param_on_stopped ()
	Update on_stopped event parameters with new data if available.

virtual capabilities2_events::EventParameters	param_on_failure ()
	Update on_failure event parameters with new data if available.

const std::string	get_resource_name_by_type (const std::string &resource_type, const std::string &msg_type) const
	Get a resource name by data type from the config.

const std::string	get_parameter_name_by_type (const std::string &param_type) const
	Get a parameter name by type.

const std::string	get_topic_name_by_type (const std::string &topic_type) const
	Get a topic name by type.

const std::string	get_service_name_by_type (const std::string &srv_type) const
	Get a service name by type.

const std::string	get_action_name_by_type (const std::string &action_type) const
	Get the action name by type object.

const std::string	get_first_resource_name (const std::string &resource_type) const
	get first name of a given resource

const std::string	get_first_parameter_name () const
	Get the first parameter name.

const std::string	get_first_topic_name () const
	Get the first topic name.

const std::string	get_first_service_name () const
	Get the first service name.

const std::string	get_first_action_name () const
	Get the first action name.

void	emit_started (const std::string &bond_id, const std::string &instance_id, capabilities2_events::EventParameters parameters=capabilities2_events::EventParameters())
	emit STARTED event

void	emit_stopped (const std::string &bond_id, const std::string &instance_id, capabilities2_events::EventParameters parameters=capabilities2_events::EventParameters())
	emit STOPPED event

void	emit_succeeded (const std::string &bond_id, const std::string &instance_id, capabilities2_events::EventParameters parameters=capabilities2_events::EventParameters())
	emit SUCCEEDED event

void	emit_failed (const std::string &bond_id, const std::string &instance_id, capabilities2_events::EventParameters parameters=capabilities2_events::EventParameters())
	emit FAILED event

Protected Member Functions inherited from capabilities2_events::EventNode
void	set_source (const capabilities2_msgs::msg::Capability &src)
	Set the source object.

void	set_event_emitter (std::shared_ptr< EventBase > event_emitter)
	event emitter for this event node

void	add_connection (const std::string &connection_id, const capabilities2_msgs::msg::CapabilityEventCode &type, const capabilities2_msgs::msg::Capability &target, EventBase::event_callback_t event_cb)
	make EventNode::add_connection public method on runner api.

void	remove_connection (const std::string &connection_id)
	Remove a connection by its id.

void	clear_connections ()
	clear all connections from this event node

std::vector< capabilities2_msgs::msg::CapabilityConnection >	list_connections () const
	List all connections from this event node.

bool	has_connection (const std::string &connection_id) const
	Check if a connection exists.

size_t	connection_count () const
	current connection count

const std::string &	get_id () const
	unique id of this event node

const capabilities2_msgs::msg::Capability &	get_source () const
	source capability of this event node

bool	is_event_emitter_set () const
	event emitter is set on this node

Additional Inherited Members
Static Public Member Functions inherited from capabilities2_runner::ThreadTriggerRunner
static const std::string	bond_from_thread_id (const std::string &thread_id)
	helper function to extract bond_id from thread_id

static const std::string	instance_from_thread_id (const std::string &thread_id)
	helper function to extract instance_id from thread_id

Protected Attributes inherited from capabilities2_runner::ServiceRunner< capabilities2_msgs::srv::GetCapabilitySpecs >
rclcpp::Client< capabilities2_msgs::srv::GetCapabilitySpecs >::SharedPtr	service_client_

ServiceT::Response::SharedPtr	response_

Protected Attributes inherited from capabilities2_runner::ThreadTriggerRunner
std::map< std::string, std::thread >	execution_thread_pool_
	dictionary of threads that executes the execute function

std::mutex	mutex_
	mutex for threadpool synchronisation.

std::atomic< bool >	execution_should_stop_
	flag to signal execution threads to stop.

Protected Attributes inherited from capabilities2_runner::RunnerBase
rclcpp::Node::SharedPtr	node_
	shared pointer to the capabilities node Allows to use ros node related functionalities

runner_opts	run_config_
	run_config_ runner configuration

Detailed Description

Executor runner class.

Class to run capabilities2 executor action based capability

Constructor & Destructor Documentation

◆ GetCapabilitySpecsRunner()

capabilities2_runner::GetCapabilitySpecsRunner::GetCapabilitySpecsRunner ( )

inline

Member Function Documentation

◆ generate_request()

virtual capabilities2_msgs::srv::GetCapabilitySpecs::Request capabilities2_runner::GetCapabilitySpecsRunner::generate_request ( capabilities2_events::EventParameters & parameters )

inlineoverrideprotectedvirtual

This generate goal function overrides the generate_goal() function from ActionRunner()

Parameters

parameters XMLElement that contains parameters in the format '<Event name=follow_waypoints provider=WaypointRunner x='$value' y='$value' >'

Returns: ActionT::Goal the generated goal

Implements capabilities2_runner::ServiceRunner< capabilities2_msgs::srv::GetCapabilitySpecs >.

◆ param_on_success()

virtual capabilities2_events::EventParameters capabilities2_runner::GetCapabilitySpecsRunner::param_on_success ( )

inlineoverrideprotectedvirtual

This function overrides the param_on_success() function from RunnerBase to provide specific implementation for the GetCapabilitySpecsRunner.

Parameters

parameters EventParameters containing parameters for the trigger event

Returns: EventParameters updated parameters for on_success event

Reimplemented from capabilities2_runner::RunnerBase.

◆ process_response()

virtual void capabilities2_runner::GetCapabilitySpecsRunner::process_response ( typename capabilities2_msgs::srv::GetCapabilitySpecs::Response::SharedPtr response )

inlineoverrideprotectedvirtual

◆ start()

virtual void capabilities2_runner::GetCapabilitySpecsRunner::start	(	rclcpp::Node::SharedPtr	node,
		const runner_opts &	run_config,
		const std::string &	bond_id
	)

inlineoverridevirtual

Starter function for starting the action runner.

Parameters

node	shared pointer to the capabilities node. Allows to use ros node related functionalities
run_config	runner configuration loaded from the yaml file
bond_id	unique identifier for the group of connections associated with this runner trigger event

Implements capabilities2_runner::RunnerBase.

The documentation for this class was generated from the following file:

capabilities2_runner/include/capabilities2_runner/system/get_capability_specs_runner.hpp

Public Member Functions

Protected Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ GetCapabilitySpecsRunner()

Member Function Documentation

◆ generate_request()

◆ param_on_success()

◆ process_response()

◆ start()