In This Package:

StagePuller.cc

Go to the documentation of this file.

#include "StagePuller.h"
#include "Stage/HeaderStageData.h"
#include "Event/HeaderObject.h"

StagePuller::StagePuller(const std::string& name, ISvcLocator* pSvcLocator)
    : GaudiAlgorithm(name,pSvcLocator)
    , m_stage("Stage")
    , m_startTime(TimeStamp::GetBOT())
{
    declareProperty("Stage",m_stage, "Stage to pull from.");
    declareProperty("RunTimeSeconds",m_runTimeSeconds=0,
                    "Period of time, in seconds, that the job should run, if non-zero.");
}

StagePuller::~StagePuller()
{
}

StatusCode StagePuller::initialize()
{
    StatusCode sc = this->GaudiAlgorithm::initialize();
    if (sc.isFailure()) return sc;

    MsgStream log(msgSvc(), name());

    log << MSG::DEBUG
        << "Retrieving stage " << m_stage.typeAndName() << endreq;
    if (m_stage.retrieve().isFailure()) {
        log << MSG::ERROR
            << "Failed to retrieve " << m_stage << endreq;
        return StatusCode::FAILURE;
    }

    return StatusCode::SUCCESS;
}

StatusCode StagePuller::execute()
{
    MsgStream log(msgSvc(), name());

    log << MSG::DEBUG
        << "===> Pulling from last stage" << endreq;

    IStageData* data = 0;
    StatusCode sc = m_stage->nextElement(data,true);
    if (!data || sc.isFailure()) {
        log << MSG::WARNING
            << "Failed to pull next element" << endreq;
        return sc;
    }

    if (m_runTimeSeconds) {
        if (m_startTime == TimeStamp::GetBOT()) {
            m_startTime = data->time();
        }
        double dt_seconds = data->time() - m_startTime;
        if (dt_seconds > m_runTimeSeconds) {
            
        }
    }

    log << MSG::DEBUG
        << "Pulled data at time: " << data->time()
        << endreq;

    IStageData* hsdb = dynamic_cast< IStageData* >(data);
    if (!hsdb) {
        debug() << "StageData not a StageData, oh well." << endreq;
        delete data;
        return StatusCode::SUCCESS;
    }

    DayaBay::HeaderObject& ho = hsdb->header();
    put(&ho,ho.defLoc());
    delete data;
    return StatusCode::SUCCESS;
}

StatusCode StagePuller::finalize()
{
    m_stage->release();
    return this->GaudiAlgorithm::finalize();
}

// Local Variables:
// c-basic-offset: 4
// End:

---