edm::service::StallMonitor Class Reference

Public Member Functions
	StallMonitor (ParameterSet const &, ActivityRegistry &)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Private Types
using	ModuleID = decltype(std::declval< ModuleDescription >().id())
using	StreamID_value = decltype(std::declval< StreamID >().value())

Private Member Functions
void	postBeginJob ()
void	postEndJob ()
void	postEvent (StreamContext const &)
void	postEventReadFromSource (StreamContext const &, ModuleCallingContext const &)
void	postModuleEvent (StreamContext const &, ModuleCallingContext const &)
void	postModuleEventAcquire (StreamContext const &, ModuleCallingContext const &)
void	postModuleEventPrefetching (StreamContext const &, ModuleCallingContext const &)
void	postModuleGlobalTransition (GlobalContext const &, ModuleCallingContext const &)
void	postModuleStreamTransition (StreamContext const &, ModuleCallingContext const &)
void	postSourceEvent (StreamID)
void	preEvent (StreamContext const &)
void	preEventReadFromSource (StreamContext const &, ModuleCallingContext const &)
void	preModuleConstruction (edm::ModuleDescription const &)
void	preModuleEvent (StreamContext const &, ModuleCallingContext const &)
void	preModuleEventAcquire (StreamContext const &, ModuleCallingContext const &)
void	preModuleGlobalTransition (GlobalContext const &, ModuleCallingContext const &)
void	preModuleStreamTransition (StreamContext const &, ModuleCallingContext const &)
void	preSourceEvent (StreamID)

Private Attributes
decltype(now())	beginTime_ {}
ThreadSafeOutputFileStream	file_
std::vector< std::string >	moduleLabels_ {}
std::vector< StallStatistics >	moduleStats_ {}
unsigned int	numStreams_
tbb::concurrent_unordered_map< std::pair< StreamID_value, ModuleID >, std::pair< decltype(beginTime_), bool > >	stallStart_ {}
duration_t const	stallThreshold_
bool const	validFile_

Detailed Description

Definition at line 193 of file StallMonitor.cc.

Member Typedef Documentation

using edm::service::StallMonitor::ModuleID = decltype(std::declval<ModuleDescription>().id())

private

Definition at line 228 of file StallMonitor.cc.

using edm::service::StallMonitor::StreamID_value = decltype(std::declval<StreamID>().value())

private

Definition at line 227 of file StallMonitor.cc.

Constructor & Destructor Documentation

StallMonitor::StallMonitor	(	ParameterSet const &	iPS,
		ActivityRegistry &	iRegistry
	)

Definition at line 250 of file StallMonitor.cc.

