// ------------------------------------------------------------------
// -----                     TGet4v1Rec.cxx                     -----
// -----              Created 22/07/2013 by P.-A. Loizeau       -----
// -----                 Adapted from TGet4v1Rec.cxx            -----
// -----         in RocLib/beamtime/tof-tdctest rev.4862        -----
// ------------------------------------------------------------------

#include "TGet4v1Rec.h"

TimeWindowCond::TimeWindowCond():
   TNamed("", "Time Window Condition")
{
   fdLowT  = 0.0;
   fdHighT = 0.0;
}
TimeWindowCond::TimeWindowCond( const char* name, Double_t tLow, Double_t tHigh ):
   TNamed( name, "Time Window Condition" )
{
   fdLowT  = tLow;
   fdHighT = tHigh;
}

void TimeWindowCond::SetValues( Double_t tLow, Double_t tHigh )
{
   fdLowT  = tLow;
   fdHighT = tHigh;
}
void TimeWindowCond::Clear(Option_t *t)
{
   TNamed::Clear( t );
   fdLowT  = 0.0;
   fdHighT = 0.0;
}

Bool_t TimeWindowCond::Test( Double_t dValToTest)
{
   if( fdLowT <= dValToTest && dValToTest <= fdHighT)
      return kTRUE;
      else return kFALSE;
}

