edm::SystemTimeKeeper Class Reference

#include <SystemTimeKeeper.h>

Classes
struct	ModuleInPathTiming
struct	ModuleTiming
struct	PathTiming

Public Member Functions
void	fillTriggerTimingReport (TriggerTimingReport &rep) const
SystemTimeKeeper &	operator= (const SystemTimeKeeper &)=delete
void	pauseModuleEvent (StreamContext const &, ModuleCallingContext const &)
void	removeModuleIfExists (ModuleDescription const &module)
void	restartModuleEvent (StreamContext const &, ModuleCallingContext const &)
void	startEvent (StreamID)
void	startModuleEvent (StreamContext const &, ModuleCallingContext const &)
void	startPath (StreamContext const &, PathContext const &)
void	startProcessingLoop ()
void	stopEvent (StreamContext const &)
void	stopModuleEvent (StreamContext const &, ModuleCallingContext const &)
void	stopPath (StreamContext const &, PathContext const &, HLTPathStatus const &)
void	stopProcessingLoop ()
	SystemTimeKeeper (unsigned int iNumStreams, std::vector< const ModuleDescription *> const &iModules, service::TriggerNamesService const &iNameService, ProcessContext const *iProcessContext)
	SystemTimeKeeper (const SystemTimeKeeper &)=delete

Private Member Functions
bool	checkBounds (unsigned int id) const
PathTiming &	pathTiming (StreamContext const &, PathContext const &)

Private Attributes
unsigned int	m_endPathOffset
unsigned int	m_minModuleID
std::vector< const ModuleDescription * >	m_modules
std::vector< std::vector< std::string > >	m_modulesOnPaths
std::atomic< unsigned int >	m_numberOfEvents
std::vector< std::string >	m_pathNames
ProcessContext const *	m_processContext
ChildrenCPUTimer	m_processingLoopChildrenTimer
CPUTimer	m_processingLoopTimer
std::vector< WallclockTimer >	m_streamEventTimer
std::vector< std::vector< ModuleTiming > >	m_streamModuleTiming
std::vector< std::vector< PathTiming > >	m_streamPathTiming

Detailed Description

Definition at line 47 of file SystemTimeKeeper.h.

Constructor & Destructor Documentation

SystemTimeKeeper() [1/2]

SystemTimeKeeper::SystemTimeKeeper	(	unsigned int	iNumStreams,
		std::vector< const ModuleDescription *> const &	iModules,
		service::TriggerNamesService const &	iNameService,
		ProcessContext const *	iProcessContext
	)

Definition at line 47 of file SystemTimeKeeper.cc.

References filterCSVwithJSON::copy, edm::service::TriggerNamesService::getEndPathModules(), edm::service::TriggerNamesService::getEndPaths(), edm::service::TriggerNamesService::getTrigPathModules(), edm::service::TriggerNamesService::getTrigPaths(), mps_fire::i, m_endPathOffset, m_minModuleID, m_modules, m_modulesOnPaths, m_pathNames, m_streamModuleTiming, m_streamPathTiming, jetUpdater_cfi::sort, and cms::cuda::stream.

    : m_streamEventTimer(iNumStreams),
      m_streamPathTiming(iNumStreams),
      m_modules(iModules),
      m_processContext(iProcessContext),
      m_minModuleID(0),
      m_numberOfEvents(0) {
  std::sort(m_modules.begin(), m_modules.end(), lessModuleDescription);
  if (not m_modules.empty()) {
    m_minModuleID = m_modules.front()->id();
    unsigned int numModuleSlots = m_modules.back()->id() - m_minModuleID + 1;
    m_streamModuleTiming.resize(iNumStreams);
    for (auto& stream : m_streamModuleTiming) {
      stream.resize(numModuleSlots);
    }
  }

  std::vector<unsigned int> numModulesInPath;
  std::vector<unsigned int> numModulesInEndPath;

  const unsigned int numPaths = iNamesService.getTrigPaths().size();
  const unsigned int numEndPaths = iNamesService.getEndPaths().size();
  m_pathNames.reserve(numPaths + numEndPaths);
  std::copy(iNamesService.getTrigPaths().begin(), iNamesService.getTrigPaths().end(), std::back_inserter(m_pathNames));
  std::copy(iNamesService.getEndPaths().begin(), iNamesService.getEndPaths().end(), std::back_inserter(m_pathNames));

  numModulesInPath.reserve(numPaths);
  numModulesInEndPath.reserve(numEndPaths);

  m_modulesOnPaths.reserve(numPaths + numEndPaths);

  for (unsigned int i = 0; i < numPaths; ++i) {
    numModulesInPath.push_back(iNamesService.getTrigPathModules(i).size());
    m_modulesOnPaths.push_back(iNamesService.getTrigPathModules(i));
  }
  for (unsigned int i = 0; i < numEndPaths; ++i) {
    numModulesInEndPath.push_back(iNamesService.getEndPathModules(i).size());
    m_modulesOnPaths.push_back(iNamesService.getEndPathModules(i));
  }

  m_endPathOffset = numModulesInPath.size();

  for (auto& stream : m_streamPathTiming) {
    unsigned int index = 0;
    stream.resize(numModulesInPath.size() + numModulesInEndPath.size());
    for (unsigned int numMods : numModulesInPath) {
      stream[index].m_moduleTiming.resize(numMods);
      ++index;
    }
    for (unsigned int numMods : numModulesInEndPath) {
      stream[index].m_moduleTiming.resize(numMods);
      ++index;
    }
  }
}

