cond::persistency::Logger Class Reference

#include <Logger.h>

Public Member Functions
void	end (int retCode)
std::iostream &	log (const std::string &tag)
EchoedLogStream< edm::LogDebug_ >	logDebug ()
EchoedLogStream< edm::LogError >	logError ()
	Logger ()=delete
	Logger (const std::string &jobName)
EchoedLogStream< edm::LogInfo >	logInfo ()
EchoedLogStream< edm::LogWarning >	logWarning ()
void	save ()
void	saveOnDb ()
void	saveOnFile ()
void	setDbDestination (const std::string &connectionString)
void	start ()
void	subscribeCoralMessages (const std::weak_ptr< MsgDispatcher > &dispatcher)
virtual	~Logger ()

Private Member Functions
void	clearBuffer ()

Private Attributes
std::string	m_connectionString
std::weak_ptr< MsgDispatcher >	m_dispatcher
boost::posix_time::ptime	m_endTime
std::string	m_jobName
std::stringstream	m_log
int	m_retCode
bool	m_started
boost::posix_time::ptime	m_startTime

Detailed Description

Definition at line 85 of file Logger.h.

Constructor & Destructor Documentation

Logger() [1/2]

cond::persistency::Logger::Logger ( )

delete

Logger() [2/2]

Logger::Logger ( const std::string &  jobName )

explicit

Definition at line 48 of file Logger.cc.

        : m_jobName(jobName),
          m_connectionString(""),
          m_started(false),
          m_startTime(),
          m_endTime(),
          m_retCode(0),
          m_log() {}

~Logger()

Logger::~Logger ( )

virtual

Definition at line 58 of file Logger.cc.

                    {
      auto dispatcher = m_dispatcher.lock();
      if (dispatcher.get())
        dispatcher->unsubscribe();
    }

References m_dispatcher.

Member Function Documentation

clearBuffer()

void Logger::clearBuffer ( )

private

Definition at line 43 of file Logger.cc.

                             {
      m_log.str("");
      m_log.clear();
    }

References m_log.

Referenced by end(), and start().

end()

void Logger::end

(

int

retCode

)

Definition at line 80 of file Logger.cc.

                                {
      if (m_started) {
        m_endTime = boost::posix_time::microsec_clock::universal_time();
        m_started = false;
        m_retCode = retCode;
        log("END_JOB") << ": return code:" << retCode;
        save();
        clearBuffer();
      }
    }

References clearBuffer(), log(), m_endTime, m_retCode, m_started, and save().

Referenced by Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), BeamMonitor::endLuminosityBlock(), and FakeBeamMonitor::endLuminosityBlock().

log()

std::iostream & Logger::log

(

const std::string &

tag

)

Definition at line 150 of file Logger.cc.

                                                 {
      if (std::size(m_log.str()) != 0)
        m_log << std::endl;
      m_log << "[" << get_timestamp() << "] " << tag << ": ";
      return m_log;
    }

References cond::persistency::get_timestamp(), m_log, findQualityFiles::size, and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by personalPlayback.Playback::do_create_lumi(), personalPlayback.Playback::do_exec(), personalPlayback.FrameworkJob::do_exec(), end(), conddbCopyTest.CopyTest::execute(), logDebug(), logError(), logInfo(), logWarning(), start(), personalPlayback.FrameworkJob::start_run(), and conditionUploadTest.UploadTest::upload().

logDebug()

EchoedLogStream< edm::LogDebug_ > Logger::logDebug

(

)

Definition at line 161 of file Logger.cc.

                                                   {
      log("DEBUG");
      return EchoedLogStream<edm::LogDebug_>(m_jobName, m_log);
    }

References log(), m_jobName, and m_log.

Referenced by reportToRecipient().

logError()

EchoedLogStream< edm::LogError > Logger::logError

(

)

Definition at line 165 of file Logger.cc.

                                                  {
      log("ERROR");
      return EchoedLogStream<edm::LogError>(m_jobName, m_log);
    }

References log(), m_jobName, and m_log.

Referenced by BeamMonitor::FitAndFill(), FakeBeamMonitor::FitAndFill(), reportToRecipient(), and saveOnDb().

logInfo()

EchoedLogStream< edm::LogInfo > Logger::logInfo

(

)

Definition at line 157 of file Logger.cc.

                                                {
      log("INFO");
      return EchoedLogStream<edm::LogInfo>(m_jobName, m_log);
    }

References log(), m_jobName, and m_log.

Referenced by BeamMonitor::beginLuminosityBlock(), FakeBeamMonitor::beginLuminosityBlock(), BeamMonitor::endLuminosityBlock(), FakeBeamMonitor::endLuminosityBlock(), BeamMonitor::FitAndFill(), FakeBeamMonitor::FitAndFill(), reportToRecipient(), cond::service::OnlineDBOutputService::writeForNextLumisection(), and cond::service::PoolDBOutputService::writeOne().

logWarning()

EchoedLogStream< edm::LogWarning > Logger::logWarning

(

)

Definition at line 169 of file Logger.cc.

                                                      {
      log("WARNING");
      return EchoedLogStream<edm::LogWarning>(m_jobName, m_log);
    }