References edm::Event, edm::ParameterSet::getUntrackedParameter(), edm::service::SystemBounds::maxNumberOfStreams(), numStreams_, postBeginJob(), postEndJob(), postEvent(), postEventReadFromSource(), postModuleEvent(), postModuleEventAcquire(), postModuleEventPrefetching(), postModuleGlobalTransition(), postModuleStreamTransition(), postSourceEvent(), preEvent(), preEventReadFromSource(), preModuleConstruction(), preModuleEvent(), preModuleEventAcquire(), preModuleGlobalTransition(), preModuleStreamTransition(), preSourceEvent(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::ThreadSafeOutputFileStream::write().

    : file_{iPS.getUntrackedParameter<std::string>("fileName", filename_default)},
      validFile_{file_},
      stallThreshold_{
          std::chrono::round<duration_t>(duration<double>(iPS.getUntrackedParameter<double>("stallThreshold")))} {
  iRegistry.watchPreModuleConstruction(this, &StallMonitor::preModuleConstruction);
  iRegistry.watchPostBeginJob(this, &StallMonitor::postBeginJob);
  iRegistry.watchPostModuleEventPrefetching(this, &StallMonitor::postModuleEventPrefetching);
  iRegistry.watchPreModuleEventAcquire(this, &StallMonitor::preModuleEventAcquire);
  iRegistry.watchPreModuleEvent(this, &StallMonitor::preModuleEvent);
  iRegistry.watchPostEndJob(this, &StallMonitor::postEndJob);

  if (validFile_) {
    // Only enable the following callbacks if writing to a file.
    iRegistry.watchPreSourceEvent(this, &StallMonitor::preSourceEvent);
    iRegistry.watchPostSourceEvent(this, &StallMonitor::postSourceEvent);
    iRegistry.watchPreEvent(this, &StallMonitor::preEvent);
    iRegistry.watchPostModuleEventAcquire(this, &StallMonitor::postModuleEventAcquire);
    iRegistry.watchPreEventReadFromSource(this, &StallMonitor::preEventReadFromSource);
    iRegistry.watchPostEventReadFromSource(this, &StallMonitor::postEventReadFromSource);
    iRegistry.watchPostModuleEvent(this, &StallMonitor::postModuleEvent);
    iRegistry.watchPostEvent(this, &StallMonitor::postEvent);

    iRegistry.watchPreModuleStreamBeginRun(this, &StallMonitor::preModuleStreamTransition);
    iRegistry.watchPostModuleStreamBeginRun(this, &StallMonitor::postModuleStreamTransition);
    iRegistry.watchPreModuleStreamEndRun(this, &StallMonitor::preModuleStreamTransition);
    iRegistry.watchPostModuleStreamEndRun(this, &StallMonitor::postModuleStreamTransition);

    iRegistry.watchPreModuleStreamBeginLumi(this, &StallMonitor::preModuleStreamTransition);
    iRegistry.watchPostModuleStreamBeginLumi(this, &StallMonitor::postModuleStreamTransition);
    iRegistry.watchPreModuleStreamEndLumi(this, &StallMonitor::preModuleStreamTransition);
    iRegistry.watchPostModuleStreamEndLumi(this, &StallMonitor::postModuleStreamTransition);

    iRegistry.watchPreModuleGlobalBeginRun(this, &StallMonitor::preModuleGlobalTransition);
    iRegistry.watchPostModuleGlobalBeginRun(this, &StallMonitor::postModuleGlobalTransition);
    iRegistry.watchPreModuleGlobalEndRun(this, &StallMonitor::preModuleGlobalTransition);
    iRegistry.watchPostModuleGlobalEndRun(this, &StallMonitor::postModuleGlobalTransition);
    iRegistry.watchPreModuleWriteRun(this, &StallMonitor::preModuleGlobalTransition);
    iRegistry.watchPostModuleWriteRun(this, &StallMonitor::postModuleGlobalTransition);

    iRegistry.watchPreModuleGlobalBeginLumi(this, &StallMonitor::preModuleGlobalTransition);
    iRegistry.watchPostModuleGlobalBeginLumi(this, &StallMonitor::postModuleGlobalTransition);
    iRegistry.watchPreModuleGlobalEndLumi(this, &StallMonitor::preModuleGlobalTransition);
    iRegistry.watchPostModuleGlobalEndLumi(this, &StallMonitor::postModuleGlobalTransition);
    iRegistry.watchPreModuleWriteLumi(this, &StallMonitor::preModuleGlobalTransition);
    iRegistry.watchPostModuleWriteLumi(this, &StallMonitor::postModuleGlobalTransition);

    iRegistry.preallocateSignal_.connect(
        [this](service::SystemBounds const& iBounds) { numStreams_ = iBounds.maxNumberOfStreams(); });

    std::ostringstream oss;
    oss << "# Transition       Symbol\n";
    oss << "#----------------- ------\n";
    oss << "# globalBeginRun  " << Phase::globalBeginRun << "\n"
        << "# streamBeginRun  " << Phase::streamBeginRun << "\n"
        << "# globalBeginLumi " << Phase::globalBeginLumi << "\n"
        << "# streamBeginLumi " << Phase::streamBeginLumi << "\n"
        << "# Event           " << Phase::Event << "\n"
        << "# streamEndLumi   " << Phase::streamEndLumi << "\n"
        << "# globalEndLumi   " << Phase::globalEndLumi << "\n"
        << "# streamEndRun    " << Phase::streamEndRun << "\n"
        << "# globalEndRun    " << Phase::globalEndRun << "\n";
    oss << "# Step                       Symbol Entries\n"
        << "# -------------------------- ------ ------------------------------------------\n"
        << "# preSourceEvent                " << step::preSourceEvent << "   <Stream ID> <Time since beginJob (ms)>\n"
        << "# postSourceEvent               " << step::postSourceEvent << "   <Stream ID> <Time since beginJob (ms)>\n"
        << "# preEvent                      " << step::preEvent
        << "   <Stream ID> <Run#> <LumiBlock#> <Event#> <Time since beginJob (ms)>\n"
        << "# postModuleEventPrefetching    " << step::postModuleEventPrefetching
        << "   <Stream ID> <Module ID> <Time since beginJob (ms)>\n"
        << "# preModuleEventAcquire         " << step::preModuleEventAcquire
        << "   <Stream ID> <Module ID> <Time since beginJob (ms)>\n"
        << "# postModuleEventAcquire        " << step::postModuleEventAcquire
        << "   <Stream ID> <Module ID> <Time since beginJob (ms)>\n"
        << "# preModuleTransition           " << step::preModuleEvent
        << "   <Stream ID> <Module ID> <Transition type> <Time since beginJob (ms)>\n"
        << "# preEventReadFromSource        " << step::preEventReadFromSource
        << "   <Stream ID> <Module ID> <Time since beginJob (ms)>\n"
        << "# postEventReadFromSource       " << step::postEventReadFromSource
        << "   <Stream ID> <Module ID> <Time since beginJob (ms)>\n"
        << "# postModuleTransition          " << step::postModuleEvent
        << "   <Stream ID> <Module ID> <Transition type> <Time since beginJob (ms)>\n"
        << "# postEvent                     " << step::postEvent
        << "   <Stream ID> <Run#> <LumiBlock#> <Event#> <Time since beginJob (ms)>\n";
    file_.write(oss.str());
  }
}

Member Function Documentation

void StallMonitor::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 338 of file StallMonitor.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::ConfigurationDescriptions::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                           {
  ParameterSetDescription desc;
  desc.addUntracked<std::string>("fileName", filename_default)
      ->setComment(
          "Name of file to which detailed timing information should be written.\n"
          "An empty filename argument (the default) indicates that no extra\n"
          "information will be written to a dedicated file, but only the summary\n"
          "including stalling-modules information will be logged.");
  desc.addUntracked<double>("stallThreshold", threshold_default)
      ->setComment(
          "Threshold (in seconds) used to classify modules as stalled.\n"
          "Microsecond granularity allowed.");
  descriptions.add("StallMonitor", desc);
  descriptions.setComment(
      "This service keeps track of various times in event-processing to determine which modules are stalling.");
}

void StallMonitor::postBeginJob ( )

private

Definition at line 376 of file StallMonitor.cc.

References beginTime_, mps_fire::i, label, moduleLabels_, moduleStats_, cmsPerfSuiteHarvest::now, findQualityFiles::size, AlCaHLTBitMon_QueryRunRegistry::string, ApeEstimator_cff::width, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                {
  // Since a (push,emplace)_back cannot be called for a vector of a
  // type containing atomics (like 'StallStatistics')--i.e. atomics
  // have no copy/move-assignment operators, we must specify the size
  // of the vector at construction time.
  moduleStats_ = std::vector<StallStatistics>(moduleLabels_.size());
  for (std::size_t i{}; i < moduleStats_.size(); ++i) {
    moduleStats_[i].setLabel(moduleLabels_[i]);
  }

  if (validFile_) {
    std::size_t const width{std::to_string(moduleLabels_.size()).size()};

    OStreamColumn col0{"Module ID", width};
    std::string const lastCol{"Module label"};

    std::ostringstream oss;
    oss << "\n#  " << col0 << space << lastCol << '\n';
    oss << "#  " << std::string(col0.width() + space.size() + lastCol.size(), '-') << '\n';

    for (std::size_t i{}; i < moduleLabels_.size(); ++i) {
      auto const& label = moduleLabels_[i];
      if (label.empty())
        continue;  // See comment in filling of moduleLabels_;
      oss << "#M " << std::setw(width) << std::left << col0(i) << space << std::left << moduleLabels_[i] << '\n';
    }
    oss << '\n';
    file_.write(oss.str());
  }
  // Don't need the labels anymore--info. is now part of the
  // module-statistics objects.
  moduleLabels_.clear();

  beginTime_ = now();
}

void StallMonitor::postEndJob ( )

private

Definition at line 544 of file StallMonitor.cc.

References KineDebug3::count(), DEFINE_FWK_SERVICE, edm::for_all(), SiStripPI::max, moduleStats_, MillePedeFileConverter_cfg::out, AlCaHLTBitMon_QueryRunRegistry::string, GlobalPosition_Frontier_DevDB_cff::tag, protons_cff::time, and ApeEstimator_cff::width.

Referenced by StallMonitor().

                              {
  // Prepare summary
  std::size_t width{};
  edm::for_all(moduleStats_, [&width](auto const& stats) {
    if (stats.numberOfStalls() == 0u)
      return;
    width = std::max(width, stats.label().size());
  });

  OStreamColumn tag{"StallMonitor>"};
  OStreamColumn col1{"Module label", width};
  OStreamColumn col2{"# of stalls"};
  OStreamColumn col3{"Total stalled time"};
  OStreamColumn col4{"Max stalled time"};

  LogAbsolute out{"StallMonitor"};
  out << '\n';
  out << tag << space << col1 << space << col2 << space << col3 << space << col4 << '\n';

  out << tag << space << std::setfill('-') << col1(std::string{}) << space << col2(std::string{}) << space
      << col3(std::string{}) << space << col4(std::string{}) << '\n';

  using seconds_d = duration<double>;

  auto to_seconds_str = [](auto const& duration) {
    std::ostringstream oss;
    auto const time = duration_cast<seconds_d>(duration).count();
    oss << time << " s";
    return oss.str();
  };

  out << std::setfill(' ');
  for (auto const& stats : moduleStats_) {
    if (stats.label().empty() ||  // See comment in filling of moduleLabels_;
        stats.numberOfStalls() == 0u)
      continue;
    out << std::left << tag << space << col1(stats.label()) << space << std::right << col2(stats.numberOfStalls())
        << space << col3(to_seconds_str(stats.totalStalledTime())) << space
        << col4(to_seconds_str(stats.maxStalledTime())) << '\n';
  }
}

void StallMonitor::postEvent ( StreamContext const &  sc )

private

Definition at line 537 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), runTauDisplay::eid, edm::StreamContext::eventID(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                    {
  auto const t = duration_cast<duration_t>(now() - beginTime_).count();
  auto const& eid = sc.eventID();
  auto msg = assembleMessage<step::postEvent>(stream_id(sc), eid.run(), eid.luminosityBlock(), eid.event(), t);
  file_.write(std::move(msg));
}

void StallMonitor::postEventReadFromSource ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 524 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                   {
  auto const t = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::postEventReadFromSource>(stream_id(sc), module_id(mcc), t);
  file_.write(std::move(msg));
}

void StallMonitor::postModuleEvent ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 530 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), edm::Event, eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                           {
  auto const postModEvent = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::postModuleEvent>(
      stream_id(sc), module_id(mcc), static_cast<std::underlying_type_t<Phase>>(Phase::Event), postModEvent);
  file_.write(std::move(msg));
}

