snapshot.cpp
/tmp/ws/src/rosbag_snapshot/rosbag_snapshot/src/
snapshot_8cpp.html
rosbag_snapshot/snapshotter.h
void
appendParamOptions
snapshot_8cpp.html
a4ff635c60d64420ac1e80384e87651ee
(ros::NodeHandle &nh, SnapshotterOptions &opts)
int
main
snapshot_8cpp.html
a3c04138a5bfe5d72780bb7e82a18e627
(int argc, char **argv)
bool
parseOptions
snapshot_8cpp.html
affe0abe23153a3be8b1f39c0b84c38b9
(po::variables_map &vm, int argc, char **argv)
bool
parseVariablesMap
snapshot_8cpp.html
a8a2de4696fcaf1819525306e92017397
(SnapshotterOptions &opts, po::variables_map const &vm)
bool
parseVariablesMapClient
snapshot_8cpp.html
a3b5678942bb0ae61ea4e94ffb65852c2
(SnapshotterClientOptions &opts, po::variables_map const &vm)
const int
MB_TO_BYTES
snapshot_8cpp.html
a67ba9b4e4298ccabb6ddd832d39fb365
snapshotter.cpp
/tmp/ws/src/rosbag_snapshot/rosbag_snapshot/src/
snapshotter_8cpp.html
rosbag_snapshot/snapshotter.h
rosbag_snapshot
snapshotter.h
/tmp/ws/src/rosbag_snapshot/rosbag_snapshot/include/rosbag_snapshot/
snapshotter_8h.html
rosbag_snapshot::MessageQueue
rosbag_snapshot::SnapshotMessage
rosbag_snapshot::Snapshotter
rosbag_snapshot::SnapshotterClient
rosbag_snapshot::SnapshotterClientOptions
rosbag_snapshot::SnapshotterOptions
rosbag_snapshot::SnapshotterTopicOptions
rosbag_snapshot
class ROSBAG_DECL
Snapshotter
namespacerosbag__snapshot.html
a2d60c2effa8e62ccb7d36c48f5096ffc
test_snapshot.py
/tmp/ws/src/rosbag_snapshot/rosbag_snapshot/test/
test__snapshot_8py.html
test_snapshot::TestRosbagSnapshot
test_snapshot
anonymous
namespacetest__snapshot.html
aa12f3dc319c9eedde05c50fdc57c0ff4
string
PKG
namespacetest__snapshot.html
a77a83ed52f8e8d9a02b467f15eccb1bc
rosbag_snapshot::MessageQueue
classrosbag__snapshot_1_1MessageQueue.html
std::pair< queue_t::const_iterator, queue_t::const_iterator >
range_t
classrosbag__snapshot_1_1MessageQueue.html
a5f5d7a1314509d636ee1180cfd7cfb92
void
clear
classrosbag__snapshot_1_1MessageQueue.html
a7aabac9cefd837a3d97bbebeb6ce1eee
()
ros::Duration
duration
classrosbag__snapshot_1_1MessageQueue.html
a5080c800a8840292c116cb2e8d45afb8
() const
void
fillStatus
classrosbag__snapshot_1_1MessageQueue.html
ad746b97bebb8682ab62384e517bf1c15
(rosgraph_msgs::TopicStatistics &status)
int64_t
getMessageSize
classrosbag__snapshot_1_1MessageQueue.html
adaa46a79e1357a2fb4603f0ecb9553b7
(SnapshotMessage const &msg) const
MessageQueue
classrosbag__snapshot_1_1MessageQueue.html
a1f5cc6fc3072b196ca695668449648a7
(SnapshotterTopicOptions const &options)
SnapshotMessage
pop
classrosbag__snapshot_1_1MessageQueue.html
a6b1b274b1f1a37c46d99ee1e205d3015
()
void
push
classrosbag__snapshot_1_1MessageQueue.html
afc4911c45f7aee4ddc887c80d0aa34b5
(SnapshotMessage const &msg)
range_t
rangeFromTimes
classrosbag__snapshot_1_1MessageQueue.html
a40db88e284026a35773e68d0c51b75bc
(ros::Time const &start, ros::Time const &end)
void
setSubscriber
classrosbag__snapshot_1_1MessageQueue.html
a8dcf0988087d04e64200238bb7777f50
(boost::shared_ptr< ros::Subscriber > sub)
std::deque< SnapshotMessage >
queue_t
classrosbag__snapshot_1_1MessageQueue.html
a48377f7ad7662d8c2aa4ea566846b5f6
void
_clear
classrosbag__snapshot_1_1MessageQueue.html
adefdc5e9a85ca5888cc78ab493f4d0a3
()
SnapshotMessage
_pop
classrosbag__snapshot_1_1MessageQueue.html
acdb7711c021b3a0b16e6de68cab803da
()
void
_push
classrosbag__snapshot_1_1MessageQueue.html
aa196a0dd9aea87918c55215b1eb2048d
(SnapshotMessage const &msg)
bool
preparePush
classrosbag__snapshot_1_1MessageQueue.html
a41039d239cd0e9efba43a82f87d561fe
(int32_t size, ros::Time const &time)
boost::mutex
lock
classrosbag__snapshot_1_1MessageQueue.html
a70b45fe3905c5cf7daae3be226583653
SnapshotterTopicOptions
options_
classrosbag__snapshot_1_1MessageQueue.html
ae81af32c6c17ff4c504ce57ecc21f096
queue_t
queue_
classrosbag__snapshot_1_1MessageQueue.html
a3902523550997bad19ef743dbdde4be0
int64_t
size_
classrosbag__snapshot_1_1MessageQueue.html
a0e484ad3c7dc5e8bdd341e4a4dc3b6e6
friend
Snapshotter
classrosbag__snapshot_1_1MessageQueue.html
a167c4a5edefa882199f15b77c48f46c0
boost::shared_ptr< ros::Subscriber >
sub_
classrosbag__snapshot_1_1MessageQueue.html
af31a152c2f9932d2a5108d4f92dab327
rosbag_snapshot::SnapshotMessage
structrosbag__snapshot_1_1SnapshotMessage.html
SnapshotMessage
structrosbag__snapshot_1_1SnapshotMessage.html
a205f81c8f574f231f8a7fb400cd71a8b
(topic_tools::ShapeShifter::ConstPtr _msg, boost::shared_ptr< ros::M_string > _connection_header, ros::Time _time)
boost::shared_ptr< ros::M_string >
connection_header
structrosbag__snapshot_1_1SnapshotMessage.html
a2beca957f9e3d785e25afbd1129dc61e
topic_tools::ShapeShifter::ConstPtr
msg
structrosbag__snapshot_1_1SnapshotMessage.html
a1840aa6c8201574460e20c7100a53c58
ros::Time
time
structrosbag__snapshot_1_1SnapshotMessage.html
a5e6ee98926d8e622e901c29fbd32d2c3
rosbag_snapshot::Snapshotter
classrosbag__snapshot_1_1Snapshotter.html
int
run
classrosbag__snapshot_1_1Snapshotter.html
a2a7e075d3dc15c9358f5a39d21649973
()
Snapshotter
classrosbag__snapshot_1_1Snapshotter.html
a39a1a05aaae33258f3a30d2f1d615c96
(SnapshotterOptions const &options)
~Snapshotter
classrosbag__snapshot_1_1Snapshotter.html
aee07ab2b0be004e22bb00af1be1dd87b
()
std::map< std::string, boost::shared_ptr< MessageQueue > >
buffers_t
classrosbag__snapshot_1_1Snapshotter.html
a27add0096ce55a62f725545fb16dd24c
void
clear
classrosbag__snapshot_1_1Snapshotter.html
a28ba7e6195d8dded67bcc1a88230a12a
()
bool
enableCB
classrosbag__snapshot_1_1Snapshotter.html
a95ce2165678097ef4f0783accb88d503
(std_srvs::SetBool::Request &req, std_srvs::SetBool::Response &res)
void
fixTopicOptions
classrosbag__snapshot_1_1Snapshotter.html
a2c062133d0c969fe4e94fbcf6da63cc9
(SnapshotterTopicOptions &options)
void
pause
classrosbag__snapshot_1_1Snapshotter.html
acfb5a4646e6da6851dae24e2a9f0e463
()
void
pollTopics
classrosbag__snapshot_1_1Snapshotter.html
af2da7c09e62381c1667f68c14f2f4b25
(ros::TimerEvent const &e, rosbag_snapshot::SnapshotterOptions *options)
bool
postfixFilename
classrosbag__snapshot_1_1Snapshotter.html
ad3a0339341b6663b78f2f11ea2ec20a0
(std::string &file)
void
publishStatus
classrosbag__snapshot_1_1Snapshotter.html
ad9d67672131e2de55046701eedf90f0a
(ros::TimerEvent const &e)
void
resume
classrosbag__snapshot_1_1Snapshotter.html
a26076112679e81e7f5f12e4707cc9883
()
void
subscribe
classrosbag__snapshot_1_1Snapshotter.html
a83deda8fe8197817f4c69671462719a2
(std::string const &topic, boost::shared_ptr< MessageQueue > queue)
std::string
timeAsStr
classrosbag__snapshot_1_1Snapshotter.html
a4347748f8ce828c544224b4e056a6227
()
void
topicCB
classrosbag__snapshot_1_1Snapshotter.html
a34d2241ec8be9d0bfe62c3672b669be1
(const ros::MessageEvent< topic_tools::ShapeShifter const > &msg_event, boost::shared_ptr< MessageQueue > queue)
bool
triggerSnapshotCb
classrosbag__snapshot_1_1Snapshotter.html
aaa75670ba5f7fbafd98e91db86e1cf5e
(rosbag_snapshot_msgs::TriggerSnapshot::Request &req, rosbag_snapshot_msgs::TriggerSnapshot::Response &res)
bool
writeTopic
classrosbag__snapshot_1_1Snapshotter.html
a46759d837ea354f1f29d936750e99889
(rosbag::Bag &bag, MessageQueue &message_queue, std::string const &topic, rosbag_snapshot_msgs::TriggerSnapshot::Request &req, rosbag_snapshot_msgs::TriggerSnapshot::Response &res)
buffers_t
buffers_
classrosbag__snapshot_1_1Snapshotter.html
a2738b7dcc0d5049ed7c5864b1e961452
ros::ServiceServer
enable_server_
classrosbag__snapshot_1_1Snapshotter.html
a024fb52ffe7435adb828adcd3b2c4d3a
ros::NodeHandle
nh_
classrosbag__snapshot_1_1Snapshotter.html
a8952fceb748bd071b5fb0d04fed0970a
SnapshotterOptions
options_
classrosbag__snapshot_1_1Snapshotter.html
a81b1851419701f3b0202b2e914e54ea3
ros::Timer
poll_topic_timer_
classrosbag__snapshot_1_1Snapshotter.html
a3e9d4115c684f466811dbf9e3a19e39c
bool
recording_
classrosbag__snapshot_1_1Snapshotter.html
ac5d8e626c98534974e0be34e7636acc1
boost::upgrade_mutex
state_lock_
classrosbag__snapshot_1_1Snapshotter.html
a19731fabe4841de5a1858051349d7f9b
ros::Publisher
status_pub_
classrosbag__snapshot_1_1Snapshotter.html
a8928a45946e5afe5c15dcd57457400a9
ros::Timer
status_timer_
classrosbag__snapshot_1_1Snapshotter.html
ac03f75efd8d273d399ed23eb5072917d
ros::ServiceServer
trigger_snapshot_server_
classrosbag__snapshot_1_1Snapshotter.html
a4676f57502f81ca9575bfe76b99fa738
bool
writing_
classrosbag__snapshot_1_1Snapshotter.html
ada63dad6300db67c7ac3cdbe1f559851
static const int
QUEUE_SIZE
classrosbag__snapshot_1_1Snapshotter.html
a81e841435780937d3799be7d2b25f191
rosbag_snapshot::SnapshotterClient
classrosbag__snapshot_1_1SnapshotterClient.html
int
run
classrosbag__snapshot_1_1SnapshotterClient.html
a38ec876f7c9ab21415734f9d98d95538
(SnapshotterClientOptions const &opts)
SnapshotterClient
classrosbag__snapshot_1_1SnapshotterClient.html
add33ecb2b1b793eed3b31760cf8ea7b7
()
ros::NodeHandle
nh_
classrosbag__snapshot_1_1SnapshotterClient.html
ada8f9f2a0d921534918557d74ed6c49e
rosbag_snapshot::SnapshotterClientOptions
structrosbag__snapshot_1_1SnapshotterClientOptions.html
Action
structrosbag__snapshot_1_1SnapshotterClientOptions.html
abd227af1e225abe2b039538e14387731
TRIGGER_WRITE
structrosbag__snapshot_1_1SnapshotterClientOptions.html
abd227af1e225abe2b039538e14387731ab5ddc3f00ebf610845dd5e48efc39261
PAUSE
structrosbag__snapshot_1_1SnapshotterClientOptions.html
abd227af1e225abe2b039538e14387731a41bf01ec557f908f2a34fdf749c3a3b1
RESUME
structrosbag__snapshot_1_1SnapshotterClientOptions.html
abd227af1e225abe2b039538e14387731a9d9c6ac32b4111fca77199b110022b59
PAUSE
structrosbag__snapshot_1_1SnapshotterClientOptions.html
abd227af1e225abe2b039538e14387731a41bf01ec557f908f2a34fdf749c3a3b1
RESUME
structrosbag__snapshot_1_1SnapshotterClientOptions.html
abd227af1e225abe2b039538e14387731a9d9c6ac32b4111fca77199b110022b59
TRIGGER_WRITE
structrosbag__snapshot_1_1SnapshotterClientOptions.html
abd227af1e225abe2b039538e14387731ab5ddc3f00ebf610845dd5e48efc39261
SnapshotterClientOptions
structrosbag__snapshot_1_1SnapshotterClientOptions.html
a93209e73298ec448b03e50e4472db0f0
()
Action
action_
structrosbag__snapshot_1_1SnapshotterClientOptions.html
ac79eadc65bb398d3e31a3e3397f46ad1
std::string
filename_
structrosbag__snapshot_1_1SnapshotterClientOptions.html
aa9e0f48db7ad263e3b9ab7190814d2aa
std::string
prefix_
structrosbag__snapshot_1_1SnapshotterClientOptions.html
afb48fbc6ddaa379744d80640d9035695
std::vector< std::string >
topics_
structrosbag__snapshot_1_1SnapshotterClientOptions.html
a33b4397d574068ae01cd6ddc93f7913a
rosbag_snapshot::SnapshotterOptions
structrosbag__snapshot_1_1SnapshotterOptions.html
std::map< std::string, SnapshotterTopicOptions >
topics_t
structrosbag__snapshot_1_1SnapshotterOptions.html
aac4615f3bb6d383862caa9bcd2ea1b35
bool
addTopic
structrosbag__snapshot_1_1SnapshotterOptions.html
a21dc7c42de22728e761a4f0f340a4dfa
(std::string const &topic, ros::Duration duration_limit=SnapshotterTopicOptions::INHERIT_DURATION_LIMIT, int32_t memory_limit=SnapshotterTopicOptions::INHERIT_MEMORY_LIMIT, int32_t count_limit=SnapshotterTopicOptions::INHERIT_COUNT_LIMIT)
SnapshotterOptions
structrosbag__snapshot_1_1SnapshotterOptions.html
aebd2ea76758de2d2df87addf240e29da
(ros::Duration default_duration_limit=ros::Duration(30), int32_t default_memory_limit=-1, int32_t default_count_limit=-1, ros::Duration status_period=ros::Duration(1), bool clear_buffer=true)
bool
all_topics_
structrosbag__snapshot_1_1SnapshotterOptions.html
ac71d8afe3e7444f14302cf9a45d194f7
bool
clear_buffer_
structrosbag__snapshot_1_1SnapshotterOptions.html
a80f4c6b4c017ce190f13c2df7f6b9451
std::string
compression_
structrosbag__snapshot_1_1SnapshotterOptions.html
a1e993771a3db019f4adbb908910a629e
int32_t
default_count_limit_
structrosbag__snapshot_1_1SnapshotterOptions.html
af9d0bbf6f843ff62c151eb1949e889e4
ros::Duration
default_duration_limit_
structrosbag__snapshot_1_1SnapshotterOptions.html
a7af4d60c13a6a84e15bf81f271ef4e2d
int32_t
default_memory_limit_
structrosbag__snapshot_1_1SnapshotterOptions.html
a8a486e0f3a39bfb74c9560e104e9d60e
ros::Duration
status_period_
structrosbag__snapshot_1_1SnapshotterOptions.html
a2bd787364340ea068feccea2bb8644db
topics_t
topics_
structrosbag__snapshot_1_1SnapshotterOptions.html
a36331aa76612921bd5a252e43ea2b222
rosbag_snapshot::SnapshotterTopicOptions
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
SnapshotterTopicOptions
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
a29525010778a10348d336a107b01539d
(ros::Duration duration_limit=INHERIT_DURATION_LIMIT, int32_t memory_limit=INHERIT_MEMORY_LIMIT, int32_t count_limit=INHERIT_COUNT_LIMIT)
int32_t
count_limit_
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
ac2ec94cc9aa9fd5693d7389bcc8a4f22
ros::Duration
duration_limit_
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
ac02e32d366e133e1548107ca62dbe3b9
int32_t
memory_limit_
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
a629aece5af4848dd02e73ecbad1f5005
static const int32_t
INHERIT_COUNT_LIMIT
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
a7ef22142c0b920153769db1e687bc36e
static const ros::Duration
INHERIT_DURATION_LIMIT
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
a5b008788e966d0fa0d8ea0c26f7d772e
static const int32_t
INHERIT_MEMORY_LIMIT
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
af0fd6fa09062ff278848386c7b747a6e
static const int32_t
NO_COUNT_LIMIT
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
a1b63351335d811e0d487ba67a05f7b05
static const ros::Duration
NO_DURATION_LIMIT
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
a3bbf5cf8efc3d5a9c1fb130e6f96efc0
static const int32_t
NO_MEMORY_LIMIT
structrosbag__snapshot_1_1SnapshotterTopicOptions.html
a4eca452b70f2757e719752a7464ed649
test_snapshot::TestRosbagSnapshot
classtest__snapshot_1_1TestRosbagSnapshot.html
def
__init__
classtest__snapshot_1_1TestRosbagSnapshot.html
ad78bea8df49ef4e3ae5c42bd678fa0e1
(self, *args)
def
test_1_service_connects
classtest__snapshot_1_1TestRosbagSnapshot.html
a1b03da0d7711c98872b9e050a08c1660
(self)
def
test_invalid_topics
classtest__snapshot_1_1TestRosbagSnapshot.html
a6a7893cd6e829b9bea9194cd579fe3bb
(self)
def
test_write_advanced
classtest__snapshot_1_1TestRosbagSnapshot.html
a050df9044ba982dcb227d2a88f86ce1c
(self)
def
test_write_all
classtest__snapshot_1_1TestRosbagSnapshot.html
a2af40c53faf659bc1dbbcf6877cba204
(self)
default_count_limit
classtest__snapshot_1_1TestRosbagSnapshot.html
a85987cd8bbe56196270ca96b181a7fa3
default_duration_limit
classtest__snapshot_1_1TestRosbagSnapshot.html
aa8a0747bb59635e90d26cd88a9112ae0
default_memory_limit
classtest__snapshot_1_1TestRosbagSnapshot.html
a217a49183786392ab89b5bda2299fef1
enable
classtest__snapshot_1_1TestRosbagSnapshot.html
a431b18e7e27435e456c1574da16506ac
last_status
classtest__snapshot_1_1TestRosbagSnapshot.html
a0e8783f799f4427126cecd5630f17f50
params
classtest__snapshot_1_1TestRosbagSnapshot.html
a55fbec437e270a2e6891f885c1c9c14c
status_sub
classtest__snapshot_1_1TestRosbagSnapshot.html
a23b74d8ca47367c31e64b61c7e4323f7
topic_limits
classtest__snapshot_1_1TestRosbagSnapshot.html
a3602964344b1eb32c2ea5c957b99e578
trigger
classtest__snapshot_1_1TestRosbagSnapshot.html
a000553da215a63c4bfc5007d6aa0bd45
def
_assert_bag_valid
classtest__snapshot_1_1TestRosbagSnapshot.html
a420f9ab6f3eb7a43baf32e8aaf99f6d1
(self, filename, topics=None, start_time=None, stop_time=None)
def
_assert_limits_enforced
classtest__snapshot_1_1TestRosbagSnapshot.html
aecbccdc1a184b86439b5c665afaad62e
(self, test_topic, duration, memory, count)
def
_assert_no_data
classtest__snapshot_1_1TestRosbagSnapshot.html
a513f07a53f61ab958e8838692f03a8fe
(self, topics=[])
def
_assert_record_success
classtest__snapshot_1_1TestRosbagSnapshot.html
aaec4b289a7117e6ea0f80f0b23eb784e
(self, data)
def
_assert_status_valid
classtest__snapshot_1_1TestRosbagSnapshot.html
a85bfb24dc808e274187c8ad04fa55c58
(self)
def
_assert_write_success
classtest__snapshot_1_1TestRosbagSnapshot.html
abae6714dd4a716496f659e30f1d9c60e
(self, topics=[], prefix_mode=False, **kwargs)
def
_parse_params
classtest__snapshot_1_1TestRosbagSnapshot.html
abb046a0ed4074dbd7a4ff8e46cb149d4
(self, params)
def
_pause
classtest__snapshot_1_1TestRosbagSnapshot.html
a49fd13f1d8577110e32b31b915c81c76
(self)
def
_resume
classtest__snapshot_1_1TestRosbagSnapshot.html
aaca12fb6dec0c83f4474d3fc9436d643
(self)
def
_status_cb
classtest__snapshot_1_1TestRosbagSnapshot.html
a20b722f096b2888e387e19d50d71464d
(self, msg)
rosbag_snapshot
namespacerosbag__snapshot.html
rosbag_snapshot::MessageQueue
rosbag_snapshot::SnapshotMessage
rosbag_snapshot::Snapshotter
rosbag_snapshot::SnapshotterClient
rosbag_snapshot::SnapshotterClientOptions
rosbag_snapshot::SnapshotterOptions
rosbag_snapshot::SnapshotterTopicOptions
class ROSBAG_DECL
Snapshotter
namespacerosbag__snapshot.html
a2d60c2effa8e62ccb7d36c48f5096ffc
test_snapshot
namespacetest__snapshot.html
test_snapshot::TestRosbagSnapshot
anonymous
namespacetest__snapshot.html
aa12f3dc319c9eedde05c50fdc57c0ff4
string
PKG
namespacetest__snapshot.html
a77a83ed52f8e8d9a02b467f15eccb1bc