CMS 3D CMS Logo

List of all members | Public Member Functions | Static Public Member Functions | Protected Member Functions | Private Member Functions | Private Attributes
ConditionDBWriter< T > Class Template Referenceabstract

#include <ConditionDBWriter.h>

Inheritance diagram for ConditionDBWriter< T >:
edm::one::EDAnalyzer< edm::one::WatchRuns, edm::one::WatchLuminosityBlocks > edm::one::EDAnalyzerBase edm::EDConsumerBase

Public Member Functions

 ConditionDBWriter (const edm::ParameterSet &iConfig)
 
 ~ConditionDBWriter () override
 
- Public Member Functions inherited from edm::one::EDAnalyzer< edm::one::WatchRuns, edm::one::WatchLuminosityBlocks >
 EDAnalyzer ()=default
 
 EDAnalyzer (const EDAnalyzer &)=delete
 
SerialTaskQueueglobalLuminosityBlocksQueue () final
 
SerialTaskQueueglobalRunsQueue () final
 
const EDAnalyzeroperator= (const EDAnalyzer &)=delete
 
bool wantsGlobalLuminosityBlocks () const final
 
bool wantsGlobalRuns () const final
 
bool wantsInputProcessBlocks () const final
 
bool wantsProcessBlocks () const final
 
- Public Member Functions inherited from edm::one::EDAnalyzerBase
void callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
 
 EDAnalyzerBase ()
 
ModuleDescription const & moduleDescription () const
 
bool wantsStreamLuminosityBlocks () const
 
bool wantsStreamRuns () const
 
 ~EDAnalyzerBase () override
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfoconsumesInfo () const
 
void convertCurrentProcessAlias (std::string const &processName)
 Convert "@currentProcess" in InputTag process names to the actual current process name. More...
 
 EDConsumerBase ()
 
 EDConsumerBase (EDConsumerBase const &)=delete
 
 EDConsumerBase (EDConsumerBase &&)=default
 
ESProxyIndex const * esGetTokenIndices (edm::Transition iTrans) const
 
std::vector< ESProxyIndex > const & esGetTokenIndicesVector (edm::Transition iTrans) const
 
std::vector< ESRecordIndex > const & esGetTokenRecordIndicesVector (edm::Transition iTrans) const
 
ProductResolverIndexAndSkipBit indexFrom (EDGetToken, BranchType, TypeID const &) const
 
void itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
void itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
std::vector< ProductResolverIndexAndSkipBit > const & itemsToGetFrom (BranchType iType) const
 
void labelsForToken (EDGetToken iToken, Labels &oLabels) const
 
void modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const *> *, NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const *> const &labelsToDesc, std::string const &processName) const
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
EDConsumerBaseoperator= (EDConsumerBase &&)=default
 
bool registeredToConsume (ProductResolverIndex, bool, BranchType) const
 
bool registeredToConsumeMany (TypeID const &, BranchType) const
 
void selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)
 
ProductResolverIndexAndSkipBit uncheckedIndexFrom (EDGetToken) const
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
 
void updateLookup (eventsetup::ESRecordsToProxyIndices const &)
 
virtual ~EDConsumerBase () noexcept(false)
 

Static Public Member Functions

static void fillPSetDescription (edm::ParameterSetDescription &desc)
 
- Static Public Member Functions inherited from edm::one::EDAnalyzerBase
static const std::string & baseType ()
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &descriptions)
 

Protected Member Functions

void setDoStore (const bool doStore)
 When set to false the payload will not be written to the db. More...
 
void storeOnDbNow ()
 
cond::Time_t timeOfLastIOV ()
 
- Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< Bconsumes (edm::InputTag tag) noexcept
 
