#include <SQLMonitoringService.h>

Inheritance diagram for cond::SQLMonitoringService:

Public Member Functions
virtual bool	active (const std::string &contextKey) const

virtual void	disable (const std::string &contextKey)

virtual void	enable (const std::string &contextKey)

virtual coral::monitor::Level	level (const std::string &contextKey) const

virtual std::set< std::string >	monitoredDataSources () const

virtual void	record (const std::string &contextKey, coral::monitor::Source source, coral::monitor::Type type, const std::string &description)

virtual void	record (const std::string &contextKey, coral::monitor::Source source, coral::monitor::Type type, const std::string &description, int data)

virtual void	record (const std::string &contextKey, coral::monitor::Source source, coral::monitor::Type type, const std::string &description, long long data)

virtual void	record (const std::string &contextKey, coral::monitor::Source source, coral::monitor::Type type, const std::string &description, double data)

virtual void	record (const std::string &contextKey, coral::monitor::Source source, coral::monitor::Type type, const std::string &description, const std::string &data)

virtual void	report (unsigned int level) const

virtual void	report (const std::string &contextKey, unsigned int level) const

virtual const coral::IMonitoringReporter &	reporter () const

void	reportForSession (Repository::const_iterator &it, std::ostream &os) const

void	reportForSession (Repository::const_iterator &it, coral::MessageStream &os) const

void	reportOnEvent (EventStream::const_iterator &it, std::ostream &os) const

void	reportOnEvent (EventStream::const_iterator &it, coral::MessageStream &os) const

virtual void	reportToOutputStream (const std::string &contextKey, std::ostream &os, unsigned int level) const

virtual void	setLevel (const std::string &contextKey, coral::monitor::Level level)

	SQLMonitoringService (const std::string &)

virtual	~SQLMonitoringService ()

Private Attributes
Repository	m_events
	The all events repository classified by the sessions' keys. More...

std::set< std::string >	m_monitoredDS

Detailed Description

Definition at line 40 of file SQLMonitoringService.h.

Constructor & Destructor Documentation

cond::SQLMonitoringService::SQLMonitoringService ( const std::string & key )

explicit

Definition at line 20 of file SQLMonitoringService.cc.

     : coral::Service( key ),
       m_events()
   {
   }

cond::SQLMonitoringService::~SQLMonitoringService ( )

virtual

Definition at line 26 of file SQLMonitoringService.cc.

27 {

28 }

Member Function Documentation

bool cond::SQLMonitoringService::active ( const std::string & contextKey ) const

virtual

Return monitoring activity status

Definition at line 62 of file SQLMonitoringService.cc.

References m_events, and mergeVDriftHistosByStation::name.

Referenced by record().

   {
     Repository::const_iterator rit;
     
     if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
       throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::active", this->name() );
     
     return (*rit).second.active;
   }

void cond::SQLMonitoringService::disable ( const std::string & contextKey )

virtual

Definition at line 82 of file SQLMonitoringService.cc.

References m_events, and mergeVDriftHistosByStation::name.

     {
       Repository::iterator rit;
       
       if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
         throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::disable", this->name() );
       
       (*rit).second.active = false;
     }

void cond::SQLMonitoringService::enable ( const std::string & contextKey )

virtual

Definition at line 72 of file SQLMonitoringService.cc.

References m_events, and mergeVDriftHistosByStation::name.

     {
       Repository::iterator rit;
       
       if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
         throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::enable", this->name() );
 
       (*rit).second.active = true;
     }

coral::monitor::Level cond::SQLMonitoringService::level ( const std::string & contextKey ) const

virtual

Return current monitoring level

Definition at line 52 of file SQLMonitoringService.cc.

References m_events, and mergeVDriftHistosByStation::name.

Referenced by setLevel().

   {
     Repository::const_iterator rit;
     
     if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
       throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::level", this->name() );
     
     return (*rit).second.level;
   }

std::set< std::string > cond::SQLMonitoringService::monitoredDataSources ( ) const

virtual

Return the set of currently monitored data sources

Definition at line 179 of file SQLMonitoringService.cc.

References m_monitoredDS.

     {
       return m_monitoredDS;
     }

void cond::SQLMonitoringService::record	(	const std::string &	contextKey,
		coral::monitor::Source	source,
		coral::monitor::Type	type,
		const std::string &	description
	)

