beamtime/tof-tdctest/go4/GET4V10/TGet4v1Proc.h (r4864/r4849)

Go to the documentation of this file.

#ifndef TGET4V1PROC_H
#define TGET4V1PROC_H

#include "roc/Iterator.h"

#include <vector>
#include <stdint.h>

#include "TCBMBeamtimeProc.h"

#include "roc/Message.h"
#include "roc/Board.h"

class TGet4v1Param;
class TGo4MbsSubEvent;
class TGet4MessageFull;

#include "TGet4v1Event.h"
#include "TGet4v1Rec.h"


class TGet4v1Proc : public TCBMBeamtimeProc {
   public:
      TGet4v1Proc();  // <- Done
      TGet4v1Proc(const char* name);
      virtual ~TGet4v1Proc() ;                                                          // <- Done

      virtual void InitEvent(TGo4EventElement * evt);                                   // <- Done

      virtual void ProcessSubevent(TGo4MbsSubEvent* subevt);                           // <- Done

      virtual void FinalizeEvent();

   protected:

      void ProcessExtendedMessage(UInt_t uRocId, TGet4v1MessageExtended& extMess);     // <- Done
      void ProcessTriggerMessage(UInt_t uRocId, TGet4v1MessageExtended& extMess,
                                     Int_t iTriggerIndex = -1);                           // <- Done
      Bool_t BuildHits(UInt_t uRocId, UInt_t uGet4Id, Bool_t bBufferToBuild);                // <- Done
      Bool_t CheckHit(UInt_t uRocId, UInt_t uGet4Id, Get4v1Hit& hit);                    // <- Done

      void CheckEventClosure();                                                         // <- Done

      Bool_t ProcessRocSyncMessage(    UInt_t uRocId, TGet4v1MessageExtended& extMess); // <- Done
      Bool_t ProcessRocEpochMessage(  UInt_t uRocId, TGet4v1MessageExtended& extMess);  // <- Done
      Bool_t ProcessGet4EpochMessage(  UInt_t uRocId, TGet4v1MessageExtended& extMess); // <- Done
      Bool_t ProcessGet4DataMessage(   UInt_t uRocId, TGet4v1MessageExtended& extMess); // <- Done
      Bool_t ProcessGet4ExtSyncMessage(UInt_t uRocId, TGet4v1MessageExtended& extMess); // <- NOT Done
      Bool_t ProcessGet4SuppEpochMessage(  UInt_t uRocId, TGet4v1MessageExtended& extMess); // <- Done
      Bool_t ProcessGet4SuppDataMessage(   UInt_t uRocId, TGet4v1MessageExtended& extMess); // <- Done
      Bool_t ProcessGet4ReprocessSuppData( UInt_t uRocId, UInt_t uGet4Id ); // <- Done
      
      Int_t Process32BitGet4Message(UInt_t uRocId, TGet4v1MessageExtended& extMess);   // <- Done

      Bool_t fb24bitsReadoutDetected;
      Bool_t fb32bitsReadoutDetected;
      Bool_t AnalyzeAllGet4Channels( Get4v1Event &eventFull );                          // <- Done
      Bool_t AnalyzeAllGet4Channels24Bits( Get4v1Event &eventFull );                   // <- Done
      Bool_t AnalyzeAllGet4Channels32Bits( Get4v1Event &eventFull );                   // <- Done

      Bool_t PrintRocEpochIndexes(UInt_t uRocId, Int_t uMessagePriority = 0);           // <- Done
      Bool_t PrintRocEpochCycles(UInt_t uRocId, Int_t uMessagePriority = 0);            // <- Done

      /* after event completion reset until next triggers are found*/
      void ResetTrigger();

      /* after all input buffers are done, we reset end of buffer flag*/
      void ResetEndOfBuffer();

      /* For Debug histograms*/
      void UpdateLeadingDnlHistograms( Get4v1Event &eventFull, UInt_t uRocId = 0 );
      void UpdateTrailingDnlHistograms( Get4v1Event &eventFull, UInt_t uRocId = 0 );

      TGet4v1Param   *fParam;
      TGet4v1Event *fOutputEvent;  
      Get4v1Event   fCurrentGet4Event;

      Bool_t fIsTimeSorted; // true if messages within mbs container are strictly time sorted

      TH1           *fEvntSize;
      TH1           *fEvtPerProc;
      TH1           *fEvtIndexRoc;
      TH1           *fEvtIndexTrig;
      TH1           *fEvtIndexVme;
      UInt_t uInitialEvent;
      UInt_t uEventCountsRoc;
      UInt_t uEventCountsTrig;
      UInt_t uEventCountsVme;
      TH1           *fTriggerNumber;

      TH1           *fMsgsPerRoc;
      TH1           *fTriggerPerRoc;

      TH1* fDeltaTriggerTime;            // absolute time difference of all hits with respect to global trigger
      TGo4WinCond* fGlobalTriggerWind;   // time window to assign hits to output event (relative to last global trigger)
      TGo4WinCond* fGlobalAUXWind;       // time window to assign AUX to output event (relative to last global trigger)
      TGo4WinCond* fGlobalSelfTriggWind; // time window to detect coincidence of channel in self triggering case

      ULong_t fTotaldatasize;

      UInt_t         fCurrEvntTm;

      Double_t       fLastRateTm; // last time of rate measurement
      Double_t       fRate;       // currently calculated rate

      std::vector<TGet4v1Rec> ROC;  
      Bool_t fFirstSubEvent;     

      Bool_t fHasNewGlobalTrigger; 
      unsigned fTriggerCounter; 
      

      // General counters (allow for example event jumps by stream server)
      UInt_t     printData;
      UInt_t     uNbEvents[MAX_ROC];
      UInt_t     uFirstEventIndex[MAX_ROC];
      UInt_t     uPrevEventIndex[MAX_ROC];
      
      // Real events counters
      UInt_t     uEventInsideMbsEvtCount[MAX_ROC];
      UInt_t     uRealEventsCount[MAX_ROC];
      UInt_t     uNotEmptyEventInsideMbsEvtCount[MAX_ROC];
      UInt_t     uNotEmptyRealEventsCount[MAX_ROC];

      // Variables
      Get4v1Hit fHitTemp;
      // Histograms
      

      // Get4 v1.0

      // 24 bits

      // 32 bits
   private:

      /*#  TGet4v1Rec lnkTGet4v1Rec; */


      ClassDef(TGet4v1Proc,1)
};

#endif //TGET4V1PROC_H