SystemTimeKeeper() [2/2]

edm::SystemTimeKeeper::SystemTimeKeeper ( const SystemTimeKeeper &  )

delete

Member Function Documentation

checkBounds()

bool SystemTimeKeeper::checkBounds ( unsigned int  id ) const

inlineprivate

Definition at line 132 of file SystemTimeKeeper.cc.

References m_minModuleID, and m_streamModuleTiming.

Referenced by pauseModuleEvent(), restartModuleEvent(), startModuleEvent(), and stopModuleEvent().

                                                               {
  return id >= m_minModuleID and id < m_streamModuleTiming.front().size() + m_minModuleID;
}

fillTriggerTimingReport()

void SystemTimeKeeper::fillTriggerTimingReport

(

TriggerTimingReport &

rep

)

const

Definition at line 249 of file SystemTimeKeeper.cc.

References edm::ChildrenCPUTimer::cpuTime(), edm::CPUTimer::cpuTime(), edm::fillPathSummary(), m_endPathOffset, m_minModuleID, m_modules, m_modulesOnPaths, m_numberOfEvents, m_pathNames, m_processingLoopChildrenTimer, m_processingLoopTimer, m_streamEventTimer, m_streamModuleTiming, m_streamPathTiming, mod(), gpuClustering::moduleId, castor_dqm_sourceclient_file_cfg::path, edm::CPUTimer::realTime(), cuy::rep, findQualityFiles::size, edm::sort_all(), cms::cuda::stream, edmLumisInFiles::summary, ecalMatacq_cfi::timing, and class-composition::visited.

                                                                             {
  {
    rep.eventSummary.totalEvents = m_numberOfEvents;
    double sumEventTime = 0.;
    for (auto const& stream : m_streamEventTimer) {
      sumEventTime += stream.realTime();
    }
    rep.eventSummary.realTime = m_processingLoopTimer.realTime();
    rep.eventSummary.cpuTime = m_processingLoopTimer.cpuTime() + m_processingLoopChildrenTimer.cpuTime();
    rep.eventSummary.sumStreamRealTime = sumEventTime;
  }

  //Per module summary
  {
    auto& summary = rep.workerSummaries;
    summary.resize(m_modules.size());
    //Figure out how often a module was visited
    std::map<std::string, unsigned int> visited;
    for (auto const& stream : m_streamPathTiming) {
      unsigned int pathIndex = 0;
      for (auto const& path : stream) {
        unsigned int modIndex = 0;
        for (auto const& mod : path.m_moduleTiming) {
          visited[m_modulesOnPaths[pathIndex][modIndex]] += mod.m_timesVisited;
          ++modIndex;
        }
        ++pathIndex;
      }
    }

    unsigned int modIndex = 0;
    for (auto const& mod : m_modules) {
      auto& outMod = summary[modIndex];
      outMod.moduleLabel = mod->moduleLabel();
      outMod.realTime = 0.;

      auto moduleId = mod->id() - m_minModuleID;
      for (auto const& stream : m_streamModuleTiming) {
        auto const& timing = stream[moduleId];
        outMod.realTime += timing.m_timer.realTime();
        outMod.timesRun += timing.m_timesRun;
      }
      outMod.timesVisited = visited[mod->moduleLabel()];
      if (0 == outMod.timesVisited) {
        outMod.timesVisited = outMod.timesRun;
      }
      ++modIndex;
    }
  }
  sort_all(rep.workerSummaries);

  //Per path summary
  {
    fillPathSummary(0, m_endPathOffset, m_pathNames, m_modulesOnPaths, m_streamPathTiming, rep.trigPathSummaries);
    fillPathSummary(m_endPathOffset,
                    m_streamPathTiming[0].size(),
                    m_pathNames,
                    m_modulesOnPaths,
                    m_streamPathTiming,
                    rep.endPathSummaries);
  }
}

