#include <ProfilerService.h>

Public Member Functions
bool	active () const
	true if instrumentation is active More...

void	beginEventI (edm::StreamContext const &stream)

void	beginPathI (edm::StreamContext const &stream, edm::PathContext const &path)

bool	doEvent () const
	true if the current event has to be instrumented More...

void	dumpStat () const
	dump profiling information More...

void	endEventI (edm::StreamContext const &stream)

void	endPathI (edm::StreamContext const &stream, edm::PathContext const &path, edm::HLTPathStatus const &)

bool	forceStopInstrumentation ()
	forced stop instrumentation independenly of activity status; true if stopped now More...

bool	pauseInstrumentation ()

void	preSourceI (edm::StreamID)

	ProfilerService (edm::ParameterSet const &pset, edm::ActivityRegistry &activity)
	Standard Service Constructor. More...

bool	resumeInstrumentation ()

bool	startInstrumentation ()
	start instrumentation if not active. true if started now More...

bool	stopInstrumentation ()
	stop instrumentation if not active anymore; true if stopped now More...

	~ProfilerService ()
	Destructor. More...

Private Member Functions
void	beginEvent ()

void	beginPath (std::string const &path)

void	endEvent ()

void	endPath (std::string const &path)

void	fullEvent ()

void	newEvent ()

Private Attributes
int	m_active

std::string	m_activePath

bool	m_allPaths

int	m_counts

bool	m_doEvent

int	m_dumpInterval

int	m_evtCount

std::vector< std::string >	m_excludedPaths

int	m_firstEvent

int	m_lastEvent

std::vector< std::string >	m_paths

bool	m_paused

Friends
struct	test::CheckPaths

class	test::TestProfilerService

Detailed Description

A Service to start and stop calgrind profiling on demand... act also as profiler watchdog (in the same service to avoid dependency between service)

Definition at line 23 of file ProfilerService.h.

Constructor & Destructor Documentation

◆ ProfilerService()

ProfilerService::ProfilerService	(	edm::ParameterSet const &	pset,
		edm::ActivityRegistry &	activity
	)

Standard Service Constructor.

Definition at line 12 of file ProfilerService.cc.

     :
  
       m_firstEvent(pset.getUntrackedParameter<int>("firstEvent", 0)),
       m_lastEvent(pset.getUntrackedParameter<int>("lastEvent", std::numeric_limits<int>::max())),
       m_dumpInterval(pset.getUntrackedParameter<int>("dumpInterval", 100)),
       m_paths(pset.getUntrackedParameter<std::vector<std::string> >("paths", std::vector<std::string>())),
       m_excludedPaths(
           pset.getUntrackedParameter<std::vector<std::string> >("excludePaths", std::vector<std::string>())),
       m_allPaths(false),
       m_evtCount(0),
       m_counts(0),
       m_doEvent(false),
       m_active(0),
       m_paused(false) {
   static std::string const allPaths("ALL");
   m_allPaths = std::find(m_paths.begin(), m_paths.end(), allPaths) != m_paths.end();
  
   // either FullEvent or selected path
   static std::string const fullEvent("FullEvent");
   if (std::find(m_paths.begin(), m_paths.end(), fullEvent) != m_paths.end())
     activity.watchPostSourceEvent(this, &ProfilerService::preSourceI);
   else {
     activity.watchPreEvent(this, &ProfilerService::beginEventI);
     activity.watchPostEvent(this, &ProfilerService::endEventI);
     activity.watchPrePathEvent(this, &ProfilerService::beginPathI);
     activity.watchPostPathEvent(this, &ProfilerService::endPathI);
   }
 }

References mutracking_dqm_sourceclient-live_cfg::allPaths, beginEventI(), beginPathI(), endEventI(), endPathI(), spr::find(), fullEvent(), m_allPaths, m_paths, preSourceI(), AlCaHLTBitMon_QueryRunRegistry::string, edm::ActivityRegistry::watchPostEvent(), edm::ActivityRegistry::watchPostPathEvent(), edm::ActivityRegistry::watchPostSourceEvent(), edm::ActivityRegistry::watchPreEvent(), and edm::ActivityRegistry::watchPrePathEvent().

