Decoder.h

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
 
#ifndef ALICEO2_TOF_DECODER_H
#define ALICEO2_TOF_DECODER_H
 
#include <fstream>
#include <string>
#include <cstdint>
#include "DataFormatsTOF/CompressedDataFormat.h"
#include "TOFBase/Geo.h"
#include "TOFBase/Digit.h"
#include "TOFBase/Strip.h"
#include "TOFBase/WindowFiller.h"
#include <array>
#include "Headers/RAWDataHeader.h"
 
namespace o2
{
namespace tof
{
namespace compressed
{
class Decoder : public WindowFiller
{
 
 public:
  Decoder();
  ~Decoder() = default;
 
  bool open(std::string name);
 
  bool decode();
  void readTRM(int icru, int icrate, uint32_t orbit, uint16_t bunchid);
  void InsertDigit(int icrate, int itrm, int itdc, int ichain, int channel, uint32_t orbit, uint16_t bunchid, int time_ext, int tdc, int tot);
  void fillWindows();
  void clear();
 
  bool close();
  void setVerbose(bool val) { mVerbose = val; };
 
  void printRDH() const;
  void printCrateInfo(int icru) const;
  void printTRMInfo(int icru) const;
  void printCrateTrailerInfo(int icru) const;
  void printHitInfo(int icru) const;
 
  struct DigitInfo {
    uint64_t bcAbs;
    int channel;
    int tdc;
    int tot;
    uint32_t orbit;
    uint16_t bc;
  };
 
  static void fromRawHit2Digit(int icrate, int itrm, int itdc, int ichain, int channel, uint32_t orbit, uint16_t bunchid, int tdc, int tot, DigitInfo& dinfo); // convert raw info in digit info (channel, tdc, tot, bc), tdc = packetHit.time + (frameHeader.frameID << 13)
 
  char* nextPage(void* current, int shift = 8192);
 
  std::vector<uint64_t>& getErrors() { return mErrors; }
  void addError(const uint32_t val, int icrate) { mErrors.push_back((uint64_t(icrate) << 32) + val); }
 
 protected:
  static const int NCRU = 4;
 
  // benchmarks
  int mIntegratedBytes[NCRU];
  double mIntegratedTime = 0.;
 
  std::ifstream mFile[NCRU];
  bool mVerbose = false;
  bool mCruIn[NCRU];
 
  char* mBuffer[NCRU];
  std::vector<char> mBufferLocal;
  long mSize[NCRU];
  Union_t* mUnion[NCRU];
  Union_t* mUnionEnd[NCRU];
 
  int mHitDecoded = 0;
 
  o2::header::RAWDataHeader* mRDH;
};
 
} // namespace compressed
} // namespace tof
} // namespace o2
#endif