SubProcessor.h

#ifndef HADAQ_SUBPROCESSOR_H
#define HADAQ_SUBPROCESSOR_H
 
#include "base/StreamProc.h"
 
#include "hadaq/definess.h"
 
#include <map>
 
 
namespace hadaq {
 
   class SubProcessor;
   class TrbProcessor;
   class HldProcessor;
 
   typedef std::map<unsigned,SubProcessor*> SubProcMap;
 
   class SubProcessor : public base::StreamProc {
 
      friend class TrbProcessor;
 
      protected:
         TrbProcessor *fTrb;   
         unsigned fSeqeunceId; 
         bool fIsTDC;          
 
         base::H1handle *fMsgPerBrd;  
         base::H1handle *fErrPerBrd;  
         base::H1handle *fHitsPerBrd; 
         base::H2handle *fCalHitsPerBrd; 
         base::H2handle *fToTPerBrd;  
 
         bool fNewDataFlag;  
         bool fPrintRawData; 
         bool fCrossProcess; 
 
         SubProcessor(TrbProcessor *trb, const char* nameprefix, unsigned subid);
 
         virtual void BeforeFill() {}
 
         virtual void AfterFill(SubProcMap* = nullptr) {}
 
         virtual void AppendTrbSync(uint32_t) {}
 
         void SetNewDataFlag(bool on) { fNewDataFlag = on; }
         bool IsNewDataFlag() const { return fNewDataFlag; }
 
         void AssignPerBrdHistos(TrbProcessor *trb, unsigned seqid);
 
      public:
 
         virtual ~SubProcessor() {}
 
         virtual void UserPreLoop();
 
         inline bool IsTDC() const { return fIsTDC; }
 
         void SetPrintRawData(bool on = true) { fPrintRawData = on; }
         bool IsPrintRawData() const { return fPrintRawData; }
 
         bool IsCrossProcess() const { return fCrossProcess; }
 
         HldProcessor *GetHLD() const;
 
   };
 
}
 
#endif