theLHCInfoPerLSImpl Namespace Reference

Functions
bool	comparePayloads (const LHCInfoPerLS &rhs, const LHCInfoPerLS &lhs)
size_t	transferPayloads (const std::vector< std::pair< cond::Time_t, std::shared_ptr< LHCInfoPerLS >>> &buffer, std::map< cond::Time_t, std::shared_ptr< LHCInfoPerLS >> &iovsToTransfer, std::shared_ptr< LHCInfoPerLS > &prevPayload)

Function Documentation

comparePayloads()

bool theLHCInfoPerLSImpl::comparePayloads	(	const LHCInfoPerLS &	rhs,
		const LHCInfoPerLS &	lhs
	)

Definition at line 37 of file LHCInfoPerLSPopConAnalyzer.cc.

References LHCInfoPerLS::betaStarX(), LHCInfoPerLS::betaStarY(), LHCInfoPerLS::crossingAngleX(), LHCInfoPerLS::crossingAngleY(), LHCInfoPerLS::fillNumber(), and LHCInfoPerLS::runNumber().

Referenced by transferPayloads().

                                                                         {
    if (rhs.fillNumber() != lhs.fillNumber() || rhs.runNumber() != lhs.runNumber() ||
        rhs.crossingAngleX() != lhs.crossingAngleX() || rhs.crossingAngleY() != lhs.crossingAngleY() ||
        rhs.betaStarX() != lhs.betaStarX() || rhs.betaStarY() != lhs.betaStarY()) {
      return false;
    }
    return true;
  }

transferPayloads()

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

Definition at line 46 of file LHCInfoPerLSPopConAnalyzer.cc.

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

Referenced by LHCInfoPerLSPopConSourceHandler::getNewObjects().

                                                                    {
    size_t niovs = 0;
    std::stringstream condIovs;
    for (auto& iov : buffer) {
      bool add = false;
      auto payload = iov.second;
      cond::Time_t since = iov.first;
      if (iovsToTransfer.empty()) {
        add = true;
      } else {
        LHCInfoPerLS& lastAdded = *iovsToTransfer.rbegin()->second;
        if (!comparePayloads(lastAdded, *payload)) {
          add = true;
        }
      }
      if (add) {
        niovs++;
        condIovs << since << " ";
        iovsToTransfer.insert(std::make_pair(since, payload));
        prevPayload = iov.second;
      }
    }
    edm::LogInfo("transferPayloads") << "TRANSFERED COND IOVS: " << condIovs.str();
    return niovs;
  }