operator=()

SystemTimeKeeper& edm::SystemTimeKeeper::operator= ( const SystemTimeKeeper &  )

delete

pathTiming()

SystemTimeKeeper::PathTiming & SystemTimeKeeper::pathTiming ( StreamContext const &  iStream, PathContext const &  iPath  )

private

Definition at line 118 of file SystemTimeKeeper.cc.

References cms::cuda::assert(), edm::PathContext::isEndPath(), m_endPathOffset, m_streamPathTiming, hltrates_dqm_sourceclient-live_cfg::offset, edm::PathContext::pathID(), edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by pauseModuleEvent(), startPath(), stopModuleEvent(), and stopPath().

                                                                                                               {
  unsigned int offset = 0;
  if (iPath.isEndPath()) {
    offset = m_endPathOffset;
  }
  assert(iPath.pathID() + offset < m_streamPathTiming[iStream.streamID().value()].size());
  return m_streamPathTiming[iStream.streamID().value()][iPath.pathID() + offset];
}

pauseModuleEvent()

void SystemTimeKeeper::pauseModuleEvent	(	StreamContext const &	iStream,
		ModuleCallingContext const &	iModule
	)

Definition at line 185 of file SystemTimeKeeper.cc.

References checkBounds(), edm::ModuleDescription::id(), edm::ParentContext::kPlaceInPath, m_minModuleID, edm::SystemTimeKeeper::PathTiming::m_moduleTiming, m_streamModuleTiming, mod(), edm::ModuleCallingContext::moduleDescription(), pathTiming(), edm::ModuleCallingContext::placeInPathContext(), edm::StreamContext::streamID(), edm::ModuleCallingContext::type(), and edm::StreamID::value().

                                                                                                         {
  if (checkBounds(iModule.moduleDescription()->id())) {
    auto& mod = m_streamModuleTiming[iStream.streamID().value()][iModule.moduleDescription()->id() - m_minModuleID];
    auto times = mod.m_timer.stop();

    if (iModule.type() == ParentContext::Type::kPlaceInPath) {
      auto place = iModule.placeInPathContext();

      auto& modTiming = pathTiming(iStream, *(place->pathContext())).m_moduleTiming[place->placeInPath()];
      modTiming.m_realTime += times;
    }
  }
}

removeModuleIfExists()

void SystemTimeKeeper::removeModuleIfExists

(

ModuleDescription const &

module

)

Definition at line 109 of file SystemTimeKeeper.cc.

References newFWLiteAna::found, pfDeepBoostedJetPreprocessParams_cfi::lower_bound, m_modules, and callgraph::module.

                                                                           {
  // The deletion of a module is signaled to all (Sub)Processes, even
  // though the module exists in only one of them.
  auto found = std::lower_bound(m_modules.begin(), m_modules.end(), &module, lessModuleDescription);
  if (*found == &module) {
    m_modules.erase(found);
  }
}

restartModuleEvent()

