HmpidCoder2.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 COMMON_HMPIDCODER2_H_
#define COMMON_HMPIDCODER2_H_
 
#include <cstdio>
#include <cstdint>
#include <iostream>
#include <cstring>
#include <cmath>
#include <cstdlib>
#include <vector>
#include <memory>
 
#include "Headers/RAWDataHeader.h"
#include "CommonDataFormat/InteractionRecord.h"
#include "DetectorsRaw/HBFUtils.h"
#include "DetectorsRaw/RawFileWriter.h"
 
#include <fairlogger/Logger.h>
#include "HMPIDBase/Geo.h"
#include "DataFormatsHMP/Digit.h"
 
// ---- RDH 6  standard dimension -------
#define RAWBLOCKDIMENSION_W 2048
#define HEADERDIMENSION_W 16
#define PAYLOADDIMENSION_W 2032
#define PAYLOADMAXSPACE_W 2028
 
// ---- CHARGE CONSTANTS -----
#define CHARGE_CONST 150
#define CHARGE_RAND_MAX 400
 
using namespace o2::raw;
 
namespace o2
{
 
namespace hmpid
{
 
class HmpidCoder2
{
 public:
  int mVerbose;
  int mNumberOfEquipments;
 
  RawFileWriter mWriter{"HMP", false};
 
 private:
  // The standard definition of HMPID equipments at P2
  //  const int mEqIds[Geo::MAXEQUIPMENTS] = {0, 1, 2, 3, 4, 5, 8, 9, 6, 7, 10, 11, 12, 13};
  //  const int mCruIds[Geo::MAXEQUIPMENTS] = {0, 0, 0, 0, 1, 1, 1, 1, 2, 2, 2, 3, 3, 3};
  //  const int mLinkIds[Geo::MAXEQUIPMENTS] = {0, 1, 2, 3, 0, 1, 2, 3, 0, 1, 2, 0, 1, 2};
  //  const int mFlpIds[Geo::MAXEQUIPMENTS] = {160, 160, 160, 160, 160, 160, 160, 160, 161, 161, 161, 161, 161, 161};
 
  uint32_t* mPayloadBufferPtr;
  uint32_t* mPadMap;
  int mEventSizePerEquipment[Geo::MAXEQUIPMENTS];
  int mEventPadsPerEquipment[Geo::MAXEQUIPMENTS];
  int mPayloadBufferDimPerEquipment;
  long mPadsCoded;
  bool mSkipEmptyEvents;
  std::unique_ptr<uint32_t[]> mUPayloadBufferPtr;
  std::unique_ptr<uint32_t[]> mUPadMap;
 
  LinkSubSpec_t mTheRFWLinks[Geo::MAXEQUIPMENTS];
 
  int mBusyTime;
  int mHmpidErrorFlag;
  int mHmpidFrwVersion;
 
 public:
  HmpidCoder2(int numOfEquipments);
  virtual ~HmpidCoder2() = default;
 
  void setVerbosity(int Level)
  {
    mVerbose = Level;
  };
  int getVerbosity()
  {
    return (mVerbose);
  };
  int getNumberOfEquipments()
  {
    return (mNumberOfEquipments);
  };
  void setSkipEmptyEvents(bool Skip)
  {
    mSkipEmptyEvents = Skip;
  }
  bool getSkipEmptyEvents()
  {
    return (mSkipEmptyEvents);
  }
  o2::raw::RawFileWriter& getWriter() { return mWriter; }
 
  void setDetectorSpecificFields(float BusyTime = 0.001, int Error = 0, int Version = 9);
  void openOutputStream(const std::string& outputFileName, const std::string& fileFor);
  void closeOutputStream();
 
  void codeEventChunkDigits(std::vector<o2::hmpid::Digit>& digits, InteractionRecord ir);
  void dumpResults(const std::string& outputFileName);
 
 private:
  int getEquipmentPadIndex(int eq, int col, int dil, int cha);
  void fillTheOutputBuffer(uint32_t* padMap);
  void writePaginatedEvent(uint32_t orbit, uint16_t bc);
  void setRDHFields(int eq = -1);
};
 
} // namespace hmpid
} // namespace o2
 
#endif /* COMMON_HMPIDCODER_H_ */