void StallMonitor::postModuleEventAcquire ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 464 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                  {
  auto const postModEventAcquire = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::postModuleEventAcquire>(stream_id(sc), module_id(mcc), postModEventAcquire);
  file_.write(std::move(msg));
}

void StallMonitor::postModuleEventPrefetching ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 431 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, stallStart_, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                      {
  auto const sid = stream_id(sc);
  auto const mid = module_id(mcc);
  auto start = stallStart_[std::make_pair(sid, mid)] = std::make_pair(now(), false);

  if (validFile_) {
    auto const t = duration_cast<duration_t>(start.first - beginTime_).count();
    auto msg = assembleMessage<step::postModuleEventPrefetching>(sid, mid, t);
    file_.write(std::move(msg));
  }
}

void StallMonitor::postModuleGlobalTransition ( GlobalContext const &  gc, ModuleCallingContext const &  mcc  )

private

Definition at line 512 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, numStreams_, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                      {
  auto const postModTime = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::postModuleEvent>(numStreams_, module_id(mcc), toTransition(gc), postModTime);
  file_.write(std::move(msg));
}

void StallMonitor::postModuleStreamTransition ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 500 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                      {
  auto const t = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::postModuleEvent>(stream_id(sc), module_id(mcc), toTransition(sc), t);
  file_.write(std::move(msg));
}

