edm::DaqProvenanceHelper Struct Reference

#include <DaqProvenanceHelper.h>

Public Types
typedef oneapi::tbb::concurrent_unordered_map< ParentageID, ParentageID, dqh::parentage_hash >	ParentageIDMap
typedef std::map< ProcessHistoryID, ProcessHistoryID >	ProcessHistoryIDMap

Public Member Functions
BranchDescription const &	branchDescription () const
ProcessHistoryID	daqInit (ProductRegistry &productRegistry, ProcessHistoryRegistry &processHistoryRegistry) const
	DaqProvenanceHelper (TypeID const &rawDataType)
ProductProvenance const &	dummyProvenance () const
void	fixMetaData (ProcessConfigurationVector &pcv, std::vector< ProcessHistory > &phv)
void	fixMetaData (std::vector< BranchID > &branchIDs) const
void	fixMetaData (BranchIDLists const &) const
void	fixMetaData (BranchChildren &branchChildren) const
BranchID const &	mapBranchID (BranchID const &branchID) const
ParentageID const &	mapParentageID (ParentageID const &phid) const
ProcessHistoryID const &	mapProcessHistoryID (ProcessHistoryID const &phid)
bool	matchProcesses (ProcessConfiguration const &pc, ProcessHistory const &ph) const
ProcessHistoryID const *	oldProcessHistoryID () const
void	saveInfo (BranchDescription const &oldBD, BranchDescription const &newBD)
void	setOldParentageIDToNew (ParentageID const &iOld, ParentageID const &iNew)

Private Attributes
BranchDescription const	constBranchDescription_
ProductProvenance	dummyProvenance_
BranchID	newBranchID_
BranchID	oldBranchID_
ProcessHistoryID const *	oldProcessHistoryID_
std::string	oldProcessName_
ParentageIDMap	parentageIDMap_
ProcessHistoryIDMap	phidMap_
ParameterSet	processParameterSet_

Detailed Description

Definition at line 27 of file DaqProvenanceHelper.h.

Member Typedef Documentation

ParentageIDMap

typedef oneapi::tbb::concurrent_unordered_map<ParentageID, ParentageID, dqh::parentage_hash> edm::DaqProvenanceHelper::ParentageIDMap

Definition at line 29 of file DaqProvenanceHelper.h.

ProcessHistoryIDMap

typedef std::map<ProcessHistoryID, ProcessHistoryID> edm::DaqProvenanceHelper::ProcessHistoryIDMap

Definition at line 28 of file DaqProvenanceHelper.h.

Constructor & Destructor Documentation

DaqProvenanceHelper()

edm::DaqProvenanceHelper::DaqProvenanceHelper ( TypeID const &  rawDataType )

explicit

Definition at line 37 of file DaqProvenanceHelper.cc.

References edm::ParameterSet::addParameter(), constBranchDescription_, relativeConstraints::empty, HerwigMaxPtPartonFilter_cfi::moduleLabel, edm::BranchDescription::moduleLabel(), edm::moduleName(), edm::BranchDescription::moduleName(), SimL1EmulatorRepack_CalouGT_cff::processName, edm::BranchDescription::processName(), processParameterSet_, edm::ParameterSet::registerIt(), AlCaHLTBitMon_QueryRunRegistry::string, and triggerPaths.

      : constBranchDescription_(makeDescriptionForDaqProvHelper(rawDataType)),
        dummyProvenance_(constBranchDescription_.branchID()),
        processParameterSet_(),
        oldProcessName_(),
        oldBranchID_(),
        newBranchID_(),
        oldProcessHistoryID_(nullptr),
        phidMap_() {
    // Now we create a process parameter set for the "LHC" process.
    // We don't currently use the untracked parameters, However, we make them available, just in case.
    std::string const& moduleLabel = constBranchDescription_.moduleLabel();
    std::string const& processName = constBranchDescription_.processName();
    std::string const& moduleName = constBranchDescription_.moduleName();
    typedef std::vector<std::string> vstring;
    vstring empty;

    vstring modlbl;
    modlbl.reserve(1);
    modlbl.push_back(moduleLabel);
    processParameterSet_.addParameter("@all_sources", modlbl);

    ParameterSet triggerPaths;
    triggerPaths.addParameter<vstring>("@trigger_paths", empty);
    processParameterSet_.addParameter<ParameterSet>("@trigger_paths", triggerPaths);

    ParameterSet pseudoInput;
    pseudoInput.addParameter<std::string>("@module_edm_type", "Source");
    pseudoInput.addParameter<std::string>("@module_label", moduleLabel);
    pseudoInput.addParameter<std::string>("@module_type", moduleName);
    processParameterSet_.addParameter<ParameterSet>(moduleLabel, pseudoInput);

    processParameterSet_.addParameter<vstring>("@all_esmodules", empty);
    processParameterSet_.addParameter<vstring>("@all_esprefers", empty);
    processParameterSet_.addParameter<vstring>("@all_essources", empty);
    processParameterSet_.addParameter<vstring>("@all_loopers", empty);
    processParameterSet_.addParameter<vstring>("@all_modules", empty);
    processParameterSet_.addParameter<vstring>("@end_paths", empty);
    processParameterSet_.addParameter<vstring>("@paths", empty);
    processParameterSet_.addParameter<std::string>("@process_name", processName);
    // Now we register the process parameter set.
    processParameterSet_.registerIt();

    //std::cerr << processParameterSet_.dump() << std::endl;
  }

