RepositoryBenchmark.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_REPOSITORYBENCHMARK_H
#define QC_REPOSITORYBENCHMARK_H

#include "QualityControl/DatabaseInterface.h"
#include <fairmq/FairMQDevice.h>
#include <TH1.h>
#include <Monitoring/MonitoringFactory.h>
#include <boost/asio.hpp>
#include <thread>
#include <string>

namespace o2::quality_control::core
{

class RepositoryBenchmark : public FairMQDevice
{
 public:
  RepositoryBenchmark() = default;
  virtual ~RepositoryBenchmark() = default;

 protected:
  virtual void InitTask();
  virtual bool ConditionalRun();
  void emptyDatabase();
  void checkTimedOut();
  TH1* createHisto(uint64_t sizeObjects, std::string name);

 private:
  // user params
  uint64_t mMaxIterations = 0;
  uint64_t mNumIterations = 0;
  uint64_t mNumberObjects = 1;
  uint64_t mSizeObjects = 1;
  std::string mTaskName;
  std::string mObjectName;
  bool mDeletionMode = false; // todo: is false ok as default?

  // monitoring
  std::unique_ptr<o2::monitoring::Monitoring> mMonitoring;
  uint64_t mTotalNumberObjects = 0;
  bool mThreadedMonitoring = true;
  uint64_t mThreadedMonitoringInterval = 10;

  // internal state
  std::unique_ptr<o2::quality_control::repository::DatabaseInterface> mDatabase;
  std::vector<std::shared_ptr<MonitorObject>> mMyObjects;
  //  TH1* mMyHisto;

  // variables for the timer
  boost::asio::deadline_timer* mTimer; 
  boost::asio::io_service io;
  std::thread* th;
};

} // namespace o2::quality_control::core

#endif // QC_REPOSITORYBENCHMARK_H