EDGetToken consumes (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken consumes (TypeToGet const &id, edm::InputTag const &tag)
 
ConsumesCollector consumesCollector ()
 Use a ConsumesCollector to gather consumes information from helper functions. More...
 
template<typename ProductType , BranchType B = InEvent>
void consumesMany ()
 
void consumesMany (const TypeToGet &id)
 
template<BranchType B>
void consumesMany (const TypeToGet &id)
 
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes ()
 
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes (ESInputTag const &tag)
 
template<Transition Tr = Transition::Event>
constexpr auto esConsumes ()
 
template<Transition Tr = Transition::Event>
auto esConsumes (ESInputTag tag)
 
template<Transition Tr = Transition::Event>
ESGetTokenGeneric esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
 Used with EventSetupRecord::doGet. More...
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > mayConsume (edm::InputTag const &tag)
 
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
void resetItemsToGetFrom (BranchType iType)
 

Private Member Functions

virtual void algoAnalyze (const edm::Event &, const edm::EventSetup &)
 
virtual void algoBeginJob (const edm::EventSetup &)
 
virtual void algoBeginLuminosityBlock (const edm::LuminosityBlock &, const edm::EventSetup &)
 
virtual void algoBeginRun (const edm::Run &, const edm::EventSetup &)
 
virtual void algoEndJob ()
 
virtual void algoEndLuminosityBlock (const edm::LuminosityBlock &, const edm::EventSetup &)
 
virtual void algoEndRun (const edm::Run &, const edm::EventSetup &)
 
void analyze (const edm::Event &event, const edm::EventSetup &iSetup) override
 
void beginJob () override
 
void beginLuminosityBlock (const edm::LuminosityBlock &lumiBlock, const edm::EventSetup &iSetup) override
 
void beginRun (const edm::Run &run, const edm::EventSetup &es) override
 
void endJob () override
 
void endLuminosityBlock (const edm::LuminosityBlock &lumiBlock, const edm::EventSetup &es) override
 
void endRun (const edm::Run &run, const edm::EventSetup &es) override
 
virtual std::unique_ptr< TgetNewObject ()=0
 
void setTime ()
 
void storeOnDb (std::unique_ptr< T > &objPointer)
 

Private Attributes

bool AlgoDrivenMode_
 
bool doStore_
 
bool firstRun_
 
bool JobMode_
 
bool LumiBlockMode_
 
unsigned int maxRunRange_
 
unsigned int minRunRange_
 
std::string Record_
 
bool RunMode_
 
bool setSinceTime_
 
bool SinceAppendMode_
 
cond::Time_t Time_
 
bool timeFromEndRun_
 
bool timeFromStartOfRunRange_
 

Additional Inherited Members

- Public Types inherited from edm::one::EDAnalyzerBase
typedef EDAnalyzerBase ModuleType
 
- Public Types inherited from edm::EDConsumerBase
typedef ProductLabels Labels
 

Detailed Description

template<class T>
class ConditionDBWriter< T >

Implementation:

This class can be very useful whenever a CMSSW application needs to store data to the offline DB. Typically such applications require access to event data and/or need to be notified about the start of Run, Lumi section in order to set a correct Interval Of Validity (IOV) for the data they have to store. Therefore the FWK EDAnalyzer is an excellent candidate for the implementation of such applications; this is the reason why this class inherits from the EDAnalyzer class.

The user class should inherit from this class. The templated type must be the type of the object that has to be written on the DB (e.g. MyCalibration). Examples of use of this class can be found in package CalibTracker/SiStripChannelGain. Have a look also at the test/ directory for examples of full cfg files.

The user must implement in his derived class the abstract method below

virtual std::unique_ptr<MyCalibration> getNewObject()=0;

The user can optionally implement the following methods

//Will be called at the beginning of the job virtual void algoBeginJob(const edm::EventSetup&){}; //Will be called at the beginning of each run in the job virtual void algoBeginRun(const edm::Run &, const edm::EventSetup &){}; //Will be called at the beginning of each luminosity block in the run virtual void algoBeginLuminosityBlock(const edm::LuminosityBlock &, const edm::EventSetup &){}; //Will be called at every event virtual void algoAnalyze(const edm::Event&, const edm::EventSetup&){}; //Will be called at the end of each run in the job virtual void algoEndRun(const edm::Run &, const edm::EventSetup &){}; //Will be called at the end of the job virtual void algoEndJob(){};

where he can access information needed to build his object. For instance, if he is computing a calibration that is computed as the mean of a certain quantity that varies from event to event, he will implement the algoAnalyze method.

The important part is the IOV setting. The advantage of using this class is that this setting is performed almost automatically: the only thing that the user has to do is to pass prescriptions about the IOV setting in the configuration of his module. A typical configuration is as follows:

   module prod =  SiStripGainRandomCalculator {

   #parameters of the derived class
    double MinPositiveGain = 0.1
    double MeanGain    = 1
    double SigmaGain   = 0
             untracked bool   printDebug = true

   #parameters of the base class
    string IOVMode       = "Run"
    bool SinceAppendMode = true
    string Record        = "SiStripApvGainRcd"

            }

Two subsets of parameters can be found. The first subset contains the specific parameters of the user class, which is called in this case SiStripGainRandomCalculator. The second subset contains the parameters of the base class. These are the following:

1) string IOVMode

