PartitionSwitchTool.cpp

Go to the documentation of this file.

// Framework include files
#include "GaudiKernel/AlgTool.h"
#include "GaudiKernel/SmartIF.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/IPartitionControl.h"

class PartitionSwitchTool: public extends1<AlgTool, IPartitionControl> {

  using CSTR = const std::string&;
  using STATUS = StatusCode;

private:

  std::string                m_actorName;
  SmartIF<IPartitionControl> m_actor;

public:

  PartitionSwitchTool(const std::string& typ, const std::string& nam, const IInterface* parent)
  : base_class( typ, nam , parent)
  {
    declareProperty("Actor", m_actorName = "EventDataService");
  }
  ~PartitionSwitchTool()   override = default; 

  STATUS initialize()  override {
    STATUS sc = AlgTool::initialize();
    MsgStream log(msgSvc(), name());
    if ( !sc.isSuccess() )  {
      log << MSG::ERROR << "Cannot initialize base class!" << endmsg;
      return sc;
    }
    m_actor = nullptr;
    IPartitionControl* tmpPtr = nullptr;
    sc = service(m_actorName, tmpPtr);
    m_actor = tmpPtr;
    if ( !sc.isSuccess() )  {
      log << MSG::ERROR << "Cannot retrieve partition controller \""
          << m_actorName << "\"!" << endmsg;
      return sc;
    }
    return sc;
  }
  STATUS finalize()   override {
    m_actor = nullptr;
    return AlgTool::finalize();
  }

  void _check(STATUS sc, CSTR msg)  const {
    MsgStream log(msgSvc(), name());
    log << MSG::ERROR << msg << " Status=" << sc.getCode() << endmsg;
  }
#define CHECK(x,y) if ( !x.isSuccess() ) _check(x, y); return x;

  STATUS create(CSTR nam, CSTR typ)  override {
    STATUS sc = m_actor ? m_actor->create(nam,typ) : NO_INTERFACE;
    CHECK(sc, "Cannot create partition: "+nam+" of type "+typ);
  }
  STATUS create(CSTR nam, CSTR typ, IInterface*& pPartition)  override {
    STATUS sc = m_actor ? m_actor->create(nam,typ,pPartition) : NO_INTERFACE;
    CHECK(sc, "Cannot create partition: "+nam+" of type "+typ);
  }
  STATUS drop(CSTR nam)  override {
    STATUS sc = m_actor ? m_actor->drop(nam) : NO_INTERFACE;
    CHECK(sc, "Cannot drop partition: "+nam);
  }
  STATUS drop(IInterface* pPartition)  override {
    STATUS sc = m_actor ? m_actor->drop(pPartition) : NO_INTERFACE;
    CHECK(sc, "Cannot drop partition by Interface.");
  }
  STATUS activate(CSTR nam)  override {
    STATUS sc = m_actor ? m_actor->activate(nam) : NO_INTERFACE;
    CHECK(sc, "Cannot activate partition: "+nam);
  }
  STATUS activate(IInterface* pPartition)  override {
    STATUS sc = m_actor ? m_actor->activate(pPartition) : NO_INTERFACE;
    CHECK(sc, "Cannot activate partition by Interface.");
  }
  STATUS get(CSTR nam, IInterface*& pPartition) const  override {
    STATUS sc = m_actor ? m_actor->get(nam, pPartition) : NO_INTERFACE;
    CHECK(sc, "Cannot get partition "+nam);
  }
  STATUS activePartition(std::string& nam, IInterface*& pPartition) const  override {
    STATUS sc = m_actor ? m_actor->activePartition(nam, pPartition) : NO_INTERFACE;
    CHECK(sc, "Cannot determine active partition.");
  }
};

// Declaration of the Tool Factory
DECLARE_COMPONENT(PartitionSwitchTool)