◆ ~ProfilerService()

ProfilerService::~ProfilerService ( )

Destructor.

Definition at line 42 of file ProfilerService.cc.

42 { dumpStat(); }

References dumpStat().

Member Function Documentation

◆ active()

bool ProfilerService::active ( void ) const

inline

true if instrumentation is active

Definition at line 59 of file ProfilerService.h.

59 { return m_active > 0; }

References m_active.

◆ beginEvent()

void ProfilerService::beginEvent ( )

private

Definition at line 119 of file ProfilerService.cc.

                                  {
   newEvent();
   //  static std::string const fullEvent("FullEvent");
   //  if (std::find(m_paths.begin(),m_paths.end(),fullEvent) != m_paths.end())
   if (m_allPaths)
     startInstrumentation();
 }

References m_allPaths, newEvent(), and startInstrumentation().

Referenced by beginEventI().

◆ beginEventI()

void ProfilerService::beginEventI ( edm::StreamContext const & stream )

inline

Definition at line 65 of file ProfilerService.h.

65 { beginEvent(); }

References beginEvent().

Referenced by ProfilerService().

◆ beginPath()

void ProfilerService::beginPath ( std::string const & path )

private

Definition at line 133 of file ProfilerService.cc.

                                                      {
   if (!doEvent())
     return;
   // assume less than 5-6 path to instrument or to exclude
   if (std::find(m_excludedPaths.begin(), m_excludedPaths.end(), path) != m_excludedPaths.end()) {
     pauseInstrumentation();
     return;
   }
   if (std::find(m_paths.begin(), m_paths.end(), path) == m_paths.end())
     return;
   m_activePath = path;
   startInstrumentation();
 }

References doEvent(), spr::find(), m_activePath, m_excludedPaths, m_paths, castor_dqm_sourceclient_file_cfg::path, pauseInstrumentation(), and startInstrumentation().

Referenced by beginPathI().

◆ beginPathI()

void ProfilerService::beginPathI	(	edm::StreamContext const &	stream,
		edm::PathContext const &	path
	)

inline

Definition at line 68 of file ProfilerService.h.

68 { beginPath(path.pathName()); }

References beginPath(), and castor_dqm_sourceclient_file_cfg::path.

Referenced by ProfilerService().

◆ doEvent()

bool ProfilerService::doEvent ( ) const

inline

true if the current event has to be instrumented

Definition at line 56 of file ProfilerService.h.

56 { return m_doEvent; }

References m_doEvent.

Referenced by beginPath(), and startInstrumentation().

◆ dumpStat()

void ProfilerService::dumpStat ( ) const

dump profiling information

Definition at line 99 of file ProfilerService.cc.

99 { CALLGRIND_DUMP_STATS; }

Referenced by fullEvent(), resumeInstrumentation(), startInstrumentation(), and ~ProfilerService().

◆ endEvent()

void ProfilerService::endEvent ( )

private

Definition at line 127 of file ProfilerService.cc.

                                {
   stopInstrumentation();
   // force, a nested instrumentation may fail to close in presence of filters
   forceStopInstrumentation();
 }

References forceStopInstrumentation(), and stopInstrumentation().

Referenced by endEventI().

◆ endEventI()

void ProfilerService::endEventI ( edm::StreamContext const & stream )

inline

Definition at line 67 of file ProfilerService.h.

67 { endEvent(); }

References endEvent().

Referenced by ProfilerService().

◆ endPath()

void ProfilerService::endPath ( std::string const & path )

private

Definition at line 147 of file ProfilerService.cc.

                                                    {
   resumeInstrumentation();
   if (m_activePath == path) {
     stopInstrumentation();
     m_activePath.clear();
   }
   // do to force, a nested instrumentation may fail to close in presence of filters
   // forceStopInstrumentation();
 }