4 possible values can be given: "Job", "Run", "LumiBlock" and "AlgoDriven" This card determines the length of the IOV. In other words, together with
the number of Lumysections/runs the user has decided to run his application, this card determines the number of objects that will be stored on the DB (the getNewObject method will be called as many times). For example if the user is running on the events of one Run, which has 10 luminosity sections and chooses the "LumiBlock" mode, then 10 objects with corresponding IOV will be written. If the "Job" mode is chosen, only one object will be stored irrespective of the dataset on which the user is running. The "AlgoDriven" option is special. If this choice is made, then it is up to the user to tell in the code when the getNewObject method must be called. This can be done by calling the method below void storeOnDbNow() must be invoked whenever a certain condition that justifies the start/end of an IOV is met.

2) bool SinceAppendMode

obsolete option now ONLY Since append mode is supported

 WARNING: due to the policy of the framework, objects SHALL be stored
 in IOV chronological order. If you have 10 runs, then execute your application starting from run 1 and not for example in two steps: first from Run 6 to Run 10 and then from Run 1 to Run 6.

3)string Record

this is the eventsetup record of your object.

Note that the setDoStore method changes the doStore parameter read from configuration file. This is sometimes needed e.g. to avoid filling bad payloads to the database.

Definition at line 149 of file ConditionDBWriter.h.

Constructor & Destructor Documentation

◆ ConditionDBWriter()

template<class T>
ConditionDBWriter< T >::ConditionDBWriter ( const edm::ParameterSet iConfig)
inlineexplicit

Definition at line 151 of file ConditionDBWriter.h.

152  : minRunRange_(1 << 31),
153  maxRunRange_(0),
154  LumiBlockMode_(false),
155  RunMode_(false),
156  JobMode_(false),
157  AlgoDrivenMode_(false),
158  Time_(0),
159  setSinceTime_(false),
160  firstRun_(true) {
161  edm::LogInfo("ConditionDBWriter::ConditionDBWriter()") << std::endl;
162  SinceAppendMode_ = iConfig.getParameter<bool>("SinceAppendMode");
163  std::string IOVMode = iConfig.getParameter<std::string>("IOVMode");
164  if (IOVMode == std::string("Job"))
165  JobMode_ = true;
166  else if (IOVMode == std::string("Run"))
167  RunMode_ = true;
168  else if (IOVMode == std::string("LumiBlock"))
169  LumiBlockMode_ = true;
170  else if (IOVMode == std::string("AlgoDriven"))
171  AlgoDrivenMode_ = true;
172  else
174  "ConditionDBWriter::ConditionDBWriter(): ERROR - unknown IOV interval write mode...will not store anything "
175  "on the DB")
176  << std::endl;
177  Record_ = iConfig.getParameter<std::string>("Record");
178  doStore_ = iConfig.getParameter<bool>("doStoreOnDB");
179  timeFromEndRun_ = iConfig.getUntrackedParameter<bool>("TimeFromEndRun", false);
180  timeFromStartOfRunRange_ = iConfig.getUntrackedParameter<bool>("TimeFromStartOfRunRange", false);
181 
182  if (!SinceAppendMode_)
183  edm::LogError("ConditionDBWriter::endJob(): ERROR - only SinceAppendMode support!!!!");
184  }
T getParameter(std::string const &) const
Definition: ParameterSet.h:303
Log< level::Error, false > LogError
unsigned int maxRunRange_
T getUntrackedParameter(std::string const &, T const &) const
Log< level::Info, false > LogInfo
unsigned int minRunRange_

