edm::service::IgProfService Class Reference

#include <IgProfService.h>

Public Member Functions
	IgProfService (const ParameterSet &, ActivityRegistry &)
bool	isProcessWideService (IgProfService const *)
void	postBeginJob ()
void	postBeginLumi (GlobalContext const &gc)
void	postBeginRun (GlobalContext const &gc)
void	postCloseFile (std::string const &)
void	postEndJob ()
void	postEndLumi (GlobalContext const &gc)
void	postEndRun (GlobalContext const &gc)
void	postEvent (StreamContext const &sc)
void	postModuleEvent (StreamContext const &sc, ModuleCallingContext const &mcc)
void	postOpenFile (std::string const &)
void	preEvent (StreamContext const &sc)
void	preModuleEvent (StreamContext const &sc, ModuleCallingContext const &mcc)

Private Member Functions
void	makeDump (const std::string &format, std::string_view moduleLabel="")

Static Private Member Functions
static std::string	replace (const std::string &s, const char *pat, int val)
static std::string	replace (const std::string &s, const char *pat, std::string_view val)
static std::string	replaceU64 (const std::string &s, const char *pat, unsigned long long val)

Private Attributes
std::string	atPostBeginJob_
std::string	atPostBeginLumi_
std::string	atPostBeginRun_
std::string	atPostCloseFile_
std::string	atPostEndJob_
std::string	atPostEndLumi_
std::string	atPostEndRun_
std::string	atPostEvent_
std::string	atPostModuleEvent_
std::string	atPostOpenFile_
std::string	atPreEvent_
std::string	atPreModuleEvent_
void(*	dump_ )(const char *)
int	mineventrecord_
std::vector< std::string >	modules_
std::vector< std::string >	moduleTypes_
edm::EventNumber_t	nevent_
int	nfileclosed_
int	nfileopened_
edm::LuminosityBlockNumber_t	nlumi_
int	nrecord_
edm::RunNumber_t	nrun_
int	prescale_

Detailed Description

Definition at line 20 of file IgProfService.h.

Constructor & Destructor Documentation

IgProfService()

IgProfService::IgProfService	(	const ParameterSet &	ps,
		ActivityRegistry &	iRegistry
	)

Definition at line 25 of file IgProfService.cc.

