edm::ProcessBlockHelperBase Class Reference

#include <ProcessBlockHelperBase.h>

Inheritance diagram for edm::ProcessBlockHelperBase:

Public Member Functions
std::vector< std::string > const &	addedProcesses () const
virtual std::vector< unsigned int > const &	cacheEntriesPerFile () const =0
virtual std::vector< unsigned int > const &	cacheIndexVectorsPerFile () const =0
void	emplaceBackAddedProcessName (std::string const &processName)
void	emplaceBackProcessName (std::string const &processName)
virtual std::vector< std::vector< unsigned int > > const &	nEntries () const =0
virtual unsigned int	nProcessesInFirstFile () const =0
virtual unsigned int	outerOffset () const =0
virtual std::vector< std::vector< unsigned int > > const &	processBlockCacheIndices () const =0
virtual unsigned int	processBlockIndex (std::string const &processName, EventToProcessBlockIndexes const &) const =0
std::vector< std::string > const &	processesWithProcessBlockProducts () const
std::string	selectProcess (ProductRegistry const &, ProductLabels const &, TypeID const &) const
void	setAddedProcesses (std::vector< std::string > const &val)
void	setProcessesWithProcessBlockProducts (std::vector< std::string > const &val)
virtual ProcessBlockHelperBase const *	topProcessBlockHelper () const =0
virtual std::vector< std::string > const &	topProcessesWithProcessBlockProducts () const =0
void	updateForNewProcess (ProductRegistry const &, std::string const &processName)
virtual	~ProcessBlockHelperBase ()

Static Public Member Functions
static constexpr unsigned int	invalidCacheIndex ()
static constexpr unsigned int	invalidProcessIndex ()

Private Attributes
std::vector< std::string >	addedProcesses_
std::vector< std::string >	processesWithProcessBlockProducts_

Detailed Description

Author

W. David Dagenhart, created 30 December, 2020

Definition at line 18 of file ProcessBlockHelperBase.h.

Constructor & Destructor Documentation

~ProcessBlockHelperBase()

edm::ProcessBlockHelperBase::~ProcessBlockHelperBase ( )

virtualdefault

Member Function Documentation

addedProcesses()

std::vector<std::string> const& edm::ProcessBlockHelperBase::addedProcesses ( ) const

inline

Definition at line 32 of file ProcessBlockHelperBase.h.

References addedProcesses_.

Referenced by edm::OutputProcessBlockHelper::updateAfterProductSelection(), edm::SubProcessBlockHelper::updateFromParentProcess(), and edm::TestOneOutput::writeProcessBlock().

{ return addedProcesses_; }

cacheEntriesPerFile()

virtual std::vector<unsigned int> const& edm::ProcessBlockHelperBase::cacheEntriesPerFile ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::SubProcessBlockHelper::cacheEntriesPerFile(), edm::OutputProcessBlockHelper::fillCacheIndices(), and edm::TestOneOutput::writeProcessBlock().

cacheIndexVectorsPerFile()

virtual std::vector<unsigned int> const& edm::ProcessBlockHelperBase::cacheIndexVectorsPerFile ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::SubProcessBlockHelper::cacheIndexVectorsPerFile(), edm::OutputProcessBlockHelper::fillCacheIndices(), and edm::TestOneOutput::writeProcessBlock().

emplaceBackAddedProcessName()

void edm::ProcessBlockHelperBase::emplaceBackAddedProcessName ( std::string const &  processName )

inline

Definition at line 34 of file ProcessBlockHelperBase.h.

References addedProcesses_, and SimL1EmulatorRepack_CalouGT_cff::processName.

Referenced by edm::SubProcessBlockHelper::updateFromParentProcess().

{ addedProcesses_.emplace_back(processName); }

emplaceBackProcessName()

void edm::ProcessBlockHelperBase::emplaceBackProcessName ( std::string const &  processName )

inline

Definition at line 28 of file ProcessBlockHelperBase.h.

References processesWithProcessBlockProducts_, and SimL1EmulatorRepack_CalouGT_cff::processName.

