#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 &	,
		ActivityRegistry &
	)

Definition at line 25 of file IgProfService.cc.

   : 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 46 of file IgProfService.h.

References makeDump(), replace(), replaceU64(), alignCSCRings::s, AlCaHLTBitMon_QueryRunRegistry::string, and heppy_batch::val.

                                                       {
         return true;
       }

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

private

Definition at line 151 of file IgProfService.cc.

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

Referenced by isProcessWideService(), 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 102 of file IgProfService.cc.

References atPostBeginJob_, and makeDump().

Referenced by IgProfService().

                                  { 
   makeDump(atPostBeginJob_); 
 }

void IgProfService::postBeginLumi ( GlobalContext const & gc )

Definition at line 110 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 106 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 146 of file IgProfService.cc.

References atPostCloseFile_, makeDump(), and nfileclosed_.

Referenced by IgProfService().

                                                          {
   ++nfileclosed_; 
   makeDump(atPostCloseFile_);
 }  

void IgProfService::postEndJob ( )

Definition at line 137 of file IgProfService.cc.

References atPostEndJob_, and makeDump().

Referenced by IgProfService().

                                { 
   makeDump(atPostEndJob_); 
 }

void IgProfService::postEndLumi ( GlobalContext const & gc )

Definition at line 129 of file IgProfService.cc.

References atPostEndLumi_, and makeDump().

Referenced by IgProfService().

                                                      { 
   makeDump(atPostEndLumi_); 
 }

void IgProfService::postEndRun ( GlobalContext const & gc )

Definition at line 133 of file IgProfService.cc.

References atPostEndRun_, and makeDump().

Referenced by IgProfService().

                                                     { 
   makeDump(atPostEndRun_); 
 }

void IgProfService::postEvent ( StreamContext const & sc )

Definition at line 122 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 141 of file IgProfService.cc.

References atPostOpenFile_, makeDump(), and nfileopened_.

Referenced by IgProfService().

                                                         {
   ++nfileopened_; 
   makeDump(atPostOpenFile_);
 }  

void IgProfService::preEvent ( StreamContext const & sc )

Definition at line 114 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 166 of file IgProfService.cc.

References gen::n, mps_fire::result, alignCSCRings::s, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by isProcessWideService(), and 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 182 of file IgProfService.cc.

References DEFINE_FWK_SERVICE, gen::n, mps_fire::result, alignCSCRings::s, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by isProcessWideService(), and 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;
 }