Method Submit

be/src/observe/buffered-span.cc:149–189

}// function AddEvent

void BufferedSpan::Submit() {
  if (span_submitted_ || cancelled_) {
    VLOG(2) << strings::Substitute("Not submitting span '$0', submitted='$1' "
        "cancelled='$2'.", name_, span_submitted_, cancelled_);
    return;
  }

  VLOG(2) << "Submitting span '" << name_ << "'.";

  if (!span_) {
    Start();
  }

  if (!end_time_set_) {
    RecordEndTimeNow();
  }

  const int64_t end_time = chrono::duration_cast<chrono::milliseconds>(
      end_steady_time_.time_since_epoch()).count();
  const int64_t start_time = chrono::duration_cast<chrono::milliseconds>(
      start_steady_time_.time_since_epoch()).count();

  span_->SetAttribute("EndTime",
      static_cast<int64_t>(chrono::duration_cast<chrono::milliseconds>(
      end_steady_time_.time_since_epoch()).count()));
  span_->SetAttribute(duration_attribute_name_, (end_time - start_time));

  for (const auto& a : attributes_) {
    nostd::visit([&](const auto& value) {
      span_->SetAttribute(a.first, value);
    }, a.second);
  }

  AddEventsToSpan();

  trace::EndSpanOptions end_options;
  end_options.end_steady_time = end_steady_time_;
  span_->End(end_options);
  span_submitted_ = true;
  span_ = nullptr;
} // function Submit

const trace::SpanContext BufferedSpan::GetContext() const {
  if (span_) {