virtual

Records an event without a payload ( time event for example )

Definition at line 93 of file SQLMonitoringService.cc.

References active(), m_events, and mergeVDriftHistosByStation::name.

     {
       Repository::iterator rit;
       
       if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
         throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::record", this->name() );
       
       bool                  active = (*rit).second.active;
       //coral::monitor::Level level  = (*rit).second.level;
        
       if( active/* && (type & level)*/ )
       {
     (*rit).second.stream.push_back( coral::monitor::createEvent( source, type, description ) );
       }
     }

void cond::SQLMonitoringService::record	(	const std::string &	contextKey,
		coral::monitor::Source	source,
		coral::monitor::Type	type,
		const std::string &	description,
		int	data
	)

virtual

Records an event with a payload

Definition at line 109 of file SQLMonitoringService.cc.

References active(), m_events, and mergeVDriftHistosByStation::name.

   {
     Repository::iterator rit;
 
     if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
       throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::record", this->name() );
     
     bool                  active = (*rit).second.active;
     //coral::monitor::Level level  = (*rit).second.level;
     
     if( active/* && (type & level)*/ )
       {
     (*rit).second.stream.push_back( coral::monitor::createEvent( source, type, description, data ) );
       }
   }

void cond::SQLMonitoringService::record	(	const std::string &	contextKey,
		coral::monitor::Source	source,
		coral::monitor::Type	type,
		const std::string &	description,
		long long	data
	)

virtual

Records an event with a payload

Definition at line 125 of file SQLMonitoringService.cc.

References active(), m_events, and mergeVDriftHistosByStation::name.

   {
     Repository::iterator rit;
 
     if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
       throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::record", this->name() );
     
     bool                  active = (*rit).second.active;
     //coral::monitor::Level level  = (*rit).second.level;
     
     if( active/* && (type & level)*/ )
       {
     (*rit).second.stream.push_back( coral::monitor::createEvent( source, type, description, data ) );
       }
   }

void cond::SQLMonitoringService::record	(	const std::string &	contextKey,
		coral::monitor::Source	source,
		coral::monitor::Type	type,
		const std::string &	description,
		double	data
	)

virtual

Records an event with a payload

Definition at line 141 of file SQLMonitoringService.cc.

References active(), m_events, and mergeVDriftHistosByStation::name.

     {
       Repository::iterator rit;
 
       if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
         throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::record", this->name() );
 
       bool                  active = (*rit).second.active;
       //coral::monitor::Level level  = (*rit).second.level;
       
       if( active/* && (type & level)*/ )
       {
     (*rit).second.stream.push_back( coral::monitor::createEvent( source, type, description, data ) );
       }
     }

void cond::SQLMonitoringService::record	(	const std::string &	contextKey,
		coral::monitor::Source	source,
		coral::monitor::Type	type,
		const std::string &	description,
		const std::string &	data
	)

virtual

Records an event with a payload

Definition at line 157 of file SQLMonitoringService.cc.

References active(), m_events, and mergeVDriftHistosByStation::name.

     {
       Repository::iterator rit;
 
       if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
         throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::record", this->name() );
 
       bool                  active = (*rit).second.active;
       //coral::monitor::Level level  = (*rit).second.level;
       
       if( active /*&& (type & level)*/ )
       {
     (*rit).second.stream.push_back( coral::monitor::createEvent( source, type, description, data ) );
       }
     }

void cond::SQLMonitoringService::report ( unsigned int level ) const

virtual

Reports all the events

Parameters

contextKey The session ID for which to make the report

Definition at line 184 of file SQLMonitoringService.cc.

References funct::log(), m_events, and reportForSession().

     {
       Repository::const_iterator rit;
       coral::MessageStream  log( "MonitoringService" );
       
       // Dummy reporting so far
       for( rit = m_events.begin(); rit != m_events.end(); ++rit )
         reportForSession( rit, log );
     }

void cond::SQLMonitoringService::report	(	const std::string &	contextKey,
		unsigned int	level
	)		const

virtual

Reports the events to the default reporter

Parameters

contextKey The session ID for which to make the report

Definition at line 194 of file SQLMonitoringService.cc.