◆ ~ConditionDBWriter()

template<class T>
ConditionDBWriter< T >::~ConditionDBWriter ( )
inlineoverride

Definition at line 186 of file ConditionDBWriter.h.

186 { edm::LogInfo("ConditionDBWriter::~ConditionDBWriter()") << std::endl; }
Log< level::Info, false > LogInfo

Member Function Documentation

◆ algoAnalyze()

template<class T>
virtual void ConditionDBWriter< T >::algoAnalyze ( const edm::Event ,
const edm::EventSetup  
)
inlineprivatevirtual

◆ algoBeginJob()

template<class T>
virtual void ConditionDBWriter< T >::algoBeginJob ( const edm::EventSetup )
inlineprivatevirtual

◆ algoBeginLuminosityBlock()

template<class T>
virtual void ConditionDBWriter< T >::algoBeginLuminosityBlock ( const edm::LuminosityBlock ,
const edm::EventSetup  
)
inlineprivatevirtual

◆ algoBeginRun()

template<class T>
virtual void ConditionDBWriter< T >::algoBeginRun ( const edm::Run ,
const edm::EventSetup  
)
inlineprivatevirtual

◆ algoEndJob()

template<class T>
virtual void ConditionDBWriter< T >::algoEndJob ( )
inlineprivatevirtual

◆ algoEndLuminosityBlock()

template<class T>
virtual void ConditionDBWriter< T >::algoEndLuminosityBlock ( const edm::LuminosityBlock ,
const edm::EventSetup  
)
inlineprivatevirtual

Definition at line 273 of file ConditionDBWriter.h.

Referenced by ConditionDBWriter< SiStripApvGain >::endLuminosityBlock().

273 {};

◆ algoEndRun()

template<class T>
virtual void ConditionDBWriter< T >::algoEndRun ( const edm::Run ,
const edm::EventSetup  
)
inlineprivatevirtual

Reimplemented in SiStripGainFromCalibTree.

Definition at line 214 of file ConditionDBWriter.h.

Referenced by ConditionDBWriter< SiStripApvGain >::endRun().

214 {};

◆ analyze()

template<class T>
void ConditionDBWriter< T >::analyze ( const edm::Event event,
const edm::EventSetup iSetup 
)
inlineoverrideprivatevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 247 of file ConditionDBWriter.h.

247  {
248  if (setSinceTime_) {
249  setTime(); //set new since time for possible next upload to DB
250  setSinceTime_ = false;
251  }
252  algoAnalyze(event, iSetup);
253  }
virtual void algoAnalyze(const edm::Event &, const edm::EventSetup &)
Definition: event.py:1

◆ beginJob()

template<class T>
void ConditionDBWriter< T >::beginJob ( )
inlineoverrideprivatevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 218 of file ConditionDBWriter.h.

218 {}

◆ beginLuminosityBlock()

template<class T>
void ConditionDBWriter< T >::beginLuminosityBlock ( const edm::LuminosityBlock lumiBlock,
const edm::EventSetup iSetup 
)
inlineoverrideprivate

Definition at line 240 of file ConditionDBWriter.h.

