BeamSpotOnlineRecordsWriter Class Reference

#include <CondTools/BeamSpot/plugins/BeamSpotOnlineRecordsWriter.cc>

Inheritance diagram for BeamSpotOnlineRecordsWriter:

Public Member Functions
	BeamSpotOnlineRecordsWriter (const edm::ParameterSet &)
cond::Time_t	pack (uint32_t, uint32_t)
	~BeamSpotOnlineRecordsWriter () override
Public Member Functions inherited from edm::one::EDAnalyzer<>
	EDAnalyzer ()=default
	EDAnalyzer (const EDAnalyzer &)=delete
SerialTaskQueue *	globalLuminosityBlocksQueue () final
SerialTaskQueue *	globalRunsQueue () final
const EDAnalyzer &	operator= (const EDAnalyzer &)=delete
bool	wantsGlobalLuminosityBlocks () const final
bool	wantsGlobalRuns () const final
bool	wantsInputProcessBlocks () const final
bool	wantsProcessBlocks () const final
Public Member Functions inherited from edm::one::EDAnalyzerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
	EDAnalyzerBase ()
ModuleDescription const &	moduleDescription () const
bool	wantsStreamLuminosityBlocks () const
bool	wantsStreamRuns () const
	~EDAnalyzerBase () override
Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const
void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...
	EDConsumerBase ()
	EDConsumerBase (EDConsumerBase const &)=delete
	EDConsumerBase (EDConsumerBase &&)=default
ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const
std::vector< ESProxyIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const
std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const
ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const
void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
std::vector < ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const
void	labelsForToken (EDGetToken iToken, Labels &oLabels) const
void	modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const * > *, NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const
EDConsumerBase const &	operator= (EDConsumerBase const &)=delete
EDConsumerBase &	operator= (EDConsumerBase &&)=default
bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const
bool	registeredToConsumeMany (TypeID const &, BranchType) const
void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)
ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const
void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)
virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)
Static Public Member Functions inherited from edm::one::EDAnalyzerBase
static const std::string &	baseType ()
static void	fillDescriptions (ConfigurationDescriptions &descriptions)
static void	prevalidate (ConfigurationDescriptions &descriptions)

Private Member Functions
void	analyze (const edm::Event &, const edm::EventSetup &) override
void	endJob () override

Private Attributes
std::ifstream	fasciiFile
std::string	fasciiFileName
uint32_t	fIOVStartLumi
uint32_t	fIOVStartRun
bool	fIsHLT
cond::Time_t	fnewSince
bool	fuseNewSince

Additional Inherited Members
Public Types inherited from edm::one::EDAnalyzerBase
typedef EDAnalyzerBase	ModuleType
Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels
Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)
template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)
ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...
template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()
void	consumesMany (const TypeToGet &id)
template<BranchType B>
void	consumesMany (const TypeToGet &id)
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)
template<Transition Tr = Transition::Event>
constexpr auto	esConsumes ()
template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag)
template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)
template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)
void	resetItemsToGetFrom (BranchType iType)

Detailed Description

Description: EDAnalyzer to create a BeamSpotOnlineHLTObjectsRcd or BeamSpotOnlineLegacyObjectsRcd payload from a txt file and dump it in a db file

Implementation: [Notes on implementation]

Definition at line 45 of file BeamSpotOnlineRecordsWriter.cc.

Constructor & Destructor Documentation

BeamSpotOnlineRecordsWriter::BeamSpotOnlineRecordsWriter ( const edm::ParameterSet &  iConfig )

explicit

Definition at line 70 of file BeamSpotOnlineRecordsWriter.cc.

