LHCInfoImpl Namespace Reference

Classes
struct	IOVComp
struct	LumiSectionFilter

Functions
template<typename T >
T &	accessParams (std::vector< T > &params, size_t index)
bool	comparePayloads (const LHCInfo &rhs, const LHCInfo &lhs)
template<typename T >
const T &	getOneParam (const std::vector< std::vector< T > > &params, size_t index)
template<typename T >
const T &	getParams (const std::vector< T > &params, size_t index)
bool	makeFillPayload (std::unique_ptr< LHCInfo > &targetPayload, const cond::OMSServiceResult &queryResult)
std::vector< std::pair< cond::Time_t, std::shared_ptr< LHCInfo > > >::const_iterator	search (const cond::Time_t &val, const std::vector< std::pair< cond::Time_t, std::shared_ptr< LHCInfo >>> &container)
void	setElementData (cond::Time_t since, const std::string &dipVal, unsigned int elementNr, float value, LHCInfo &payload, std::set< cond::Time_t > &initList)
template<typename T >
void	setOneParam (std::vector< std::vector< T > > &params, size_t index, const T &value)
template<typename T >
void	setParams (std::vector< T > &params, size_t index, const T &value)
size_t	transferPayloads (const std::vector< std::pair< cond::Time_t, std::shared_ptr< LHCInfo >>> &buffer, std::map< cond::Time_t, std::shared_ptr< LHCInfo >> &iovsToTransfer, std::shared_ptr< LHCInfo > &prevPayload)

Variables
static const std::map< std::string, int >	vecMap

Function Documentation

accessParams()

template<typename T >

T& LHCInfoImpl::accessParams	(	std::vector< T > &	params,
		size_t	index
	)

Definition at line 124 of file LHCInfo.cc.

References submitPVValidationJobs::params, and cond::impl::to_string().

Referenced by LHCInfo::beam1RF(), LHCInfo::beam1VC(), LHCInfo::beam2RF(), and LHCInfo::beam2VC().

                                                      {
    if (index >= params.size())
      throw std::out_of_range("Parameter with index " + std::to_string(index) + " is out of range.");
    return params[index];
  }

comparePayloads()

bool LHCInfoImpl::comparePayloads	(	const LHCInfo &	rhs,
		const LHCInfo &	lhs
	)

Definition at line 554 of file LHCInfoPopConSourceHandler.cc.

References LHCInfo::betaStar(), LHCInfo::crossingAngle(), LHCInfo::ctppsStatus(), LHCInfo::delivLumi(), LHCInfo::fillNumber(), LHCInfo::instLumi(), LHCInfo::instLumiError(), LHCInfo::lhcComment(), LHCInfo::lhcState(), and LHCInfo::recLumi().

Referenced by transferPayloads().

                                                               {
    if (rhs.fillNumber() != lhs.fillNumber())
      return false;
    if (rhs.delivLumi() != lhs.delivLumi())
      return false;
    if (rhs.recLumi() != lhs.recLumi())
      return false;
    if (rhs.instLumi() != lhs.instLumi())
      return false;
    if (rhs.instLumiError() != lhs.instLumiError())
      return false;
    if (rhs.crossingAngle() != rhs.crossingAngle())
      return false;
    if (rhs.betaStar() != rhs.betaStar())
      return false;
    if (rhs.lhcState() != rhs.lhcState())
      return false;
    if (rhs.lhcComment() != rhs.lhcComment())
      return false;
    if (rhs.ctppsStatus() != rhs.ctppsStatus())
      return false;
    return true;
  }

getOneParam()

template<typename T >

const T& LHCInfoImpl::getOneParam	(	const std::vector< std::vector< T > > &	params,
		size_t	index
	)

Definition at line 131 of file LHCInfo.cc.

References SurfaceOrientation::inner, Skims_PA_cff::name, submitPVValidationJobs::params, and cond::impl::to_string().

Referenced by LHCInfo::beginTime(), LHCInfo::betaStar(), LHCInfo::bunchesInBeam1(), LHCInfo::bunchesInBeam2(), LHCInfo::collidingBunches(), LHCInfo::createTime(), LHCInfo::crossingAngle(), LHCInfo::ctppsStatus(), LHCInfo::delivLumi(), LHCInfo::endTime(), LHCInfo::energy(), LHCInfo::fillNumber(), LHCInfo::fillType(), LHCInfo::injectionScheme(), LHCInfo::instLumi(), LHCInfo::instLumiError(), LHCInfo::intensityForBeam1(), LHCInfo::intensityForBeam2(), LHCInfo::lhcComment(), LHCInfo::lhcState(), LHCInfo::lumiSection(), LHCInfo::particleTypeForBeam1(), LHCInfo::particleTypeForBeam2(), LHCInfo::recLumi(), and LHCInfo::targetBunches().

                                                                             {
    if (index >= params.size())
      throw std::out_of_range("Parameter with index " + std::to_string(index) + " is out of range.");
    const std::vector<T>& inner = params[index];
    if (inner.empty())
      throw std::out_of_range("Parameter with index " + std::to_string(index) + " type=" + typeid(T).name() +
                              " has no value stored.");
    return inner[0];
  }