TGet4v1Rec::TGet4v1Rec()
{
   fRocId = 0;

   fAUXch = 0;
   fMsgTypes = 0;
   fSysTypes = 0;
   fSysUserTypes = 0;
   fTrigger_All = 0;
   fTrigger_All_100 = 0;
   fTrigger_All_us = 0;
   fTrigger_All_ms = 0;
   fTrigger_All_s = 0;
   fTriggerWind = 0; // time window to assign hits to event
   fAUXWind = 0; // time window to assign AUX to event
   fEvntMultipl = 0; // event multiplicity in time window after trigger signal

   fLastTm = 0;  //
   fLastTriggerTm = 0;

   for (int n=0;n<get4v10::kiMaxAux;n++) fLastAuxTm[n] = 0;
   for (int n=0;n<get4v10::kiMaxSync;n++) {
      fLastSyncTm[n] = 0;
      fLastSyncId[n] = 0;
   }
   fStartSyncTm = 0;
   fStopSyncTm = 0;

   for (int aux=0;aux<get4v10::kiMaxAux;aux++)
      fAUXt[aux] = 0; // time distribution of aux signals
   for (int n=0;n<get4v10::kiMaxSync;n++)
   {
      fSYNCt[n] = 0; // time distribution of sync signals
      fSyncLongT[n] = 0; // time distribution of sync signals
   }
   fALLt  = 0;
   fDATAt = 0;
   fERRORt = 0;
   fSLOWCt = 0;
   fSelfTriggT = 0;
   fEPOCHt = 0;
   fAllSelectedT = 0;

   // Long duration time distribution (1 min. bin, 10 days length)
   fAllLongT       = 0;
   fDataLongT      = 0;
   fErrorLongT     = 0;
   fSlowCLongT     = 0;
   fSelfTriggLongT = 0;
   fEpochLongT     = 0;
   fAllEpoch2LongT = 0;
   fAllSelLongT    = 0;

   fUnprocessedMsg.clear();

   fDabcSeparator=-1;

   bIgnoreData = kFALSE;
   fIgnoreCnt = 0;
   fIgnoreTime = 0;       // time when ignore message was generated
   fCollectTime = 0;      // time when collect message was generated

   /** GET4 unpacking & pre-processing **/
   /*************************************/

   /* Modified part */

      // Epochs
   fuCurrEpoch = 0;             // current epoch on the roc
   fuEpochCycle = 0;            // Number of time the epoch counter cycled
   for( Int_t iGet4 = 0; iGet4 < get4v10::kiMaxGet4Roc; iGet4++)
   {
      fEPOCH2t[iGet4] = 0;
      fuCurrEpoch2[iGet4] = 0;  // current epoch2 for each get4 chip
      fuEpoch2Cycle[iGet4] = 0; // Number of time the epoch2 counter cycled
      fiEpochShift[iGet4] = 0;
      fuNbShiftedEpochs[iGet4] = 0;
      fEpochShiftsDuration[iGet4] = 0;
      fuEpochWithData[iGet4] = 0; // Data flag for suppressed epoch mode
      fEpSuppBuffer[iGet4].clear(); // temp buffer in supp epoch mode to wait for epoch message
   }
   fDistribEpochs      = 0;
   fDistribEpochs2     = 0;
   fEpochShiftsPerChip = 0;
   fEpochShiftsDurationPerChip = 0;

      // Buffers
   fbBufferWithLastFullEpoch = kFALSE;
   fPrevEpochsBuffer[0].clear(); // buffer of all ROC messages in current epoch and previous one
   fPrevEpochsBuffer[1].clear(); // buffer of all ROC messages in current epoch and previous one
   fbEpochSinceTrigger = kFALSE;
   for( Int_t iGet4 = 0; iGet4 < get4v10::kiMaxGet4Roc; iGet4++)
   {
      fbBufferWithLastFullEpoch2[iGet4] = kFALSE;
      fPrevEpochs2Buffer[iGet4][0].clear(); // buffer of all get4 messages in current epoch and previous one
      fPrevEpochs2Buffer[iGet4][1].clear(); // buffer of all get4 messages in current epoch and previous one
      bLookInPreviousEpoch[iGet4] = kFALSE;
      bLookInNextEpoch[iGet4] = kFALSE;
      fbEpoch2SinceTrigger[iGet4]= kFALSE;

      for( Int_t iGet4Chan = 0; iGet4Chan < get4v10::kuNbChan; iGet4Chan++)
      {
         fSelectedT[iGet4][iGet4Chan] = 0;
         fTrigger_Get4Channel[iGet4][iGet4Chan] = 0;
         fTriggerMs_Get4Channel[iGet4][iGet4Chan] = 0;
         fTriggerS_Get4Channel[iGet4][iGet4Chan] = 0;
         fbDllFlag[iGet4][iGet4Chan] = kFALSE;

         fbDataTimeOut[iGet4][iGet4Chan] = kFALSE;
         fbDataFallingOut[iGet4][iGet4Chan] = kFALSE;

         fLastExtMess[iGet4][iGet4Chan].Clear();
      } // for( Int_t iGet4Chan = 0; iGet4Chan < get4v10::kuNbChan; iGet4Chan++)
      fGet4V1HitsDistanceNs[iGet4] = 0;
      fGet4V1HitsDistanceUs[iGet4] = 0;
      fGet4V1HitsDistanceMs[iGet4] = 0;
      fGet4V1HitsDistanceS[iGet4]  = 0;
   } // for( Int_t iGet4 = 0; iGet4 < get4v10::kiMaxGet4Roc; iGet4++)
   fb24bitsReadoutDetected = kFALSE;
   fb32bitsReadoutDetected = kFALSE;

      // HitsSelection
   fbSelectionRocDone   = kTRUE;
   for( Int_t iGet4 = 0; iGet4 < get4v10::kiMaxGet4Roc; iGet4++)
   {
      fbSelectionDone[iGet4]      = kTRUE;
   }

      // Triggering on data themselves
   fDataSelfTriggerPerEvent = 0;
   fDataSelfTrigDistanceNs  = 0;
   fDataSelfTrigDistanceUs  = 0;
   fDataSelfTrigDistanceMs  = 0;
   fDataSelfTrigDistanceS   = 0;
   for( Int_t iTrigger = 0; iTrigger < get4v10::kiMaxNbDataTriggs; iTrigger++)
   {
      fuDataSelfTriggerCount[iTrigger] = 0;
      fdLastFullTimeSelfTrigger[iTrigger] = 0;
      fextMessLastMainChannel[iTrigger].Clear();
      fdLastFullTimeMainChannelTot[iTrigger]  = 0;
      for( Int_t iSecTriggerChan = 0; iSecTriggerChan < get4v10::kiMaxNbSecTriggCh; iSecTriggerChan++)
      {
         fdLastFullTimeSecChannel[iTrigger][iSecTriggerChan]  = 0;
         fdLastFullTimeSecChannelTot[iTrigger][iSecTriggerChan]  = 0;
      }
   }

   // Event statistics
   fNbEventsPerMbsEvent = 0;
   fNbNotEmptyEventsPerMbsEvent = 0;
   fChannelsMapping = 0;
   fChannelInputMessCount = 0;
   fChannelMultiplicity = 0;
   fdRateEvolutionBinSize = 0;
   for( Int_t iGet4 = 0; iGet4 < get4v10::kiMaxGet4Roc; iGet4++)
   {
      fuNbHitsChipEpoch[iGet4] = 0;
      fChipRateEvolution[iGet4]    = 0;
      for( Int_t iGet4Chan = 0; iGet4Chan < get4v10::kuNbChan; iGet4Chan++)
      {
         fChannelRateEvolution[iGet4][iGet4Chan] = 0;
      } // for( Int_t iGet4Chan = 0; iGet4Chan < get4v10::kuNbChan; iGet4Chan++)
   } //  for( Int_t iGet4 = 0; iGet4 < get4v10::kiMaxGet4Roc; iGet4++)

}