void SystemTimeKeeper::restartModuleEvent	(	StreamContext const &	iStream,
		ModuleCallingContext const &	iModule
	)

Definition at line 198 of file SystemTimeKeeper.cc.

References checkBounds(), edm::ModuleDescription::id(), m_minModuleID, m_streamModuleTiming, mod(), edm::ModuleCallingContext::moduleDescription(), edm::StreamContext::streamID(), and edm::StreamID::value().

                                                                                                           {
  if (checkBounds(iModule.moduleDescription()->id())) {
    auto& mod = m_streamModuleTiming[iStream.streamID().value()][iModule.moduleDescription()->id() - m_minModuleID];
    mod.m_timer.start();
  }
}

startEvent()

void SystemTimeKeeper::startEvent

(

StreamID

iID

)

Definition at line 136 of file SystemTimeKeeper.cc.

References m_numberOfEvents, m_streamEventTimer, and edm::StreamID::value().

                                              {
  m_numberOfEvents++;
  m_streamEventTimer[iID.value()].start();
}

startModuleEvent()

void SystemTimeKeeper::startModuleEvent	(	StreamContext const &	iStream,
		ModuleCallingContext const &	iModule
	)

Definition at line 165 of file SystemTimeKeeper.cc.

References checkBounds(), edm::ModuleDescription::id(), m_minModuleID, m_streamModuleTiming, mod(), edm::ModuleCallingContext::moduleDescription(), edm::StreamContext::streamID(), and edm::StreamID::value().

                                                                                                         {
  if (checkBounds(iModule.moduleDescription()->id())) {
    auto& mod = m_streamModuleTiming[iStream.streamID().value()][iModule.moduleDescription()->id() - m_minModuleID];
    mod.m_timer.start();
    ++(mod.m_timesRun);
  }
}

startPath()

void SystemTimeKeeper::startPath	(	StreamContext const &	iStream,
		PathContext const &	iPath
	)

Definition at line 145 of file SystemTimeKeeper.cc.

References m_processContext, pathTiming(), edm::StreamContext::processContext(), and ecalMatacq_cfi::timing.

                                                                                       {
  if (m_processContext == iStream.processContext()) {
    auto& timing = pathTiming(iStream, iPath);
    timing.m_timer.start();
  }
}

startProcessingLoop()

void SystemTimeKeeper::startProcessingLoop

(

)

Definition at line 205 of file SystemTimeKeeper.cc.

References m_processingLoopChildrenTimer, m_processingLoopTimer, edm::ChildrenCPUTimer::start(), and edm::CPUTimer::start().

                                           {
  m_processingLoopTimer.start();
  m_processingLoopChildrenTimer.start();
}

stopEvent()

void SystemTimeKeeper::stopEvent

(

StreamContext const &

iContext

)

Definition at line 141 of file SystemTimeKeeper.cc.

References m_streamEventTimer, edm::StreamContext::streamID(), and edm::StreamID::value().

                                                              {
  m_streamEventTimer[iContext.streamID().value()].stop();
}

stopModuleEvent()

void SystemTimeKeeper::stopModuleEvent	(	StreamContext const &	iStream,
		ModuleCallingContext const &	iModule
	)

Definition at line 172 of file SystemTimeKeeper.cc.

References checkBounds(), edm::ModuleDescription::id(), edm::ParentContext::kPlaceInPath, m_minModuleID, edm::SystemTimeKeeper::PathTiming::m_moduleTiming, m_streamModuleTiming, mod(), edm::ModuleCallingContext::moduleDescription(), pathTiming(), edm::ModuleCallingContext::placeInPathContext(), edm::StreamContext::streamID(), edm::ModuleCallingContext::type(), and edm::StreamID::value().

                                                                                                        {
  if (checkBounds(iModule.moduleDescription()->id())) {
    auto& mod = m_streamModuleTiming[iStream.streamID().value()][iModule.moduleDescription()->id() - m_minModuleID];
    auto times = mod.m_timer.stop();

    if (iModule.type() == ParentContext::Type::kPlaceInPath) {
      auto place = iModule.placeInPathContext();

      auto& modTiming = pathTiming(iStream, *(place->pathContext())).m_moduleTiming[place->placeInPath()];
      modTiming.m_realTime += times;
    }
  }
}