getParams()

template<typename T >

const T& LHCInfoImpl::getParams	(	const std::vector< T > &	params,
		size_t	index
	)

Definition at line 117 of file LHCInfo.cc.

References submitPVValidationJobs::params, and cond::impl::to_string().

Referenced by LHCInfo::beam1RF(), LHCInfo::beam1VC(), LHCInfo::beam2RF(), LHCInfo::beam2VC(), and LHCInfo::lumiPerBX().

                                                               {
    if (index >= params.size())
      throw std::out_of_range("Parameter with index " + std::to_string(index) + " is out of range.");
    return params[index];
  }

makeFillPayload()

bool LHCInfoImpl::makeFillPayload	(	std::unique_ptr< LHCInfo > &	targetPayload,
		const cond::OMSServiceResult &	queryResult
	)

Definition at line 111 of file LHCInfoPopConSourceHandler.cc.

References cond::OMSServiceResult::begin(), BeamSpotPI::creationTime, cond::OMSServiceResult::empty(), HCALHighEnergyHPDFilter_cfi::energy, cond::time::from_boost(), runTheMatrix::ret, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by LHCInfoPopConSourceHandler::getNewObjects().

                                                                                                       {
    bool ret = false;
    if (!queryResult.empty()) {
      auto row = *queryResult.begin();
      auto currentFill = row.get<unsigned short>("fill_number");
      auto bunches1 = row.get<unsigned short>("bunches_beam1");
      auto bunches2 = row.get<unsigned short>("bunches_beam2");
      auto collidingBunches = row.get<unsigned short>("bunches_colliding");
      auto targetBunches = row.get<unsigned short>("bunches_target");
      auto fillType = row.get<LHCInfo::FillType>("fill_type_runtime");
      auto particleType1 = row.get<LHCInfo::ParticleType>("fill_type_party1");
      auto particleType2 = row.get<LHCInfo::ParticleType>("fill_type_party2");
      auto intensityBeam1 = row.get<float>("intensity_beam1");
      auto intensityBeam2 = row.get<float>("intensity_beam2");
      auto energy = row.get<float>("energy");
      auto creationTime = row.get<boost::posix_time::ptime>("start_time");
      auto stableBeamStartTime = row.get<boost::posix_time::ptime>("start_stable_beam");
      auto beamDumpTime = row.get<boost::posix_time::ptime>("end_time");
      auto injectionScheme = row.get<std::string>("injection_scheme");
      targetPayload = std::make_unique<LHCInfo>();
      targetPayload->setFillNumber(currentFill);
      targetPayload->setBunchesInBeam1(bunches1);
      targetPayload->setBunchesInBeam2(bunches2);
      targetPayload->setCollidingBunches(collidingBunches);
      targetPayload->setTargetBunches(targetBunches);
      targetPayload->setFillType(fillType);
      targetPayload->setParticleTypeForBeam1(particleType1);
      targetPayload->setParticleTypeForBeam2(particleType2);
      targetPayload->setIntensityForBeam1(intensityBeam1);
      targetPayload->setIntensityForBeam2(intensityBeam2);
      targetPayload->setEnergy(energy);
      targetPayload->setCreationTime(cond::time::from_boost(creationTime));
      targetPayload->setBeginTime(cond::time::from_boost(stableBeamStartTime));
      targetPayload->setEndTime(cond::time::from_boost(beamDumpTime));
      targetPayload->setInjectionScheme(injectionScheme);
      ret = true;
    }
    return ret;
  }

search()

std::vector<std::pair<cond::Time_t, std::shared_ptr<LHCInfo> > >::const_iterator LHCInfoImpl::search	(	const cond::Time_t &	val,
		const std::vector< std::pair< cond::Time_t, std::shared_ptr< LHCInfo >>> &	container
	)

Definition at line 103 of file LHCInfoPopConSourceHandler.cc.

References AlCaHLTBitMon_ParallelJobs::p, pfDeepBoostedJetPreprocessParams_cfi::upper_bound, and heppy_batch::val.

Referenced by LHCInfoImpl::LumiSectionFilter::process().

                                                                                                      {
    if (container.empty())
      return container.end();
    auto p = std::upper_bound(container.begin(), container.end(), val, IOVComp());
    return (p != container.begin()) ? p - 1 : container.end();
  }

setElementData()

void LHCInfoImpl::setElementData	(	cond::Time_t	since,
		const std::string &	dipVal,
		unsigned int	elementNr,
		float	value,
		LHCInfo &	payload,
		std::set< cond::Time_t > &	initList
	)

Definition at line 394 of file LHCInfoPopConSourceHandler.cc.

References LHCInfo::bunchSlots, jetsAK4_Puppi_cff::payload, SiStripBadComponentsDQMServiceTemplate_cfg::since, relativeConstraints::value, and vecMap.

