CbmMcbm2018UnpackerAlgoPsd.cxx

Go to the documentation of this file.

/* Copyright (C) 2019-2021 GSI Helmholtzzentrum fuer Schwerionenforschung, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Nikolay Karpushkin, David Emschermann [committer], Pierre-Alain Loizeau */
 
// -----------------------------------------------------------------------------
// -----                                                                   -----
// -----                     CbmMcbm2018UnpackerAlgoPsd                    -----
// -----                 Created 09.10.2019 by N.Karpushkin                -----
// -----        based on CbmMcbm2018UnpackerAlgoTof by P.-A. Loizeau       -----
// -----                                                                   -----
// -----------------------------------------------------------------------------
 
#include "CbmMcbm2018UnpackerAlgoPsd.h"
 
#include "CbmFormatMsHeaderPrintout.h"
#include "CbmMcbm2018PsdPar.h"
#include "CbmPsdAddress.h"
#include "TCanvas.h"
#include "TH1.h"
#include "TH2.h"
#include "TList.h"
#include "TProfile.h"
#include "TROOT.h"
#include "TString.h"
 
#include <Logger.h>
 
#include <cstdint>
#include <fstream>
#include <iomanip>
#include <iostream>
 
// -------------------------------------------------------------------------
CbmMcbm2018UnpackerAlgoPsd::CbmMcbm2018UnpackerAlgoPsd()
  : CbmStar2019Algo()
{
}
 
CbmMcbm2018UnpackerAlgoPsd::~CbmMcbm2018UnpackerAlgoPsd()
{
  if (nullptr != fPsdDigiVector) {
    fPsdDigiVector->clear();
    delete fPsdDigiVector;
  }
  if (nullptr != fPsdDspVector) {
    fPsdDspVector->clear();
    delete fPsdDspVector;
  }
}
 
// -------------------------------------------------------------------------
Bool_t CbmMcbm2018UnpackerAlgoPsd::Init()
{
  LOG(info) << "Initializing mCBM PSD 2019 unpacker algo";
 
  return kTRUE;
}
void CbmMcbm2018UnpackerAlgoPsd::Reset()
{
  if (fPsdDigiVector) fPsdDigiVector->clear();
  if (fPsdDspVector) fPsdDspVector->clear();
}
void CbmMcbm2018UnpackerAlgoPsd::Finish() {}
 