240  {
241  edm::LogInfo("ConditionDBWriter::beginLuminosityBlock") << std::endl;
243  setSinceTime_ = true;
244  algoBeginLuminosityBlock(lumiBlock, iSetup);
245  }
virtual void algoBeginLuminosityBlock(const edm::LuminosityBlock &, const edm::EventSetup &)
Log< level::Info, false > LogInfo

◆ beginRun()

template<class T>
void ConditionDBWriter< T >::beginRun ( const edm::Run run,
const edm::EventSetup es 
)
inlineoverrideprivate

Definition at line 220 of file ConditionDBWriter.h.

220  {
221  if (firstRun_) {
222  edm::LogInfo("ConditionDBWriter::beginJob") << std::endl;
224  setSinceTime_ = true;
225  algoBeginJob(es);
226  firstRun_ = false;
227  }
228 
229  if (run.id().run() < minRunRange_)
230  minRunRange_ = run.id().run();
231  if (run.id().run() > maxRunRange_)
232  maxRunRange_ = run.id().run();
233 
234  edm::LogInfo("ConditionDBWriter::beginRun") << std::endl;
235  if (RunMode_ && SinceAppendMode_)
236  setSinceTime_ = true;
237  algoBeginRun(run, es);
238  }
virtual void algoBeginJob(const edm::EventSetup &)
unsigned int maxRunRange_
virtual void algoBeginRun(const edm::Run &, const edm::EventSetup &)
Log< level::Info, false > LogInfo
unsigned int minRunRange_

◆ endJob()

template<class T>
void ConditionDBWriter< T >::endJob ( void  )
inlineoverrideprivatevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 296 of file ConditionDBWriter.h.

Referenced by o2olib.O2ORunMgr::executeJob().

296  {
297  edm::LogInfo("ConditionDBWriter::endJob") << std::endl;
298 
299  algoEndJob();
300 
301  if (JobMode_) {
302  std::unique_ptr<T> objPointer = getNewObject();
303 
304  if (objPointer) {
305  storeOnDb(objPointer);
306  }
307 
308  else {
310  "ConditionDBWriter::endJob(): ERROR - requested to store on DB on a Job based interval, but received null "
311  "pointer...will not store anything on the DB")
312  << std::endl;
313  }
314  }
315  }
Log< level::Error, false > LogError
virtual void algoEndJob()
void storeOnDb(std::unique_ptr< T > &objPointer)
virtual std::unique_ptr< T > getNewObject()=0
Log< level::Info, false > LogInfo

◆ endLuminosityBlock()

template<class T>
void ConditionDBWriter< T >::endLuminosityBlock ( const edm::LuminosityBlock lumiBlock,
const edm::EventSetup es 
)
inlineoverrideprivate

Definition at line 255 of file ConditionDBWriter.h.

255  {
256  edm::LogInfo("ConditionDBWriter::endLuminosityBlock") << std::endl;
257  algoEndLuminosityBlock(lumiBlock, es);
258 
259  if (LumiBlockMode_) {
260  std::unique_ptr<T> objPointer = getNewObject();
261 
262  if (objPointer) {
263  storeOnDb(objPointer);
264  } else {
266  "ConditionDBWriter::endLuminosityblock(): ERROR - requested to store on DB on a Lumi Block based interval, "
267  "but received null pointer...will not store anything on the DB")
268  << std::endl;
269  }
270  }
271  }
Log< level::Error, false > LogError
void storeOnDb(std::unique_ptr< T > &objPointer)
virtual std::unique_ptr< T > getNewObject()=0
Log< level::Info, false > LogInfo
virtual void algoEndLuminosityBlock(const edm::LuminosityBlock &, const edm::EventSetup &)

◆ endRun()

template<class T>
void ConditionDBWriter< T >::endRun ( const edm::Run run,
const edm::EventSetup es 
)
inlineoverrideprivate

Definition at line 275 of file ConditionDBWriter.h.

