RootPerfMonSvc.h

Go to the documentation of this file.

//====================================================================
//  RootPerfMonSvc definition
//--------------------------------------------------------------------
//
//  Author     : M.Frank
//====================================================================
#ifndef GAUDIROOTCNV_GAUDIROOTPERFMONSVC_H
#define GAUDIROOTCNV_GAUDIROOTPERFMONSVC_H

#include <memory>
// Framework include files
#include "GaudiKernel/IIncidentListener.h"
#include "GaudiKernel/Service.h"

#include "TTree.h"
#include "TFile.h"

#include "RootCnv/SysProcStat.h"

// C/C++ include files
#include <set>

// Forward declarations
class IIncidentSvc;

/*
 * Gaudi namespace declaration
 */
namespace Gaudi {

  class GAUDI_API RootPerfMonSvc : public Service, virtual public IIncidentListener {
  protected:

    SmartIF<IIncidentSvc>               m_incidentSvc ;
    std::string                 m_ioPerfStats;
    std::unique_ptr<MsgStream>  m_log;
    // Passed parameters
    std::string                 m_setStreams;
    std::string                 m_basketSize;
    std::string                 m_bufferSize;
    std::string                 m_splitLevel;
    // Reference to a tree with statistics
    TTree*                      m_perfTree;
    // Reference to a file where statistics are persisted
    std::unique_ptr<TFile>      m_perfFile;
    // Reference to all connected output files
    std::set<std::string>       m_outputs;
    // The newest observed values
    Int_t                       m_eventType;
    ULong_t                     m_utime, m_stime, m_vsize;
    Long_t                      m_eventNumber, m_rss, m_time;

    // Types of records
    enum EventType { EVENT = 1, FSR = 2 };

    // Adding newest observed values to the tree with statistics
    virtual void record(EventType eventType);

    MsgStream& log() const { return *m_log; }

  public:
    RootPerfMonSvc(const std::string& name, ISvcLocator* svc);

    ~RootPerfMonSvc() override = default;

    StatusCode error(const std::string& msg);

    StatusCode initialize() override;

    StatusCode finalize() override;

    void handle(const Incident& incident) override;

    // Service overload: Stop the service
    StatusCode stop() override;
  };
}

#endif  // GAUDIROOTCNV_GAUDIROOTPERFMONSVC_H