ROCmMonitoringService Class Reference

Public Member Functions
void	postEvent (edm::StreamContext const &sc)
void	postModuleBeginStream (edm::StreamContext const &, edm::ModuleCallingContext const &mcc)
void	postModuleConstruction (edm::ModuleDescription const &desc)
void	postModuleEvent (edm::StreamContext const &sc, edm::ModuleCallingContext const &mcc)
	ROCmMonitoringService (edm::ParameterSet const &iConfig, edm::ActivityRegistry &iRegistry)
	~ROCmMonitoringService ()=default

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

Private Attributes
int	numberOfDevices_ = 0

Detailed Description

Definition at line 21 of file ROCmMonitoringService.cc.

Constructor & Destructor Documentation

ROCmMonitoringService()

ROCmMonitoringService::ROCmMonitoringService	(	edm::ParameterSet const &	iConfig,
		edm::ActivityRegistry &	iRegistry
	)

Definition at line 37 of file ROCmMonitoringService.cc.

References numberOfDevices_, or, postEvent(), postModuleBeginStream(), postModuleConstruction(), postModuleEvent(), edm::ActivityRegistry::watchPostEvent(), edm::ActivityRegistry::watchPostModuleBeginStream(), edm::ActivityRegistry::watchPostModuleConstruction(), and edm::ActivityRegistry::watchPostModuleEvent().

                                                                                                         {
  // make sure that ROCm is initialised, and that the ROCmService destructor is called after this service's destructor
  edm::Service<ROCmInterface> service;
  if (not service or not service->enabled())
    return;

  numberOfDevices_ = service->numberOfDevices();

  if (config.getUntrackedParameter<bool>("memoryConstruction")) {
    registry.watchPostModuleConstruction(this, &ROCmMonitoringService::postModuleConstruction);
  }
  if (config.getUntrackedParameter<bool>("memoryBeginStream")) {
    registry.watchPostModuleBeginStream(this, &ROCmMonitoringService::postModuleBeginStream);
  }
  if (config.getUntrackedParameter<bool>("memoryPerModule")) {
    registry.watchPostModuleEvent(this, &ROCmMonitoringService::postModuleEvent);
  }
  if (config.getUntrackedParameter<bool>("memoryPerEvent")) {
    registry.watchPostEvent(this, &ROCmMonitoringService::postEvent);
  }
}

~ROCmMonitoringService()

ROCmMonitoringService::~ROCmMonitoringService ( )

default

Member Function Documentation

fillDescriptions()

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

static

Definition at line 59 of file ROCmMonitoringService.cc.

References edm::ConfigurationDescriptions::add(), submitPVResolutionJobs::desc, and edm::ConfigurationDescriptions::setComment().

                                                                                       {
  edm::ParameterSetDescription desc;

  desc.addUntracked<bool>("memoryConstruction", false)
      ->setComment("Print memory information for each device after the construction of each module");
  desc.addUntracked<bool>("memoryBeginStream", true)
      ->setComment("Print memory information for each device after the beginStream() of each module");
  desc.addUntracked<bool>("memoryPerModule", true)
      ->setComment("Print memory information for each device after the event of each module");
  desc.addUntracked<bool>("memoryPerEvent", true)
      ->setComment("Print memory information for each device after each event");

  descriptions.add("ROCmMonitoringService", desc);
  descriptions.setComment(
      "The memory information is the global state of the device. This gets confusing if there are multiple processes "
      "running on the same device. Probably the information retrieval should be re-thought?");
}

postEvent()

void ROCmMonitoringService::postEvent

(

edm::StreamContext const &

sc

)

Definition at line 115 of file ROCmMonitoringService.cc.

References CrabHelper::log, and numberOfDevices_.

Referenced by ROCmMonitoringService().

                                                                {
  auto log = edm::LogPrint("ROCmMonitoringService");
  log << "ROCm device memory after event";
  dumpUsedMemory(log, numberOfDevices_);
}

postModuleBeginStream()

void ROCmMonitoringService::postModuleBeginStream	(	edm::StreamContext const &	,
		edm::ModuleCallingContext const &	mcc
	)

Definition at line 101 of file ROCmMonitoringService.cc.

References CrabHelper::log, edm::ModuleCallingContext::moduleDescription(), edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), and numberOfDevices_.

Referenced by ROCmMonitoringService().

                                                                                                             {
  auto log = edm::LogPrint("ROCmMonitoringService");
  log << "ROCm device memory after beginStream() of " << mcc.moduleDescription()->moduleLabel() << " ("
      << mcc.moduleDescription()->moduleName() << ")";
  dumpUsedMemory(log, numberOfDevices_);
}

postModuleConstruction()

void ROCmMonitoringService::postModuleConstruction

(

edm::ModuleDescription const &

desc

)

Definition at line 95 of file ROCmMonitoringService.cc.

References submitPVResolutionJobs::desc, CrabHelper::log, and numberOfDevices_.

Referenced by ROCmMonitoringService().

                                                                                   {
  auto log = edm::LogPrint("ROCmMonitoringService");
  log << "ROCm device memory after construction of " << desc.moduleLabel() << " (" << desc.moduleName() << ")";
  dumpUsedMemory(log, numberOfDevices_);
}

postModuleEvent()

void ROCmMonitoringService::postModuleEvent	(	edm::StreamContext const &	sc,
		edm::ModuleCallingContext const &	mcc
	)

Definition at line 108 of file ROCmMonitoringService.cc.

References CrabHelper::log, edm::ModuleCallingContext::moduleDescription(), edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), and numberOfDevices_.

Referenced by ROCmMonitoringService().

                                                                                                       {
  auto log = edm::LogPrint("ROCmMonitoringService");
  log << "ROCm device memory after processing an event by " << mcc.moduleDescription()->moduleLabel() << " ("
      << mcc.moduleDescription()->moduleName() << ")";
  dumpUsedMemory(log, numberOfDevices_);
}

Member Data Documentation

numberOfDevices_

int ROCmMonitoringService::numberOfDevices_ = 0

private

Definition at line 34 of file ROCmMonitoringService.cc.

Referenced by postEvent(), postModuleBeginStream(), postModuleConstruction(), postModuleEvent(), and ROCmMonitoringService().