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 &, bool)
void	postEndJob ()
void	postEndLumi (GlobalContext const &gc)
void	postEndRun (GlobalContext const &gc)
void	postEvent (StreamContext const &sc)
void	postOpenFile (std::string const &, bool)
void	preEvent (StreamContext const &sc)

Private Member Functions
void	makeDump (const std::string &format)

Static Private Member Functions
static std::string	replace (const std::string &s, const char *pat, int 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	atPostOpenFile_
std::string	atPreEvent_
void(*	dump_ )(const char *)
int	mineventrecord_
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	(	const ParameterSet &	ps,
		ActivityRegistry &	iRegistry
	)

Definition at line 25 of file IgProfService.cc.

References atPostBeginJob_, atPostBeginLumi_, atPostBeginRun_, atPostCloseFile_, atPostEndJob_, atPostEndLumi_, atPostEndRun_, atPostEvent_, atPostOpenFile_, atPreEvent_, dump_, edm::ParameterSet::getUntrackedParameter(), mineventrecord_, postBeginJob(), postBeginLumi(), postBeginRun(), postCloseFile(), postEndJob(), postEndLumi(), postEndRun(), postEvent(), postOpenFile(), preEvent(), prescale_, 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::watchPostOpenFile(), and edm::ActivityRegistry::watchPreEvent().

    : 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_);

  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);

  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

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

inline

Definition at line 43 of file IgProfService.h.

{ return true; }

void IgProfService::makeDump ( const std::string &  format )

private

Definition at line 125 of file IgProfService.cc.

References dump_, diffTreeTool::format(), nevent_, nfileclosed_, nfileopened_, nlumi_, nrecord_, nrun_, replace(), replaceU64(), and AlCaHLTBitMon_QueryRunRegistry::string.

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

                                                    {
  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_);
  dump_(final.c_str());
}

void IgProfService::postBeginJob

(

)

Definition at line 84 of file IgProfService.cc.

References atPostBeginJob_, and makeDump().

Referenced by IgProfService().

{ makeDump(atPostBeginJob_); }

void IgProfService::postBeginLumi

(

GlobalContext const &

gc

)

Definition at line 91 of file IgProfService.cc.

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

Referenced by IgProfService().

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

void IgProfService::postBeginRun

(

GlobalContext const &

gc

)

Definition at line 86 of file IgProfService.cc.

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

Referenced by IgProfService().

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

void IgProfService::postCloseFile	(	std::string const &	,
		bool
	)

Definition at line 120 of file IgProfService.cc.

References atPostCloseFile_, makeDump(), and nfileclosed_.

Referenced by IgProfService().

                                                         {
  ++nfileclosed_;
  makeDump(atPostCloseFile_);
}

void IgProfService::postEndJob

(

)

Definition at line 113 of file IgProfService.cc.

References atPostEndJob_, and makeDump().

Referenced by IgProfService().

{ makeDump(atPostEndJob_); }

void IgProfService::postEndLumi

(

GlobalContext const &

gc

)

Definition at line 109 of file IgProfService.cc.

References atPostEndLumi_, and makeDump().

Referenced by IgProfService().

{ makeDump(atPostEndLumi_); }

void IgProfService::postEndRun

(

GlobalContext const &

gc

)

Definition at line 111 of file IgProfService.cc.

References atPostEndRun_, and makeDump().

Referenced by IgProfService().

{ makeDump(atPostEndRun_); }

void IgProfService::postEvent

(

StreamContext const &

sc

)

Definition at line 103 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_);
}

void IgProfService::postOpenFile	(	std::string const &	,
		bool
	)

Definition at line 115 of file IgProfService.cc.

References atPostOpenFile_, makeDump(), and nfileopened_.

Referenced by IgProfService().

                                                        {
  ++nfileopened_;
  makeDump(atPostOpenFile_);
}

void IgProfService::preEvent

(

StreamContext const &

sc

)

Definition at line 96 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_);
}

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

staticprivate

Definition at line 139 of file IgProfService.cc.

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

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;
}

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

staticprivate

Definition at line 153 of file IgProfService.cc.

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

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

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

private

Definition at line 52 of file IgProfService.h.

Referenced by IgProfService(), and postBeginJob().

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

private

Definition at line 54 of file IgProfService.h.

Referenced by IgProfService(), and postBeginLumi().

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

private

Definition at line 53 of file IgProfService.h.

Referenced by IgProfService(), and postBeginRun().

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

private

Definition at line 64 of file IgProfService.h.

Referenced by IgProfService(), and postCloseFile().

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

private

Definition at line 61 of file IgProfService.h.

Referenced by IgProfService(), and postEndJob().

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

private

Definition at line 59 of file IgProfService.h.

Referenced by IgProfService(), and postEndLumi().

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

private

Definition at line 60 of file IgProfService.h.

Referenced by IgProfService(), and postEndRun().

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

private

Definition at line 57 of file IgProfService.h.

Referenced by IgProfService(), and postEvent().

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

private

Definition at line 63 of file IgProfService.h.

Referenced by IgProfService(), and postOpenFile().

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

private

Definition at line 56 of file IgProfService.h.

Referenced by IgProfService(), and preEvent().

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

private

Definition at line 50 of file IgProfService.h.

Referenced by IgProfService(), and makeDump().

int edm::service::IgProfService::mineventrecord_

private

Definition at line 66 of file IgProfService.h.

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

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

private

Definition at line 69 of file IgProfService.h.

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

int edm::service::IgProfService::nfileclosed_

private

Definition at line 73 of file IgProfService.h.

Referenced by makeDump(), and postCloseFile().

int edm::service::IgProfService::nfileopened_

private

Definition at line 72 of file IgProfService.h.

Referenced by makeDump(), and postOpenFile().

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

private

Definition at line 71 of file IgProfService.h.

Referenced by makeDump(), and postBeginLumi().

int edm::service::IgProfService::nrecord_

private

Definition at line 68 of file IgProfService.h.

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

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

private

Definition at line 70 of file IgProfService.h.

Referenced by makeDump(), and postBeginRun().

int edm::service::IgProfService::prescale_

private

Definition at line 67 of file IgProfService.h.

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