References atPostBeginJob_, atPostBeginLumi_, atPostBeginRun_, atPostCloseFile_, atPostEndJob_, atPostEndLumi_, atPostEndRun_, atPostEvent_, atPostModuleEvent_, atPostOpenFile_, atPreEvent_, atPreModuleEvent_, dump_, edm::ParameterSet::getUntrackedParameter(), mineventrecord_, modules_, moduleTypes_, or, postBeginJob(), postBeginLumi(), postBeginRun(), postCloseFile(), postEndJob(), postEndLumi(), postEndRun(), postEvent(), postModuleEvent(), postOpenFile(), preEvent(), preModuleEvent(), prescale_, jetUpdater_cfi::sort, AlCaHLTBitMon_QueryRunRegistry::string, edm::ActivityRegistry::watchPostBeginJob(), edm::ActivityRegistry::watchPostCloseFile(), edm::ActivityRegistry::watchPostEndJob(), edm::ActivityRegistry::watchPostEvent(), edm::ActivityRegistry::watchPostGlobalBeginLumi(), edm::ActivityRegistry::watchPostGlobalBeginRun(), edm::ActivityRegistry::watchPostGlobalEndLumi(), edm::ActivityRegistry::watchPostGlobalEndRun(), edm::ActivityRegistry::watchPostModuleEvent(), edm::ActivityRegistry::watchPostOpenFile(), edm::ActivityRegistry::watchPreEvent(), and edm::ActivityRegistry::watchPreModuleEvent().

    : dump_(nullptr),
      mineventrecord_(1),
      prescale_(1),
      nrecord_(0),
      nevent_(0),
      nrun_(0),
      nlumi_(0),
      nfileopened_(0),
      nfileclosed_(0) {
  // Removing the __extension__ gives a warning which
  // is acknowledged as a language problem in the C++ Standard Core
  // Language Defect Report
  //
  // http://www.open-std.org/jtc1/sc22/wg21/docs/cwg_defects.html#195
  //
  // since the suggested decision seems to be that the syntax should
  // actually be "Conditionally-Supported Behavior" in some
  // future C++ standard I simply silence the warning.
  if (void *sym = dlsym(nullptr, "igprof_dump_now")) {
    dump_ = __extension__(void (*)(const char *)) sym;
  } else
    edm::LogWarning("IgProfModule") << "IgProfModule requested but application is not"
                                    << " currently being profiled with igprof\n";

  // Get the configuration
  prescale_ = ps.getUntrackedParameter<int>("reportEventInterval", prescale_);
  mineventrecord_ = ps.getUntrackedParameter<int>("reportFirstEvent", mineventrecord_);

  atPostBeginJob_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostBeginJob", atPostBeginJob_);
  atPostBeginRun_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostBeginRun", atPostBeginRun_);
  atPostBeginLumi_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostBeginLumi", atPostBeginLumi_);

  atPreEvent_ = ps.getUntrackedParameter<std::string>("reportToFileAtPreEvent", atPreEvent_);
  atPostEvent_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostEvent", atPostEvent_);

  modules_ = ps.getUntrackedParameter<std::vector<std::string>>("reportModules", modules_);
  moduleTypes_ = ps.getUntrackedParameter<std::vector<std::string>>("reportModuleTypes", moduleTypes_);
  std::sort(modules_.begin(), modules_.end());
  std::sort(moduleTypes_.begin(), moduleTypes_.end());
  atPreModuleEvent_ = ps.getUntrackedParameter<std::string>("reportToFileAtPreModuleEvent", atPreModuleEvent_);
  atPostModuleEvent_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostModuleEvent", atPostModuleEvent_);

  atPostEndLumi_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostEndLumi", atPostEndLumi_);
  atPostEndRun_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostEndRun", atPostEndRun_);
  atPostEndJob_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostEndJob", atPostEndJob_);

  atPostOpenFile_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostOpenFile", atPostOpenFile_);
  atPostCloseFile_ = ps.getUntrackedParameter<std::string>("reportToFileAtPostCloseFile", atPostCloseFile_);

  // Register for the framework signals
  iRegistry.watchPostBeginJob(this, &IgProfService::postBeginJob);
  iRegistry.watchPostGlobalBeginRun(this, &IgProfService::postBeginRun);
  iRegistry.watchPostGlobalBeginLumi(this, &IgProfService::postBeginLumi);

  iRegistry.watchPreEvent(this, &IgProfService::preEvent);
  iRegistry.watchPostEvent(this, &IgProfService::postEvent);

  if (not modules_.empty() or not moduleTypes_.empty()) {
    iRegistry.watchPreModuleEvent(this, &IgProfService::preModuleEvent);
    iRegistry.watchPostModuleEvent(this, &IgProfService::postModuleEvent);
  }

  iRegistry.watchPostGlobalEndLumi(this, &IgProfService::postEndLumi);
  iRegistry.watchPostGlobalEndRun(this, &IgProfService::postEndRun);
  iRegistry.watchPostEndJob(this, &IgProfService::postEndJob);

  iRegistry.watchPostOpenFile(this, &IgProfService::postOpenFile);
  iRegistry.watchPostCloseFile(this, &IgProfService::postCloseFile);
}

Member Function Documentation

isProcessWideService()

bool edm::service::IgProfService::isProcessWideService ( IgProfService const *  )

inline

Definition at line 46 of file IgProfService.h.

{ return true; }

makeDump()

void IgProfService::makeDump ( const std::string &  format, std::string_view  moduleLabel = ""  )

private

Definition at line 167 of file IgProfService.cc.

