AdcProcessor.h

#ifndef HADAQ_ADCPROCESSOR_H
#define HADAQ_ADCPROCESSOR_H
 
#include "hadaq/SubProcessor.h"
 
#include "hadaq/AdcMessage.h"
#include "hadaq/AdcSubEvent.h"
#include <limits>
#include <iostream>
#include <vector>
 
namespace hadaq {
 
class TrbProcessor;
 
class AdcProcessor : public SubProcessor {
 
   friend class TrbProcessor;
 
protected:
 
   struct ChannelRec {
   public:
      ChannelRec() :
         fHValues(0),
         fHWaveform(0),
         fHIntegral(0),
         fHSamples(0),
         fHCoarseTiming(0),
         fHFineTiming(0)
      {}
      base::H1handle fHValues;          
      base::H2handle fHWaveform;        
      base::H1handle fHIntegral;        
      base::H2handle fHSamples;         
      base::H1handle fHCoarseTiming;    
      base::H1handle fHFineTiming;      
   };
 
   const double fSamplingPeriod;      
 
   static std::vector<double> storage;   
 
   base::H1handle fKinds;        
   base::H1handle fChannels;     
   std::vector<ChannelRec>  fCh; 
 
   std::vector<hadaq::AdcMessage>   fStoreVect; 
   std::vector<hadaq::AdcMessage>  *pStoreVect; 
 
   virtual void CreateBranch(TTree*);
 
public:
 
   AdcProcessor(TrbProcessor* trb, unsigned subid, unsigned numchannels = 48,
                double samplingPeriod = 1000.0e-9/80);
   virtual ~AdcProcessor();
 
   inline unsigned NumChannels() const { return fCh.size(); }
 
   virtual bool FirstBufferScan(const base::Buffer& buf);
 
   virtual bool SecondBufferScan(const base::Buffer& buf);
 
   virtual void Store(base::Event*);
   virtual void ResetStore();
};
 
}
 
#endif