InertMessageSvc.cpp

Go to the documentation of this file.

// Include files

// From Gaudi
#include "GaudiKernel/SvcFactory.h"
// local
#include "InertMessageSvc.h"

// ----------------------------------------------------------------------------
// Implementation file for class: InertMessageSvc
//
// 12/02/2013: Danilo Piparo
// ----------------------------------------------------------------------------
DECLARE_SERVICE_FACTORY(InertMessageSvc)

//---------------------------------------------------------------------------

InertMessageSvc::InertMessageSvc(const std::string& name, ISvcLocator* pSvcLocator)
  : MessageSvc(name, pSvcLocator),
    m_isActive(false){
}

//---------------------------------------------------------------------------

InertMessageSvc::~InertMessageSvc() {
}

//---------------------------------------------------------------------------

StatusCode InertMessageSvc::initialize() {
  StatusCode sc = MessageSvc::initialize(); // must be executed first
  if ( sc.isFailure() ) return sc; // error printed already by MessageSvc

  info() << "Activating in a separate thread" << endmsg;
  m_thread = std::thread (std::bind(&InertMessageSvc::m_activate,
                                    this));

  return StatusCode::SUCCESS;
}

//---------------------------------------------------------------------------

StatusCode InertMessageSvc::InertMessageSvc::finalize() {

  m_deactivate();

  m_thread.join();

  return MessageSvc::finalize(); // must be called after all other actions

}

//---------------------------------------------------------------------------

void InertMessageSvc::m_activate(){
  m_isActive=true;
  messageActionPtr thisMessageAction;
  while (m_isActive or not m_messageActionsQueue.empty()){
    m_messageActionsQueue.pop(thisMessageAction);
    (*thisMessageAction)();
  }
}

//---------------------------------------------------------------------------

void InertMessageSvc::m_deactivate(){

  if (m_isActive){
      // This would be the last action
      m_messageActionsQueue.push(messageActionPtr(new messageAction([this]() {m_isActive=false;})));
    }
}

//---------------------------------------------------------------------------
void InertMessageSvc::reportMessage(const Message& msg, int outputLevel) {
  // msg has to be copied as the reference may become invalid by the time it's used
  m_messageActionsQueue.push
    (messageActionPtr(new messageAction([this, m=Message(msg),outputLevel] ()
                                        {this->i_reportMessage(m, outputLevel);})));
}

//---------------------------------------------------------------------------

void InertMessageSvc::reportMessage(const Message& msg) {
  // msg has to be copied as the reference may become invalid by the time it's used
  m_messageActionsQueue.push
    (messageActionPtr(new messageAction([this,m=Message(msg)] ()
                                       {this->i_reportMessage(m, this->outputLevel(m.getSource()));})));
}

//---------------------------------------------------------------------------

void InertMessageSvc::reportMessage(const StatusCode& code, const std::string& source) {
  // msg has to be copied as the source may become invalid by the time it's used
  m_messageActionsQueue.push(
                             messageActionPtr(new messageAction([this,code,s=std::string(source)] ()
                                       {this->i_reportMessage(code, s);})));
}

//---------------------------------------------------------------------------