#ifndef GET4_PROCESSOR_H
#define GET4_PROCESSOR_H

#include "base/SysCoreProc.h"

#include "get4/Iterator.h"

namespace get4 {

   enum { NumChannels = 4 };

   struct Get4Rec {
      bool used;

      base::H1handle fChannels;  ///<! histogram with channels

      base::H1handle fRisCoarseTm[NumChannels]; ///< histograms of rising stamp for each channel
      base::H1handle fFalCoarseTm[NumChannels]; ///< histograms of falling stamp for each channel
      base::H1handle fRisFineTm[NumChannels];   ///< histograms of rising stamp for each channel
      base::H1handle fFalFineTm[NumChannels];   ///< histograms of falling stamp for each channel
      base::H1handle fTotTm[NumChannels];       ///< histograms of time-over threshold for each channel

      Get4Rec();
   };

   class Processor : public base::SysCoreProc {

      protected:

         get4::Iterator fIter1;  ///<! first iterator over all messages
         get4::Iterator fIter2;  ///<! second iterator over all messages

         base::H1handle fMsgsKind;   ///<! histogram with messages kinds
         base::H1handle fSysTypes;   ///<! histogram with system types
         base::H1handle fMsgPerGet4;   ///<! histogram with system types

         base::H2handle fSlMsgPerGet4; ///<! histogram with slow control per GET4
         base::H2handle fScalerPerGet4; ///<! histogram with slow control scaler per GET4
         base::H2handle fDeadPerGet4; ///<! histogram with slow control dead time per GET4
         base::H2handle fSpiPerGet4; ///<! histogram with slow control Spi per GET4
         base::H2handle fSeuPerGet4; ///<! histogram with slow control SEU counter per GET4

         base::H2handle fDllPerGet4; ///<! histogram with DLL flag per GET4

         std::vector<get4::Get4Rec> GET4;      ///<! usage masks for nxyters

         unsigned fRefChannelId;              ///<! set channel ID, which used as trigger

         bool   fIgnore250Mhz;                ///<! if set, times of 250 Mhz messages not used for any analysis

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

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

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

         // this constant identify to which extend NX time can be disordered
         double MaximumDisorderTm() const override { return 1e-6; }

         /** Returns true when processor used to select trigger signal */
         bool doTriggerSelection() const override { return (fTriggerSignal < 4) || (fTriggerSignal==10) || (fTriggerSignal==11); }

         int Get4TimeDiff(uint64_t t1, uint64_t t2) { return t1<=t2 ? t2-t1 : -1*((int) (t1-t2)); }

      public:

         Processor(unsigned rocid, unsigned get4mask = 0x3, base::OpticSplitter* spl = nullptr);
         virtual ~Processor();

         void setRefChannel(unsigned ref_get4, unsigned ref_ch, unsigned ref_edge = 0);

         void SetIgnore250Mhz(bool on = true) { fIgnore250Mhz = on; }

         /** Scan all messages, find reference signals */
         bool FirstBufferScan(const base::Buffer& buf) override;

         /** Scan buffer for selecting them inside trigger */
         bool SecondBufferScan(const base::Buffer& buf) override;
   };
}

#endif