Conditions.cxx

#include "Framework/Conditions.h"
 
#include <sstream>
 
#include "Framework/PluginFactory.h"
#include "Framework/Process.h"
 
namespace framework {
 
Conditions::Conditions(Process& p) : process_{p} {}
 
void Conditions::createConditionsObjectProvider(
    const std::string& classname, const std::string& objname,
    const std::string& tagname, const framework::config::Parameters& params) {
  ConditionsObjectProvider* cop =
      PluginFactory::getInstance().createConditionsObjectProvider(
          classname, objname, tagname, params, process_);
 
  if (cop) {
    std::string provides = cop->getConditionObjectName();
    if (providerMap_.find(provides) != providerMap_.end()) {
      EXCEPTION_RAISE(
          "ConditionAmbiguityException",
          "Multiple ConditonsObjectProviders configured to provide " +
              provides);
    }
    providerMap_[provides] = cop;
  } else {
    EXCEPTION_RAISE("ConditionsException",
                    "No ConditionsObjectProvider for " + classname);
  }
}
 
void Conditions::onProcessStart() {
  for (auto ptr : providerMap_) ptr.second->onProcessStart();
}
 
void Conditions::onProcessEnd() {
  for (auto ptr : providerMap_) ptr.second->onProcessEnd();
}
 
void Conditions::onNewRun(ldmx::RunHeader& rh) {
  for (auto ptr : providerMap_) ptr.second->onNewRun(rh);
}
 
ConditionsIOV Conditions::getConditionIOV(
    const std::string& condition_name) const {
  auto cacheptr = cache_.find(condition_name);
  if (cacheptr == cache_.end())
    return ConditionsIOV();
  else
    return cacheptr->second.iov;
}
 
const ConditionsObject* Conditions::getConditionPtr(
    const std::string& condition_name) {
  const ldmx::EventHeader& context = *(process_.getEventHeader());
  auto cacheptr = cache_.find(condition_name);
 
  if (cacheptr == cache_.end()) {
    auto copptr = providerMap_.find(condition_name);
 
    if (copptr == providerMap_.end()) {
      EXCEPTION_RAISE("ConditionUnavailable",
                      "No provider is available for : " + condition_name);
    }
 
    std::pair<const ConditionsObject*, ConditionsIOV> cond =
        copptr->second->getCondition(context);
 
    if (!cond.first) {
      EXCEPTION_RAISE(
          "ConditionUnavailable",
          "Null condition returned for requested item : " + condition_name);
    }
 
    // first request, create a cache entry
    CacheEntry ce;
    ce.iov = cond.second;
    ce.obj = cond.first;
    ce.provider = copptr->second;
    cache_[condition_name] = ce;
    return ce.obj;
  } else {
    if (cacheptr->second.iov.validForEvent(context))
      return cacheptr->second.obj;
    else {
      // if not, we release the old object
      cacheptr->second.provider->releaseConditionsObject(cacheptr->second.obj);
      // now ask for a new one
      std::pair<const ConditionsObject*, ConditionsIOV> cond =
          cacheptr->second.provider->getCondition(context);
 
      if (!cond.first) {
        std::stringstream s;
        s << "Unable to update condition '" << condition_name << "' for event "
          << context.getEventNumber() << " run " << context.getRun();
        if (context.isRealData())
          s << " DATA";
        else
          s << " MC";
        EXCEPTION_RAISE("ConditionUnavailable", s.str());
      }
      cacheptr->second.iov = cond.second;
      cacheptr->second.obj = cond.first;
      return cond.first;
    }
  }
}
 
}  // namespace framework