In This Package:

MainAlgorithm.cc

Go to the documentation of this file.

#include "MainAlgorithm.h"

#include "GaudiKernel/IDataManagerSvc.h"

#include "ROBufferSvc/ROBufferSvc.h"

using namespace std;
using namespace DayaBay;

MainAlgorithm::MainAlgorithm(const string& name, ISvcLocator* pSvcLocator) 
              :GaudiAlgorithm(name, pSvcLocator)
{
  info()<< "Construct:MainAlgorithm()!"<< endreq;

  m_roBSvc  = 0;
  m_execNum = 0;
}

StatusCode MainAlgorithm::initialize()
{
  StatusCode sc = this->GaudiAlgorithm::initialize();
  if(sc.isFailure()) 
  { 
    error()<< "Error when initializing  GaudiAlgorithm"<< endreq;
    return sc;
  }

  //Prepare the sub algorithm--DigitalizeAlg
  Algorithm* subAlg = 0; 
  sc = createSubAlgorithm("DigitalizeAlg", "DigitalizeAlg", subAlg);
  if(sc.isFailure()) 
  {
    error()<< "Error creating Sub-Algorithm: DigitalizeAlg!" << endreq;
    return sc;
  }
  //m_digitAlg = dynamic_cast< DigitalizeAlg* >(subAlg);
  m_digitAlg = (DigitalizeAlg*)subAlg;
  if(!m_digitAlg)
  {
    error()<< "Can not converte Algorithm* to DigitalizeAlg* !"<< endreq;
    return StatusCode::SUCCESS;
  }

  //Initialize the ROBufferSvc
  IService* isvc = 0;
  sc = serviceLocator()->service("ROBufferSvc", isvc, true);
  if(sc.isFailure()) 
  {
    error()<< "Service:ROBufferSvc could not be retrieved"<< endreq;
    return sc;
  }
  isvc->addRef();
  sc = isvc->queryInterface(IROBufferSvc::interfaceID(), (void**)&m_roBSvc);
  if(sc.isFailure()) 
  {
    error()<< "ROBufferSvc does not implement IROBufferSvc."<< endreq;
    return sc;
  }

  info()<< "MainAlgorithm initialize()!"<< endreq;

  return StatusCode::SUCCESS;
}

StatusCode MainAlgorithm::execute() 
{
  //In one execute(), output one ReadoutHeader!
  info()<< "Now into MainAlgorithm "<< m_execNum<< " executation!"<< endreq;

  for( ; ; )
  {
    //If the MixHeader buffer is empty, notice the DigitalizeAlg
    if(0 == m_roBSvc->getMBufferSize())
    {
      info()<< "The MixHeader buffer is empty!"<< endreq;
      //Fill the MixHeader buffer
      StatusCode sc = m_digitAlg->execute();
      if(sc.isFailure())
      {
        error()<< "Error in DigitalizeAlg::execute()!"<< endreq;
        return StatusCode::FAILURE;
      }
      continue;
    }
    //If the MixHeader buffer is not empty, get one ReadoutHeader directly
    else
    {
      ReadoutHeader* roh = 0;
      roh = m_roBSvc->getROHeader();
      if(!roh)
      {
        error()<< "Failed to get one ReadoutHeader!"<< endreq;
        return StatusCode::FAILURE;
      }

      info()<< "Put the ReadoutHeader: "<< roh<< " into TES!"<< endreq;
      this->put(evtSvc(), roh, ReadoutHeaderLocation::Default);
      break;
    }
  }

  m_execNum++;
  info()<< "MainAlgorithm execute() finalized!" << endreq;

  return StatusCode::SUCCESS;
}

StatusCode MainAlgorithm::finalize() 
{
  info()<< "MainAlgorithm finalize()!"<< endreq;
  return StatusCode::SUCCESS;
}

MainAlgorithm::~MainAlgorithm()
{
  info()<< "Destructor:~MainAlgorithm()!"<< endreq;
}

---