void StallMonitor::postSourceEvent ( StreamID  sid )

private

Definition at line 418 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, edm::StreamID::value(), and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                     {
  auto const t = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::postSourceEvent>(sid.value(), t);
  file_.write(std::move(msg));
}

void StallMonitor::preEvent ( StreamContext const &  sc )

private

Definition at line 424 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), runTauDisplay::eid, edm::StreamContext::eventID(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                   {
  auto const t = duration_cast<duration_t>(now() - beginTime_).count();
  auto const& eid = sc.eventID();
  auto msg = assembleMessage<step::preEvent>(stream_id(sc), eid.run(), eid.luminosityBlock(), eid.event(), t);
  file_.write(std::move(msg));
}

void StallMonitor::preEventReadFromSource ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 518 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                  {
  auto const t = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::preEventReadFromSource>(stream_id(sc), module_id(mcc), t);
  file_.write(std::move(msg));
}

void StallMonitor::preModuleConstruction ( edm::ModuleDescription const &  md )

private

Definition at line 355 of file StallMonitor.cc.

References edm::ModuleDescription::id(), edm::ModuleDescription::moduleLabel(), and moduleLabels_.

Referenced by StallMonitor().

                                                                    {
  // Module labels are dense, so if the module id is greater than the
  // size of moduleLabels_, grow the vector to the correct index and
  // assign the last entry to the desired label.  Note that with the
  // current implementation, there is no module with ID '0'.  In
  // principle, the module-information vectors are therefore each one
  // entry too large.  However, since removing the entry at the front
  // makes for awkward indexing later on, and since the sizes of these
  // extra entries are on the order of bytes, we will leave them in
  // and skip over them later when printing out summaries.  The
  // extraneous entries can be identified by their module labels being
  // empty.
  auto const mid = md.id();
  if (mid < moduleLabels_.size()) {
    moduleLabels_[mid] = md.moduleLabel();
  } else {
    moduleLabels_.resize(mid + 1);
    moduleLabels_.back() = md.moduleLabel();
  }
}

void StallMonitor::preModuleEvent ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 470 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), edm::Event, moduleStats_, eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, stallStart_, lumiCalc2::startT, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                          {
  auto const preModEvent = now();
  auto const sid = stream_id(sc);
  auto const mid = module_id(mcc);
  auto const& start = stallStart_[std::make_pair(sid, mid)];
  auto startT = start.first.time_since_epoch();
  if (validFile_) {
    auto t = duration_cast<duration_t>(preModEvent - beginTime_).count();
    auto msg =
        assembleMessage<step::preModuleEvent>(sid, mid, static_cast<std::underlying_type_t<Phase>>(Phase::Event), t);
    file_.write(std::move(msg));
  }
  // Check for stalls if prefetch was called and we did not already check before acquire
  if (duration_t::duration::zero() != startT && !start.second) {
    auto const preFetch_to_preModEvent = duration_cast<duration_t>(preModEvent - start.first);
    if (preFetch_to_preModEvent < stallThreshold_)
      return;
    moduleStats_[mid].update(preFetch_to_preModEvent);
  }
}

