TaskCompressedData.h

Go to the documentation of this file.

// Copyright CERN and copyright holders of ALICE O2. This software is
// distributed under the terms of the GNU General Public License v3 (GPL
// Version 3), copied verbatim in the file "COPYING".
//
// See http://alice-o2.web.cern.ch/license for full licensing information.
//
// 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 QC_MODULE_TOF_TASKCOMPRESSEDDATA_H
#define QC_MODULE_TOF_TASKCOMPRESSEDDATA_H

// O2 includes
#include "TOFReconstruction/DecoderBase.h"
#include "DataFormatsTOF/CompressedDataFormat.h"
using namespace o2::tof::compressed;

// QC includes
#include "QualityControl/TaskInterface.h"

class TH1;
class TH1F;
class TH2F;

using namespace o2::quality_control::core;

namespace o2::quality_control_modules::tof
{

class CompressedDataDecoder final : public DecoderBase
{
 public:
  CompressedDataDecoder() = default;
  ~CompressedDataDecoder() = default;

  void decode();

  std::map<std::string, std::shared_ptr<TH1>> mHistos;

  Int_t rdhread = 0; 

  void initHistograms();

  void resetHistograms();

  // Histograms filled in the decoder
  std::shared_ptr<TH1F> mHits;         
  std::shared_ptr<TH1F> mTime;         
  std::shared_ptr<TH1F> mTimeBC;       
  std::shared_ptr<TH1F> mTOT;          
  std::shared_ptr<TH1F> mIndexE;       
  std::shared_ptr<TH2F> mSlotPartMask; 
  std::shared_ptr<TH2F> mDiagnostic;   
  std::shared_ptr<TH1F> mNErrors;      
  std::shared_ptr<TH1F> mErrorBits;    
  std::shared_ptr<TH2F> mError;        
  std::shared_ptr<TH1F> mNTests;       
  std::shared_ptr<TH2F> mTest;         
  std::shared_ptr<TH2F> mOrbitID;      

 private:
  void rdhHandler(const o2::header::RAWDataHeader* rdh) override;
  void headerHandler(const CrateHeader_t* crateHeader, const CrateOrbit_t* crateOrbit) override;
  void frameHandler(const CrateHeader_t* crateHeader, const CrateOrbit_t* crateOrbit,
                    const FrameHeader_t* frameHeader, const PackedHit_t* packedHits) override;
  void trailerHandler(const CrateHeader_t* crateHeader, const CrateOrbit_t* crateOrbit,
                      const CrateTrailer_t* crateTrailer, const Diagnostic_t* diagnostics,
                      const Error_t* errors) override;
};

class TaskCompressedData final : public TaskInterface
{
 public:
  TaskCompressedData() = default;
  ~TaskCompressedData() override = default;

  // Definition of the methods for the template method pattern
  void initialize(o2::framework::InitContext& ctx) override;
  void startOfActivity(Activity& activity) override;
  void startOfCycle() override;
  void monitorData(o2::framework::ProcessingContext& ctx) override;
  void endOfCycle() override;
  void endOfActivity(Activity& activity) override;
  void reset() override;

 private:
  CompressedDataDecoder mDecoder; 
};

} // namespace o2::quality_control_modules::tof

#endif // QC_MODULE_TOF_TASKCOMPRESSEDDATA_H