Class Player
Defined in File player.hpp
Nested Relationships
Nested Types
Inheritance Relationships
Base Type
public rclcpp::Node
Class Documentation
-
class Player : public rclcpp::Node
Public Functions
-
explicit ROSBAG2_TRANSPORT_PUBLIC Player(const std::string &node_name = "rosbag2_player", const rclcpp::NodeOptions &node_options = rclcpp::NodeOptions())
-
ROSBAG2_TRANSPORT_PUBLIC Player(const rosbag2_storage::StorageOptions &storage_options, const rosbag2_transport::PlayOptions &play_options, const std::string &node_name = "rosbag2_player", const rclcpp::NodeOptions &node_options = rclcpp::NodeOptions())
-
ROSBAG2_TRANSPORT_PUBLIC Player(std::unique_ptr<rosbag2_cpp::Reader> reader, const rosbag2_storage::StorageOptions &storage_options, const rosbag2_transport::PlayOptions &play_options, const std::string &node_name = "rosbag2_player", const rclcpp::NodeOptions &node_options = rclcpp::NodeOptions())
-
virtual ROSBAG2_TRANSPORT_PUBLIC ~Player()
- ROSBAG2_TRANSPORT_PUBLIC void play ()
- virtual ROSBAG2_TRANSPORT_PUBLIC void pause ()
Pause the flow of time for playback.
- virtual ROSBAG2_TRANSPORT_PUBLIC void resume ()
Start the flow of time for playback.
- ROSBAG2_TRANSPORT_PUBLIC void toggle_paused ()
Pause if time running, resume if paused.
- ROSBAG2_TRANSPORT_PUBLIC bool is_paused () const
Return whether the playback is currently paused.
- ROSBAG2_TRANSPORT_PUBLIC double get_rate () const
Return current playback rate.
- virtual ROSBAG2_TRANSPORT_PUBLIC bool set_rate (double)
Set the playback rate.
- Returns:
false if an invalid value was provided (<= 0).
- virtual ROSBAG2_TRANSPORT_PUBLIC bool play_next ()
Playing next message from queue when in pause.
This is blocking call and it will wait until next available message will be published or rclcpp context shut down.
Note
If internal player queue is starving and storage has not been completely loaded, this method will wait until new element will be pushed to the queue.
- Returns:
true if player in pause mode and successfully played next message, otherwise false.
- virtual ROSBAG2_TRANSPORT_PUBLIC size_t burst (const size_t num_messages)
Burst the next
num_messagesmessages from the queue when paused.This call will play the next
num_messagesfrom the queue in burst mode. The timing of the messages is ignored.Note
If internal player queue is starving and storage has not been completely loaded, this method will wait until new element will be pushed to the queue.
- Parameters:
num_messages – The number of messages to burst from the queue.
- Returns:
The number of messages that was played.
- ROSBAG2_TRANSPORT_PUBLIC void seek (rcutils_time_point_value_t time_point)
Advance player to the message with closest timestamp >= time_point.
This is blocking call and it will wait until current message will be published and message queue will be refilled. If time_point is before the beginning of the bag, then playback time will be set to the beginning of the bag. If time_point is after the end of the bag, playback time will be set to the end of the bag, which will then end playback, or if loop is enabled then will start playing at the beginning of the next loop.
- Parameters:
time_point – Time point in ROS playback timeline.
Protected Attributes
-
bool is_ready_to_play_from_queue_ = {false}
-
std::mutex ready_to_play_from_queue_mutex_
-
std::condition_variable ready_to_play_from_queue_cv_
-
rclcpp::Publisher<rosgraph_msgs::msg::Clock>::SharedPtr clock_publisher_
-
std::unordered_map<std::string, std::shared_ptr<PlayerPublisher>> publishers_
-
class PlayerPublisher
-
explicit ROSBAG2_TRANSPORT_PUBLIC Player(const std::string &node_name = "rosbag2_player", const rclcpp::NodeOptions &node_options = rclcpp::NodeOptions())