References dump_, dqm-mbProfile::format, HerwigMaxPtPartonFilter_cfi::moduleLabel, nevent_, nfileclosed_, nfileopened_, nlumi_, nrecord_, nrun_, replace(), replaceU64(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by postBeginJob(), postBeginLumi(), postBeginRun(), postCloseFile(), postEndJob(), postEndLumi(), postEndRun(), postEvent(), postModuleEvent(), postOpenFile(), preEvent(), and preModuleEvent().

                                                                                {
  if (!dump_ || format.empty())
    return;

  std::string final(format);
  final = replace(final, "%I", nrecord_);
  final = replaceU64(final, "%E", nevent_);
  final = replaceU64(final, "%R", nrun_);
  final = replaceU64(final, "%L", nlumi_);
  final = replace(final, "%F", nfileopened_);
  final = replace(final, "%C", nfileclosed_);
  final = replace(final, "%M", moduleLabel);
  dump_(final.c_str());
}

postBeginJob()

void IgProfService::postBeginJob

(

)

Definition at line 96 of file IgProfService.cc.

References atPostBeginJob_, and makeDump().

Referenced by IgProfService().

{ makeDump(atPostBeginJob_); }

postBeginLumi()

void IgProfService::postBeginLumi

(

GlobalContext const &

gc

)

Definition at line 103 of file IgProfService.cc.

References atPostBeginLumi_, edm::LuminosityBlockID::luminosityBlock(), edm::GlobalContext::luminosityBlockID(), makeDump(), and nlumi_.

Referenced by IgProfService().

                                                         {
  nlumi_ = gc.luminosityBlockID().luminosityBlock();
  makeDump(atPostBeginLumi_);
}

postBeginRun()

void IgProfService::postBeginRun

(

GlobalContext const &

gc

)

Definition at line 98 of file IgProfService.cc.

References atPostBeginRun_, edm::GlobalContext::luminosityBlockID(), makeDump(), nrun_, and edm::LuminosityBlockID::run().

Referenced by IgProfService().

                                                        {
  nrun_ = gc.luminosityBlockID().run();
  makeDump(atPostBeginRun_);
}

postCloseFile()

void IgProfService::postCloseFile

(

std::string const &

)

Definition at line 162 of file IgProfService.cc.

References atPostCloseFile_, makeDump(), and nfileclosed_.

Referenced by IgProfService().

                                                   {
  ++nfileclosed_;
  makeDump(atPostCloseFile_);
}

postEndJob()

void IgProfService::postEndJob

(

)

Definition at line 155 of file IgProfService.cc.

References atPostEndJob_, and makeDump().

Referenced by IgProfService().

{ makeDump(atPostEndJob_); }

postEndLumi()

void IgProfService::postEndLumi

(

GlobalContext const &

gc

)

Definition at line 145 of file IgProfService.cc.

References atPostEndLumi_, edm::LuminosityBlockID::luminosityBlock(), edm::GlobalContext::luminosityBlockID(), makeDump(), and nlumi_.

Referenced by IgProfService().

                                                       {
  nlumi_ = gc.luminosityBlockID().luminosityBlock();
  makeDump(atPostEndLumi_);
}

postEndRun()

void IgProfService::postEndRun

(

GlobalContext const &

gc

)

Definition at line 150 of file IgProfService.cc.

References atPostEndRun_, edm::GlobalContext::luminosityBlockID(), makeDump(), nrun_, and edm::LuminosityBlockID::run().

Referenced by IgProfService().

                                                      {
  nrun_ = gc.luminosityBlockID().run();
  makeDump(atPostEndRun_);
}

postEvent()

void IgProfService::postEvent

(

StreamContext const &

sc

)

Definition at line 115 of file IgProfService.cc.

References atPostEvent_, edm::EventID::event(), edm::StreamContext::eventID(), makeDump(), mineventrecord_, nevent_, nrecord_, and prescale_.

Referenced by IgProfService().

                                                          {
  nevent_ = iStream.eventID().event();
  if ((prescale_ > 0) && (nrecord_ >= mineventrecord_) && (((nrecord_ - mineventrecord_) % prescale_) == 0))
    makeDump(atPostEvent_);
}

postModuleEvent()

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

Definition at line 133 of file IgProfService.cc.

References atPostModuleEvent_, edm::EventID::event(), edm::StreamContext::eventID(), makeDump(), mineventrecord_, edm::ModuleCallingContext::moduleDescription(), HerwigMaxPtPartonFilter_cfi::moduleLabel, edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), modules_, moduleTypes_, nevent_, nrecord_, or, and prescale_.

Referenced by IgProfService().

                                                                                                 {
  nevent_ = iStream.eventID().event();
  if ((prescale_ > 0) && (nrecord_ >= mineventrecord_) && (((nrecord_ - mineventrecord_) % prescale_) == 0)) {
    auto const &moduleLabel = mcc.moduleDescription()->moduleLabel();
    auto const &moduleType = mcc.moduleDescription()->moduleName();
    if (std::binary_search(modules_.begin(), modules_.end(), moduleLabel) or
        std::binary_search(moduleTypes_.begin(), moduleTypes_.end(), moduleType)) {
      makeDump(atPostModuleEvent_, moduleLabel);
    }
  }
}