Referenced by LHCInfoPopConSourceHandler::getEcalData().

                                                    {
    if (initList.find(since) == initList.end()) {
      payload.beam1VC().resize(LHCInfo::bunchSlots, 0.);
      payload.beam2VC().resize(LHCInfo::bunchSlots, 0.);
      payload.beam1RF().resize(LHCInfo::bunchSlots, 0.);
      payload.beam2RF().resize(LHCInfo::bunchSlots, 0.);
      initList.insert(since);
    }
    // set the current values to all of the payloads of the lumi section samples after the current since
    if (elementNr < LHCInfo::bunchSlots) {
      switch (vecMap.at(dipVal)) {
        case 1:
          payload.beam1VC()[elementNr] = value;
          break;
        case 2:
          payload.beam2VC()[elementNr] = value;
          break;
        case 3:
          payload.beam1RF()[elementNr] = value;
          break;
        case 4:
          payload.beam2RF()[elementNr] = value;
          break;
        default:
          break;
      }
    }
  }

setOneParam()

template<typename T >

void LHCInfoImpl::setOneParam	(	std::vector< std::vector< T > > &	params,
		size_t	index,
		const T &	value
	)

Definition at line 142 of file LHCInfo.cc.

References submitPVValidationJobs::params, cond::impl::to_string(), and relativeConstraints::value.

Referenced by LHCInfo::setBeginTime(), LHCInfo::setBetaStar(), LHCInfo::setBunchesInBeam1(), LHCInfo::setBunchesInBeam2(), LHCInfo::setCollidingBunches(), LHCInfo::setCreationTime(), LHCInfo::setCrossingAngle(), LHCInfo::setCtppsStatus(), LHCInfo::setDelivLumi(), LHCInfo::setEndTime(), LHCInfo::setEnergy(), LHCInfo::setFillNumber(), LHCInfo::setFillType(), LHCInfo::setInjectionScheme(), LHCInfo::setInstLumi(), LHCInfo::setInstLumiError(), LHCInfo::setIntensityForBeam1(), LHCInfo::setIntensityForBeam2(), LHCInfo::setLhcComment(), LHCInfo::setLhcState(), LHCInfo::setLumiSection(), LHCInfo::setParticleTypeForBeam1(), LHCInfo::setParticleTypeForBeam2(), LHCInfo::setRecLumi(), and LHCInfo::setTargetBunches().

                                                                                   {
    if (index >= params.size())
      throw std::out_of_range("Parameter with index " + std::to_string(index) + " is out of range.");
    params[index] = std::vector<T>(1, value);
  }

setParams()

template<typename T >

void LHCInfoImpl::setParams	(	std::vector< T > &	params,
		size_t	index,
		const T &	value
	)

Definition at line 149 of file LHCInfo.cc.

References submitPVValidationJobs::params, cond::impl::to_string(), and relativeConstraints::value.

Referenced by LHCInfo::setBeam1RF(), LHCInfo::setBeam1VC(), LHCInfo::setBeam2RF(), LHCInfo::setBeam2VC(), and LHCInfo::setLumiPerBX().

                                                                     {
    if (index >= params.size())
      throw std::out_of_range("Parameter with index " + std::to_string(index) + " is out of range.");
    params[index] = value;
  }

transferPayloads()

size_t LHCInfoImpl::transferPayloads	(	const std::vector< std::pair< cond::Time_t, std::shared_ptr< LHCInfo >>> &	buffer,
		std::map< cond::Time_t, std::shared_ptr< LHCInfo >> &	iovsToTransfer,
		std::shared_ptr< LHCInfo > &	prevPayload
	)

Definition at line 578 of file LHCInfoPopConSourceHandler.cc.

References PVValHelper::add(), edmScanValgrind::buffer, comparePayloads(), jetsAK4_Puppi_cff::payload, and SiStripBadComponentsDQMServiceTemplate_cfg::since.

Referenced by LHCInfoPopConSourceHandler::getNewObjects().

                                                               {
    size_t niovs = 0;
    for (auto& iov : buffer) {
      bool add = false;
      auto payload = iov.second;
      cond::Time_t since = iov.first;
      if (iovsToTransfer.empty()) {
        add = true;
      } else {
        LHCInfo& lastAdded = *iovsToTransfer.rbegin()->second;
        if (!comparePayloads(lastAdded, *payload)) {
          add = true;
        }
      }
      if (add) {
        niovs++;
        iovsToTransfer.insert(std::make_pair(since, payload));
        prevPayload = iov.second;
      }
    }
    return niovs;
  }

Variable Documentation

vecMap

const std::map<std::string, int> LHCInfoImpl::vecMap

static

Initial value:

= {
      {"Beam1/beamPhaseMean", 1}, {"Beam2/beamPhaseMean", 2}, {"Beam1/cavPhaseMean", 3}, {"Beam2/cavPhaseMean", 4}}

Definition at line 392 of file LHCInfoPopConSourceHandler.cc.

Referenced by setElementData().