ModuleAllocMonitor Class Reference

Public Member Functions
	ModuleAllocMonitor (edm::ParameterSet const &iPS, edm::ActivityRegistry &iAR)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &iDesc)

Private Member Functions
bool	forThisModule (unsigned int iID)

Private Attributes
edm::service::moduleAlloc::Filter	filter_
std::vector< int >	moduleIDs_
std::vector< std::string >	moduleNames_
std::atomic< unsigned int >	nEventsStarted_ {0}
unsigned int	nEventsToSkip_ = 0

Detailed Description

Definition at line 240 of file ModuleAllocMonitor.cc.

Constructor & Destructor Documentation

ModuleAllocMonitor()

ModuleAllocMonitor::ModuleAllocMonitor ( edm::ParameterSet const &  iPS, edm::ActivityRegistry &  iAR  )

inline

Definition at line 242 of file ModuleAllocMonitor.cc.

References cms::perftools::AllocMonitorRegistry::createAndRegisterMonitor(), makeListRunsInFiles::description, spr::find(), newFWLiteAna::found, edm::ParameterSet::getUntrackedParameter(), cms::perftools::AllocMonitorRegistry::instance(), label, edm::service::moduleAlloc::setupFile(), jetUpdater_cfi::sort, AlCaHLTBitMon_QueryRunRegistry::string, funct::void, edm::ActivityRegistry::watchPostESModuleRegistration(), edm::ActivityRegistry::watchPreModuleConstruction(), and edm::ActivityRegistry::watchPreSourceEvent().

      : moduleNames_(iPS.getUntrackedParameter<std::vector<std::string>>("moduleNames")),
        nEventsToSkip_(iPS.getUntrackedParameter<unsigned int>("nEventsToSkip")),
        filter_(&moduleIDs_) {
    (void)cms::perftools::AllocMonitorRegistry::instance().createAndRegisterMonitor<MonitorAdaptor>();

    if (nEventsToSkip_ > 0) {
      filter_.setGlobalKeep(false);
    }
    if (not moduleNames_.empty()) {
      iAR.watchPreModuleConstruction([this](auto const& description) {
        auto found = std::find(moduleNames_.begin(), moduleNames_.end(), description.moduleLabel());
        if (found != moduleNames_.end()) {
          moduleIDs_.push_back(description.id());
          std::sort(moduleIDs_.begin(), moduleIDs_.end());
        }
      });

      iAR.watchPostESModuleRegistration([this](auto const& iDescription) {
        auto label = iDescription.label_;
        if (label.empty()) {
          label = iDescription.type_;
        }
        auto found = std::find(moduleNames_.begin(), moduleNames_.end(), label);
        if (found != moduleNames_.end()) {
          //NOTE: we want the id to start at 1 not 0
          moduleIDs_.push_back(-1 * (iDescription.id_ + 1));
          std::sort(moduleIDs_.begin(), moduleIDs_.end());
        }
      });
    }
    if (nEventsToSkip_ > 0) {
      iAR.watchPreSourceEvent([this](auto) {
        ++nEventsStarted_;
        if (nEventsStarted_ > nEventsToSkip_) {
          filter_.setGlobalKeep(true);
        }
      });
    }
    edm::service::moduleAlloc::setupFile(iPS.getUntrackedParameter<std::string>("fileName"), iAR, &filter_);
  }

Member Function Documentation

fillDescriptions()

static void ModuleAllocMonitor::fillDescriptions ( edm::ConfigurationDescriptions &  iDesc )

inlinestatic

Definition at line 284 of file ModuleAllocMonitor.cc.

References edm::ConfigurationDescriptions::addDefault(), edm::ParameterSetDescription::addUntracked(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                    {
    edm::ParameterSetDescription ps;
    ps.addUntracked<std::string>("fileName");
    ps.addUntracked<std::vector<std::string>>("moduleNames", std::vector<std::string>());
    ps.addUntracked<unsigned int>("nEventsToSkip", 0);
    iDesc.addDefault(ps);
  }

forThisModule()

bool ModuleAllocMonitor::forThisModule ( unsigned int  iID )

inlineprivate

Definition at line 293 of file ModuleAllocMonitor.cc.

References ALPAKA_ACCELERATOR_NAMESPACE::lst::binary_search(), and or.

                                       {
    return (moduleNames_.empty() or std::binary_search(moduleIDs_.begin(), moduleIDs_.end(), iID));
  }

Member Data Documentation

filter_

edm::service::moduleAlloc::Filter ModuleAllocMonitor::filter_

private

Definition at line 300 of file ModuleAllocMonitor.cc.

moduleIDs_

std::vector<int> ModuleAllocMonitor::moduleIDs_

private

Definition at line 297 of file ModuleAllocMonitor.cc.

moduleNames_

std::vector<std::string> ModuleAllocMonitor::moduleNames_

private

Definition at line 296 of file ModuleAllocMonitor.cc.

nEventsStarted_

std::atomic<unsigned int> ModuleAllocMonitor::nEventsStarted_ {0}

private

Definition at line 299 of file ModuleAllocMonitor.cc.

nEventsToSkip_

unsigned int ModuleAllocMonitor::nEventsToSkip_ = 0

private

Definition at line 298 of file ModuleAllocMonitor.cc.