postOpenFile()

void IgProfService::postOpenFile

(

std::string const &

)

Definition at line 157 of file IgProfService.cc.

References atPostOpenFile_, makeDump(), and nfileopened_.

Referenced by IgProfService().

                                                  {
  ++nfileopened_;
  makeDump(atPostOpenFile_);
}

preEvent()

void IgProfService::preEvent

(

StreamContext const &

sc

)

Definition at line 108 of file IgProfService.cc.

References atPreEvent_, edm::EventID::event(), edm::StreamContext::eventID(), makeDump(), mineventrecord_, nevent_, nrecord_, and prescale_.

Referenced by IgProfService().

                                                         {
  ++nrecord_;  // count before events
  nevent_ = iStream.eventID().event();
  if ((prescale_ > 0) && (nrecord_ >= mineventrecord_) && (((nrecord_ - mineventrecord_) % prescale_) == 0))
    makeDump(atPreEvent_);
}

preModuleEvent()

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

Definition at line 121 of file IgProfService.cc.

References atPreModuleEvent_, edm::EventID::event(), edm::StreamContext::eventID(), makeDump(), mineventrecord_, edm::ModuleCallingContext::moduleDescription(), HerwigMaxPtPartonFilter_cfi::moduleLabel, edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), modules_, moduleTypes_, nevent_, nrecord_, or, and prescale_.

Referenced by IgProfService().

                                                                                                {
  nevent_ = iStream.eventID().event();
  if ((prescale_ > 0) && (nrecord_ >= mineventrecord_) && (((nrecord_ - mineventrecord_) % prescale_) == 0)) {
    auto const &moduleLabel = mcc.moduleDescription()->moduleLabel();
    auto const &moduleType = mcc.moduleDescription()->moduleName();
    if (std::binary_search(modules_.begin(), modules_.end(), moduleLabel) or
        std::binary_search(moduleTypes_.begin(), moduleTypes_.end(), moduleType)) {
      makeDump(atPreModuleEvent_, moduleLabel);
    }
  }
}

replace() [1/2]

std::string IgProfService::replace ( const std::string &  s, const char *  pat, int  val  )

staticprivate

Definition at line 182 of file IgProfService.cc.

References visDQMUpload::buf, dqmiodumpmetadata::n, mps_fire::result, alignCSCRings::s, AlCaHLTBitMon_QueryRunRegistry::string, and heppy_batch::val.

Referenced by makeDump().

                                                                             {
  size_t pos = 0;
  size_t patlen = strlen(pat);
  std::string result = s;
  while ((pos = result.find(pat, pos)) != std::string::npos) {
    char buf[64];
    int n = sprintf(buf, "%d", val);
    result.replace(pos, patlen, buf);
    pos = pos - patlen + n;
  }

  return result;
}

replace() [2/2]

std::string IgProfService::replace ( const std::string &  s, const char *  pat, std::string_view  val  )

staticprivate

Definition at line 210 of file IgProfService.cc.

References mps_fire::result, alignCSCRings::s, AlCaHLTBitMon_QueryRunRegistry::string, and heppy_batch::val.

                                                                                        {
  size_t pos = 0;
  size_t patlen = strlen(pat);
  std::string result = s;
  while ((pos = result.find(pat, pos)) != std::string::npos) {
    result.replace(pos, patlen, val.data());
    pos = pos - patlen + val.size();
  }

  return result;
}

replaceU64()

std::string IgProfService::replaceU64 ( const std::string &  s, const char *  pat, unsigned long long  val  )

staticprivate

Definition at line 196 of file IgProfService.cc.

References visDQMUpload::buf, dqmiodumpmetadata::n, mps_fire::result, alignCSCRings::s, AlCaHLTBitMon_QueryRunRegistry::string, and heppy_batch::val.

Referenced by makeDump().

                                                                                               {
  size_t pos = 0;
  size_t patlen = strlen(pat);
  std::string result = s;
  while ((pos = result.find(pat, pos)) != std::string::npos) {
    char buf[64];
    int n = sprintf(buf, "%llu", val);
    result.replace(pos, patlen, buf);
    pos = pos - patlen + n;
  }

  return result;
}

Member Data Documentation

atPostBeginJob_

std::string edm::service::IgProfService::atPostBeginJob_

private

Definition at line 56 of file IgProfService.h.

Referenced by IgProfService(), and postBeginJob().