References funct::log(), m_events, mergeVDriftHistosByStation::name, and reportForSession().

     {
       Repository::const_iterator rit;
       
       if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
         throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::record", this->name() );
 
       // Dummy reporting so far
       coral::MessageStream log( "MonitoringService" );
 
       reportForSession( rit, log );
     }

const coral::IMonitoringReporter & cond::SQLMonitoringService::reporter ( ) const

virtual

Return the current reporter

Definition at line 173 of file SQLMonitoringService.cc.

     {
       return( static_cast<const coral::IMonitoringReporter&>(*this) );
     }

void cond::SQLMonitoringService::reportForSession	(	Repository::const_iterator &	it,
		std::ostream &	os
	)		const

Definition at line 237 of file SQLMonitoringService.cc.

References reportOnEvent().

Referenced by report(), and reportToOutputStream().

     {
       const EventStream& evsref = (*it).second.stream;
       
       for( EventStream::const_iterator evit = evsref.begin(); evit != evsref.end(); ++evit )
       {
         reportOnEvent( evit, os );
       }
     }

void cond::SQLMonitoringService::reportForSession	(	Repository::const_iterator &	it,
		coral::MessageStream &	os
	)		const

Definition at line 247 of file SQLMonitoringService.cc.

References reportOnEvent().

     {
       const EventStream& evsref = (*it).second.stream;
       
       for( EventStream::const_iterator evit = evsref.begin(); evit != evsref.end(); ++evit )
       {
         reportOnEvent( evit, os );
       }
 
     }

void cond::SQLMonitoringService::reportOnEvent	(	EventStream::const_iterator &	it,
		std::ostream &	os
	)		const

Definition at line 220 of file SQLMonitoringService.cc.

Referenced by reportForSession().

   {
     if(it->m_source == coral::monitor::Statement)
       {
     os << (*it).m_description << ";"<< std::endl;
       }
   }

void cond::SQLMonitoringService::reportOnEvent	(	EventStream::const_iterator &	it,
		coral::MessageStream &	os
	)		const

Definition at line 229 of file SQLMonitoringService.cc.

     {
       if(it->m_source == coral::monitor::Statement)
     {
       os << (*it).m_description <<coral::MessageStream::flush;
     }
     }

void cond::SQLMonitoringService::reportToOutputStream	(	const std::string &	contextKey,
		std::ostream &	os,
		unsigned int	level
	)		const

virtual

Reports the events to the specified output stream

Parameters

contextKey The session ID for which to make the report

Definition at line 207 of file SQLMonitoringService.cc.

References funct::log(), m_events, mergeVDriftHistosByStation::name, and reportForSession().

     {
       Repository::const_iterator rit;
       
       if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
         throw coral::MonitoringException( "Monitoring for session " + contextKey + " not initialized...", "MonitoringService::record", this->name() );
 
       // Dummy reporting so far
       coral::MessageStream log( "MonitoringService" );
 
       reportForSession( rit, os );
     }

void cond::SQLMonitoringService::setLevel	(	const std::string &	contextKey,
		coral::monitor::Level	level
	)

virtual

The implementation coral::IMonitoringService interface Sets the level

Parameters

contextKey	The session ID for which to make the report
level	The monitoring level ( Default, Debug, Trace )

Definition at line 30 of file SQLMonitoringService.cc.

References level(), m_events, and m_monitoredDS.

   {
     Repository::const_iterator rit;
     
     if( ( rit = m_events.find( contextKey ) ) == m_events.end() )
       {        
         m_events[contextKey] = SessionMonitor();
         m_monitoredDS.insert( contextKey );
       }
     
     m_events[contextKey].level = level;
     
     if( level == coral::monitor::Off )
       {
         m_events[contextKey].active = false;
       }
     else
       {
         m_events[contextKey].active = true;        
       }
     }

Member Data Documentation

Repository cond::SQLMonitoringService::m_events

private

The all events repository classified by the sessions' keys.

Definition at line 153 of file SQLMonitoringService.h.

Referenced by active(), disable(), enable(), level(), record(), report(), reportToOutputStream(), and setLevel().

std::set<std::string> cond::SQLMonitoringService::m_monitoredDS

private

Definition at line 154 of file SQLMonitoringService.h.

Referenced by monitoredDataSources(), and setLevel().

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation