StartProcessor.h

#ifndef HADAQ_STARTPROCESSOR_H
#define HADAQ_STARTPROCESSOR_H
 
#include "base/StreamProc.h"
 
namespace hadaq {
 
class StartProcessor : public base::StreamProc {
 
protected:
   base::H1handle fEvType;    
   base::H1handle fEvSize;    
   base::H1handle fSubevSize; 
 
   base::H1handle fEpochDiff;  
 
   unsigned fStartId; 
 
   unsigned fTdcMin; 
   unsigned fTdcMax; 
 
   inline int EpochDiff(unsigned ep1, unsigned ep2)
   {
      unsigned res = ep1 <= ep2 ? ep2 - ep1 : ep2 + 0x10000000 - ep1;
 
      return res < 0x8000000 ? res : (int) res - 0x10000000;
   }
 
   double EpochTmDiff(unsigned ep1, unsigned ep2);
 
public:
   StartProcessor();
   virtual ~StartProcessor();
 
   virtual bool FirstBufferScan(const base::Buffer &buf);
 
   void SetStartId(unsigned id)
   {
      fStartId = id;
   }
 
   void SetTdcRange(unsigned min, unsigned max)
   {
      fTdcMin = min;
      fTdcMax = max;
   }
};
}
 
#endif