// -------------------------------------------------------------------------
Bool_t CbmMcbm2018UnpackerAlgoPsd::InitContainers()
{
  LOG(info) << "Init parameter containers for CbmMcbm2018UnpackerAlgoPsd";
  Bool_t initOK = ReInitContainers();
 
  return initOK;
}
Bool_t CbmMcbm2018UnpackerAlgoPsd::ReInitContainers()
{
  LOG(info) << "**********************************************";
  LOG(info) << "ReInit parameter containers for CbmMcbm2018UnpackerAlgoPsd";
 
  fUnpackPar = (CbmMcbm2018PsdPar*) fParCList->FindObject("CbmMcbm2018PsdPar");
  if (nullptr == fUnpackPar) return kFALSE;
 
  Bool_t initOK = InitParameters();
 
  return initOK;
}
TList* CbmMcbm2018UnpackerAlgoPsd::GetParList()
{
  if (nullptr == fParCList) fParCList = new TList();
  fUnpackPar = new CbmMcbm2018PsdPar("CbmMcbm2018PsdPar");
  fParCList->Add(fUnpackPar);
 
  return fParCList;
}
Bool_t CbmMcbm2018UnpackerAlgoPsd::InitParameters()
{
  fuRawDataVersion = fUnpackPar->GetDataVersion();
  LOG(info) << "Data Version: " << fuRawDataVersion;
 
  fuNrOfGdpbs = fUnpackPar->GetNrOfGdpbs();
  LOG(info) << "Nr. of Tof GDPBs: " << fuNrOfGdpbs;
 
  fuNrOfFeePerGdpb = fUnpackPar->GetNrOfFeesPerGdpb();
  LOG(info) << "Nr. of FEEs per Psd GDPB: " << fuNrOfFeePerGdpb;
 
  fuNrOfChannelsPerFee = fUnpackPar->GetNrOfChannelsPerFee();
  LOG(info) << "Nr. of channels per FEE: " << fuNrOfChannelsPerFee;
 
  fuNrOfChannelsPerGdpb = fuNrOfChannelsPerFee * fuNrOfFeePerGdpb;
  LOG(info) << "Nr. of channels per GDPB: " << fuNrOfChannelsPerGdpb;
 
  fGdpbIdIndexMap.clear();
  for (UInt_t i = 0; i < fuNrOfGdpbs; ++i) {
    fGdpbIdIndexMap[fUnpackPar->GetGdpbId(i)] = i;
    LOG(info) << "GDPB Id of PSD  " << i << " : " << std::hex << fUnpackPar->GetGdpbId(i) << std::dec;
  }  // for( UInt_t i = 0; i < fuNrOfGdpbs; ++i )
 
  fuNrOfGbtx = fUnpackPar->GetNrOfGbtx();
  LOG(info) << "Nr. of GBTx: " << fuNrOfGbtx;
 
  //Temporary until creation of full psd map
  UInt_t uNrOfModules  = 1;
  UInt_t uNrOfSections = 32;
  UInt_t uNrOfChannels = uNrOfModules * uNrOfSections;
  LOG(info) << "Nr. of possible Psd channels: " << uNrOfChannels;
  fviPsdChUId.resize(uNrOfChannels);
 
  UInt_t iCh = 0;
  for (UInt_t iModule = 0; iModule < uNrOfModules; ++iModule) {
    for (UInt_t iSection = 0; iSection < uNrOfSections; ++iSection) {
      iCh              = iModule * uNrOfSections + iSection;
      fviPsdChUId[iCh] = CbmPsdAddress::GetAddress(iModule, iSection);
    }
  }
 
  return kTRUE;
}
// -------------------------------------------------------------------------
 
void CbmMcbm2018UnpackerAlgoPsd::AddMsComponentToList(size_t component, UShort_t usDetectorId)
{
  for (UInt_t uCompIdx = 0; uCompIdx < fvMsComponentsList.size(); ++uCompIdx)
    if (component == fvMsComponentsList[uCompIdx]) return;

  fvMsComponentsList.push_back(component);
 
  LOG(info) << "CbmMcbm2018UnpackerAlgoPsd::AddMsComponentToList => Component " << component << " with detector ID 0x"
            << std::hex << usDetectorId << std::dec << " added to list";
}
// -------------------------------------------------------------------------
 