atPostBeginLumi_

std::string edm::service::IgProfService::atPostBeginLumi_

private

Definition at line 58 of file IgProfService.h.

Referenced by IgProfService(), and postBeginLumi().

atPostBeginRun_

std::string edm::service::IgProfService::atPostBeginRun_

private

Definition at line 57 of file IgProfService.h.

Referenced by IgProfService(), and postBeginRun().

atPostCloseFile_

std::string edm::service::IgProfService::atPostCloseFile_

private

Definition at line 73 of file IgProfService.h.

Referenced by IgProfService(), and postCloseFile().

atPostEndJob_

std::string edm::service::IgProfService::atPostEndJob_

private

Definition at line 70 of file IgProfService.h.

Referenced by IgProfService(), and postEndJob().

atPostEndLumi_

std::string edm::service::IgProfService::atPostEndLumi_

private

Definition at line 68 of file IgProfService.h.

Referenced by IgProfService(), and postEndLumi().

atPostEndRun_

std::string edm::service::IgProfService::atPostEndRun_

private

Definition at line 69 of file IgProfService.h.

Referenced by IgProfService(), and postEndRun().

atPostEvent_

std::string edm::service::IgProfService::atPostEvent_

private

Definition at line 61 of file IgProfService.h.

Referenced by IgProfService(), and postEvent().

atPostModuleEvent_

std::string edm::service::IgProfService::atPostModuleEvent_

private

Definition at line 66 of file IgProfService.h.

Referenced by IgProfService(), and postModuleEvent().

atPostOpenFile_

std::string edm::service::IgProfService::atPostOpenFile_

private

Definition at line 72 of file IgProfService.h.

Referenced by IgProfService(), and postOpenFile().

atPreEvent_

std::string edm::service::IgProfService::atPreEvent_

private

Definition at line 60 of file IgProfService.h.

Referenced by IgProfService(), and preEvent().

atPreModuleEvent_

std::string edm::service::IgProfService::atPreModuleEvent_

private

Definition at line 65 of file IgProfService.h.

Referenced by IgProfService(), and preModuleEvent().

dump_

void(* edm::service::IgProfService::dump_) (const char *)

private

Definition at line 54 of file IgProfService.h.

Referenced by IgProfService(), and makeDump().

mineventrecord_

int edm::service::IgProfService::mineventrecord_

private

Definition at line 75 of file IgProfService.h.

Referenced by IgProfService(), postEvent(), postModuleEvent(), preEvent(), and preModuleEvent().

modules_

std::vector<std::string> edm::service::IgProfService::modules_

private

Definition at line 63 of file IgProfService.h.

Referenced by IgProfService(), postModuleEvent(), and preModuleEvent().

moduleTypes_

std::vector<std::string> edm::service::IgProfService::moduleTypes_

private

Definition at line 64 of file IgProfService.h.

Referenced by IgProfService(), postModuleEvent(), and preModuleEvent().

nevent_

edm::EventNumber_t edm::service::IgProfService::nevent_

private

Definition at line 78 of file IgProfService.h.

Referenced by makeDump(), postEvent(), postModuleEvent(), preEvent(), and preModuleEvent().

nfileclosed_

int edm::service::IgProfService::nfileclosed_

private

Definition at line 82 of file IgProfService.h.

Referenced by makeDump(), and postCloseFile().

nfileopened_

int edm::service::IgProfService::nfileopened_

private

Definition at line 81 of file IgProfService.h.

Referenced by makeDump(), and postOpenFile().

nlumi_

edm::LuminosityBlockNumber_t edm::service::IgProfService::nlumi_

private

Definition at line 80 of file IgProfService.h.

Referenced by makeDump(), postBeginLumi(), and postEndLumi().

nrecord_

int edm::service::IgProfService::nrecord_

private

Definition at line 77 of file IgProfService.h.

Referenced by makeDump(), postEvent(), postModuleEvent(), preEvent(), and preModuleEvent().

nrun_

edm::RunNumber_t edm::service::IgProfService::nrun_

private

Definition at line 79 of file IgProfService.h.

Referenced by makeDump(), postBeginRun(), and postEndRun().

prescale_

int edm::service::IgProfService::prescale_

private

Definition at line 76 of file IgProfService.h.

Referenced by IgProfService(), postEvent(), postModuleEvent(), preEvent(), and preModuleEvent().