CTPPSRPAlignmentCorrectionsDataESSourceXML Class Reference

Inheritance diagram for CTPPSRPAlignmentCorrectionsDataESSourceXML:

Public Member Functions
	CTPPSRPAlignmentCorrectionsDataESSourceXML (const edm::ParameterSet &p)
std::unique_ptr< CTPPSRPAlignmentCorrectionsData >	produceMeasured (const CTPPSRPAlignmentCorrectionsDataRcd &)
std::unique_ptr< CTPPSRPAlignmentCorrectionsData >	produceMisaligned (const RPMisalignedAlignmentRecord &)
std::unique_ptr< CTPPSRPAlignmentCorrectionsData >	produceReal (const RPRealAlignmentRecord &)
	~CTPPSRPAlignmentCorrectionsDataESSourceXML () override
Public Member Functions inherited from edm::ESProducer
	ESProducer ()
ESProxyIndex const *	getTokenIndices (unsigned int iIndex) const
void	updateLookup (eventsetup::ESRecordsToProxyIndices const &) final
	~ESProducer ()(false) override
Public Member Functions inherited from edm::ESProxyFactoryProducer
	ESProxyFactoryProducer ()
void	newInterval (const eventsetup::EventSetupRecordKey &iRecordType, const ValidityInterval &iInterval) override
	overrides DataProxyProvider method More...
	~ESProxyFactoryProducer () noexcept(false) override
Public Member Functions inherited from edm::eventsetup::DataProxyProvider
	DataProxyProvider ()
const ComponentDescription &	description () const
bool	isUsingRecord (const EventSetupRecordKey &) const
const KeyedProxies &	keyedProxies (const EventSetupRecordKey &iRecordKey) const
void	resetProxies (const EventSetupRecordKey &iRecordType)
void	resetProxiesIfTransient (const EventSetupRecordKey &iRecordType)
void	setAppendToDataLabel (const edm::ParameterSet &)
void	setDescription (const ComponentDescription &iDescription)
std::set< EventSetupRecordKey >	usingRecords () const
virtual	~DataProxyProvider () noexcept(false)
Public Member Functions inherited from edm::EventSetupRecordIntervalFinder
const eventsetup::ComponentDescription &	descriptionForFinder () const
	EventSetupRecordIntervalFinder ()
std::set< eventsetup::EventSetupRecordKey >	findingForRecords () const
const ValidityInterval &	findIntervalFor (const eventsetup::EventSetupRecordKey &, const IOVSyncValue &)
void	setDescriptionForFinder (const eventsetup::ComponentDescription &iDescription)
virtual	~EventSetupRecordIntervalFinder () noexcept(false)

Protected Member Functions
CTPPSRPAlignmentCorrectionsDataSequence	Merge (const std::vector< CTPPSRPAlignmentCorrectionsDataSequence > &) const
	merges an array of sequences to one More...
void	PrepareSequence (const std::string &label, CTPPSRPAlignmentCorrectionsDataSequence &seq, const std::vector< std::string > &files) const
	builds a sequence of corrections from provided sources and runs a few checks More...
void	setIntervalFor (const edm::eventsetup::EventSetupRecordKey &, const edm::IOVSyncValue &, edm::ValidityInterval &) override
Protected Member Functions inherited from edm::ESProducer
	ESProducer (const ESProducer &)=delete
ESProducer const &	operator= (const ESProducer &)=delete
template<typename T >
auto	setWhatProduced (T *iThis, const es::Label &iLabel={})
template<typename T >
auto	setWhatProduced (T *iThis, const char *iLabel)
template<typename T >
auto	setWhatProduced (T *iThis, const std::string &iLabel)
template<typename T , typename TDecorator >
auto	setWhatProduced (T *iThis, const TDecorator &iDec, const es::Label &iLabel={})
template<typename T , typename TReturn , typename TRecord >
auto	setWhatProduced (T *iThis, TReturn(T::*iMethod)(const TRecord &), const es::Label &iLabel={})
template<typename T , typename TReturn , typename TRecord , typename TArg >
ESConsumesCollectorT< TRecord >	setWhatProduced (T *iThis, TReturn(T::*iMethod)(const TRecord &), const TArg &iDec, const es::Label &iLabel={})
Protected Member Functions inherited from edm::ESProxyFactoryProducer
template<class TFactory >
void	registerFactory (std::unique_ptr< TFactory > iFactory, const std::string &iLabel=std::string())
virtual void	registerFactoryWithKey (const eventsetup::EventSetupRecordKey &iRecord, std::unique_ptr< eventsetup::ProxyFactoryBase > iFactory, const std::string &iLabel=std::string())
void	registerProxies (const eventsetup::EventSetupRecordKey &iRecord, KeyedProxies &aProxyList) override
	override DataProxyProvider method More...