Bool_t CbmMcbm2018UnpackerAlgoPsd::ProcessTs(const fles::Timeslice& ts)
{
 
  fulCurrentTsIdx = ts.index();
  fdTsStartTime   = static_cast<Double_t>(ts.start_time());

  if (0 == fulCurrentTsIdx) { return kTRUE; }  // if( 0 == fulCurrentTsIdx )

  if (-1.0 == fdTsCoreSizeInNs) {
    fuNbCoreMsPerTs  = ts.num_core_microslices();
    fuNbOverMsPerTs  = ts.num_microslices(0) - ts.num_core_microslices();
    fdTsCoreSizeInNs = fdMsSizeInNs * (fuNbCoreMsPerTs);
    fdTsFullSizeInNs = fdMsSizeInNs * (fuNbCoreMsPerTs + fuNbOverMsPerTs);
    LOG(info) << "Timeslice parameters: each TS has " << fuNbCoreMsPerTs << " Core MS and " << fuNbOverMsPerTs
              << " Overlap MS, for a core duration of " << fdTsCoreSizeInNs << " ns and a full duration of "
              << fdTsFullSizeInNs << " ns";

    fuNbMsLoop = fuNbCoreMsPerTs;
    if (kFALSE == fbIgnoreOverlapMs) fuNbMsLoop += fuNbOverMsPerTs;
    LOG(info) << "In each TS " << fuNbMsLoop << " MS will be looped over";
  }  // if( -1.0 == fdTsCoreSizeInNs )

  fdTsStopTimeCore = fdTsStartTime + fdTsCoreSizeInNs;
  //      LOG(info) << Form( "TS %5d Start %12f Stop %12f", fulCurrentTsIdx, fdTsStartTime, fdTsStopTimeCore );
 
  fDigiVect.clear();
  for (fuMsIndex = 0; fuMsIndex < fuNbMsLoop; fuMsIndex++) {
    for (UInt_t uMsCompIdx = 0; uMsCompIdx < fvMsComponentsList.size(); ++uMsCompIdx) {
      UInt_t uMsComp = fvMsComponentsList[uMsCompIdx];
      if (kFALSE == ProcessMs(ts, uMsComp, fuMsIndex)) {
        LOG(error) << "Failed to process ts " << fulCurrentTsIdx << " MS " << fuMsIndex << " for component " << uMsComp;
        return kFALSE;
      }  // if( kFALSE == ProcessMs( ts, uMsCompIdx, fuMsIndex ) )
    }    // for( UInt_t uMsCompIdx = 0; uMsCompIdx < fvMsComponentsList.size(); ++uMsCompIdx )
  }      // for( fuMsIndex = 0; fuMsIndex < uNbMsLoop; fuMsIndex ++ )

  //std::sort(fDigiVect.begin(), fDigiVect.end(),
  // [](const CbmPsdDigi& a, const CbmPsdDigi& b) -> bool { return a.GetTime() < b.GetTime(); });
 
  std::sort(fPsdDigiVector->begin(), fPsdDigiVector->end(),
            [](const CbmPsdDigi& a, const CbmPsdDigi& b) -> bool { return a.GetTime() < b.GetTime(); });
 
  if (fbDebugWriteOutput && (fPsdDspVector != nullptr)) {
    std::sort(fPsdDspVector->begin(), fPsdDspVector->end(),
              [](const CbmPsdDsp& a, const CbmPsdDsp& b) -> bool { return a.GetTime() < b.GetTime(); });
  }
 
  return kTRUE;
}
 
 
Bool_t CbmMcbm2018UnpackerAlgoPsd::ProcessMs(const fles::Timeslice& ts, size_t uMsCompIdx, size_t uMsIdx)
{
  auto msDescriptor        = ts.descriptor(uMsCompIdx, uMsIdx);
  fuCurrentEquipmentId     = msDescriptor.eq_id;
  const uint8_t* msContent = reinterpret_cast<const uint8_t*>(ts.content(uMsCompIdx, uMsIdx));
 
  uint32_t uSize  = msDescriptor.size;
  fulCurrentMsIdx = msDescriptor.idx;
 
  fdMsTime = static_cast<double>(fulCurrentMsIdx);
 
  LOG(debug) << "Microslice: " << fulCurrentMsIdx << " from EqId " << std::hex << fuCurrentEquipmentId << std::dec
             << " has size: " << uSize;
 
  if (0 == fvbMaskedComponents.size()) fvbMaskedComponents.resize(ts.num_components(), kFALSE);
 
  fuCurrDpbId = static_cast<uint32_t>(fuCurrentEquipmentId & 0xFFFF);

  auto it = fGdpbIdIndexMap.find(fuCurrDpbId);
  if (it == fGdpbIdIndexMap.end()) {
    if (kFALSE == fvbMaskedComponents[uMsCompIdx]) {
      LOG(info) << "---------------------------------------------------------------";
 
      LOG(info) << FormatMsHeaderPrintout(msDescriptor);
      LOG(warning) << "Could not find the gDPB index for AFCK id 0x" << std::hex << fuCurrDpbId << std::dec
                   << " in timeslice " << fulCurrentTsIdx << " in microslice " << uMsIdx << " component " << uMsCompIdx
                   << "\n"
                   << "If valid this index has to be added in the PSD "
                      "parameter file in the DbpIdArray field";
      fvbMaskedComponents[uMsCompIdx] = kTRUE;
    }  // if( kFALSE == fvbMaskedComponents[ uMsComp ] )
    else
      return kTRUE;

 
 
    return kFALSE;
 
  }  // if( it == fGdpbIdIndexMap.end() )
  else
    fuCurrDpbIdx = fGdpbIdIndexMap[fuCurrDpbId];
 
  fuCurrentMsSysId = static_cast<unsigned int>(msDescriptor.sys_id);
 
  // If not integer number of message in input buffer, print warning/error
  if (0 != (uSize % kuBytesPerMessage))
    LOG(error) << "The input microslice buffer does NOT "
               << "contain only complete nDPB messages!";

  if (fdStartTime < 0) fdStartTime = fdMsTime;
  Double_t dMsRelativeTime = fdMsTime - fdTsStartTime;
 
  // If MS time is less than start time print error and return
  if (fdMsTime - fdStartTime < 0) {
    LOG(error) << "CbmMcbm2018UnpackerAlgoPsd:: Negative time! MS time = " << fdMsTime
               << "; Start time = " << fdStartTime;
    //return kFALSE;
  }
 
  // Compute the number of complete messages in the input microslice buffer
  uint32_t uNbMessages = (uSize - (uSize % kuBytesPerMessage)) / kuBytesPerMessage;
 
  // Prepare variables for the loop on contents
  const uint64_t* pInBuff = reinterpret_cast<const uint64_t*>(msContent);
 
  /*
  if (uSize != 0) {
    printf("%u = %u 64bit messages\n", uSize, uNbMessages);
    for(uint32_t line_iter = 0; line_iter<uNbMessages; line_iter++){
      printf("%016lx\n", (pInBuff[line_iter])); 
    }
  }
*/
 
  if ((fair::Logger::Logging(fair::Severity::debug)) && (uNbMessages > 1)) {
    printf("%u = %u 64bit messages\n", uSize, uNbMessages);
    for (uint32_t line_iter = 0; line_iter < uNbMessages - 2; line_iter += 2) {
      printf("%010llx", static_cast<unsigned long long int>(pInBuff[line_iter] & 0xffffffffff));
      printf("%010llx", static_cast<unsigned long long int>(pInBuff[line_iter + 1] & 0xffffffffff));
      printf("   %u - %u", line_iter + 1, line_iter + 2);
      printf("\n");
    }
    printf("%020llx   %u\n", static_cast<unsigned long long int>(pInBuff[uNbMessages - 1]), uNbMessages);
  }
 
  // every 80bit gbt word is decomposed into two 64bit words
  if (uNbMessages > 1) {  //more than one 64 bit word
 
    switch (fuRawDataVersion) {
        // --------------------------------------------------------------------------------------------------
      case 100: {
 
        PsdDataV100::PsdGbtReader PsdReader(pInBuff);
        if (fair::Logger::Logging(fair::Severity::debug)) PsdReader.SetPrintOutMode(true);
 
        while (PsdReader.GetTotalGbtWordsRead() < uNbMessages) {
          int ReadResult = PsdReader.ReadMs();
          if (fair::Logger::Logging(fair::Severity::debug)) {
            printf("\nMicroslice idx: %llu\n", fulCurrentMsIdx);
            PsdReader.PrintOut(); /*PsdReader.PrintSaveBuff();*/
          }
          if (ReadResult == 0) {
 
            double prev_hit_time =
              dMsRelativeTime + (double) PsdReader.VectPackHdr.at(0).uAdcTime * 12.5 - fdTimeOffsetNs;  //in ns
 
            //hit loop
            for (uint64_t hit_iter = 0; hit_iter < PsdReader.VectHitHdr.size(); hit_iter++) {
              if (PsdReader.VectPackHdr.size() != PsdReader.VectHitHdr.size()) {
                LOG(error) << "Different vector headers sizes!"
                           << " in VectPackHdr " << PsdReader.VectPackHdr.size() << " in VectHitHdr "
                           << PsdReader.VectHitHdr.size() << "\n";
                break;
              }
 
              uint8_t uHitChannel = PsdReader.VectHitHdr.at(hit_iter).uHitChannel;
              //uint8_t uLinkIndex     = PsdReader.VectPackHdr.at(hit_iter).uLinkIndex;
              if (uHitChannel >= fviPsdChUId.size()) {
                LOG(error) << "hit channel number out of range! channel index: " << uHitChannel
                           << " max: " << fviPsdChUId.size();
                break;
              }
              UInt_t uChanUId = fviPsdChUId[uHitChannel];  //unique ID
 
              UInt_t fuAddress = uChanUId;                
              Double_t fdTime  = dMsRelativeTime + (double) PsdReader.VectPackHdr.at(hit_iter).uAdcTime * 12.5
                                - fdTimeOffsetNs;  
              Double_t fdTsTime =
                fdTsStartTime - fdStartTime;  
              Double_t fdEdep = (double) PsdReader.VectHitHdr.at(hit_iter).uSignalCharge
                                / fUnpackPar->GetMipCalibration(uHitChannel);   
              UInt_t fuZL      = PsdReader.VectHitHdr.at(hit_iter).uZeroLevel;  
              Double_t fdAccum = (double) PsdReader.VectHitHdr.at(hit_iter).uFeeAccum;    
              Double_t fdAdcTime = (double) PsdReader.VectPackHdr.at(hit_iter).uAdcTime;  
 
              Double_t fdEdepWfm          = 0.;  
              Double_t fdAmpl             = 0.;  
              UInt_t fuMinimum            = 0;   
              UInt_t fuTimeMax            = 0;   
              std::vector<uint16_t> fuWfm = PsdReader.VectHitData.at(hit_iter).uWfm;
 
              Double_t fdFitAmpl    = 0.;    
              Double_t fdFitZL      = 0.;    
              Double_t fdFitEdep    = 0.;    
              Double_t fdFitR2      = 999.;  
              Double_t fdFitTimeMax = -1.;   
              std::vector<uint16_t> fuFitWfm;
 
              if (!fuWfm.empty()) {
 
                int32_t iHitChargeWfm = std::accumulate(fuWfm.begin(), fuWfm.end(), -fuZL * fuWfm.size());
                auto const max_iter   = std::max_element(fuWfm.begin(), fuWfm.end());
                assert(max_iter != fuWfm.end());
                if (max_iter == fuWfm.end()) break;
                uint8_t uHitTimeMax   = std::distance(fuWfm.begin(), max_iter);
                int32_t iHitAmlpitude = *max_iter - fuZL;
                auto const min_iter   = std::min_element(fuWfm.begin(), fuWfm.end());
                uint32_t uHitMinimum  = *min_iter;
 
                fdEdepWfm = (double) iHitChargeWfm / fUnpackPar->GetMipCalibration(uHitChannel);  // ->now in MeV
                fdAmpl    = (double) iHitAmlpitude / 16.5;                                        // -> now in mV
                fuTimeMax = uHitTimeMax;
                fuMinimum = uHitMinimum;
 
                int gate_beg = 0;
                int gate_end = (int) fuWfm.size() - 1;
                PsdSignalFitting::PronyFitter Pfitter(2, 2, gate_beg, gate_end);
                Pfitter.SetDebugMode(0);
                //std::vector<int> iWfm(fuWfm.begin(), fuWfm.end());
                Pfitter.SetWaveform(fuWfm, fuZL);
                int SignalBeg = 4;
                //0.6, 0.2 // 0.72 0.38
                std::complex<float> first_fit_harmonic  = {0.72, 0.0};
                std::complex<float> second_fit_harmonic = {0.38, -0.0};
                Pfitter.SetExternalHarmonics(first_fit_harmonic, second_fit_harmonic);
                Int_t best_signal_begin = Pfitter.ChooseBestSignalBegin(SignalBeg - 1, SignalBeg + 1);
                Pfitter.SetSignalBegin(best_signal_begin);
                Pfitter.CalculateFitAmplitudes();
 
                fdFitEdep =
                  Pfitter.GetIntegral(gate_beg, gate_end) / fUnpackPar->GetMipCalibration(uHitChannel);  // ->now in MeV
                fdFitAmpl    = (Pfitter.GetMaxAmplitude() - Pfitter.GetZeroLevel()) / 16.5;              // ->now in mV
                fdFitR2      = Pfitter.GetRSquare(gate_beg, gate_end);
                fdFitZL      = Pfitter.GetZeroLevel();
                fdFitTimeMax = Pfitter.GetSignalMaxTime();
                fuFitWfm     = Pfitter.GetFitWfm();
              }
 
              CbmPsdDsp dsp = CbmPsdDsp(fuAddress, fdTime, fdTsTime, fdEdep, fuZL, fdAccum, fdAdcTime,
 
                                        fdEdepWfm, fdAmpl, fuMinimum, fuTimeMax, fuWfm,
 
                                        fdFitAmpl, fdFitZL, fdFitEdep, fdFitR2, fdFitTimeMax, fuFitWfm);
 
              std::unique_ptr<CbmPsdDigi> digi = MakeDigi(dsp);
              if (digi) fPsdDigiVector->emplace_back(*digi);
 
              if (fbDebugWriteOutput && (fPsdDspVector != nullptr)) { fPsdDspVector->emplace_back(dsp); }
 
              //DEBUG
              if (fdTime < prev_hit_time) printf("negative time btw hits! %f after %f \n", fdTime, prev_hit_time);
              //DEBUG END
              prev_hit_time = fdTime;
              //DEBUG
 
            }  // for (uint64_t hit_iter = 0; hit_iter < PsdReader.VectHitHdr.size(); hit_iter++) {
          }
          else if (ReadResult == 1) {
            LOG(error) << "no pack headers in message!";
            break;
          }
          else if (ReadResult == 2) {
            LOG(error) << "wrong channel! In header: " << PsdReader.HitHdr.uHitChannel;
            break;
          }
          else if (ReadResult == 3) {
            LOG(error) << "check number of waveform points! In header: " << PsdReader.HitHdr.uWfmWords - 1;
            break;
          }
          else {
            LOG(error) << "PsdGbtReader.ReadEventFles() didn't return expected values";
            break;
          }
 
 
        }  // while(PsdReader.GetTotalGbtWordsRead()<uNbMessages)
 
        if (uNbMessages != PsdReader.GetTotalGbtWordsRead())
          LOG(error) << "Wrong amount of messages read!"
                     << " in microslice " << uNbMessages << " by PsdReader " << PsdReader.GetTotalGbtWordsRead()
                     << "\n";
 
        break;
      }  // case 100
         // --------------------------------------------------------------------------------------------------
         // --------------------------------------------------------------------------------------------------
      case 000: {
 
        PsdDataV000::PsdGbtReader PsdReader(pInBuff);
        //PsdReader.SetPrintOutMode(true);
 
        while (PsdReader.GetTotalGbtWordsRead() < uNbMessages) {
          int ReadResult = PsdReader.ReadEventFles();
          if (PsdReader.EvHdrAb.uHitsNumber > fviPsdChUId.size()) {
            LOG(error) << "too many triggered channels! In header: " << PsdReader.EvHdrAb.uHitsNumber
                       << " in PSD: " << fviPsdChUId.size();
            break;
          }
 
          if (ReadResult == 0) {
            //hit loop
            for (int hit_iter = 0; hit_iter < PsdReader.EvHdrAb.uHitsNumber; hit_iter++) {
              UInt_t uHitChannel   = PsdReader.VectHitHdr.at(hit_iter).uHitChannel;
              UInt_t uSignalCharge = PsdReader.VectHitHdr.at(hit_iter).uSignalCharge;
              //UInt_t uZeroLevel          = PsdReader.VectHitHdr.at(hit_iter).uZeroLevel;
              Double_t dHitTime =
                (double) PsdReader.EvHdrAb.ulMicroSlice + (double) PsdReader.EvHdrAc.uAdcTime * 12.5 - fdTimeOffsetNs;
 
              if (uHitChannel >= fviPsdChUId.size()) {
                LOG(error) << "hit channel number out of range! channel index: " << uHitChannel
                           << " max: " << fviPsdChUId.size();
                break;
              }
              UInt_t uChanUId = fviPsdChUId[uHitChannel];  //unique ID
 
              LOG(debug) << Form("Insert 0x%08x digi with charge ", uChanUId) << uSignalCharge
                         << Form(", at %u,", PsdReader.EvHdrAc.uAdcTime)
                         << " epoch: " << PsdReader.EvHdrAb.ulMicroSlice;
 
              fPsdDigiVector->emplace_back(uChanUId, dHitTime, (double) uSignalCharge);
 
            }  // for(int hit_iter = 0; hit_iter < PsdReader.EvHdrAb.uHitsNumber; hit_iter++)
          }
          else if (ReadResult == 1) {
            LOG(error) << "no event headers in message!";
            break;
          }
          else if (ReadResult == 2) {
            LOG(error) << "check number of waveform points! In header: " << PsdReader.HitHdr.uWfmPoints
                       << " should be: " << 8;
            break;
          }
          else if (ReadResult == 3) {
            LOG(error) << "wrong amount of hits read! In header: " << PsdReader.EvHdrAb.uHitsNumber
                       << " in hit vector: " << PsdReader.VectHitHdr.size();
            break;
          }
          else {
            LOG(error) << "PsdGbtReader.ReadEventFles() didn't return expected values";
            break;
          }
 
        }  // while(PsdReader.GetTotalGbtWordsRead()<uNbMessages)
 
        if (uNbMessages != PsdReader.GetTotalGbtWordsRead())
          LOG(error) << "Wrong amount of messages read!"
                     << " in microslice " << uNbMessages << " by PsdReader " << PsdReader.GetTotalGbtWordsRead()
                     << "\n";
 
        if (fulCurrentMsIdx != PsdReader.EvHdrAb.ulMicroSlice)
          LOG(error) << "Wrong MS index!"
                     << " in microslice " << fulCurrentMsIdx << " by PsdReader " << PsdReader.EvHdrAb.ulMicroSlice
                     << "\n";
        break;
      }  //case 000
         // --------------------------------------------------------------------------------------------------
 
    }  // switch
 
  }  //if(uNbMessages > 1)
 
 
  return kTRUE;
}
 
