#include <snapshotter.h>
Public Types | |
typedef std::pair< queue_t::const_iterator, queue_t::const_iterator > | range_t |
Public Member Functions | |
void | clear () |
ros::Duration | duration () const |
void | fillStatus (rosgraph_msgs::TopicStatistics &status) |
MessageQueue (SnapshotterTopicOptions const &options) | |
SnapshotMessage | pop () |
void | push (SnapshotMessage const &msg) |
range_t | rangeFromTimes (ros::Time const &start, ros::Time const &end) |
void | setSubscriber (boost::shared_ptr< ros::Subscriber > sub) |
Private Types | |
typedef std::deque< SnapshotMessage > | queue_t |
Private Member Functions | |
void | _clear () |
SnapshotMessage | _pop () |
void | _push (SnapshotMessage const &msg) |
bool | preparePush (int32_t size, ros::Time const &time) |
Private Attributes | |
boost::mutex | lock |
SnapshotterTopicOptions | options_ |
queue_t | queue_ |
int64_t | size_ |
friend | Snapshotter |
boost::shared_ptr< ros::Subscriber > | sub_ |
Definition at line 127 of file snapshotter.h.
|
private |
Definition at line 138 of file snapshotter.h.
typedef std::pair<queue_t::const_iterator, queue_t::const_iterator> rosbag_snapshot::MessageQueue::range_t |
Definition at line 157 of file snapshotter.h.
|
explicit |
Definition at line 94 of file snapshotter.cpp.
|
private |
Definition at line 120 of file snapshotter.cpp.
|
private |
Definition at line 194 of file snapshotter.cpp.
|
private |
Definition at line 183 of file snapshotter.cpp.
void rosbag_snapshot::MessageQueue::clear | ( | ) |
Definition at line 114 of file snapshotter.cpp.
ros::Duration rosbag_snapshot::MessageQueue::duration | ( | ) | const |
Definition at line 126 of file snapshotter.cpp.
void rosbag_snapshot::MessageQueue::fillStatus | ( | rosgraph_msgs::TopicStatistics & | status | ) |
Definition at line 103 of file snapshotter.cpp.
SnapshotMessage rosbag_snapshot::MessageQueue::pop | ( | ) |
Definition at line 178 of file snapshotter.cpp.
|
private |
Definition at line 134 of file snapshotter.cpp.
void rosbag_snapshot::MessageQueue::push | ( | SnapshotMessage const & | msg | ) |
Definition at line 167 of file snapshotter.cpp.
MessageQueue::range_t rosbag_snapshot::MessageQueue::rangeFromTimes | ( | ros::Time const & | start, |
ros::Time const & | end | ||
) |
Definition at line 203 of file snapshotter.cpp.
void rosbag_snapshot::MessageQueue::setSubscriber | ( | boost::shared_ptr< ros::Subscriber > | sub | ) |
Definition at line 98 of file snapshotter.cpp.
|
private |
Definition at line 133 of file snapshotter.h.
|
private |
Definition at line 135 of file snapshotter.h.
|
private |
Definition at line 139 of file snapshotter.h.
|
private |
Definition at line 137 of file snapshotter.h.
|
private |
Definition at line 129 of file snapshotter.h.
|
private |
Definition at line 141 of file snapshotter.h.