message: Fix race in record_yielder.
diff: @@ -146,6 +146,7 @@ void RecordYielder::MainLoop() {
  }
  if (num_records_added_in_epoch_ < opts_.bufsize) {
  + mutex_lock l(mu_);
  opts_.bufsize = num_records_added_in_epoch_;
  }
  