Member Function Documentation

branchDescription()

BranchDescription const& edm::DaqProvenanceHelper::branchDescription ( ) const

inline

Definition at line 46 of file DaqProvenanceHelper.h.

References constBranchDescription_.

Referenced by FedRawDataInputSource::read().

{ return constBranchDescription_; }

daqInit()

ProcessHistoryID edm::DaqProvenanceHelper::daqInit	(	ProductRegistry &	productRegistry,
		ProcessHistoryRegistry &	processHistoryRegistry
	)		const

Definition at line 83 of file DaqProvenanceHelper.cc.

References constBranchDescription_, edm::ProductRegistry::copyProduct(), edm::ProcessHistory::emplace_back(), edm::getPassID(), edm::getReleaseVersion(), edm::ParameterSet::id(), edm::BranchDescription::processName(), processParameterSet_, edm::ProcessHistoryRegistry::registerProcessHistory(), and edm::ProcessHistory::setProcessHistoryID().

Referenced by FedRawDataInputSource::FedRawDataInputSource().

                                                                                                      {
    // Now we need to set all the metadata
    // Add the product to the product registry
    productRegistry.copyProduct(constBranchDescription_);

    // Insert an entry for this process in the process history registry
    ProcessHistory ph;
    ph.emplace_back(constBranchDescription_.processName(), processParameterSet_.id(), getReleaseVersion(), getPassID());
    processHistoryRegistry.registerProcessHistory(ph);

    // Save the process history ID for use every event.
    return ph.setProcessHistoryID();
  }

dummyProvenance()

ProductProvenance const& edm::DaqProvenanceHelper::dummyProvenance ( ) const

inline

Definition at line 48 of file DaqProvenanceHelper.h.

References dummyProvenance_.

Referenced by FedRawDataInputSource::read().

{ return dummyProvenance_; }

fixMetaData() [1/4]

void edm::DaqProvenanceHelper::fixMetaData	(	ProcessConfigurationVector &	pcv,
		std::vector< ProcessHistory > &	phv
	)

fixMetaData() [2/4]

void edm::DaqProvenanceHelper::fixMetaData

(

std::vector< BranchID > &

branchIDs

)

const

Definition at line 139 of file DaqProvenanceHelper.cc.

References newBranchID_, oldBranchID_, and python.rootplot.root2matplotlib::replace().

                                                                           {
    std::replace(branchID.begin(), branchID.end(), oldBranchID_, newBranchID_);
  }

fixMetaData() [3/4]

void edm::DaqProvenanceHelper::fixMetaData

(

BranchIDLists const &

branchIDLists

)

const

Definition at line 143 of file DaqProvenanceHelper.cc.

References edm::BranchID::id(), newBranchID_, oldBranchID_, and python.rootplot.root2matplotlib::replace().

                                                                                {
    BranchID::value_type oldID = oldBranchID_.id();
    BranchID::value_type newID = newBranchID_.id();
    // The const_cast is ugly, but it beats the alternatives.
    BranchIDLists& lists = const_cast<BranchIDLists&>(branchIDLists);
    for (auto& list : lists) {
      std::replace(list.begin(), list.end(), oldID, newID);
    }
  }

fixMetaData() [4/4]

void edm::DaqProvenanceHelper::fixMetaData

(

BranchChildren &

branchChildren

)

const

Definition at line 153 of file DaqProvenanceHelper.cc.

References edm::BranchChildren::childLookup(), mps_fire::i, newBranchID_, and oldBranchID_.

                                                                            {
    typedef std::map<BranchID, std::set<BranchID> > BCMap;
    // The const_cast is ugly, but it beats the alternatives.
    BCMap& childLookup = const_cast<BCMap&>(branchChildren.childLookup());
    // First fix any old branchID's in the key.
    {
      BCMap::iterator i = childLookup.find(oldBranchID_);
      if (i != childLookup.end()) {
        childLookup.insert(std::make_pair(newBranchID_, i->second));
        childLookup.erase(i);
      }
    }
    // Now fix any old branchID's in the sets;
    for (auto& child : childLookup) {
      if (child.second.erase(oldBranchID_) != 0) {
        child.second.insert(newBranchID_);
      }
    }
  }

mapBranchID()

BranchID const & edm::DaqProvenanceHelper::mapBranchID

(

BranchID const &

branchID

)

const

Definition at line 191 of file DaqProvenanceHelper.cc.

References newBranchID_, and oldBranchID_.

Referenced by edm::ReducedProvenanceReader::readProvenance(), edm::FullProvenanceReader::readProvenance(), and edm::OldProvenanceReader::readProvenance().

                                                                                 {
    return (branchID == oldBranchID_ ? newBranchID_ : branchID);
  }