References edm::ParameterSet::exists(), fasciiFile, fasciiFileName, fIOVStartLumi, fIOVStartRun, fIsHLT, fnewSince, fuseNewSince, edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), pack(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                       {
  //now do what ever initialization is needed
  fIsHLT = iConfig.getParameter<bool>("isHLT");
  fasciiFileName = iConfig.getUntrackedParameter<std::string>("InputFileName");
  fasciiFile.open(fasciiFileName.c_str());
  if (iConfig.exists("IOVStartRun") && iConfig.exists("IOVStartLumi")) {
    fIOVStartRun = iConfig.getUntrackedParameter<uint32_t>("IOVStartRun");
    fIOVStartLumi = iConfig.getUntrackedParameter<uint32_t>("IOVStartLumi");
    fnewSince = BeamSpotOnlineRecordsWriter::pack(fIOVStartRun, fIOVStartLumi);
    fuseNewSince = true;
    edm::LogPrint("BeamSpotOnlineRecordsWriter") << "useNewSince = True";
  } else {
    fuseNewSince = false;
    edm::LogPrint("BeamSpotOnlineRecordsWriter") << "useNewSince = False";
  }
}

BeamSpotOnlineRecordsWriter::~BeamSpotOnlineRecordsWriter ( )

overridedefault

Member Function Documentation

void BeamSpotOnlineRecordsWriter::analyze ( const edm::Event &  iEvent, const edm::EventSetup &  iSetup  )

overrideprivatevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 99 of file BeamSpotOnlineRecordsWriter.cc.

{}

void BeamSpotOnlineRecordsWriter::endJob ( void  )

overrideprivatevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 102 of file BeamSpotOnlineRecordsWriter.cc.

References cond::service::PoolDBOutputService::appendOneIOV(), cond::service::PoolDBOutputService::beginOfTime(), submitPVResolutionJobs::count, cond::service::PoolDBOutputService::createOneIOV(), BeamSpotPI::creationTime, cond::service::PoolDBOutputService::currentTime(), dxdz, dydz, alignCSCRings::e, Exception, fasciiFile, fasciiFileName, fIsHLT, fnewSince, fuseNewSince, mps_fire::i, edm::Service< T >::isAvailable(), cond::service::PoolDBOutputService::isNewTagRequest(), dqmiolumiharvest::j, submitPVValidationJobs::now, BeamSpotObjects::setBeamWidthX(), BeamSpotObjects::setBeamWidthY(), BeamSpotObjects::setBetaStar(), BeamSpotObjects::setCovariance(), BeamSpotOnlineObjects::setCreationTime(), BeamSpotObjects::setdxdz(), BeamSpotObjects::setdydz(), BeamSpotObjects::setEmittanceX(), BeamSpotObjects::setEmittanceY(), BeamSpotOnlineObjects::setEndTimeStamp(), BeamSpotOnlineObjects::setLastAnalyzedFill(), BeamSpotOnlineObjects::setLastAnalyzedLumi(), BeamSpotOnlineObjects::setLastAnalyzedRun(), BeamSpotObjects::setPosition(), BeamSpotObjects::setSigmaZ(), BeamSpotOnlineObjects::setStartTimeStamp(), BeamSpotObjects::setType(), BeamSpotPI::sigmaZ, AlCaHLTBitMon_QueryRunRegistry::string, GlobalPosition_Frontier_DevDB_cff::tag, edm::errors::Unknown, x, y, and z.

                                         {
  const std::string fLabel = (fIsHLT) ? "BeamSpotOnlineHLTObjectsRcd" : "BeamSpotOnlineLegacyObjectsRcd";
  edm::LogInfo("BeamSpotOnlineRecordsWriter")
      << "Reading " << fLabel << " data from text file: " << fasciiFileName << std::endl;

  // extract from file
  double x, y, z, sigmaZ, dxdz, dydz, beamWidthX, beamWidthY, emittanceX, emittanceY, betastar;
  double cov[7][7];
  int type, lastAnalyzedLumi, firstAnalyzedLumi, lastAnalyzedRun, lastAnalyzedFill;
  std::string tag;
  std::time_t lumiRangeBeginTime, lumiRangeEndTime;

  fasciiFile >> tag >> lastAnalyzedRun;
  fasciiFile >> tag >> tag >> tag >> tag >> lumiRangeBeginTime;  // BeginTimeOfFit parsing (not used in payload)
  fasciiFile >> tag >> tag >> tag >> tag >> lumiRangeEndTime;    // EndTimeOfFit parsing (not used in payload)
  fasciiFile >> tag >> firstAnalyzedLumi;
  fasciiFile >> tag >> lastAnalyzedLumi;
  fasciiFile >> tag >> type;
  fasciiFile >> tag >> x;
  fasciiFile >> tag >> y;
  fasciiFile >> tag >> z;
  fasciiFile >> tag >> sigmaZ;
  fasciiFile >> tag >> dxdz;
  fasciiFile >> tag >> dydz;
  fasciiFile >> tag >> beamWidthX;
  fasciiFile >> tag >> beamWidthY;
  fasciiFile >> tag >> cov[0][0] >> cov[0][1] >> cov[0][2] >> cov[0][3] >> cov[0][4] >> cov[0][5] >> cov[0][6];
  fasciiFile >> tag >> cov[1][0] >> cov[1][1] >> cov[1][2] >> cov[1][3] >> cov[1][4] >> cov[1][5] >> cov[1][6];
  fasciiFile >> tag >> cov[2][0] >> cov[2][1] >> cov[2][2] >> cov[2][3] >> cov[2][4] >> cov[2][5] >> cov[2][6];
  fasciiFile >> tag >> cov[3][0] >> cov[3][1] >> cov[3][2] >> cov[3][3] >> cov[3][4] >> cov[3][5] >> cov[3][6];
  fasciiFile >> tag >> cov[4][0] >> cov[4][1] >> cov[4][2] >> cov[4][3] >> cov[4][4] >> cov[4][5] >> cov[4][6];
  fasciiFile >> tag >> cov[5][0] >> cov[5][1] >> cov[5][2] >> cov[5][3] >> cov[5][4] >> cov[5][5] >> cov[5][6];
  fasciiFile >> tag >> cov[6][0] >> cov[6][1] >> cov[6][2] >> cov[6][3] >> cov[6][4] >> cov[6][5] >> cov[6][6];
  fasciiFile >> tag >> emittanceX;
  fasciiFile >> tag >> emittanceY;
  fasciiFile >> tag >> betastar;

  lastAnalyzedFill = -999;

  // Verify that the parsing was correct by checking the BS positions
  if (std::fabs(x) > 1000. || std::fabs(x) < 1.e-20 || std::fabs(y) > 1000. || std::fabs(y) < 1.e-20 ||
      std::fabs(z) > 1000. || std::fabs(z) < 1.e-20) {
    throw edm::Exception(edm::errors::Unknown)
        << " !!! Error in parsing input file, parsed BS (x,y,z): (" << x << "," << y << "," << z << ") !!!";
  }

  edm::LogPrint("BeamSpotOnlineRecordsWriter") << "---- Parsed these parameters from input txt file ----";
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " lastAnalyzedRun   : " << lastAnalyzedRun;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " lastAnalyzedFill  : " << lastAnalyzedFill;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " firstAnalyzedLumi : " << firstAnalyzedLumi;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " lastAnalyzedLumi  : " << lastAnalyzedLumi;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " lumiRangeBeginTime: " << lumiRangeBeginTime;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " lumiRangeEndTime  : " << lumiRangeEndTime;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " type              : " << type;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " x                 : " << x;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " y                 : " << y;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " z                 : " << z;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " sigmaZ            : " << sigmaZ;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " dxdz              : " << dxdz;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " dydz              : " << dydz;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " beamWidthX        : " << beamWidthX;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " beamWidthY        : " << beamWidthY;
  edm::LogPrint("BeamSpotOnlineRecordsWriter")
      << " Cov(0,j)          : " << cov[0][0] << " " << cov[0][1] << " " << cov[0][2] << " " << cov[0][3] << " "
      << cov[0][4] << " " << cov[0][5] << " " << cov[0][6];
  edm::LogPrint("BeamSpotOnlineRecordsWriter")
      << " Cov(1,j)          : " << cov[1][0] << " " << cov[1][1] << " " << cov[1][2] << " " << cov[1][3] << " "
      << cov[1][4] << " " << cov[1][5] << " " << cov[1][6];
  edm::LogPrint("BeamSpotOnlineRecordsWriter")
      << " Cov(2,j)          : " << cov[2][0] << " " << cov[2][1] << " " << cov[2][2] << " " << cov[2][3] << " "
      << cov[2][4] << " " << cov[2][5] << " " << cov[2][6];
  edm::LogPrint("BeamSpotOnlineRecordsWriter")
      << " Cov(3,j)          : " << cov[3][0] << " " << cov[3][1] << " " << cov[3][2] << " " << cov[3][3] << " "
      << cov[3][4] << " " << cov[3][5] << " " << cov[3][6];
  edm::LogPrint("BeamSpotOnlineRecordsWriter")
      << " Cov(4,j)          : " << cov[4][0] << " " << cov[4][1] << " " << cov[4][2] << " " << cov[4][3] << " "
      << cov[4][4] << " " << cov[4][5] << " " << cov[4][6];
  edm::LogPrint("BeamSpotOnlineRecordsWriter")
      << " Cov(5,j)          : " << cov[5][0] << " " << cov[5][1] << " " << cov[5][2] << " " << cov[5][3] << " "
      << cov[5][4] << " " << cov[5][5] << " " << cov[5][6];
  edm::LogPrint("BeamSpotOnlineRecordsWriter")
      << " Cov(6,j)          : " << cov[6][0] << " " << cov[6][1] << " " << cov[6][2] << " " << cov[6][3] << " "
      << cov[6][4] << " " << cov[6][5] << " " << cov[6][6];
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " emittanceX        : " << emittanceX;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " emittanceY        : " << emittanceY;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " betastar          : " << betastar;
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << "-----------------------------------------------------";

  BeamSpotOnlineObjects abeam;

  abeam.setLastAnalyzedLumi(lastAnalyzedLumi);
  abeam.setLastAnalyzedRun(lastAnalyzedRun);
  abeam.setLastAnalyzedFill(lastAnalyzedFill);
  abeam.setStartTimeStamp(lumiRangeBeginTime);
  abeam.setEndTimeStamp(lumiRangeEndTime);
  abeam.setType(type);
  abeam.setPosition(x, y, z);
  abeam.setSigmaZ(sigmaZ);
  abeam.setdxdz(dxdz);
  abeam.setdydz(dydz);
  abeam.setBeamWidthX(beamWidthX);
  abeam.setBeamWidthY(beamWidthY);
  abeam.setEmittanceX(emittanceX);
  abeam.setEmittanceY(emittanceY);
  abeam.setBetaStar(betastar);

  for (int i = 0; i < 7; ++i) {
    for (int j = 0; j < 7; ++j) {
      abeam.setCovariance(i, j, cov[i][j]);
    }
  }

  // Set the creation time of the payload to the current time
  auto creationTime =
      std::chrono::duration_cast<std::chrono::microseconds>(std::chrono::system_clock::now().time_since_epoch()).count();
  abeam.setCreationTime(creationTime);

  edm::LogPrint("BeamSpotOnlineRecordsWriter") << " Writing results to DB...";

  edm::Service<cond::service::PoolDBOutputService> poolDbService;
  if (poolDbService.isAvailable()) {
    edm::LogPrint("BeamSpotOnlineRecordsWriter") << "poolDBService available";
    if (poolDbService->isNewTagRequest(fLabel)) {
      edm::LogPrint("BeamSpotOnlineRecordsWriter") << "new tag requested";
      if (fuseNewSince) {
        edm::LogPrint("BeamSpotOnlineRecordsWriter") << "Using a new Since: " << fnewSince;
        poolDbService->createOneIOV<BeamSpotOnlineObjects>(abeam, fnewSince, fLabel);
      } else
        poolDbService->createOneIOV<BeamSpotOnlineObjects>(abeam, poolDbService->beginOfTime(), fLabel);
    } else {
      edm::LogPrint("BeamSpotOnlineRecordsWriter") << "no new tag requested";
      if (fuseNewSince) {
        edm::LogPrint("BeamSpotOnlineRecordsWriter") << "Using a new Since: " << fnewSince;
        poolDbService->appendOneIOV<BeamSpotOnlineObjects>(abeam, fnewSince, fLabel);
      } else
        poolDbService->appendOneIOV<BeamSpotOnlineObjects>(abeam, poolDbService->currentTime(), fLabel);
    }
  }
  edm::LogPrint("BeamSpotOnlineRecordsWriter") << "[BeamSpotOnlineRecordsWriter] endJob done \n";
}

void BeamSpotOnlineRecordsWriter::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 244 of file BeamSpotOnlineRecordsWriter.cc.

References edm::ParameterSetDescription::add(), edm::ParameterSetDescription::addOptionalUntracked(), edm::ParameterSetDescription::addUntracked(), edm::ConfigurationDescriptions::addWithDefaultLabel(), submitPVResolutionJobs::desc, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                             {
  edm::ParameterSetDescription desc;
  desc.add<bool>("isHLT", true);
  desc.addUntracked<std::string>("InputFileName", "");
  desc.addOptionalUntracked<uint32_t>("IOVStartRun", 1);
  desc.addOptionalUntracked<uint32_t>("IOVStartLumi", 1);
  descriptions.addWithDefaultLabel(desc);
}

cond::Time_t BeamSpotOnlineRecordsWriter::pack	(	uint32_t	fIOVStartRun,
		uint32_t	fIOVStartLumi
	)

Definition at line 94 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter().

                                                                                          {
  return ((uint64_t)fIOVStartRun << 32 | fIOVStartLumi);
}

Member Data Documentation

std::ifstream BeamSpotOnlineRecordsWriter::fasciiFile

private

Definition at line 59 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter(), and endJob().

std::string BeamSpotOnlineRecordsWriter::fasciiFileName

private

Definition at line 60 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter(), and endJob().

uint32_t BeamSpotOnlineRecordsWriter::fIOVStartLumi

private

Definition at line 62 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter().

uint32_t BeamSpotOnlineRecordsWriter::fIOVStartRun

private

Definition at line 61 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter().

bool BeamSpotOnlineRecordsWriter::fIsHLT

private

Definition at line 58 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter(), and endJob().

cond::Time_t BeamSpotOnlineRecordsWriter::fnewSince

private

Definition at line 63 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter(), and endJob().

bool BeamSpotOnlineRecordsWriter::fuseNewSince

private

Definition at line 64 of file BeamSpotOnlineRecordsWriter.cc.

Referenced by BeamSpotOnlineRecordsWriter(), and endJob().