DQMProtobufReader.h

Go to the documentation of this file.

#include "FWCore/Framework/interface/Frameworkfwd.h"
#include "FWCore/Framework/interface/InputSourceMacros.h"
#include "FWCore/Framework/interface/RunPrincipal.h"
#include "FWCore/Framework/interface/LuminosityBlockPrincipal.h"
#include "FWCore/Framework/interface/LuminosityBlock.h"

#include "FWCore/ParameterSet/interface/ConfigurationDescriptions.h"
#include "FWCore/ParameterSet/interface/ParameterSetDescription.h"
#include "FWCore/Sources/interface/ProducerSourceBase.h"
#include "FWCore/Sources/interface/PuttableSourceBase.h"

#include "DQMFileIterator.h"
#include "DQMMonitoringService.h"

namespace dqmservices {

class DQMProtobufReader : public edm::PuttableSourceBase {
 public:
  explicit DQMProtobufReader(edm::ParameterSet const&,
                             edm::InputSourceDescription const&);
  ~DQMProtobufReader() override;
  static void fillDescriptions(edm::ConfigurationDescriptions& descriptions);

 private:
  edm::InputSource::ItemType getNextItemType() override;
  std::shared_ptr<edm::RunAuxiliary> readRunAuxiliary_() override;
  std::shared_ptr<edm::LuminosityBlockAuxiliary>
  readLuminosityBlockAuxiliary_() override;
  void readRun_(edm::RunPrincipal& rpCache) override;
  void readLuminosityBlock_(
      edm::LuminosityBlockPrincipal& lbCache) override;
  void readEvent_(edm::EventPrincipal&) override;

  // actual reading will happen here
  void beginLuminosityBlock(edm::LuminosityBlock& lb) override;

  void logFileAction(char const* msg, char const* fileName) const;
  bool prepareNextFile();

  bool flagSkipFirstLumis_;
  bool flagEndOfRunKills_;
  bool flagDeleteDatFiles_;
  bool flagLoadFiles_;

  std::unique_ptr<double> streamReader_;
  DQMFileIterator fiterator_;
  DQMFileIterator::LumiEntry currentLumi_;

  InputSource::ItemType nextItemType;
};

}  // end of namespace