SpillProcessor.h

#ifndef HADAQ_SPILLPROCESSOR_H
#define HADAQ_SPILLPROCESSOR_H
 
#include "base/StreamProc.h"
 
namespace hadaq {
 
class SpillProcessor : public base::StreamProc {
 
protected:
   base::H1handle fEvType;    
   base::H1handle fEvSize;    
   base::H1handle fSubevSize; 
 
   base::H1handle fHitsFast; 
   base::H1handle fHitsSlow; 
   base::H1handle fQualitySlow; 
   base::H1handle fTrendXSlow; 
   base::H1handle fTrendYSlow; 
 
   base::H1handle fHitsSpill; 
   base::H1handle fHitsLastSpill; 
 
   base::H1handle fTrendXHaloSlow; 
   base::H1handle fTrendYHaloSlow; 
 
   base::H1handle fTriggerFast; 
   base::H1handle fTriggerSlow; 
 
   base::H1handle fSpill;     
   base::H1handle fLastSpill; 
 
   base::H1handle fBeamX;     
   base::H1handle fBeamY;     
 
   base::H1handle fTrendX;    
   base::H1handle fTrendY;    
 
   base::H2handle fHaloPattern; 
   base::H2handle fVetoPattern; 
 
   long fSumX;  
   long fCntX;  
   long fSumY;  
   long fCntY;   
   long fSumHaloX; 
   long fCntHaloX; 
   long fSumHaloY; 
   long fCntHaloY;  
   unsigned fCurrXYBin;       
   double fLastX;  
   double fLastY; 
   double fLastHaloX;  
   double fLastHaloY;  
 
   unsigned fLastBinFast;  
   unsigned fLastBinSlow;   
   unsigned fLastEpoch;     
   unsigned fLastSpillEpoch; 
   unsigned fLastSpillBin;   
   bool fAutoSpillDetect;    
 
   bool fFirstEpoch;      
 
   double fSpillOnLevel; 
   double fSpillOffLevel; 
   unsigned fSpillMinCnt; 
 
   unsigned fSpillStartEpoch; 
   unsigned fSpillEndEpoch;   
   unsigned fSpillStartCoarse;  
 
   double fMinSpillLength;  
   double fMaxSpillLength; 
 
   unsigned fTdcMin;             
   unsigned fTdcMax;              
 
   unsigned fChannelsLookup1[33];   
   unsigned fChannelsLookup2[33];   
   unsigned fChannelsLookup3[33];   
 
   double fLastQSlowValue;            
 
   int CompareHistBins(unsigned leftbin, unsigned rightbin);
 
   inline unsigned EpochDiff(unsigned ep1, unsigned ep2) { return ep1 <= ep2 ? ep2 - ep1 : ep2 + 0x10000000 - ep1; }
 
   inline unsigned Get1msBin(unsigned ep1, unsigned c1, unsigned ep2, unsigned c2)
   {
      unsigned ediff = EpochDiff(ep1,ep2) * 2048 + c2 - c1; // 5ns
      return ediff / 200000;
   }
 
   double EpochTmDiff(unsigned ep1, unsigned ep2);
 
   void StartSpill(unsigned epoch, unsigned coarse = 0);
   void StopSpill(unsigned epoch);
 
   double CalcQuality(unsigned firstbin, unsigned len);
 
public:
   SpillProcessor();
   virtual ~SpillProcessor();
 
   virtual bool FirstBufferScan(const base::Buffer &buf);
 
   void SetTdcRange(unsigned min, unsigned max)
   {
      fTdcMin = min;
      fTdcMax = max;
   }
 
   void SetSpillDetect(double lvl_on, double lvl_off, unsigned cnt = 3)
   {
      fSpillOnLevel = lvl_on;
      fSpillOffLevel = lvl_off;
      fSpillMinCnt = cnt;
   }
 
   void SetMinSpillLength(double tm = 0.1) { fMinSpillLength = tm; }
   void SetMaxSpillLength(double tm = 10) { fMaxSpillLength = tm; }
 
   void SetChannelsLookup1(unsigned ch, unsigned lookup) { fChannelsLookup1[ch] = lookup; }
   void SetChannelsLookup2(unsigned ch, unsigned lookup) { fChannelsLookup2[ch] = lookup; }
   void SetChannelsLookup3(unsigned ch, unsigned lookup) { fChannelsLookup3[ch] = lookup; }
 
   void SetSpillChannel(unsigned ch)
   {
      SetChannelsLookup3(ch, 401);
      fAutoSpillDetect = false;
   }
 
   void SetTriggerChannel(unsigned ch)
   {
      SetChannelsLookup3(ch, 402);
   }
 
};
}
 
#endif