ora::Monitoring Class Reference

#include <Monitoring.h>

Public Member Functions
void	report (std::ostream &out)
SessionMonitoringData *	startSession (const std::string &connectionString)
virtual	~Monitoring () throw ()

Static Public Member Functions
static void	enable ()
static Monitoring &	get ()
static bool	isEnabled ()
static const std::string &	outFileName ()

Private Member Functions
	Monitoring ()

Private Attributes
std::map< std::string, SessionMonitoringData * >	m_sessions

Static Private Attributes
static std::atomic< bool >	s_enabled {false}

Detailed Description

Definition at line 39 of file Monitoring.h.

Constructor & Destructor Documentation

ora::Monitoring::~Monitoring ( ) throw ( )

virtual

Definition at line 102 of file Monitoring.cc.

References gather_cfg::cout, alignCSCRings::e, relativeConstraints::empty, cppFunctionSkipper::exception, GetRecoTauVFromDQM_MC_cff::outFile, TreeWriterForEcalCorrection_cfg::outFileName, and zeeHLT_cff::report.

                                  {
  if( isEnabled() ){
    try {
      if( !outFileName().empty() ){
    std::ofstream outFile;
    outFile.open(  outFileName().c_str() );
    if(outFile.good()){
      report( outFile );
      outFile.flush();
    }
        outFile.close();
    
      } else {
    report( std::cout );
      }
    } catch ( const std::exception& e ){
      std::cout <<"ORA_MONITORING Error: "<<e.what()<<std::endl;
    }
  }
  // clean up memory
  for(std::map<std::string,SessionMonitoringData*>::const_iterator iS = m_sessions.begin();
      iS != m_sessions.end();iS++ ){
    delete iS->second;
  }
}

ora::Monitoring::Monitoring ( )

private

Definition at line 154 of file Monitoring.cc.

                         :
  m_sessions(){
}

Member Function Documentation

void ora::Monitoring::enable ( )

static

Definition at line 92 of file Monitoring.cc.

                          {
  s_enabled.store(true,std::memory_order_release);
}

ora::Monitoring & ora::Monitoring::get ( )

static

Definition at line 79 of file Monitoring.cc.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), data_sources.json_list::as_dicts(), data_sources.json_list::as_table(), util.rrapi.RRApi::columns(), rrapi.RRApi::columns(), ora::DatabaseSession::connect(), util.rrapi.RRApi::count(), rrapi.RRApi::count(), rrapi.RRApi::data(), util.rrapi.RRApi::data(), data_sources.json_list::first(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), data_sources.json_list::indices(), data_sources.json_list::last(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), util.rrapi.RRApi::reports(), rrapi.RRApi::reports(), util.rrapi.RRApi::tables(), rrapi.RRApi::tables(), util.rrapi.RRApi::tags(), rrapi.RRApi::tags(), util.rrapi.RRApi::templates(), rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

                                 {
  static ora::Monitoring s_mon;
  return s_mon;
}

bool ora::Monitoring::isEnabled ( )

static

Definition at line 84 of file Monitoring.cc.

Referenced by ora::DatabaseSession::connect().

                             {
  if(! s_enabled.load(std::memory_order_acquire) ){
    const char* envVar = ::getenv( "ORA_MONITORING_LEVEL" );
    if( envVar && ::strcmp(envVar,"SESSION")==0 ) s_enabled.store(true,std::memory_order_release);
  }
  return s_enabled.load(std::memory_order_acquire);
}

const std::string & ora::Monitoring::outFileName ( )

static

Definition at line 96 of file Monitoring.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

                                           {
  const char* fileEnvVar = ::getenv( "ORA_MONITORING_FILE" );
  static const std::string s_outFileName( fileEnvVar?fileEnvVar:"");
  return s_outFileName;
}

void ora::Monitoring::report

(

std::ostream &

out

)

Definition at line 134 of file Monitoring.cc.

References data, j, ora::SessionMonitoringData::m_connectionString, ora::SessionMonitoringData::m_start, ora::SessionMonitoringData::m_stop, and zeeHLT_cff::report.

                                           {
  out << "### ---------------------------------------------------------------------- "<<std::endl;
  out << "### ORA Monitoring Summary "<<std::endl;
  out << "### "<<m_sessions.size()<<" session(s) registered."<<std::endl;
  size_t j = 1;
  for( std::map<std::string,SessionMonitoringData*>::const_iterator iS = m_sessions.begin();
       iS != m_sessions.end(); ++iS ){
    SessionMonitoringData& data = *iS->second;
    boost::posix_time::time_duration duration;
    if( !data.m_stop.is_neg_infinity() ){
      duration = data.m_stop-data.m_start;
    }
    out <<" -> Session #"<<j<<": connection=\""<<data.m_connectionString<<"\" duration="<<boost::posix_time::to_simple_string(duration)<<" transactions="<<(iS->second)->numberOfTransactions()<<std::endl;
    (iS->second)->report(out);
    j++;
  }
  out << "### ---------------------------------------------------------------------- "<<std::endl;

}

ora::SessionMonitoringData * ora::Monitoring::startSession

(

const std::string &

connectionString

)

Definition at line 128 of file Monitoring.cc.

References ora::guidFromTime(), and runTheMatrix::ret.

Referenced by ora::DatabaseSession::connect().

                                                                                        {
  ora::SessionMonitoringData* ret = new SessionMonitoringData( boost::posix_time::microsec_clock::universal_time(), connectionString );
  m_sessions.insert(std::make_pair(guidFromTime(),ret));
  return ret;
}

Member Data Documentation

std::map<std::string,SessionMonitoringData*> ora::Monitoring::m_sessions

private

Definition at line 61 of file Monitoring.h.

std::atomic< bool > ora::Monitoring::s_enabled {false}

staticprivate

Definition at line 54 of file Monitoring.h.