Protected Member Functions inherited from edm::eventsetup::DataProxyProvider
void	eraseAll (const EventSetupRecordKey &iRecordKey)
	deletes all the Proxies in aStream More...
void	invalidateProxies (const EventSetupRecordKey &iRecordKey)
template<class T >
void	usingRecord ()
void	usingRecordWithKey (const EventSetupRecordKey &)
Protected Member Functions inherited from edm::EventSetupRecordIntervalFinder
template<class T >
void	findingRecord ()
void	findingRecordWithKey (const eventsetup::EventSetupRecordKey &)

Static Protected Member Functions
static edm::EventID	nextLS (const edm::EventID &src)
static edm::EventID	previousLS (const edm::EventID &src)

Protected Attributes
CTPPSRPAlignmentCorrectionsData	acMeasured
CTPPSRPAlignmentCorrectionsData	acMisaligned
CTPPSRPAlignmentCorrectionsData	acReal
CTPPSRPAlignmentCorrectionsDataSequence	acsMeasured
CTPPSRPAlignmentCorrectionsDataSequence	acsMisaligned
CTPPSRPAlignmentCorrectionsDataSequence	acsReal
unsigned int	verbosity

Additional Inherited Members
Public Types inherited from edm::eventsetup::DataProxyProvider
typedef std::vector< std::pair< DataKey, edm::propagate_const< std::shared_ptr< DataProxy > > > >	KeyedProxies
typedef std::vector< EventSetupRecordKey >	Keys
typedef std::map< EventSetupRecordKey, KeyedProxies >	RecordProxies
Static Public Member Functions inherited from edm::eventsetup::DataProxyProvider
static void	prevalidate (ConfigurationDescriptions &)

Detailed Description

Loads alignment corrections to EventSetup.

Definition at line 37 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Constructor & Destructor Documentation

CTPPSRPAlignmentCorrectionsDataESSourceXML::CTPPSRPAlignmentCorrectionsDataESSourceXML

(

const edm::ParameterSet &

p

)

Definition at line 95 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References acsMeasured, acsMisaligned, acsReal, f, edm::ParameterSet::getParameter(), PrepareSequence(), produceMeasured(), produceMisaligned(), produceReal(), and edm::ESProducer::setWhatProduced().

                                                                                                                  :
  verbosity(pSet.getUntrackedParameter<unsigned int>("verbosity", 0))
{
  std::vector<std::string> measuredFiles;
  for (const auto &f: pSet.getParameter< vector<string> >("MeasuredFiles"))
    measuredFiles.push_back(edm::FileInPath(f).fullPath());
  PrepareSequence("Measured", acsMeasured, measuredFiles);

  std::vector<std::string> realFiles;
  for (const auto &f: pSet.getParameter< vector<string> >("RealFiles"))
    realFiles.push_back(edm::FileInPath(f).fullPath());
  PrepareSequence("Real", acsReal, realFiles);

  std::vector<std::string> misalignedFiles;
  for (const auto &f: pSet.getParameter< vector<string> >("MisalignedFiles"))
    misalignedFiles.push_back(edm::FileInPath(f).fullPath());
  PrepareSequence("Misaligned", acsMisaligned, misalignedFiles);

  setWhatProduced(this, &CTPPSRPAlignmentCorrectionsDataESSourceXML::produceMeasured);
  setWhatProduced(this, &CTPPSRPAlignmentCorrectionsDataESSourceXML::produceReal);
  setWhatProduced(this, &CTPPSRPAlignmentCorrectionsDataESSourceXML::produceMisaligned);

  findingRecord<CTPPSRPAlignmentCorrectionsDataRcd>();
  findingRecord<RPRealAlignmentRecord>();
  findingRecord<RPMisalignedAlignmentRecord>();
}

CTPPSRPAlignmentCorrectionsDataESSourceXML::~CTPPSRPAlignmentCorrectionsDataESSourceXML ( )

override

Definition at line 124 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

{
}

Member Function Documentation

CTPPSRPAlignmentCorrectionsDataSequence CTPPSRPAlignmentCorrectionsDataESSourceXML::Merge ( const std::vector< CTPPSRPAlignmentCorrectionsDataSequence > &  seqs ) const

protected