stopPath()

void SystemTimeKeeper::stopPath	(	StreamContext const &	iStream,
		PathContext const &	iPath,
		HLTPathStatus const &	iStatus
	)

Definition at line 152 of file SystemTimeKeeper.cc.

References mps_fire::i, edm::HLTPathStatus::index(), m_processContext, pathTiming(), edm::StreamContext::processContext(), and ecalMatacq_cfi::timing.

                                                                                                                    {
  if (m_processContext == iStream.processContext()) {
    auto& timing = pathTiming(iStream, iPath);
    timing.m_timer.stop();

    //mark all modules up to and including the decision module as being visited
    auto& modsOnPath = timing.m_moduleTiming;
    for (unsigned int i = 0; i < iStatus.index() + 1; ++i) {
      ++modsOnPath[i].m_timesVisited;
    }
  }
}

stopProcessingLoop()

void SystemTimeKeeper::stopProcessingLoop

(

)

Definition at line 210 of file SystemTimeKeeper.cc.

References m_processingLoopChildrenTimer, m_processingLoopTimer, edm::ChildrenCPUTimer::stop(), and edm::CPUTimer::stop().

                                          {
  m_processingLoopTimer.stop();
  m_processingLoopChildrenTimer.stop();
}

Member Data Documentation

m_endPathOffset

unsigned int edm::SystemTimeKeeper::m_endPathOffset

private

Definition at line 114 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), pathTiming(), and SystemTimeKeeper().

m_minModuleID

unsigned int edm::SystemTimeKeeper::m_minModuleID

private

Definition at line 113 of file SystemTimeKeeper.h.

Referenced by checkBounds(), fillTriggerTimingReport(), pauseModuleEvent(), restartModuleEvent(), startModuleEvent(), stopModuleEvent(), and SystemTimeKeeper().

m_modules

std::vector<const ModuleDescription*> edm::SystemTimeKeeper::m_modules

private

Definition at line 105 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), removeModuleIfExists(), and SystemTimeKeeper().

m_modulesOnPaths

std::vector<std::vector<std::string> > edm::SystemTimeKeeper::m_modulesOnPaths

private

Definition at line 107 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), and SystemTimeKeeper().

m_numberOfEvents

std::atomic<unsigned int> edm::SystemTimeKeeper::m_numberOfEvents

private

Definition at line 115 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), and startEvent().

m_pathNames

std::vector<std::string> edm::SystemTimeKeeper::m_pathNames

private

Definition at line 106 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), and SystemTimeKeeper().

m_processContext

ProcessContext const* edm::SystemTimeKeeper::m_processContext

private

Definition at line 111 of file SystemTimeKeeper.h.

Referenced by startPath(), and stopPath().

m_processingLoopChildrenTimer

ChildrenCPUTimer edm::SystemTimeKeeper::m_processingLoopChildrenTimer

private

Definition at line 110 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), startProcessingLoop(), and stopProcessingLoop().

m_processingLoopTimer

CPUTimer edm::SystemTimeKeeper::m_processingLoopTimer

private

Definition at line 109 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), startProcessingLoop(), and stopProcessingLoop().

m_streamEventTimer

std::vector<WallclockTimer> edm::SystemTimeKeeper::m_streamEventTimer

private

Definition at line 99 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), startEvent(), and stopEvent().

m_streamModuleTiming

std::vector<std::vector<ModuleTiming> > edm::SystemTimeKeeper::m_streamModuleTiming

private

Definition at line 103 of file SystemTimeKeeper.h.

Referenced by checkBounds(), fillTriggerTimingReport(), pauseModuleEvent(), restartModuleEvent(), startModuleEvent(), stopModuleEvent(), and SystemTimeKeeper().

m_streamPathTiming

std::vector<std::vector<PathTiming> > edm::SystemTimeKeeper::m_streamPathTiming

private

Definition at line 101 of file SystemTimeKeeper.h.

Referenced by fillTriggerTimingReport(), pathTiming(), and SystemTimeKeeper().