#include <CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.h>

Public Member Functions
	CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon (const edm::ParameterSet &p)

	~CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon ()

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

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

Public Attributes
CTPPSRPAlignmentCorrectionsData	acMeasured

CTPPSRPAlignmentCorrectionsData	acMisaligned

CTPPSRPAlignmentCorrectionsData	acReal

CTPPSRPAlignmentCorrectionsDataSequence	acsMeasured

CTPPSRPAlignmentCorrectionsDataSequence	acsMisaligned

CTPPSRPAlignmentCorrectionsDataSequence	acsReal

unsigned int	verbosity

Protected Member Functions
CTPPSRPAlignmentCorrectionsDataSequence	Merge (const std::vector< CTPPSRPAlignmentCorrectionsDataSequence > &) const

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

Detailed Description

Definition at line 17 of file CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.h.

Constructor & Destructor Documentation

◆ CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon()

CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon::CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon ( const edm::ParameterSet & p )

Definition at line 20 of file CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.cc.

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

References acsMeasured, acsMisaligned, acsReal, f, contentValuesFiles::fullPath, edm::ParameterSet::getParameter(), and PrepareSequence().

◆ ~CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon()

CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon::~CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon ( )

Definition at line 41 of file CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.cc.

Member Function Documentation

◆ Merge()

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

protected

Definition at line 45 of file CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.cc.

                                                                           {
   // find interval boundaries
   std::map<edm::EventID, std::vector<std::pair<bool, const CTPPSRPAlignmentCorrectionsData *> > > bounds;
  
   for (const auto &seq : seqs) {
     for (const auto &p : seq) {
       const edm::ValidityInterval &iov = p.first;
       const CTPPSRPAlignmentCorrectionsData *corr = &p.second;
  
       const edm::EventID &event_first = iov.first().eventID();
       bounds[event_first].emplace_back(std::pair<bool, const CTPPSRPAlignmentCorrectionsData *>(true, corr));
  
       const edm::EventID &event_after = nextLS(iov.last().eventID());
       bounds[event_after].emplace_back(std::pair<bool, const CTPPSRPAlignmentCorrectionsData *>(false, corr));
     }
   }
  
   // build correction sums per interval
   std::set<const CTPPSRPAlignmentCorrectionsData *> accumulator;
   CTPPSRPAlignmentCorrectionsDataSequence result;
   for (std::map<edm::EventID, std::vector<std::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 edm::EventID &event_first = tit->first;
     const edm::EventID &event_last = previousLS(tit_next->first);
  
     if (verbosity) {
       edm::LogInfo("PPS") << "    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;

References mixOne_premix_on_sim_cfi::accumulator, PVValHelper::add(), CTPPSRPAlignmentCorrectionsData::addCorrections(), alignCSCRings::corr, edm::IOVSyncValue::eventID(), edm::ValidityInterval::first(), CTPPSRPAlignmentCorrectionsMethods::iovValueToString(), edm::ValidityInterval::last(), genParticles_cff::map, nextLS(), AlCaHLTBitMon_ParallelJobs::p, previousLS(), mps_fire::result, cmsswSequenceInfo::seq, cmsswSequenceInfo::seqs, trackerHitRTTI::vector, and verbosity.

Referenced by PrepareSequence().

◆ nextLS()

edm::EventID CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon::nextLS ( const edm::EventID & src )

static

Definition at line 136 of file CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.cc.

                                                                                          {
   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());

References edm::EventID::maxLuminosityBlockNumber(), edm::EventID::maxRunNumber(), and TrackRefitter_38T_cff::src.

Referenced by Merge().

◆ PrepareSequence()

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

protected

Definition at line 108 of file CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.cc.

                                                                                                                 {
   if (verbosity)
     edm::LogInfo("PPS") << "PrepareSequence(" << label << ")";
  
   std::vector<CTPPSRPAlignmentCorrectionsDataSequence> sequences;
   sequences.reserve(files.size());
   for (const auto &file : files)
     sequences.emplace_back(CTPPSRPAlignmentCorrectionsMethods::loadFromXML(file));
  
   seq = Merge(sequences);

References FrontierConditions_GlobalTag_cff::file, submitPVResolutionJobs::files, label, CTPPSRPAlignmentCorrectionsMethods::loadFromXML(), Merge(), cmsswSequenceInfo::seq, and verbosity.

Referenced by CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon().

◆ previousLS()

edm::EventID CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon::previousLS ( const edm::EventID & src )

static

Definition at line 124 of file CTPPSRPAlignmentCorrectionsDataESSourceXMLCommon.cc.

                                                                                              {
   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());