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::SharedResources > 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, edm::one::SharedResources >
 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 150 of file ConditionDBWriter.h.

Constructor & Destructor Documentation

◆ ConditionDBWriter()

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

Definition at line 153 of file ConditionDBWriter.h.

154  : minRunRange_(1 << 31),
155  maxRunRange_(0),
156  LumiBlockMode_(false),
157  RunMode_(false),
158  JobMode_(false),
159  AlgoDrivenMode_(false),
160  Time_(0),
161  setSinceTime_(false),
162  firstRun_(true) {
163  edm::LogInfo("ConditionDBWriter::ConditionDBWriter()") << std::endl;
164  SinceAppendMode_ = iConfig.getParameter<bool>("SinceAppendMode");
165  std::string IOVMode = iConfig.getParameter<std::string>("IOVMode");
166  if (IOVMode == std::string("Job"))
167  JobMode_ = true;
168  else if (IOVMode == std::string("Run"))
169  RunMode_ = true;
170  else if (IOVMode == std::string("LumiBlock"))
171  LumiBlockMode_ = true;
172  else if (IOVMode == std::string("AlgoDriven"))
173  AlgoDrivenMode_ = true;
174  else
176  "ConditionDBWriter::ConditionDBWriter(): ERROR - unknown IOV interval write mode...will not store anything "
177  "on the DB")
178  << std::endl;
179  Record_ = iConfig.getParameter<std::string>("Record");
180  doStore_ = iConfig.getParameter<bool>("doStoreOnDB");
181  timeFromEndRun_ = iConfig.getUntrackedParameter<bool>("TimeFromEndRun", false);
182  timeFromStartOfRunRange_ = iConfig.getUntrackedParameter<bool>("TimeFromStartOfRunRange", false);
183 
184  if (!SinceAppendMode_)
185  edm::LogError("ConditionDBWriter::endJob(): ERROR - only SinceAppendMode support!!!!");
186  }
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 188 of file ConditionDBWriter.h.

188 { 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 275 of file ConditionDBWriter.h.

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

275 {};

◆ algoEndRun()

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

Reimplemented in SiStripGainFromCalibTree.

Definition at line 216 of file ConditionDBWriter.h.

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

216 {};

◆ analyze()

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

Implements edm::one::EDAnalyzerBase.

Definition at line 249 of file ConditionDBWriter.h.

249  {
250  if (setSinceTime_) {
251  setTime(); //set new since time for possible next upload to DB
252  setSinceTime_ = false;
253  }
254  algoAnalyze(event, iSetup);
255  }
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 220 of file ConditionDBWriter.h.

220 {}

◆ beginLuminosityBlock()

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

Definition at line 242 of file ConditionDBWriter.h.

242  {
243  edm::LogInfo("ConditionDBWriter::beginLuminosityBlock") << std::endl;
245  setSinceTime_ = true;
246  algoBeginLuminosityBlock(lumiBlock, iSetup);
247  }
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 222 of file ConditionDBWriter.h.

222  {
223  if (firstRun_) {
224  edm::LogInfo("ConditionDBWriter::beginJob") << std::endl;
226  setSinceTime_ = true;
227  algoBeginJob(es);
228  firstRun_ = false;
229  }
230 
231  if (run.id().run() < minRunRange_)
232  minRunRange_ = run.id().run();
233  if (run.id().run() > maxRunRange_)
234  maxRunRange_ = run.id().run();
235 
236  edm::LogInfo("ConditionDBWriter::beginRun") << std::endl;
237  if (RunMode_ && SinceAppendMode_)
238  setSinceTime_ = true;
239  algoBeginRun(run, es);
240  }
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 298 of file ConditionDBWriter.h.

Referenced by o2olib.O2ORunMgr::executeJob().

298  {
299  edm::LogInfo("ConditionDBWriter::endJob") << std::endl;
300 
301  algoEndJob();
302 
303  if (JobMode_) {
304  std::unique_ptr<T> objPointer = getNewObject();
305 
306  if (objPointer) {
307  storeOnDb(objPointer);
308  }
309 
310  else {
312  "ConditionDBWriter::endJob(): ERROR - requested to store on DB on a Job based interval, but received null "
313  "pointer...will not store anything on the DB")
314  << std::endl;
315  }
316  }
317  }
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 257 of file ConditionDBWriter.h.

