BDPipeline.h

Go to the documentation of this file.

#ifndef BDPIPELINE_H
#define BDPIPELINE_H

class RawBeamMonBlock;
class RawBeamMonHeaderBlock;

class BDProcessor;

class MomNavigator;

#include <vector>

class BDPipeline {
public:

    BDPipeline();
    ~BDPipeline();

    typedef std::vector<BDProcessor*> ProcessPipeline;

    ProcessPipeline& GetProcessPipeline();

    void SetSpill(const RawBeamMonHeaderBlock& rbmhb,
                  const RawBeamMonBlock& rbmb);

    template <class ProcessorType> ProcessorType* GetProcessor();

    const RawBeamMonHeaderBlock* GetHeaderBlock() const;

    const RawBeamMonBlock* GetPayloadBlock() const;

private:

    ProcessPipeline fPipe;
    const RawBeamMonBlock* fPayloadBlock;
    const RawBeamMonHeaderBlock* fHeaderBlock;
};

template <class ProcessorType> 
ProcessorType* BDPipeline::GetProcessor()
{
    for (size_t ind=0; ind<fPipe.size(); ++ind) {
        ProcessorType* p = dynamic_cast<ProcessorType*>(fPipe[ind]);
        if (p) return p;
    }
    return 0;
}
#endif  //  BDPIPELINE_H

---