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

edm::ProcessBlockHelperBase::~ProcessBlockHelperBase ( )

virtualdefault

Member Function Documentation

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(), and edm::SubProcessBlockHelper::updateFromParentProcess().

{ return addedProcesses_; }

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

pure virtual

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

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

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

pure virtual

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

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

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

inline

Definition at line 34 of file ProcessBlockHelperBase.h.

References addedProcesses_.

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

{ addedProcesses_.emplace_back(processName); }

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

inline

Definition at line 28 of file ProcessBlockHelperBase.h.

References processesWithProcessBlockProducts_.

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

                                                              {
      processesWithProcessBlockProducts_.emplace_back(processName);
    }

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; }

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

inlinestatic

Definition at line 54 of file ProcessBlockHelperBase.h.

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

{ return 0xffffffff; }

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(), and edm::SubProcessBlockHelper::nEntries().

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

pure virtual

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

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

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

pure virtual

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

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

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(), and edm::SubProcessBlockHelper::processBlockCacheIndices().

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().

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_;
    }

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

Definition at line 30 of file ProcessBlockHelperBase.cc.

References edm::BranchDescription::branchType(), submitPVResolutionJobs::desc, HLT_FULL_cff::distance, newFWLiteAna::found, edm::InProcess, edm::ProductLabels::module, edm::BranchDescription::moduleLabel(), position, edm::BranchDescription::present(), edm::ProductLabels::process, processesWithProcessBlockProducts_, edm::BranchDescription::processName(), FSQHLTOfflineSource_cfi::processName, edm::BranchDescription::produced(), edm::ProductLabels::productInstance, edm::BranchDescription::productInstanceName(), edm::ProductRegistry::productList(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::BranchDescription::unwrappedTypeID().

                                                                                {
    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;
  }

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

inline

Definition at line 33 of file ProcessBlockHelperBase.h.

References addedProcesses_, and hgcalPerformanceValidation::val.

{ addedProcesses_ = val; }

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

inline

Definition at line 25 of file ProcessBlockHelperBase.h.

References processesWithProcessBlockProducts_, and hgcalPerformanceValidation::val.

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

                                                                               {
      processesWithProcessBlockProducts_ = val;
    }

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

pure virtual

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

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

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

pure virtual

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

Referenced by edm::OutputProcessBlockHelper::updateAfterProductSelection().

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_, and edm::ProductRegistry::productList().

                                                                                 {
    // 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

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

private

Definition at line 70 of file ProcessBlockHelperBase.h.

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

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

private

Definition at line 64 of file ProcessBlockHelperBase.h.

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