References m_activePath, castor_dqm_sourceclient_file_cfg::path, resumeInstrumentation(), and stopInstrumentation().

Referenced by endPathI().

◆ endPathI()

void ProfilerService::endPathI	(	edm::StreamContext const &	stream,
		edm::PathContext const &	path,
		edm::HLTPathStatus const &
	)

inline

Definition at line 69 of file ProfilerService.h.

                                                                                                      {
     endPath(path.pathName());
   }

References endPath(), and castor_dqm_sourceclient_file_cfg::path.

Referenced by ProfilerService().

◆ forceStopInstrumentation()

bool ProfilerService::forceStopInstrumentation ( )

forced stop instrumentation independenly of activity status; true if stopped now

Definition at line 71 of file ProfilerService.cc.

                                                {
   if (m_active == 0)
     return false;
   // FIXME report something if appens;
   CALLGRIND_STOP_INSTRUMENTATION;
   m_active = 0;
   return true;
 }

References m_active.

Referenced by endEvent(), and fullEvent().

◆ fullEvent()

void ProfilerService::fullEvent ( )

private

Definition at line 107 of file ProfilerService.cc.

                                 {
   newEvent();
   if (m_doEvent && m_active == 0)
     startInstrumentation();
   if ((!m_doEvent) && m_active != 0) {
     stopInstrumentation();
     // force, a nested instrumentation may fail to close in presence of filters
     forceStopInstrumentation();
     dumpStat();
   }
 }

References dumpStat(), forceStopInstrumentation(), m_active, m_doEvent, newEvent(), startInstrumentation(), and stopInstrumentation().

Referenced by preSourceI(), and ProfilerService().

◆ newEvent()

void ProfilerService::newEvent ( )

private

Definition at line 102 of file ProfilerService.cc.

                                {
   ++m_evtCount;
   m_doEvent = m_evtCount >= m_firstEvent && m_evtCount <= m_lastEvent;
 }

References m_doEvent, m_evtCount, m_firstEvent, and m_lastEvent.

Referenced by beginEvent(), and fullEvent().

◆ pauseInstrumentation()

bool ProfilerService::pauseInstrumentation ( )

Definition at line 80 of file ProfilerService.cc.

                                            {
   if (m_active == 0)
     return false;
   CALLGRIND_STOP_INSTRUMENTATION;
   m_paused = true;
   return true;
 }

References m_active, and m_paused.

Referenced by beginPath().

◆ preSourceI()

void ProfilerService::preSourceI ( edm::StreamID )

inline

Definition at line 63 of file ProfilerService.h.

63 { fullEvent(); }

References fullEvent().

Referenced by ProfilerService().

◆ resumeInstrumentation()

bool ProfilerService::resumeInstrumentation ( )

Definition at line 88 of file ProfilerService.cc.

                                             {
   if (m_active == 0 || (!m_paused))
     return false;
   CALLGRIND_START_INSTRUMENTATION;
   if (m_counts % m_dumpInterval == 0)
     dumpStat();
   ++m_counts;
   m_paused = false;
   return true;
 }

References dumpStat(), m_active, m_counts, m_dumpInterval, and m_paused.

Referenced by endPath().

◆ startInstrumentation()

bool ProfilerService::startInstrumentation ( )

start instrumentation if not active. true if started now

Definition at line 46 of file ProfilerService.cc.

                                            {
   // FIXME here or in client?
   if (!doEvent())
     return false;
  
   if (m_active == 0) {
     CALLGRIND_START_INSTRUMENTATION;
     if (m_counts % m_dumpInterval == 0)
       dumpStat();
     ++m_counts;
   }
   // support nested start/stop
   ++m_active;
   return m_active == 1;
 }

References doEvent(), dumpStat(), m_active, m_counts, and m_dumpInterval.

Referenced by beginEvent(), beginPath(), and fullEvent().