275  {
276  edm::LogInfo("ConditionDBWriter::endRun") << std::endl;
277 
278  algoEndRun(run, es);
279 
280  if (RunMode_) {
281  std::unique_ptr<T> objPointer = getNewObject();
282 
283  if (objPointer) {
284  if (timeFromEndRun_)
285  Time_ = run.id().run();
286  storeOnDb(objPointer);
287  } else {
289  "ConditionDBWriter::endRun(): ERROR - requested to store on DB on a Run based interval, but received null "
290  "pointer...will not store anything on the DB")
291  << std::endl;
292  }
293  }
294  }
Log< level::Error, false > LogError
void storeOnDb(std::unique_ptr< T > &objPointer)
virtual std::unique_ptr< T > getNewObject()=0
Log< level::Info, false > LogInfo
virtual void algoEndRun(const edm::Run &, const edm::EventSetup &)

◆ fillPSetDescription()

template<class T>
static void ConditionDBWriter< T >::fillPSetDescription ( edm::ParameterSetDescription desc)
inlinestatic

Definition at line 189 of file ConditionDBWriter.h.

Referenced by SiStripBadStripFromASCIIFile::fillDescriptions(), and SiPhase2BadStripChannelBuilder::fillDescriptions().

189  {
190  desc.add<bool>("SinceAppendMode");
191  desc.add<std::string>("IOVMode");
192  desc.add<std::string>("Record");
193  desc.add<bool>("doStoreOnDB");
194  desc.addUntracked<bool>("TimeFromEndRun", false);
195  desc.addUntracked<bool>("TimeFromStartOfRunRange", false);
196  }

◆ getNewObject()

template<class T>
virtual std::unique_ptr<T> ConditionDBWriter< T >::getNewObject ( )
privatepure virtual

◆ setDoStore()

template<class T>
void ConditionDBWriter< T >::setDoStore ( const bool  doStore)
inlineprotected

When set to false the payload will not be written to the db.

Definition at line 394 of file ConditionDBWriter.h.

394 { doStore_ = doStore; }

◆ setTime()

template<class T>
void ConditionDBWriter< T >::setTime ( )
inlineprivate

Definition at line 348 of file ConditionDBWriter.h.

Referenced by ConditionDBWriter< SiStripApvGain >::analyze().

348  {
350 
351  if (mydbservice.isAvailable()) {
352  Time_ = mydbservice->currentTime();
353  edm::LogInfo("ConditionDBWriter::setTime: time set to ") << Time_ << std::endl;
354  } else {
355  edm::LogError("ConditionDBWriter::setTime(): PoolDBOutputService is not available...cannot set current time")
356  << std::endl;
357  }
358  }
Log< level::Error, false > LogError
Log< level::Info, false > LogInfo
bool isAvailable() const
Definition: Service.h:40

◆ storeOnDb()

template<class T>
void ConditionDBWriter< T >::storeOnDb ( std::unique_ptr< T > &  objPointer)
inlineprivate

Definition at line 317 of file ConditionDBWriter.h.

Referenced by ConditionDBWriter< SiStripApvGain >::endJob(), ConditionDBWriter< SiStripApvGain >::endLuminosityBlock(), ConditionDBWriter< SiStripApvGain >::endRun(), and ConditionDBWriter< SiStripApvGain >::storeOnDbNow().

