ProfilerService Class Reference

#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.

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().

    :

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

~ProfilerService()

ProfilerService::~ProfilerService

(

)

Destructor.

Definition at line 42 of file ProfilerService.cc.

References dumpStat().

{ dumpStat(); }

Member Function Documentation

active()

bool ProfilerService::active ( void  ) const

inline

true if instrumentation is active

Definition at line 59 of file ProfilerService.h.

References m_active.

{ return m_active > 0; }

beginEvent()

void ProfilerService::beginEvent ( )

private

Definition at line 119 of file ProfilerService.cc.

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

Referenced by beginEventI().

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

beginEventI()

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

inline

Definition at line 65 of file ProfilerService.h.

References beginEvent().

Referenced by ProfilerService().

{ beginEvent(); }

beginPath()

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

private

Definition at line 133 of file ProfilerService.cc.

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

Referenced by beginPathI().

                                                     {
  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();
}

beginPathI()

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

inline

Definition at line 68 of file ProfilerService.h.

References beginPath(), and castor_dqm_sourceclient_file_cfg::path.

Referenced by ProfilerService().

{ beginPath(path.pathName()); }

doEvent()

bool ProfilerService::doEvent ( ) const

inline

true if the current event has to be instrumented

Definition at line 56 of file ProfilerService.h.

References m_doEvent.

Referenced by beginPath(), and startInstrumentation().

{ return m_doEvent; }

dumpStat()

void ProfilerService::dumpStat

(

)

const

dump profiling information

Definition at line 99 of file ProfilerService.cc.

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

{ CALLGRIND_DUMP_STATS; }

endEvent()

void ProfilerService::endEvent ( )

private

Definition at line 127 of file ProfilerService.cc.

References forceStopInstrumentation(), and stopInstrumentation().

Referenced by endEventI().

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

endEventI()

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

inline

Definition at line 67 of file ProfilerService.h.

References endEvent().

Referenced by ProfilerService().

{ endEvent(); }

endPath()

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

private

Definition at line 147 of file ProfilerService.cc.

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

Referenced by endPathI().

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

endPathI()

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

inline

Definition at line 69 of file ProfilerService.h.

References endPath(), and castor_dqm_sourceclient_file_cfg::path.

Referenced by ProfilerService().

                                                                                                     {
    endPath(path.pathName());
  }

forceStopInstrumentation()

bool ProfilerService::forceStopInstrumentation

(

)

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

Definition at line 71 of file ProfilerService.cc.

References m_active.

Referenced by endEvent(), and fullEvent().

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

fullEvent()

void ProfilerService::fullEvent ( )

private

Definition at line 107 of file ProfilerService.cc.

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

Referenced by preSourceI(), and ProfilerService().

                                {
  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();
  }
}

newEvent()

void ProfilerService::newEvent ( )

private

Definition at line 102 of file ProfilerService.cc.

References m_doEvent, m_evtCount, m_firstEvent, and m_lastEvent.

Referenced by beginEvent(), and fullEvent().

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

pauseInstrumentation()

bool ProfilerService::pauseInstrumentation

(

)

Definition at line 80 of file ProfilerService.cc.

References m_active, and m_paused.

Referenced by beginPath().

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

preSourceI()

void ProfilerService::preSourceI ( edm::StreamID  )

inline

Definition at line 63 of file ProfilerService.h.

References fullEvent().

Referenced by ProfilerService().

{ fullEvent(); }

resumeInstrumentation()

bool ProfilerService::resumeInstrumentation

(

)

Definition at line 88 of file ProfilerService.cc.

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

Referenced by endPath().

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

startInstrumentation()

bool ProfilerService::startInstrumentation

(

)

start instrumentation if not active. true if started now

Definition at line 46 of file ProfilerService.cc.

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

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

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

stopInstrumentation()

bool ProfilerService::stopInstrumentation

(

)

stop instrumentation if not active anymore; true if stopped now

Definition at line 62 of file ProfilerService.cc.

References m_active.

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

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

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().