PeriodicAllocMonitor Class Reference

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

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

Private Attributes
std::atomic< bool >	continueRunning_ = true
std::atomic< std::size_t >	nEventsFinished_ = 0
std::atomic< std::size_t >	nEventsStarted_ = 0
std::atomic< std::size_t >	nLumisStarted_ = 0
std::atomic< std::size_t >	nRunsStarted_ = 0
std::thread	thread_
bool	threadShutDown_ = true

Detailed Description

Definition at line 93 of file PeriodicAllocMonitor.cc.

Constructor & Destructor Documentation

PeriodicAllocMonitor()

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

inline

Definition at line 95 of file PeriodicAllocMonitor.cc.

References continueRunning_, submitPVResolutionJobs::count, cms::perftools::AllocMonitorRegistry::createAndRegisterMonitor(), cms::perftools::AllocMonitorRegistry::deregisterMonitor(), MillePedeFileConverter_cfg::fileName, compareTotals::fs, edm::ParameterSet::getUntrackedParameter(), cms::perftools::AllocMonitorRegistry::instance(), writeEcalDQMStatus::interval, nEventsFinished_, nEventsStarted_, nLumisStarted_, submitPVValidationJobs::now, nRunsStarted_, edmIntegrityCheck::report, command_line::start, AlCaHLTBitMon_QueryRunRegistry::string, thread_, threadShutDown_, edm::ActivityRegistry::watchPostEvent(), edm::ActivityRegistry::watchPreEndJob(), edm::ActivityRegistry::watchPreEvent(), edm::ActivityRegistry::watchPreGlobalBeginLumi(), and edm::ActivityRegistry::watchPreGlobalBeginRun().

                                                                             {
    auto adaptor = cms::perftools::AllocMonitorRegistry::instance().createAndRegisterMonitor<MonitorAdaptor>();
    auto fileName = iPS.getUntrackedParameter<std::string>("filename");
    auto interval = iPS.getUntrackedParameter<unsigned long long>("millisecondsPerMeasurement");

    threadShutDown_ = false;
    thread_ = std::thread([this, fileName, interval, adaptor]() {
      auto const start = std::chrono::steady_clock::now();
      std::ofstream fs(fileName);
      fs << "timestamp, runs-started, lumis-started, events-started, events-finished, total-requested, max-actual, "
            "present-actual, max-single, nAllocs, nDeallocs\n";
      while (continueRunning_.load()) {
        auto rStarted = nRunsStarted_.load(std::memory_order_acquire);
        auto lStarted = nLumisStarted_.load(std::memory_order_acquire);
        auto const now = std::chrono::steady_clock::now();
        auto eStarted = nEventsStarted_.load(std::memory_order_acquire);
        auto eFinished = nEventsFinished_.load(std::memory_order_acquire);
        auto report = adaptor->report();

        fs << std::chrono::duration_cast<std::chrono::milliseconds>(now - start).count() << ", " << rStarted << ", "
           << lStarted << ", " << eStarted << ", " << eFinished << ", " << report.requested_ << ", "
           << report.maxActual_ << ", " << report.presentActual_ << ", " << report.maxSingleRequested_ << ", "
           << report.nAllocations_ << ", " << report.nDeallocations_ << std::endl;
        std::this_thread::sleep_for(std::chrono::milliseconds(interval));
      }
    });

    iAR.watchPreEvent([this](auto const&) { nEventsStarted_.fetch_add(1, std::memory_order_acq_rel); });
    iAR.watchPostEvent([this](auto const&) { nEventsFinished_.fetch_add(1, std::memory_order_acq_rel); });
    iAR.watchPreGlobalBeginRun([this](auto const&) { nRunsStarted_.fetch_add(1, std::memory_order_acq_rel); });
    iAR.watchPreGlobalBeginLumi([this](auto const&) { nLumisStarted_.fetch_add(1, std::memory_order_acq_rel); });
    iAR.watchPreEndJob([adaptor, this]() {
      continueRunning_ = false;
      thread_.join();
      threadShutDown_ = true;
      cms::perftools::AllocMonitorRegistry::instance().deregisterMonitor(adaptor);
    });
  }

~PeriodicAllocMonitor()

PeriodicAllocMonitor::~PeriodicAllocMonitor ( )

inline

Definition at line 133 of file PeriodicAllocMonitor.cc.

References continueRunning_, thread_, and threadShutDown_.

                          {
    if (not threadShutDown_) {
      continueRunning_ = false;
      thread_.join();
    }
  }

Member Function Documentation

fillDescriptions()

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

inlinestatic

Definition at line 140 of file PeriodicAllocMonitor.cc.

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

                                                                    {
    edm::ParameterSetDescription ps;
    ps.addUntracked<std::string>("filename", "timing.log")->setComment("Name of file to write the reports");
    ps.addUntracked<unsigned long long>("millisecondsPerMeasurement", 1000)
        ->setComment("The frequency at which to write reports");
    iDesc.addDefault(ps);
  }

Member Data Documentation

continueRunning_

std::atomic<bool> PeriodicAllocMonitor::continueRunning_ = true

private

Definition at line 154 of file PeriodicAllocMonitor.cc.

Referenced by PeriodicAllocMonitor(), and ~PeriodicAllocMonitor().

nEventsFinished_

std::atomic<std::size_t> PeriodicAllocMonitor::nEventsFinished_ = 0

private

Definition at line 153 of file PeriodicAllocMonitor.cc.

Referenced by PeriodicAllocMonitor().

nEventsStarted_

std::atomic<std::size_t> PeriodicAllocMonitor::nEventsStarted_ = 0

private

Definition at line 152 of file PeriodicAllocMonitor.cc.

Referenced by PeriodicAllocMonitor().

nLumisStarted_

std::atomic<std::size_t> PeriodicAllocMonitor::nLumisStarted_ = 0

private

Definition at line 151 of file PeriodicAllocMonitor.cc.

Referenced by PeriodicAllocMonitor().

nRunsStarted_

std::atomic<std::size_t> PeriodicAllocMonitor::nRunsStarted_ = 0

private

Definition at line 150 of file PeriodicAllocMonitor.cc.

Referenced by PeriodicAllocMonitor().

thread_

std::thread PeriodicAllocMonitor::thread_

private

Definition at line 149 of file PeriodicAllocMonitor.cc.

Referenced by PeriodicAllocMonitor(), and ~PeriodicAllocMonitor().

threadShutDown_

bool PeriodicAllocMonitor::threadShutDown_ = true

private

Definition at line 155 of file PeriodicAllocMonitor.cc.

Referenced by PeriodicAllocMonitor(), and ~PeriodicAllocMonitor().