TaskDiagnostics.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_TASKDIAGNOSTICS_H
#define QC_MODULE_TOF_TASKDIAGNOSTICS_H

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

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

class TH1F;
class TH2F;

using namespace o2::quality_control::core;
using namespace o2::tof::diagnostic;

namespace o2::quality_control_modules::tof
{

static const char* RDHDiagnosticName[2] = { "RDH_HAS_DATA", "" };

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

  void decode();

  static const int ncrates = 72;                                                   
  static const int ntrms = 10;                                                     
  static const int ntrmschains = 2;                                                
  Counter<2, RDHDiagnosticName> mRDHCounter[ncrates];                              
  Counter<32, o2::tof::diagnostic::DRMDiagnosticName> mDRMCounter[ncrates];        
  Counter<32, o2::tof::diagnostic::LTMDiagnosticName> mLTMCounter[ncrates];        
  Counter<32, o2::tof::diagnostic::TRMDiagnosticName> mTRMCounter[ncrates][ntrms]; 

 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 TaskDiagnostics    /*final*/
  : public TaskInterface // todo add back the "final" when doxygen is fixed
{
 public:
  TaskDiagnostics() = default;
  ~TaskDiagnostics() 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:
  // Histograms
  std::shared_ptr<TH2F> mRDHHisto;                            
  std::shared_ptr<TH2F> mDRMHisto;                            
  std::shared_ptr<TH2F> mLTMHisto;                            
  std::shared_ptr<TH2F> mTRMHisto[DiagnosticsCounter::ntrms]; 

  DiagnosticsCounter mDecoderCounter; 
};

} // namespace o2::quality_control_modules::tof

#endif // QC_MODULE_TOF_TASKDIAGNOSTICS_H