newmonitor/nx/Processor.h (r3879/r3877)

Go to the documentation of this file.

#ifndef NX_PROCESSOR_H
#define NX_PROCESSOR_H

#include "base/SysCoreProc.h"

#include "roc/Iterator.h"

namespace nx {

   class SubEvent;

   struct NxRec {
      bool used;

      base::H1handle fChannels;  
      base::H2handle fADCs;      
      base::H1handle fHITt;      


      // these variables for wrong last-epoch bit detection
      // idea is simple - every readout costs 32 ns
      // if last epoch is appears, one need to have long readout history

/*      unsigned lasthittm;
      unsigned reversecnt;
      unsigned lasthit[128];
      unsigned lastch;
      unsigned lastepoch;
*/
      uint64_t lastfulltm1;
      uint64_t lastfulltm2;

      NxRec() : used(false), fChannels(0), fADCs(0), fHITt(0), lastfulltm1(0), lastfulltm2(0) {}

//      void corr_reset();
//      void corr_nextepoch(unsigned epoch);
//      int corr_nexthit_old(roc::Message& msg, bool docorr = false);
//      int corr_nexthit_next(roc::Message& msg, bool docorr = false);
      int corr_nexthit(roc::Message& msg, uint64_t fulltm, bool docorr = false, bool firstscan = true);
   };

   class Processor : public base::SysCoreProc {

      protected:
         roc::Iterator fIter;  
         roc::Iterator fIter2;  

         base::H1handle fMsgsKind;   
         base::H1handle fSysTypes;   

         std::vector<nx::NxRec> NX;      

         int fNumHits;               
         int fNumBadHits;            
         int fNumCorrHits;           

         bool nx_in_use(unsigned id) { return id < NX.size() ? NX[id].used : false; }

         bool IsValidBufIndex(unsigned indx) const { return indx<fQueue.size(); }

         void AssignBufferTo(roc::Iterator& iter, const base::Buffer& buf);

         // this constant identify to which extend NX time can be disordered
         virtual double MaximumDisorderTm() const { return fNXDisorderTm; }

         virtual unsigned GetTriggerMultipl(unsigned indx);

         virtual void SortDataInSubEvent(base::SubEvent*);

         static double fNXDisorderTm;
         static bool fLastEpochCorr;

      public:

         Processor(unsigned rocid, unsigned nxmask = 0x5);
         virtual ~Processor();

         virtual bool FirstBufferScan(const base::Buffer& buf);

         virtual bool SecondBufferScan(const base::Buffer& buf);

         static void SetDisorderTm(double v) { fNXDisorderTm = v; }
         static void SetLastEpochCorr(bool on) { fLastEpochCorr = on; }
         static bool IsLastEpochCorr() { return fLastEpochCorr; }
   };
}

#endif