DIPLumiProducer.h

Go to the documentation of this file.

#ifndef RecoLuminosity_LumiProducer_DIPLumiProducer_h
#define RecoLuminosity_LumiProducer_DIPLumiProducer_h

#include "FWCore/Framework/interface/ESProducer.h"
#include "FWCore/Framework/interface/ModuleFactory.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Framework/interface/EventSetupRecordIntervalFinder.h"
#include <memory>
namespace edm {
  class IOVSyncValue;
}
namespace coral {
  class ISchema;
}
class DIPLuminosityRcd;
class DIPLumiSummary;
class DIPLumiDetail;
class DIPLumiProducer : public edm::ESProducer, public edm::EventSetupRecordIntervalFinder {
public:
  DIPLumiProducer(const edm::ParameterSet&);
  typedef std::shared_ptr<const DIPLumiSummary> ReturnSummaryType;
  ReturnSummaryType produceSummary(const DIPLuminosityRcd&);
  typedef std::shared_ptr<const DIPLumiDetail> ReturnDetailType;
  ReturnDetailType produceDetail(const DIPLuminosityRcd&);
  ~DIPLumiProducer() override;

protected:
  void setIntervalFor(const edm::eventsetup::EventSetupRecordKey&,
                      const edm::IOVSyncValue&,
                      edm::ValidityInterval&) override;

private:
  unsigned int maxavailableLSforRun(coral::ISchema& schema, const std::string& tablename, unsigned int runnumber);

private:
  std::string m_connectStr;
  std::map<unsigned int, std::shared_ptr<const DIPLumiSummary> > m_summarycache;
  std::map<unsigned int, std::shared_ptr<const DIPLumiDetail> > m_detailcache;
  bool m_isNullRun;  //if lumi data exist for this run
  unsigned int m_summarycachedrun;
  unsigned int m_detailcachedrun;
  unsigned int m_cachesize;
  std::shared_ptr<const DIPLumiSummary> m_summaryresult;
  std::shared_ptr<const DIPLumiDetail> m_detailresult;
  const edm::IOVSyncValue* m_pcurrentTime;

private:
  void fillsummarycache(unsigned int runnumber, unsigned int startlsnum);
  void filldetailcache(unsigned int runnumber, unsigned int startlsnum);
};
#endif