PndProcess.h

Go to the documentation of this file.

//****************************************************************************
//*                   This file is part of PandaRoot.                        *
//*                                                                          *
//*            PandaRoot is distributed under the terms of the               *
//*              GNU General Public License (GPL) version 3,                 *
//*                 copied verbatim in the file "LICENSE".                   *
//*                                                                          *
//*  Copyright (C) 2006 - 2024 FAIR GmbH and copyright holders of PandaRoot  *
//*     The copyright holders are listed in the file "COPYRIGHTHOLDERS".     *
//*               The authors are listed in the file "AUTHORS".              *
//****************************************************************************

#ifndef PNDPROCESS_HH
#define PNDPROCESS_HH

#include <string>
#include <typeinfo>
#include <vector>

#include "TStopwatch.h"
#include "TSystem.h"

#include "FairLogger.h"

#include "PndContainerRegister.h"
#include "PndParameterRegister.h"

class PndProcess {
 public:
  PndProcess() {}
  PndProcess(const std::string &t_processname) : fProcessName(t_processname) {}
  virtual ~PndProcess() {}

  virtual void SetDetectorName(const std::string &t_detectorname) { fDetectorName = t_detectorname; }

  const std::vector<std::string> &GetListOfRequiredParameters() const { return fParameterList; }

  virtual void RequestDataContainer(PndContainerRegister * /*t_register*/){};

  virtual void GetDataContainer(PndContainerRegister * /*t_register*/){};

  virtual void SetupParameters(const PndParameterRegister *t_parameter) = 0;

  virtual void PreProcess()
  {
    gSystem->GetProcInfo(&fProcInfo);
    fLastMemSize = fProcInfo.fMemResident;
    fTimer.Reset();
    fTimer.Start();
  };
  virtual void Process() = 0;

  virtual void PostProcess()
  {
    fTimer.Stop();
    fTotalTime += fTimer.RealTime();
    gSystem->GetProcInfo(&fProcInfo);
    LOG_IF(debug1, fProcInfo.fMemResident - fLastMemSize != 0) << "PndProcess" << fDetectorName << " Process() Memory increase after Process " << fProcessName << ". Increase by "
                                                               << fProcInfo.fMemResident - fLastMemSize << " KB. Total memory used is: " << fProcInfo.fMemResident << " KB.";

    fLastMemSize = fProcInfo.fMemResident;
  };

  virtual void TearDown() { LOG(debug) << fProcessName << " - " << fDetectorName << " took " << fTotalTime << " s processing time."; };

  virtual void SetEventTime(Double_t t_eventtime) { fEventTime = t_eventtime; }

 protected:
  std::vector<std::string> fParameterList{}; 
  std::string fDetectorName{""};             
  std::string fProcessName{"PndProcess"};    
  TStopwatch fTimer{};                       
  Double_t fTotalTime{0};                    
  ProcInfo_t fProcInfo;                      
  Long_t fLastMemSize; 
  Double_t fEventTime{0};
};

#endif /*PNDPROCESS_HH*/