ULong64_t TGet4v1Rec::GetFullEpochNumber()
{
   return (ULong64_t)(fuCurrEpoch) +
           ( (ULong64_t)(get4v10::kulMainEpochCycleSz) +1)*(ULong64_t)(fuEpochCycle);
}
ULong64_t TGet4v1Rec::GetFullEpoch2Number( UInt_t uGet4Id)
{
   return (ULong64_t)(fuCurrEpoch2[uGet4Id]) +
           ( (ULong64_t)(get4v10::kulGet4EpochCycleSz) +1)*(ULong64_t)(fuEpoch2Cycle[uGet4Id]);
}

// Functions to overcome the 32 bit limit in epoch number as input to
// GetMessageFullTime function

ULong64_t TGet4v1Rec::GetSuperCycleEpOffset( )
{
   // Nb of epoch lost by MessageTime function due to 32b limit
//   ULong64_t ulNb32bCycles = GetFullEpochNumber() / ( 0x100000000ULL );
   ULong64_t ulNb32bCycles = GetFullEpochNumber() >> 32;
   if( 0 < ulNb32bCycles)
      return (ULong64_t)( ulNb32bCycles * ( 0x100000000ULL ) )<<14; // epoch nb lost due to 32 bit limit, shifted in ns
   else return 0;
}
ULong64_t TGet4v1Rec::GetSuperCycleEp2Offset( UInt_t uGet4Id)
{
   // Nb of epoch lost by MessageTime function due to 32b limit
//   ULong64_t ulNb32bCycles = GetFullEpoch2Number( uGet4Id) / ( 0x100000000ULL );
   ULong64_t ulNb32bCycles = GetFullEpoch2Number( uGet4Id) >> 32;
   if( 0 < ulNb32bCycles)
      return (ULong64_t)( ulNb32bCycles * ( 0x100000000ULL ) )* // epoch nb lost due to 32 bit limit
              (ULong64_t)( get4tdc::kdEpochInPs / 1000 ); // Get4 epoch in ns
   return 0;
}
Double_t TGet4v1Rec::GetSuperCycleEp2OffsetD( UInt_t uGet4Id)
{
   // Nb of epoch lost by MessageTime function due to 32b limit
//   ULong64_t ulNb32bCycles = GetFullEpoch2Number( uGet4Id) / ( 0x100000000ULL );
   ULong64_t ulNb32bCycles = GetFullEpoch2Number( uGet4Id) >> 32;
   if( 0 < ulNb32bCycles)
      return (Double_t)( ulNb32bCycles * ( 0x100000000ULL ) )* // epoch nb lost due to 32 bit limit
              (Double_t)( get4tdc::kdEpochInPs) / 1000.0 ; // Get4 epoch in ns
   return 0.0;
}