merges an array of sequences to one

Definition at line 130 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References mixOne_premix_on_sim_cfi::accumulator, PVValHelper::add(), CTPPSRPAlignmentCorrectionsData::addCorrections(), corr, edm::IOVSyncValue::eventID(), edm::ValidityInterval::first(), CTPPSRPAlignmentCorrectionsDataSequence::insert(), CTPPSRPAlignmentCorrectionsMethods::iovValueToString(), edm::ValidityInterval::last(), genParticles_cff::map, nextLS(), AlCaHLTBitMon_ParallelJobs::p, previousLS(), mps_fire::result, and verbosity.

Referenced by nextLS(), and PrepareSequence().

{
  // find interval boundaries
  map< edm::EventID, vector< pair<bool, const CTPPSRPAlignmentCorrectionsData*> > > bounds;

  for (const auto & seq : seqs)
  {
    for (const auto &p : seq)
    {
      const ValidityInterval &iov = p.first;
      const CTPPSRPAlignmentCorrectionsData *corr = & p.second;

      const EventID &event_first = iov.first().eventID();
      bounds[event_first].emplace_back( pair<bool, const CTPPSRPAlignmentCorrectionsData*>(true, corr) );

      const EventID &event_after = nextLS(iov.last().eventID());
      bounds[event_after].emplace_back( pair<bool, const CTPPSRPAlignmentCorrectionsData*>(false, corr) );
    }
  }

  // build correction sums per interval
  set<const CTPPSRPAlignmentCorrectionsData*> accumulator;
  CTPPSRPAlignmentCorrectionsDataSequence result;
  for (map< EventID, vector< pair<bool, const CTPPSRPAlignmentCorrectionsData*> > >::const_iterator tit = bounds.begin(); tit != bounds.end(); ++tit)
  {
    for (const auto & cit : tit->second)
    {
      bool add = cit.first;
      const CTPPSRPAlignmentCorrectionsData *corr = cit.second;

      if (add)
        accumulator.insert(corr);
      else
        accumulator.erase(corr);
    }

    auto tit_next = tit;
    tit_next++;
    if (tit_next == bounds.end())
      break;

    const EventID &event_first = tit->first;
    const EventID &event_last = previousLS(tit_next->first);

    if (verbosity)
    {
      LogVerbatim("CTPPSRPAlignmentCorrectionsDataESSourceXML")
        << "    first=" << CTPPSRPAlignmentCorrectionsMethods::iovValueToString(edm::IOVSyncValue(event_first))
        << ", last=" << CTPPSRPAlignmentCorrectionsMethods::iovValueToString(edm::IOVSyncValue(event_last))
        << ": alignment blocks " << accumulator.size();
    }

    CTPPSRPAlignmentCorrectionsData corr_sum;
    for (auto sit : accumulator)
      corr_sum.addCorrections(*sit);

    result.insert(edm::ValidityInterval(edm::IOVSyncValue(event_first), edm::IOVSyncValue(event_last)), corr_sum);
  }

  return result;
}

static edm::EventID CTPPSRPAlignmentCorrectionsDataESSourceXML::nextLS ( const edm::EventID &  src )

inlinestaticprotected

