In This Package:

StageProcessor.h

Go to the documentation of this file.

#ifndef STAGEPROCESSOR
#define STAGEPROCESSOR

#include "Event/HeaderObject.h"
#include "DybAlg/DybAlgorithm.h"

#include "Stage/IStage.h"
#include "Stage/IStageDataManager.h"

#include <string>

template <class HEADER>
class StageProcessor : public DybAlgorithm<HEADER>
{
public:
    StageProcessor(const std::string& name, ISvcLocator* pSvcLocator);

    virtual ~StageProcessor();
    
    StatusCode initialize();

    StatusCode registerData(IStageData& data);

    IStage* thisStage() { return m_thisStage; }
    IStage* lowerStage() { return m_lowerStage; }

private:

    std::string m_thisStageName;
    std::string m_lowerStageName;

    IStage* m_thisStage;
    IStage* m_lowerStage;


    IStageDataManager* m_sdmgr;
};

//#include "Stage/StageProcessorImp.h"

template <class HEADER>
StageProcessor<HEADER>::StageProcessor(const std::string& name, ISvcLocator* pSvcLocator)
    : DybAlgorithm<HEADER>(name,pSvcLocator)
{
    declareProperty("ThisStageName",m_thisStageName = "", "Name of this stage");
    declareProperty("LowerStageName",m_lowerStageName = "", "Name of the lower stage");

    this->m_pullMode = true;
}


template <class HEADER>
StageProcessor<HEADER>::~StageProcessor()
{
}

template <class HEADER>
StatusCode StageProcessor<HEADER>::initialize()
{
    // infinite loop?
    StatusCode sc = DybAlgorithm<HEADER>::initialize();
    if (sc.isFailure()) return sc;

    // should probably make this configurable one day
    sc = this->service("StageDataManager",m_sdmgr);
    if (sc.isFailure()) return sc;


    this->debug() << "This Stage " <<m_thisStageName <<endreq;
    this->debug() << "Lower Stage " <<m_lowerStageName <<endreq;

    if ("" == m_thisStageName) {
        this->error() << "Not configured with a stage name" << endreq;
        return StatusCode::FAILURE;
    }

    sc = this->toolSvc()->retrieveTool("Stage",m_thisStageName,m_thisStage);
    if ( sc.isFailure() ) {
        this->error() << "Error retrieving the public tool" << endreq;
        return sc;
    }

    if ("" != m_lowerStageName) {
        sc= this->toolSvc()->retrieveTool("Stage",m_lowerStageName,m_lowerStage);
        if( sc.isFailure() ) {
            this->error() << "Error retrieving the public tool" << endreq;
            return StatusCode::FAILURE;
        }
    }
    return StatusCode::SUCCESS;
}

template <class HEADER>
StatusCode StageProcessor<HEADER>::registerData(IStageData& data)
{
    return m_sdmgr->registerData(this->Location(), data);
}

#endif  // STAGEPROCESSOR

---