Referenced by edm::SubProcessBlockHelper::updateFromParentProcess().

                                                              {
      processesWithProcessBlockProducts_.emplace_back(processName);
    }

invalidCacheIndex()

static constexpr unsigned int edm::ProcessBlockHelperBase::invalidCacheIndex ( )

inlinestatic

Definition at line 53 of file ProcessBlockHelperBase.h.

Referenced by edm::ProcessBlockHelper::dropProcessesAndReorderStoredImpl(), edm::OutputProcessBlockHelper::fillCacheIndices(), edm::ProcessBlockHelper::fillFromPrimaryInput(), edm::ProcessBlockHelper::fillFromPrimaryInputWhenNotEmpty(), and edm::ProcessBlockHelper::processBlockIndex().

{ return 0xffffffff; }

invalidProcessIndex()

static constexpr unsigned int edm::ProcessBlockHelperBase::invalidProcessIndex ( )

inlinestatic

Definition at line 54 of file ProcessBlockHelperBase.h.

Referenced by edm::ProcessBlockHelper::fillFromPrimaryInputWhenNotEmpty().

{ return 0xffffffff; }

nEntries()

virtual std::vector<std::vector<unsigned int> > const& edm::ProcessBlockHelperBase::nEntries ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::OutputProcessBlockHelper::fillCacheIndices(), edm::SubProcessBlockHelper::nEntries(), and edm::TestOneOutput::writeProcessBlock().

nProcessesInFirstFile()

virtual unsigned int edm::ProcessBlockHelperBase::nProcessesInFirstFile ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::SubProcessBlockHelper::nProcessesInFirstFile(), edm::OutputProcessBlockHelper::updateAfterProductSelection(), and edm::TestOneOutput::writeProcessBlock().

outerOffset()

virtual unsigned int edm::ProcessBlockHelperBase::outerOffset ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::SubProcessBlockHelper::outerOffset(), and edm::TestOneOutput::writeProcessBlock().

processBlockCacheIndices()

virtual std::vector<std::vector<unsigned int> > const& edm::ProcessBlockHelperBase::processBlockCacheIndices ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::OutputProcessBlockHelper::fillCacheIndices(), edm::SubProcessBlockHelper::processBlockCacheIndices(), and edm::TestOneOutput::writeProcessBlock().

processBlockIndex()