◆ stopInstrumentation()

bool ProfilerService::stopInstrumentation ( )

stop instrumentation if not active anymore; true if stopped now

Definition at line 62 of file ProfilerService.cc.

                                           {
   if (m_active == 0)
     return false;
   --m_active;
   if (m_active == 0)
     CALLGRIND_STOP_INSTRUMENTATION;
   return m_active == 0;
 }

References m_active.

Referenced by endEvent(), endPath(), and fullEvent().

Friends And Related Function Documentation

◆ test::CheckPaths

friend struct test::CheckPaths

friend

Definition at line 26 of file ProfilerService.h.

◆ test::TestProfilerService

friend class test::TestProfilerService

friend

Definition at line 25 of file ProfilerService.h.

Member Data Documentation

◆ m_active

int ProfilerService::m_active

private

Definition at line 96 of file ProfilerService.h.

Referenced by active(), forceStopInstrumentation(), fullEvent(), pauseInstrumentation(), resumeInstrumentation(), startInstrumentation(), and stopInstrumentation().

◆ m_activePath

std::string ProfilerService::m_activePath

private

Definition at line 98 of file ProfilerService.h.

Referenced by beginPath(), and endPath().

◆ m_allPaths

bool ProfilerService::m_allPaths

private

Definition at line 90 of file ProfilerService.h.

Referenced by beginEvent(), and ProfilerService().

◆ m_counts

int ProfilerService::m_counts

private

Definition at line 94 of file ProfilerService.h.

Referenced by resumeInstrumentation(), and startInstrumentation().

◆ m_doEvent

bool ProfilerService::m_doEvent

private

Definition at line 95 of file ProfilerService.h.

Referenced by doEvent(), fullEvent(), and newEvent().

◆ m_dumpInterval

int ProfilerService::m_dumpInterval

private

Definition at line 87 of file ProfilerService.h.

Referenced by resumeInstrumentation(), and startInstrumentation().

◆ m_evtCount

int ProfilerService::m_evtCount

private

Definition at line 93 of file ProfilerService.h.

Referenced by newEvent().

◆ m_excludedPaths

std::vector<std::string> ProfilerService::m_excludedPaths

private

Definition at line 89 of file ProfilerService.h.

Referenced by beginPath().

◆ m_firstEvent

int ProfilerService::m_firstEvent

private

Definition at line 85 of file ProfilerService.h.

Referenced by newEvent().

◆ m_lastEvent

int ProfilerService::m_lastEvent

private

Definition at line 86 of file ProfilerService.h.

Referenced by newEvent().

◆ m_paths

std::vector<std::string> ProfilerService::m_paths

private

Definition at line 88 of file ProfilerService.h.

Referenced by beginPath(), and ProfilerService().

◆ m_paused

bool ProfilerService::m_paused

private

Definition at line 97 of file ProfilerService.h.

Referenced by pauseInstrumentation(), and resumeInstrumentation().

Public Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ ProfilerService()

◆ ~ProfilerService()

Member Function Documentation

◆ active()

◆ beginEvent()

◆ beginEventI()

◆ beginPath()

◆ beginPathI()

◆ doEvent()

◆ dumpStat()

◆ endEvent()

◆ endEventI()

◆ endPath()

◆ endPathI()

◆ forceStopInstrumentation()

◆ fullEvent()

◆ newEvent()

◆ pauseInstrumentation()

◆ preSourceI()

◆ resumeInstrumentation()

◆ startInstrumentation()

◆ stopInstrumentation()

Friends And Related Function Documentation

◆ test::CheckPaths

◆ test::TestProfilerService

Member Data Documentation

◆ m_active

◆ m_activePath

◆ m_allPaths

◆ m_counts

◆ m_doEvent

◆ m_dumpInterval

◆ m_evtCount

◆ m_excludedPaths

◆ m_firstEvent

◆ m_lastEvent

◆ m_paths

◆ m_paused