257  {
258  edm::LogInfo("ConditionDBWriter::endLuminosityBlock") << std::endl;
259  algoEndLuminosityBlock(lumiBlock, es);
260 
261  if (LumiBlockMode_) {
262  std::unique_ptr<T> objPointer = getNewObject();
263 
264  if (objPointer) {
265  storeOnDb(objPointer);
266  } else {
268  "ConditionDBWriter::endLuminosityblock(): ERROR - requested to store on DB on a Lumi Block based interval, "
269  "but received null pointer...will not store anything on the DB")
270  << std::endl;
271  }
272  }
273  }
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 277 of file ConditionDBWriter.h.

277  {
278  edm::LogInfo("ConditionDBWriter::endRun") << std::endl;
279 
280  algoEndRun(run, es);
281 
282  if (RunMode_) {
283  std::unique_ptr<T> objPointer = getNewObject();
284 
285  if (objPointer) {
286  if (timeFromEndRun_)
287  Time_ = run.id().run();
288  storeOnDb(objPointer);
289  } else {
291  "ConditionDBWriter::endRun(): ERROR - requested to store on DB on a Run based interval, but received null "
292  "pointer...will not store anything on the DB")
293  << std::endl;
294  }
295  }
296  }
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 191 of file ConditionDBWriter.h.

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

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

◆ 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 396 of file ConditionDBWriter.h.

396 { doStore_ = doStore; }

◆ setTime()

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

Definition at line 350 of file ConditionDBWriter.h.

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

350  {
352 
353  if (mydbservice.isAvailable()) {
354  Time_ = mydbservice->currentTime();
355  edm::LogInfo("ConditionDBWriter::setTime: time set to ") << Time_ << std::endl;
356  } else {
357  edm::LogError("ConditionDBWriter::setTime(): PoolDBOutputService is not available...cannot set current time")
358  << std::endl;
359  }
360  }
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 319 of file ConditionDBWriter.h.

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

319  {
320  edm::LogInfo("ConditionDBWriter::storeOnDb ") << std::endl;
321 
322  setSinceTime_ = true;
323 
324  if (!objPointer) {
325  edm::LogError("ConditionDBWriter: Pointer to object has not been set...storing no data on DB");
326  return;
327  }
328 
329  //And now write data in DB
330  if (!doStore_)
331  return;
333  if (!mydbservice.isAvailable()) {
334  edm::LogError("ConditionDBWriter") << "PoolDBOutputService is unavailable" << std::endl;
335  return;
336  }
337 
339  (mydbservice->isNewTagRequest(Record_) && !timeFromEndRun_) ? mydbservice->beginOfTime() : Time_;
340 
341  //overwrite tim in the case we have the flag TimeFromStartOfRunRange set to on
344 
345  edm::LogInfo("ConditionDBWriter") << "appending a new object to tag " << Record_ << " in since mode " << std::endl;
346 
347  mydbservice->writeOneIOV<T>(*objPointer, since, Record_);
348  }
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 365 of file ConditionDBWriter.h.

365  {
366  if (AlgoDrivenMode_) {
367  setSinceTime_ = true;
368 
369  std::unique_ptr<T> objPointer = getNewObject();
370 
371  if (!objPointer) {
373  "ConditionDBWriter::storeOnDbNow: ERROR - requested to store on DB a new object (module configuration is "
374  "algo driven based IOV), but received NULL pointer...will not store anything on the DB")
375  << std::endl;
376  return;
377  } else {
378  storeOnDb(objPointer);
379  }
380 
381  } else {
383  "ConditionDBWriter::storeOnDbNow(): ERROR - received a direct request from concrete algorithm to store on DB "
384  "a new object, but module configuration is not to store on DB on an algo driven based interval...will not "
385  "store anything on the DB")
386  << std::endl;
387  return;
388  }
389  }
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 393 of file ConditionDBWriter.h.

393 { 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 416 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 400 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