std::pair<std::vector<CbmPsdDigi>*, std::vector<CbmPsdDsp>*>
CbmMcbm2018UnpackerAlgoPsd::unpack(const fles::Timeslice* ts, uint16_t icomp)
{
  AddMsComponentToList(icomp, 0x80);
  Reset();
  ProcessTs(*ts);
 
  return std::make_pair(fPsdDigiVector, fPsdDspVector);
}
 
Bool_t CbmMcbm2018UnpackerAlgoPsd::SetDigiOutputPointer(std::vector<CbmPsdDigi>* const pVector)
{
  if (nullptr == fPsdDigiVector) {
    fPsdDigiVector = pVector;
    return kTRUE;
  }
  else {
    return kFALSE;
  }
}
 
Bool_t CbmMcbm2018UnpackerAlgoPsd::SetDspOutputPointer(std::vector<CbmPsdDsp>* const pVector)
{
  if (nullptr == fPsdDspVector) {
    fPsdDspVector = pVector;
    return kTRUE;
  }
  else {
    return kFALSE;
  }
}
 
std::unique_ptr<CbmPsdDigi> CbmMcbm2018UnpackerAlgoPsd::MakeDigi(CbmPsdDsp dsp)
{
  std::unique_ptr<CbmPsdDigi> digi(new CbmPsdDigi(dsp.GetAddress(), dsp.GetTime(), dsp.fdFitEdep));
 
  return digi;
}
 
Bool_t CbmMcbm2018UnpackerAlgoPsd::CreateHistograms() { return kTRUE; }
Bool_t CbmMcbm2018UnpackerAlgoPsd::FillHistograms() { return kTRUE; }
Bool_t CbmMcbm2018UnpackerAlgoPsd::ResetHistograms() { return kTRUE; }
// -------------------------------------------------------------------------