BDPipeline.cxx

Go to the documentation of this file.

#include "BDPipeline.h"
#include "BDProcessor.h"

#include <MinosObjectMap/MomNavigator.h>
#include <RawData/RawRecord.h>
#include <RawData/RawDataBlock.h>
#include <RawData/RawBeamMonHeaderBlock.h>
#include <RawData/RawBeamMonBlock.h>


using namespace std;

BDPipeline::BDPipeline()
{
}

BDPipeline::~BDPipeline()
{
    while (fPipe.size()) {
        delete fPipe.back();
        fPipe.pop_back();
    }
}


void BDPipeline::SetSpill(const RawBeamMonHeaderBlock& rbmhb,
                          const RawBeamMonBlock& rbmb)
{
    fPayloadBlock = &rbmb;
    fHeaderBlock = &rbmhb;

    size_t siz = fPipe.size();
    for (size_t ind=0; ind<siz; ++ind) {
        fPipe[ind]->SetSpill(*fHeaderBlock,*fPayloadBlock);
    }
}

const RawBeamMonHeaderBlock* BDPipeline::GetHeaderBlock() const
{
    return fHeaderBlock;
}

const RawBeamMonBlock* BDPipeline::GetPayloadBlock() const
{
    return fPayloadBlock;
}
BDPipeline::ProcessPipeline& BDPipeline::GetProcessPipeline() 
{
    return fPipe;
}

---