p36850791
/
kinetic-devel
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

rosbag: buffer size option not being passed through

This commit is contained in:
Tim Field 2010-09-03 00:35:59 +00:00
parent 660d2c341c
commit b78a0a8f93
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tools/rosbag/src/recorder.cpp
View File

@ -93,7 +93,7 @@ RecorderOptions::RecorderOptions() :
name(""),
exclude_regex(),
split_size(0),
buffer_size(0),
buffer_size(1048576 * 256),
limit(0)
{
}
@ -105,7 +105,6 @@ Recorder::Recorder(RecorderOptions const& options) :
num_subscribers_(0),
exit_code_(0),
queue_size_(0),
max_queue_size_(1048576 * 256),
split_count_(0),
writing_enabled_(true)
{
@ -254,7 +253,7 @@ void Recorder::doQueue(ros::MessageEvent<topic_tools::ShapeShifter const> msg_ev
queue_size_ += out.msg->size();
// Check to see if buffer has been exceeded
while (max_queue_size_ > 0 && queue_size_ > max_queue_size_) {
while (options_.buffer_size > 0 && queue_size_ > options_.buffer_size) {
OutgoingMessage drop = queue_->front();
queue_->pop();
queue_size_ -= drop.msg->size();