Definition at line 66 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References edm::EventID::event(), PatBasicFWLiteAnalyzer::files, label, edm::EventID::luminosityBlock(), edm::EventID::maxLuminosityBlockNumber(), edm::EventID::maxRunNumber(), Merge(), PrepareSequence(), edm::EventID::run(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by Merge().

    {
      if (src.luminosityBlock() == edm::EventID::maxLuminosityBlockNumber())
      {
        if (src.run() == edm::EventID::maxRunNumber())
          return src;

        return edm::EventID(src.run() + 1, 0, src.event());
      }

      return edm::EventID(src.run(), src.luminosityBlock() + 1, src.event());
    }

void CTPPSRPAlignmentCorrectionsDataESSourceXML::PrepareSequence ( const std::string &  label, CTPPSRPAlignmentCorrectionsDataSequence &  seq, const std::vector< std::string > &  files  ) const

protected

builds a sequence of corrections from provided sources and runs a few checks

Definition at line 194 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References FrontierConditions_GlobalTag_cff::file, CTPPSRPAlignmentCorrectionsMethods::loadFromXML(), Merge(), and verbosity.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXML(), and nextLS().

{
  if (verbosity)
    LogVerbatim(">> CTPPSRPAlignmentCorrectionsDataESSourceXML") << "CTPPSRPAlignmentCorrectionsDataESSourceXML::PrepareSequence(" << label << ")";

  vector<CTPPSRPAlignmentCorrectionsDataSequence> sequences;
  for (const auto & file : files)
    sequences.emplace_back(CTPPSRPAlignmentCorrectionsMethods::loadFromXML(file));

  seq = Merge(sequences);
}

static edm::EventID CTPPSRPAlignmentCorrectionsDataESSourceXML::previousLS ( const edm::EventID &  src )

inlinestaticprotected

Definition at line 55 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References edm::EventID::event(), edm::EventID::luminosityBlock(), edm::EventID::maxLuminosityBlockNumber(), edm::EventID::maxRunNumber(), and edm::EventID::run().

Referenced by Merge(), and setIntervalFor().

    {
      if (src.run() == edm::EventID::maxRunNumber() && src.luminosityBlock() == edm::EventID::maxLuminosityBlockNumber())
          return src;

      if (src.luminosityBlock() == 0)
        return edm::EventID(src.run() - 1, edm::EventID::maxLuminosityBlockNumber(), src.event());

      return edm::EventID(src.run(), src.luminosityBlock() - 1, src.event());
    }

std::unique_ptr< CTPPSRPAlignmentCorrectionsData > CTPPSRPAlignmentCorrectionsDataESSourceXML::produceMeasured

(

const CTPPSRPAlignmentCorrectionsDataRcd &

iRecord

)

Definition at line 208 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References acMeasured.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXML().

{
  return std::make_unique<CTPPSRPAlignmentCorrectionsData>(acMeasured);
}

std::unique_ptr< CTPPSRPAlignmentCorrectionsData > CTPPSRPAlignmentCorrectionsDataESSourceXML::produceMisaligned

(

const RPMisalignedAlignmentRecord &

iRecord

)

Definition at line 222 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References acMisaligned.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXML().

{
  return std::make_unique<CTPPSRPAlignmentCorrectionsData>(acMisaligned);
}

std::unique_ptr< CTPPSRPAlignmentCorrectionsData > CTPPSRPAlignmentCorrectionsDataESSourceXML::produceReal

(

const RPRealAlignmentRecord &

iRecord

)

Definition at line 215 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References acReal.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXML().

{
  return std::make_unique<CTPPSRPAlignmentCorrectionsData>(acReal);
}

void CTPPSRPAlignmentCorrectionsDataESSourceXML::setIntervalFor ( const edm::eventsetup::EventSetupRecordKey &  key, const edm::IOVSyncValue &  iosv, edm::ValidityInterval &  valInt  )

overrideprotectedvirtual

Implements edm::EventSetupRecordIntervalFinder.

Definition at line 229 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

References acMeasured, acMisaligned, acReal, acsMeasured, acsMisaligned, acsReal, DEFINE_FWK_EVENTSETUP_SOURCE, edm::IOVSyncValue::endOfTime(), edm::IOVSyncValue::eventID(), Exception, edm::ValidityInterval::first(), CTPPSRPAlignmentCorrectionsMethods::iovValueToString(), edm::ValidityInterval::last(), edm::EventID::luminosityBlock(), edm::EventID::maxLuminosityBlockNumber(), edm::EventID::maxRunNumber(), edm::eventsetup::EventSetupRecordKey::name(), previousLS(), edm::EventID::run(), edm::IOVSyncValue::time(), edm::Timestamp::unixTime(), and verbosity.

{
  if (verbosity)
    {
      time_t unixTime = iosv.time().unixTime();
      char timeStr[50];
      strftime(timeStr, 50, "%F %T", localtime(&unixTime));

      LogVerbatim("CTPPSRPAlignmentCorrectionsDataESSourceXML")
    << ">> CTPPSRPAlignmentCorrectionsDataESSourceXML::setIntervalFor(" << key.name() << ")";

      LogVerbatim("CTPPSRPAlignmentCorrectionsDataESSourceXML")
    << "    event=" << iosv.eventID() << ", UNIX timestamp=" << unixTime << " (" << timeStr << ")";
    }

  // // determine what sequence and corrections should be used
  CTPPSRPAlignmentCorrectionsDataSequence *p_seq = nullptr;
  CTPPSRPAlignmentCorrectionsData *p_corr = nullptr;

  if (strcmp(key.name(), "CTPPSRPAlignmentCorrectionsDataRcd") == 0)
    {
      p_seq = &acsMeasured;
      p_corr = &acMeasured;
    }

  if (strcmp(key.name(), "RPRealAlignmentRecord") == 0)
  {
    p_seq = &acsReal;
    p_corr = &acReal;
  }

  if (strcmp(key.name(), "RPMisalignedAlignmentRecord") == 0)
  {
    p_seq = &acsMisaligned;
    p_corr = &acMisaligned;
  }

   if (p_corr == nullptr)
     throw cms::Exception("CTPPSRPAlignmentCorrectionsDataESSourceXML::setIntervalFor") << "Unknown record " << key.name();

   // // find the corresponding interval
   bool next_exists = false;
   const edm::EventID &event_curr = iosv.eventID();
   edm::EventID event_next_start(edm::EventID::maxRunNumber(), edm::EventID::maxLuminosityBlockNumber(), 1);

   for (const auto &it: *p_seq)
  {
    const auto &it_event_first = it.first.first().eventID();
    const auto &it_event_last = it.first.last().eventID();

    bool it_contained_lo = ( (it_event_first.run() < event_curr.run()) ||
        ((it_event_first.run() == event_curr.run()) && (it_event_first.luminosityBlock() <= event_curr.luminosityBlock())) );

    bool it_contained_up = ( (it_event_last.run() > event_curr.run()) ||
        ((it_event_last.run() == event_curr.run()) && (it_event_last.luminosityBlock() >= event_curr.luminosityBlock())) );

    if (it_contained_lo && it_contained_up)
    {
      valInt = it.first;
      *p_corr = it.second;

      if (verbosity)
      {
        LogVerbatim("CTPPSRPAlignmentCorrectionsDataESSourceXML")
          << "    setting validity interval ["
          << CTPPSRPAlignmentCorrectionsMethods::iovValueToString(valInt.first())
          << ", " << CTPPSRPAlignmentCorrectionsMethods::iovValueToString(valInt.last()) << "]";
      }

      return;
    }

    bool it_in_future = ( (it_event_first.run() > event_curr.run()) ||
        ((it_event_first.run() == event_curr.run() && (it_event_first.luminosityBlock() > event_curr.luminosityBlock()))) );

    if (it_in_future)
    {
      next_exists = true;
      if (event_next_start > it_event_first)
        event_next_start = it_event_first;
    }
  }

  // no interval found, set empty corrections
  *p_corr = CTPPSRPAlignmentCorrectionsData();

  if (!next_exists)
  {
    valInt = ValidityInterval(iosv, iosv.endOfTime());
  } else {
    const EventID &event_last = previousLS(event_next_start);
    valInt = ValidityInterval(iosv, IOVSyncValue(event_last));
  }

  if (verbosity)
  {
    LogVerbatim("CTPPSRPAlignmentCorrectionsDataESSourceXML")
      << "    setting validity interval ["
      << CTPPSRPAlignmentCorrectionsMethods::iovValueToString(valInt.first())
      << ", " << CTPPSRPAlignmentCorrectionsMethods::iovValueToString(valInt.last()) << "] (empty alignment corrections)";
  }

}

Member Data Documentation

CTPPSRPAlignmentCorrectionsData CTPPSRPAlignmentCorrectionsDataESSourceXML::acMeasured

protected

Definition at line 51 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Referenced by produceMeasured(), and setIntervalFor().

CTPPSRPAlignmentCorrectionsData CTPPSRPAlignmentCorrectionsDataESSourceXML::acMisaligned

protected

Definition at line 51 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Referenced by produceMisaligned(), and setIntervalFor().

CTPPSRPAlignmentCorrectionsData CTPPSRPAlignmentCorrectionsDataESSourceXML::acReal

protected

Definition at line 51 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Referenced by produceReal(), and setIntervalFor().

CTPPSRPAlignmentCorrectionsDataSequence CTPPSRPAlignmentCorrectionsDataESSourceXML::acsMeasured

protected

Definition at line 50 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXML(), and setIntervalFor().

CTPPSRPAlignmentCorrectionsDataSequence CTPPSRPAlignmentCorrectionsDataESSourceXML::acsMisaligned

protected

Definition at line 50 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXML(), and setIntervalFor().

CTPPSRPAlignmentCorrectionsDataSequence CTPPSRPAlignmentCorrectionsDataESSourceXML::acsReal

protected

Definition at line 50 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXML(), and setIntervalFor().

unsigned int CTPPSRPAlignmentCorrectionsDataESSourceXML::verbosity

protected

Definition at line 49 of file CTPPSRPAlignmentCorrectionsDataESSourceXML.cc.

Referenced by Merge(), PrepareSequence(), and setIntervalFor().