References log(), m_jobName, and m_log.

Referenced by reportToRecipient(), cond::service::OnlineDBOutputService::writeForNextLumisection(), and cond::service::PoolDBOutputService::writeOne().

save()

void Logger::save

(

)

Definition at line 143 of file Logger.cc.

                      {
      if (!m_connectionString.empty())
        saveOnDb();
      else
        saveOnFile();
    }

References m_connectionString, saveOnDb(), and saveOnFile().

Referenced by end(), and SpecificationBuilder_cfi.Specification::saveAll().

saveOnDb()

void Logger::saveOnDb

(

)

Definition at line 120 of file Logger.cc.

                          {
      if (!m_log.str().empty()) {
        if (m_connectionString.empty()) {
          throwException("Connection string for destination database has not been provided.", "Logger::saveOnDb");
        }
        coral::ConnectionService connServ;
        std::unique_ptr<coral::ISessionProxy> coralSession(
            connServ.connect(m_connectionString, auth::COND_WRITER_ROLE, coral::Update));
        coralSession->transaction().start(false);
        try {
          O2O_RUN::Table destinationTable(coralSession->nominalSchema());
          destinationTable.insert(m_jobName, m_startTime, m_endTime, m_retCode, m_log.str());
          coralSession->transaction().commit();
        } catch (const std::exception& e) {
          coralSession->transaction().rollback();
          // dump on file on this circumstance...
          logError() << e.what();
          saveOnFile();
          throwException(std::string("Failure while saving log on database:") + e.what(), "Logger::saveOnDb");
        }
      }
    }

References cond::auth::COND_WRITER_ROLE, MillePedeFileConverter_cfg::e, cppFunctionSkipper::exception, cond::persistency::O2O_RUN::Table::insert(), logError(), m_connectionString, m_endTime, m_jobName, m_log, m_retCode, m_startTime, saveOnFile(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

Referenced by save().

saveOnFile()

void Logger::saveOnFile

(

)

Definition at line 110 of file Logger.cc.

                            {
      if (!m_log.str().empty()) {
        std::string fileName(get_timestamp_for_filename() + ".log");
        std::ofstream fout(fileName, std::ofstream::app);
        fout << m_log.str() << std::endl;
        fout.close();
      }
    }

References MillePedeFileConverter_cfg::fileName, groupFilesInBlocks::fout, cond::persistency::get_timestamp_for_filename(), m_log, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by save(), and saveOnDb().

setDbDestination()

void Logger::setDbDestination

(

const std::string &

connectionString

)

Definition at line 66 of file Logger.cc.

{ m_connectionString = connectionString; }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, and m_connectionString.

start()

void Logger::start

(

)

Definition at line 69 of file Logger.cc.

                       {
      if (!m_started) {
        if (!m_log.str().empty())
          clearBuffer();
        m_startTime = boost::posix_time::microsec_clock::universal_time();
        m_started = true;
        log("START_JOB") << " " << m_jobName;
      }
    }

References clearBuffer(), log(), m_jobName, m_log, m_started, and m_startTime.

Referenced by progressbar.ProgressBar::__next__(), BeamMonitor::beginLuminosityBlock(), FakeBeamMonitor::beginLuminosityBlock(), Types.LuminosityBlockRange::cppID(), and Types.EventRange::cppID().

subscribeCoralMessages()

void Logger::subscribeCoralMessages

(

const std::weak_ptr< MsgDispatcher > &

dispatcher

)

Definition at line 64 of file Logger.cc.

{ m_dispatcher = dispatcher; }

References m_dispatcher.

Member Data Documentation

m_connectionString

std::string cond::persistency::Logger::m_connectionString

private

Definition at line 130 of file Logger.h.

Referenced by save(), saveOnDb(), and setDbDestination().

m_dispatcher

std::weak_ptr<MsgDispatcher> cond::persistency::Logger::m_dispatcher

private

Definition at line 136 of file Logger.h.

Referenced by subscribeCoralMessages(), and ~Logger().

m_endTime

boost::posix_time::ptime cond::persistency::Logger::m_endTime

private

Definition at line 133 of file Logger.h.

Referenced by end(), and saveOnDb().

m_jobName

std::string cond::persistency::Logger::m_jobName

private

Definition at line 129 of file Logger.h.

Referenced by logDebug(), logError(), logInfo(), logWarning(), saveOnDb(), and start().

m_log

std::stringstream cond::persistency::Logger::m_log

private

Definition at line 135 of file Logger.h.

Referenced by clearBuffer(), log(), logDebug(), logError(), logInfo(), logWarning(), saveOnDb(), saveOnFile(), and start().

m_retCode

int cond::persistency::Logger::m_retCode

private

Definition at line 134 of file Logger.h.

Referenced by end(), and saveOnDb().

m_started

bool cond::persistency::Logger::m_started

private

Definition at line 131 of file Logger.h.

Referenced by end(), and start().

m_startTime

boost::posix_time::ptime cond::persistency::Logger::m_startTime

private

Definition at line 132 of file Logger.h.

Referenced by saveOnDb(), and start().