// -----------------------------------------------------------------------------
// -----                                                                   -----
// -----                           CbmROCUnpackEpoch                       -----
// -----                    Created 13.12.2014 by F. Uhlig                 -----
// -----                                                                   -----
// -----------------------------------------------------------------------------
#include "CbmROCUnpackEpoch.h"

#include "CbmSourceLmdNew.h"

#include "FairRunOnline.h"
#include "FairLogger.h"

#include <iomanip>


CbmROCUnpackEpoch::CbmROCUnpackEpoch()
  : CbmROCUnpack(),
    fSource(NULL),
    fNofEpochs(0)
{
}
  
CbmROCUnpackEpoch::~CbmROCUnpackEpoch()
{
}


Bool_t CbmROCUnpackEpoch::Init()
{
  FairRunOnline* online = FairRunOnline::Instance();
  fSource = static_cast<CbmSourceLmdNew*>(online->GetSource());
  return kTRUE;
}

Bool_t CbmROCUnpackEpoch::DoUnpack(roc::Message* Message, ULong_t /*hitTime*/)
{

  Int_t rocId          = Message->getRocNumber();
  fSource->SetEpoch(rocId, Message->getEpochNumber());

  if ( rocId ) { return kTRUE; }  // Further action only for ROC Id 0

  ULong_t currentEpochTime = Message->getMsgFullTime(Message->getEpochNumber());
  fNofEpochs++;
  LOG(DEBUG) << GetName() << ": Epoch message "
             << fNofEpochs << ", epoch " << Int_t(Message->getEpochNumber())
             << ", time " << std::setprecision(9) << std::fixed
             << Double_t(currentEpochTime) * 1.e-9 << " s"
             << FairLogger::endl;

  // --- Start and stop time
  if ( fSource->GetStartTime() == 0  || 
       fSource->GetStartTime() > currentEpochTime ) {
    fSource->SetStartTime(currentEpochTime);
  }
  if ( fSource->GetStopTime() < currentEpochTime ) { 
    fSource->SetStopTime(currentEpochTime); 
  }

  return kTRUE;
}

void CbmROCUnpackEpoch::Reset()
{
}

ClassImp(CbmROCUnpackEpoch)