bmon/UnpackMS.h

Go to the documentation of this file.

/* Copyright (C) 2022 GSI Helmholtzzentrum fuer Schwerionenforschung, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Dominik Smith [committer] */
#pragma once
 
#include "CbmBmonDigi.h"
#include "CriGet4Mess001.h"
#include "MicrosliceDescriptor.hpp"
#include "Timeslice.hpp"
#include "UnpackMSBase.h"
 
#include <cassert>
#include <cstddef>
#include <cstdint>
#include <memory>
#include <sstream>
#include <vector>
 
namespace cbm::algo::bmon
{
 
 
  struct UnpackElinkPar {
    std::vector<uint32_t> fChannelUId;  
    int32_t fTimeOffset = 0.;           
  };
 
 
  struct UnpackPar {
    std::vector<UnpackElinkPar> fElinkParams = {};  
  };
 
 
  struct UnpackMonitorData {
    uint32_t fNumNonHitOrTsbMessage     = 0;
    uint32_t fNumErrElinkOutOfRange     = 0;  
    uint32_t fNumErrInvalidFirstMessage = 0;  
    uint32_t fNumErrInvalidLastMessage  = 0;  
    uint32_t fNumErrInvalidMsSize       = 0;  
    uint32_t fNumErrTimestampOverflow   = 0;  
    uint32_t fNumErrInvalidStartEpoch   = 0;  
    uint32_t fNumErrInvalidAsicEpochs   = 0;  
    bool HasErrors()
    {
      uint32_t numErrors = fNumNonHitOrTsbMessage + fNumErrElinkOutOfRange + fNumErrInvalidFirstMessage
                           + fNumErrInvalidLastMessage + fNumErrInvalidMsSize + fNumErrTimestampOverflow
                           + fNumErrInvalidStartEpoch + fNumErrInvalidAsicEpochs;
      return (numErrors > 0 ? true : false);
    }
    std::string print()
    {
      std::stringstream ss;
      ss << "errors " << fNumNonHitOrTsbMessage << " | " << fNumErrElinkOutOfRange << " | "
         << fNumErrInvalidFirstMessage << " | " << fNumErrInvalidLastMessage << " | " << fNumErrInvalidMsSize << " | "
         << fNumErrTimestampOverflow << " | " << fNumErrInvalidStartEpoch << " | " << fNumErrInvalidAsicEpochs << " | ";
      return ss.str();
    }
  };
 
  struct UnpackAuxData {
  };
 
  class UnpackMS : public UnpackMSBase<CbmBmonDigi, UnpackMonitorData, UnpackAuxData> {
 
   public:
    UnpackMS(const UnpackPar& pars);
 
    ~UnpackMS() override;
 
 
    Result_t operator()(const uint8_t* msContent, const fles::MicrosliceDescriptor& msDescr,
                        const uint64_t tTimeslice) const override;
 
    void SetParams(std::unique_ptr<UnpackPar> params) { fParams = *(std::move(params)); }
 
   private:  // datatypes
    struct TimeSpec {
      uint64_t currentTsTime;     
      uint32_t currentEpochInTs;  
    };
 
   private:  // methods
    void ProcessHitMessage(const critof001::Message& message, const TimeSpec& time, std::vector<CbmBmonDigi>& digiVec,
                           UnpackMonitorData& monitor) const;
 
    void ProcessEpochMessage(const critof001::Message& message, TimeSpec& time) const;
 
 
   private:                  // members
    UnpackPar fParams = {};  
  };
 
 
}  // namespace cbm::algo::bmon