mapParentageID()

ParentageID const & edm::DaqProvenanceHelper::mapParentageID

(

ParentageID const &

phid

)

const

Definition at line 182 of file DaqProvenanceHelper.cc.

References parentageIDMap_.

Referenced by edm::ReducedProvenanceReader::readProvenance(), edm::FullProvenanceReader::readProvenance(), and edm::OldProvenanceReader::readProvenance().

                                                                                             {
    ParentageIDMap::const_iterator it = parentageIDMap_.find(parentageID);
    if (it == parentageIDMap_.end()) {
      return parentageID;
    }
    return it->second;
  }

mapProcessHistoryID()

ProcessHistoryID const & edm::DaqProvenanceHelper::mapProcessHistoryID

(

ProcessHistoryID const &

phid

)

Definition at line 174 of file DaqProvenanceHelper.cc.

References cms::cuda::assert(), oldProcessHistoryID_, and phidMap_.

                                                                                               {
    ProcessHistoryIDMap::const_iterator it = phidMap_.find(phid);
    assert(it != phidMap_.end());
    oldProcessHistoryID_ = &it->first;
    return it->second;
  }

matchProcesses()

bool edm::DaqProvenanceHelper::matchProcesses	(	ProcessConfiguration const &	pc,
		ProcessHistory const &	ph
	)		const

Definition at line 98 of file DaqProvenanceHelper.cc.

References oldProcessName_, edm::ProcessConfiguration::passID(), and edm::ProcessConfiguration::releaseVersion().

                                                                                                            {
    for (auto const& pc : ph) {
      if (pc.processName() == oldProcessName_) {
        return (pc.releaseVersion() == newPC.releaseVersion() && pc.passID() == newPC.passID());
      }
    }
    return false;
  }

oldProcessHistoryID()

ProcessHistoryID const* edm::DaqProvenanceHelper::oldProcessHistoryID ( ) const

inline

Definition at line 47 of file DaqProvenanceHelper.h.

References oldProcessHistoryID_.

{ return oldProcessHistoryID_; }

saveInfo()

void edm::DaqProvenanceHelper::saveInfo ( BranchDescription const &  oldBD, BranchDescription const &  newBD  )

inline

Definition at line 32 of file DaqProvenanceHelper.h.

References edm::BranchDescription::branchID(), newBranchID_, oldBranchID_, oldProcessName_, and edm::BranchDescription::processName().

                                                                                  {
      oldProcessName_ = oldBD.processName();
      oldBranchID_ = oldBD.branchID();
      newBranchID_ = newBD.branchID();
    }

setOldParentageIDToNew()

void edm::DaqProvenanceHelper::setOldParentageIDToNew	(	ParentageID const &	iOld,
		ParentageID const &	iNew
	)

Definition at line 195 of file DaqProvenanceHelper.cc.

References parentageIDMap_.

                                                                                                   {
    parentageIDMap_.insert(std::make_pair(iOld, iNew));
  }

Member Data Documentation

constBranchDescription_

BranchDescription const edm::DaqProvenanceHelper::constBranchDescription_

private

Definition at line 53 of file DaqProvenanceHelper.h.

Referenced by branchDescription(), daqInit(), and DaqProvenanceHelper().

dummyProvenance_

ProductProvenance edm::DaqProvenanceHelper::dummyProvenance_

private

Definition at line 54 of file DaqProvenanceHelper.h.

Referenced by dummyProvenance().

newBranchID_

BranchID edm::DaqProvenanceHelper::newBranchID_

private

Definition at line 59 of file DaqProvenanceHelper.h.

Referenced by fixMetaData(), mapBranchID(), and saveInfo().

oldBranchID_

BranchID edm::DaqProvenanceHelper::oldBranchID_

private

Definition at line 58 of file DaqProvenanceHelper.h.

Referenced by fixMetaData(), mapBranchID(), and saveInfo().

oldProcessHistoryID_

ProcessHistoryID const* edm::DaqProvenanceHelper::oldProcessHistoryID_

private

Definition at line 60 of file DaqProvenanceHelper.h.

Referenced by mapProcessHistoryID(), and oldProcessHistoryID().

oldProcessName_

std::string edm::DaqProvenanceHelper::oldProcessName_

private

Definition at line 57 of file DaqProvenanceHelper.h.

Referenced by matchProcesses(), and saveInfo().

parentageIDMap_

ParentageIDMap edm::DaqProvenanceHelper::parentageIDMap_

private

Definition at line 62 of file DaqProvenanceHelper.h.

Referenced by mapParentageID(), and setOldParentageIDToNew().

phidMap_

ProcessHistoryIDMap edm::DaqProvenanceHelper::phidMap_

private

Definition at line 61 of file DaqProvenanceHelper.h.

Referenced by mapProcessHistoryID().

processParameterSet_

ParameterSet edm::DaqProvenanceHelper::processParameterSet_

private

Definition at line 55 of file DaqProvenanceHelper.h.

Referenced by daqInit(), and DaqProvenanceHelper().