Algorithm.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/

 
//
// includes
//
 
#include <EventLoop/Algorithm.h>
 
#include <EventLoop/StatusCode.h>
#include <EventLoop/Worker.h>
#include <RootCoreUtils/Assert.h>
#include <TH1.h>
 
#include <AsgMessaging/MsgLevel.h>
#include <AsgMessaging/MsgStream.h>
 
#include <stdexcept>
 
//
// method implementations
//
 
ClassImp (EL::Algorithm)
 
namespace EL
{
  void Algorithm ::
  testInvariant () const
  {}
 
 
 
  IWorker *Algorithm ::
  wk () const
  {
    RCU_READ_INVARIANT (this);
    return m_wk;
  }
 
 
 
  void Algorithm ::
  book (const TH1& hist)
  {
    RCU_CHANGE_INVARIANT (this);
    wk()->addOutput (hist.Clone());
  }
 
 
 
  TH1 *Algorithm ::
  hist (const std::string& name) const
  {
    RCU_READ_INVARIANT (this);
    return dynamic_cast<TH1*>(wk()->getOutputHist (name));
  }
 
 
 
  Algorithm ::
  Algorithm ()
    : m_wk (nullptr)
  {
    RCU_NEW_INVARIANT (this);
  }
 
 
 
  Algorithm ::
  ~Algorithm ()
  {
    delete m_msg;
  }
 
 
 
  asg::SgEvent *Algorithm ::
  evtStore() const
  {
    RCU_CHANGE_INVARIANT (this);
    if (m_evtStorePtr)
      return m_evtStorePtr;
    m_evtStore = asg::SgEvent (wk()->xaodEvent(), wk()->xaodStore());
    m_evtStorePtr = &m_evtStore;
    return m_evtStorePtr;
  }
 
 
 
  MsgStream& Algorithm ::
  msg () const
  {
    RCU_READ_INVARIANT (this);
    if (m_msg == 0 || m_msgName != GetName())
    {
      delete m_msg;
      m_msg = nullptr;
      m_msgName = GetName();
      std::string name;
      if (m_msgName.empty())
    name = "UnnamedAlgorithm";
      else
        name = m_msgName;
      m_msg = new MsgStream (name);
      m_msg->setLevel (MSG::Level (m_msgLevel));
    }
    return *m_msg;
  }
 
 
 
  MsgStream& Algorithm ::
  msg (int level) const
  {
    RCU_READ_INVARIANT (this);
    MsgStream& result = msg ();
    result << MSG::Level (level);
    return result;
  }
 
 
 
  bool Algorithm ::
  msgLvl (int lvl) const
  {
    RCU_READ_INVARIANT (this);
    return m_msgLevel <= lvl;
  }
 
 
 
  void Algorithm ::
  setMsgLevel (int level)
  {
    RCU_CHANGE_INVARIANT (this);
    if (m_msg)
      m_msg->setLevel (MSG::Level (level));
    m_msgLevel = level;
  }
 
 
 
  StatusCode Algorithm ::
  setupJob (Job& /*job*/)
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  fileExecute ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  endOfFile ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  changeInput (bool /*firstFile*/)
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  initialize ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  histInitialize ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  execute ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  postExecute ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  finalize ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  StatusCode Algorithm ::
  histFinalize ()
  {
    RCU_CHANGE_INVARIANT (this);
    return StatusCode::SUCCESS;
  }
 
 
 
  bool Algorithm ::
  hasName (const std::string& name) const
  {
    RCU_CHANGE_INVARIANT (this);
    return GetName() == name;
  }
 
 
 
  void Algorithm ::
  sysSetupJob (Job& job)
  {
    RCU_CHANGE_INVARIANT (this);
    if (setupJob (job) != StatusCode::SUCCESS)
      throw std::runtime_error ("Algorithm::setupJob returned StatusCode::FAILURE");
  }
 
 
 
  const std::string& Algorithm ::
  name() const
  {
    RCU_CHANGE_INVARIANT (this);
    m_nameCache = GetName();
    return m_nameCache;
  }
}