realtime_tools::RealtimePublisher< MessageT > Class Template Reference

Public Types
using	PublisherType = rclcpp::Publisher< MessageT >
	Provide various typedefs to resemble the rclcpp::Publisher type.
using	PublisherSharedPtr = typename rclcpp::Publisher< MessageT >::SharedPtr
using	PublishedType = typename rclcpp::TypeAdapter< MessageT >::custom_type
using	ROSMessageType = typename rclcpp::TypeAdapter< MessageT >::ros_message_type

Public Member Functions
	RealtimePublisher (PublisherSharedPtr publisher)
	Constructor for the realtime publisher.
	~RealtimePublisher ()
	Destructor.
void	stop ()
	Stop the realtime publisher.
bool	trylock ()
	Try to acquire the data lock for non-realtime message publishing.
bool	tryPublish (const MessageT &msg)
	Try to get the data lock from realtime and publish the given message.
void	unlockAndPublish ()
	Unlock the msg_ variable for the non-realtime thread to start publishing.
void	lock ()
	Acquire the data lock.
void	unlock ()
	Unlocks the data without publishing anything.

Public Attributes
MessageT	msg_
	The msg_ variable contains the data that will get published on the ROS topic.

Constructor & Destructor Documentation

RealtimePublisher()

template<class MessageT >

realtime_tools::RealtimePublisher< MessageT >::RealtimePublisher ( PublisherSharedPtr  publisher )

inlineexplicit

Constructor for the realtime publisher.

Starts a dedicated thread for message publishing. The publishing thread runs the publishingLoop() function to handle message delivery in a non-realtime context.

Parameters

publisher

the ROS publisher to wrap

Member Function Documentation

lock()

template<class MessageT >

void realtime_tools::RealtimePublisher< MessageT >::lock ( )

inline

Acquire the data lock.

This blocking call acquires exclusive access to the msg_ variable. Use trylock() for non-blocking attempts to acquire the lock.

stop()

template<class MessageT >

void realtime_tools::RealtimePublisher< MessageT >::stop ( )

inline

Stop the realtime publisher.

Signals the publishing thread to exit by setting keep_running_ to false and notifying the condition variable. This allows the publishing loop to break out of its wait state and exit cleanly.

trylock()

template<class MessageT >

bool realtime_tools::RealtimePublisher< MessageT >::trylock ( )

inline

Try to acquire the data lock for non-realtime message publishing.

It first checks if the current state allows non-realtime message publishing (turn_ == REALTIME) and then attempts to lock

Returns

true if the lock was successfully acquired, false otherwise

tryPublish()

template<class MessageT >

bool realtime_tools::RealtimePublisher< MessageT >::tryPublish ( const MessageT &  msg )

inline

Try to get the data lock from realtime and publish the given message.

Tries to gain unique access to msg_ variable. If this succeeds update the msg_ variable and call unlockAndPublish

Parameters

[in]

msg

The message to publish

Returns

false in case no lock for the realtime variable is acquired. This implies the message will not be published.

unlockAndPublish()

template<class MessageT >

void realtime_tools::RealtimePublisher< MessageT >::unlockAndPublish ( )

inline

Unlock the msg_ variable for the non-realtime thread to start publishing.

After a successful trylock and after the data is written to the mgs_ variable, the lock has to be released for the message to get published on the specified topic.

---

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

• realtime_tools/include/realtime_tools/realtime_publisher.hpp