void StallMonitor::preModuleEventAcquire ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 443 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), moduleStats_, eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, stallStart_, lumiCalc2::startT, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                 {
  auto const preModEventAcquire = now();
  auto const sid = stream_id(sc);
  auto const mid = module_id(mcc);
  auto& start = stallStart_[std::make_pair(sid, mid)];
  auto startT = start.first.time_since_epoch();
  start.second = true;  // record so the preModuleEvent knows that acquire was called
  if (validFile_) {
    auto t = duration_cast<duration_t>(preModEventAcquire - beginTime_).count();
    auto msg = assembleMessage<step::preModuleEventAcquire>(sid, mid, t);
    file_.write(std::move(msg));
  }
  // Check for stalls if prefetch was called
  if (duration_t::duration::zero() != startT) {
    auto const preFetch_to_preModEventAcquire = duration_cast<duration_t>(preModEventAcquire - start.first);
    if (preFetch_to_preModEventAcquire < stallThreshold_)
      return;
    moduleStats_[mid].update(preFetch_to_preModEventAcquire);
  }
}

void StallMonitor::preModuleGlobalTransition ( GlobalContext const &  gc, ModuleCallingContext const &  mcc  )

private

Definition at line 506 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, numStreams_, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                     {
  auto t = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::preModuleEvent>(numStreams_, module_id(mcc), toTransition(gc), t);
  file_.write(std::move(msg));
}