virtual unsigned int edm::ProcessBlockHelperBase::processBlockIndex ( std::string const &  processName, EventToProcessBlockIndexes const &    ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::SubProcessBlockHelper::processBlockIndex(), and edm::EventPrincipal::processBlockIndex().

processesWithProcessBlockProducts()

std::vector<std::string> const& edm::ProcessBlockHelperBase::processesWithProcessBlockProducts ( ) const

inline

Definition at line 22 of file ProcessBlockHelperBase.h.

References processesWithProcessBlockProducts_.

Referenced by edm::RootFile::dropProcessesAndReorder(), edm::ProcessBlockHelper::fillFromPrimaryInputWhenNotEmpty(), edm::ProcessBlockHelper::initializeFromPrimaryInput(), edm::ProcessBlockHelper::processBlockIndex(), edm::SubProcessBlockHelper::topProcessesWithProcessBlockProducts(), edm::ProcessBlockHelper::topProcessesWithProcessBlockProducts(), edm::OutputProcessBlockHelper::updateAfterProductSelection(), and edm::SubProcessBlockHelper::updateFromParentProcess().

                                                                          {
      return processesWithProcessBlockProducts_;
    }

selectProcess()

std::string edm::ProcessBlockHelperBase::selectProcess	(	ProductRegistry const &	productRegistry,
		ProductLabels const &	productLabels,
		TypeID const &	typeID
	)		const

Definition at line 30 of file ProcessBlockHelperBase.cc.

References submitPVResolutionJobs::desc, HLT_2024v13_cff::distance, newFWLiteAna::found, edm::InProcess, position, processesWithProcessBlockProducts_, SimL1EmulatorRepack_CalouGT_cff::processName, dumpMFGeometry_cfg::prod, HLT_2024v13_cff::productLabels, edm::ProductRegistry::productList(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                {
    std::string processName(productLabels.process);
    std::string selectedProcess;

    unsigned int bestPosition = 0;
    for (auto const& prod : productRegistry.productList()) {
      BranchDescription const& desc = prod.second;
      if (desc.branchType() == InProcess && !desc.produced() && desc.present() &&
          desc.moduleLabel() == productLabels.module && desc.productInstanceName() == productLabels.productInstance &&
          desc.unwrappedTypeID() == typeID && (processName.empty() || processName == desc.processName())) {
        // This code is to select the latest matching process
        auto found =
            std::find_if(processesWithProcessBlockProducts_.begin(),
                         processesWithProcessBlockProducts_.end(),
                         [&desc](auto const& processFromHelper) { return processFromHelper == desc.processName(); });
        if (found != processesWithProcessBlockProducts_.end()) {
          const unsigned int position = std::distance(processesWithProcessBlockProducts_.begin(), found);
          if (position >= bestPosition) {
            bestPosition = position;
            selectedProcess = desc.processName();
          }
        }
      }
    }
    return selectedProcess;
  }

setAddedProcesses()

void edm::ProcessBlockHelperBase::setAddedProcesses ( std::vector< std::string > const &  val )

inline

Definition at line 33 of file ProcessBlockHelperBase.h.

References addedProcesses_, and heppy_batch::val.

{ addedProcesses_ = val; }

setProcessesWithProcessBlockProducts()

void edm::ProcessBlockHelperBase::setProcessesWithProcessBlockProducts ( std::vector< std::string > const &  val )

inline

Definition at line 25 of file ProcessBlockHelperBase.h.

References processesWithProcessBlockProducts_, and heppy_batch::val.

Referenced by edm::ProcessBlockHelper::initializeFromPrimaryInput().

                                                                               {
      processesWithProcessBlockProducts_ = val;
    }

topProcessBlockHelper()

virtual ProcessBlockHelperBase const* edm::ProcessBlockHelperBase::topProcessBlockHelper ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::SubProcessBlockHelper::updateFromParentProcess(), and edm::TestOneOutput::writeProcessBlock().

topProcessesWithProcessBlockProducts()

virtual std::vector<std::string> const& edm::ProcessBlockHelperBase::topProcessesWithProcessBlockProducts ( ) const

pure virtual

Implemented in edm::ProcessBlockHelper, and edm::SubProcessBlockHelper.

Referenced by edm::OutputProcessBlockHelper::updateAfterProductSelection(), and edm::TestOneOutput::writeProcessBlock().

updateForNewProcess()

void edm::ProcessBlockHelperBase::updateForNewProcess	(	ProductRegistry const &	productRegistry,
		std::string const &	processName
	)

Definition at line 16 of file ProcessBlockHelperBase.cc.

References addedProcesses_, submitPVResolutionJobs::desc, edm::InProcess, processesWithProcessBlockProducts_, SimL1EmulatorRepack_CalouGT_cff::processName, and edm::ProductRegistry::productList().

Referenced by edm::Schedule::finishSetup().

                                                                                 {
    // Add the current process at the end if there are any
    // process blocks produced in the current process.
    for (auto const& product : productRegistry.productList()) {
      auto const& desc = product.second;
      if (desc.branchType() == InProcess && desc.produced() && !desc.transient()) {
        processesWithProcessBlockProducts_.emplace_back(processName);
        addedProcesses_.emplace_back(processName);
        return;
      }
    }
  }

Member Data Documentation

addedProcesses_

std::vector<std::string> edm::ProcessBlockHelperBase::addedProcesses_

private

Definition at line 70 of file ProcessBlockHelperBase.h.

Referenced by addedProcesses(), emplaceBackAddedProcessName(), setAddedProcesses(), and updateForNewProcess().

processesWithProcessBlockProducts_

std::vector<std::string> edm::ProcessBlockHelperBase::processesWithProcessBlockProducts_

private

Definition at line 64 of file ProcessBlockHelperBase.h.

Referenced by emplaceBackProcessName(), processesWithProcessBlockProducts(), selectProcess(), setProcessesWithProcessBlockProducts(), and updateForNewProcess().