317  {
318  edm::LogInfo("ConditionDBWriter::storeOnDb ") << std::endl;
319 
320  setSinceTime_ = true;
321 
322  if (!objPointer) {
323  edm::LogError("ConditionDBWriter: Pointer to object has not been set...storing no data on DB");
324  return;
325  }
326 
327  //And now write data in DB
328  if (!doStore_)
329  return;
331  if (!mydbservice.isAvailable()) {
332  edm::LogError("ConditionDBWriter") << "PoolDBOutputService is unavailable" << std::endl;
333  return;
334  }
335 
337  (mydbservice->isNewTagRequest(Record_) && !timeFromEndRun_) ? mydbservice->beginOfTime() : Time_;
338 
339  //overwrite tim in the case we have the flag TimeFromStartOfRunRange set to on
342 
343  edm::LogInfo("ConditionDBWriter") << "appending a new object to tag " << Record_ << " in since mode " << std::endl;
344 
345  mydbservice->writeOneIOV<T>(*objPointer, since, Record_);
346  }
Log< level::Error, false > LogError
unsigned long long Time_t
Definition: Time.h:14
bool isNewTagRequest(const std::string &recordName)
Hash writeOneIOV(const T &payload, Time_t time, const std::string &recordName)
Log< level::Info, false > LogInfo
bool isAvailable() const
Definition: Service.h:40
long double T
unsigned int minRunRange_

◆ storeOnDbNow()

template<class T>
void ConditionDBWriter< T >::storeOnDbNow ( )
inlineprotected

Definition at line 363 of file ConditionDBWriter.h.

363  {
364  if (AlgoDrivenMode_) {
365  setSinceTime_ = true;
366 
367  std::unique_ptr<T> objPointer = getNewObject();
368 
369  if (!objPointer) {
371  "ConditionDBWriter::storeOnDbNow: ERROR - requested to store on DB a new object (module configuration is "
372  "algo driven based IOV), but received NULL pointer...will not store anything on the DB")
373  << std::endl;
374  return;
375  } else {
376  storeOnDb(objPointer);
377  }
378 
379  } else {
381  "ConditionDBWriter::storeOnDbNow(): ERROR - received a direct request from concrete algorithm to store on DB "
382  "a new object, but module configuration is not to store on DB on an algo driven based interval...will not "
383  "store anything on the DB")
384  << std::endl;
385  return;
386  }
387  }
Log< level::Error, false > LogError
void storeOnDb(std::unique_ptr< T > &objPointer)
virtual std::unique_ptr< T > getNewObject()=0

◆ timeOfLastIOV()

template<class T>
cond::Time_t ConditionDBWriter< T >::timeOfLastIOV ( )
inlineprotected

Definition at line 391 of file ConditionDBWriter.h.

391 { return Time_; }

Member Data Documentation

◆ AlgoDrivenMode_

template<class T>
bool ConditionDBWriter< T >::AlgoDrivenMode_
private

◆ doStore_

template<class T>
bool ConditionDBWriter< T >::doStore_
private

◆ firstRun_

template<class T>
bool ConditionDBWriter< T >::firstRun_
private

Definition at line 414 of file ConditionDBWriter.h.

Referenced by ConditionDBWriter< SiStripApvGain >::beginRun().

◆ JobMode_

template<class T>
bool ConditionDBWriter< T >::JobMode_
private

◆ LumiBlockMode_

template<class T>
bool ConditionDBWriter< T >::LumiBlockMode_
private

◆ maxRunRange_

template<class T>
unsigned int ConditionDBWriter< T >::maxRunRange_
private

Definition at line 398 of file ConditionDBWriter.h.

Referenced by ConditionDBWriter< SiStripApvGain >::beginRun().

◆ minRunRange_

template<class T>
unsigned int ConditionDBWriter< T >::minRunRange_
private

◆ Record_

template<class T>
std::string ConditionDBWriter< T >::Record_
private

◆ RunMode_

template<class T>
bool ConditionDBWriter< T >::RunMode_
private

◆ setSinceTime_

template<class T>
bool ConditionDBWriter< T >::setSinceTime_
private

◆ SinceAppendMode_

template<class T>
bool ConditionDBWriter< T >::SinceAppendMode_
private

◆ Time_

template<class T>
cond::Time_t ConditionDBWriter< T >::Time_
private

◆ timeFromEndRun_

template<class T>
bool ConditionDBWriter< T >::timeFromEndRun_
private

◆ timeFromStartOfRunRange_

template<class T>
bool ConditionDBWriter< T >::timeFromStartOfRunRange_
private