void StallMonitor::preModuleStreamTransition ( StreamContext const &  sc, ModuleCallingContext const &  mcc  )

private

Definition at line 491 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                                                                     {
  auto const tNow = now();
  auto const sid = stream_id(sc);
  auto const mid = module_id(mcc);
  auto t = duration_cast<duration_t>(tNow - beginTime_).count();
  auto msg = assembleMessage<step::preModuleEvent>(sid, mid, toTransition(sc), t);
  file_.write(std::move(msg));
}

void StallMonitor::preSourceEvent ( StreamID  sid )

private

Definition at line 412 of file StallMonitor.cc.

References beginTime_, KineDebug3::count(), eostools::move(), mps_check::msg, cmsPerfSuiteHarvest::now, protons_cff::t, edm::StreamID::value(), and edm::ThreadSafeOutputFileStream::write().

Referenced by StallMonitor().

                                                    {
  auto const t = duration_cast<duration_t>(now() - beginTime_).count();
  auto msg = assembleMessage<step::preSourceEvent>(sid.value(), t);
  file_.write(std::move(msg));
}

Member Data Documentation

decltype(now()) edm::service::StallMonitor::beginTime_ {}

private

Definition at line 221 of file StallMonitor.cc.

Referenced by postBeginJob(), postEvent(), postEventReadFromSource(), postModuleEvent(), postModuleEventAcquire(), postModuleEventPrefetching(), postModuleGlobalTransition(), postModuleStreamTransition(), postSourceEvent(), preEvent(), preEventReadFromSource(), preModuleEvent(), preModuleEventAcquire(), preModuleGlobalTransition(), preModuleStreamTransition(), and preSourceEvent().

ThreadSafeOutputFileStream edm::service::StallMonitor::file_

private

Definition at line 218 of file StallMonitor.cc.

std::vector<std::string> edm::service::StallMonitor::moduleLabels_ {}

private

Definition at line 232 of file StallMonitor.cc.

Referenced by postBeginJob(), and preModuleConstruction().

std::vector<StallStatistics> edm::service::StallMonitor::moduleStats_ {}

private

Definition at line 233 of file StallMonitor.cc.

Referenced by postBeginJob(), postEndJob(), preModuleEvent(), and preModuleEventAcquire().

unsigned int edm::service::StallMonitor::numStreams_

private

Definition at line 234 of file StallMonitor.cc.

Referenced by postModuleGlobalTransition(), preModuleGlobalTransition(), and StallMonitor().

tbb::concurrent_unordered_map<std::pair<StreamID_value, ModuleID>, std::pair<decltype(beginTime_), bool> > edm::service::StallMonitor::stallStart_ {}

private

Definition at line 230 of file StallMonitor.cc.

Referenced by postModuleEventPrefetching(), preModuleEvent(), and preModuleEventAcquire().

duration_t const edm::service::StallMonitor::stallThreshold_

private

Definition at line 220 of file StallMonitor.cc.

bool const edm::service::StallMonitor::validFile_

private

Definition at line 219 of file StallMonitor.cc.