DQMService Class Reference

#include <DQMService.h>

Public Types
typedef dqm::legacy::DQMStore	DQMStore
typedef dqm::legacy::MonitorElement	MonitorElement

Public Member Functions
	DQMService (const edm::ParameterSet &pset, edm::ActivityRegistry &ar)
void	flush (edm::StreamContext const &sc)
void	flushStandalone ()
	~DQMService ()

Private Member Functions
void	shutdown ()

Private Attributes
double	lastFlush_
DQMBasicNet *	net_
double	publishFrequency_
DQMStore *	store_

Detailed Description

A bridge to udpate the DQM network layer at the end of every event.

Definition at line 12 of file DQMService.h.

Member Typedef Documentation

typedef dqm::legacy::DQMStore DQMService::DQMStore

Definition at line 14 of file DQMService.h.

typedef dqm::legacy::MonitorElement DQMService::MonitorElement

Definition at line 15 of file DQMService.h.

Constructor & Destructor Documentation

DQMService::DQMService	(	const edm::ParameterSet &	pset,
		edm::ActivityRegistry &	ar
	)

Definition at line 25 of file DQMService.cc.

References DQMNet::debug(), flush(), edm::ParameterSet::getUntrackedParameter(), query::host, net_, query::port, publishFrequency_, DQMNet::start(), AlCaHLTBitMon_QueryRunRegistry::string, DQMNet::updateToCollector(), verbose, edm::ActivityRegistry::watchPostEvent(), and edm::ActivityRegistry::watchPostStreamEndLumi().

    : store_(&*edm::Service<DQMStore>()), net_(nullptr), lastFlush_(0), publishFrequency_(5.0) {
  ar.watchPostEvent(this, &DQMService::flush);
  ar.watchPostStreamEndLumi(this, &DQMService::flush);

  std::string host = pset.getUntrackedParameter<std::string>("collectorHost", "");
  int port = pset.getUntrackedParameter<int>("collectorPort", 9090);
  bool verbose = pset.getUntrackedParameter<bool>("verbose", false);
  publishFrequency_ = pset.getUntrackedParameter<double>("publishFrequency", publishFrequency_);

  if (!host.empty() && port > 0) {
    net_ = new DQMBasicNet;
    net_->debug(verbose);
    net_->updateToCollector(host, port);
    net_->start();
  }
}

DQMService::~DQMService

(

)

Definition at line 43 of file DQMService.cc.

References shutdown().

{ shutdown(); }

Member Function Documentation

void DQMService::flush

(

edm::StreamContext const &

sc

)

Definition at line 123 of file DQMService.cc.

References flushStandalone().

Referenced by DQMService().

                                                 {
  // Call a function independent to the framework
  flushStandalone();
}

void DQMService::flushStandalone

(

)

Definition at line 48 of file DQMService.cc.

References cms::cuda::assert(), edmScanValgrind::buffer, DQMNet::CoreObject::dirname, DQMNet::dqmhash(), alignCSCRings::e, DQMNet::CoreObject::flags, das_client::fullpath(), dqm::implementation::IGetter::getAllContents(), DQMNet::Object::hash, MonitorElementData::INT, lastFlush_, DQMNet::Object::lastreq, DQMNet::lock(), hlt_dqm_clientPB-live_cfg::me, net_, class-composition::o, DQMNet::CoreObject::objname, DQMNet::packQualityData(), publishFrequency_, DQMNet::Object::qdata, DQMNet::Object::rawdata, MonitorElementData::REAL, DQMBasicNet::removeLocalExcept(), DQMNet::Object::scalar, upgradeWorkflowComponents::seen, DQMNet::sendLocalChanges(), store_, MonitorElementData::STRING, AlCaHLTBitMon_QueryRunRegistry::string, DQMNet::unlock(), DQMBasicNet::updateLocalObject(), DQMNet::CoreObject::version, and relval_steps::version.

Referenced by flush().

                                 {
  // Avoid sending updates excessively often.
  uint64_t version = lat::Time::current().ns();
  double vtime = version * 1e-9;
  if (vtime - lastFlush_ < publishFrequency_)
    return;

  // OK, send an update.
  if (net_) {
    DQMNet::Object o;
    std::set<std::string> seen;
    std::string fullpath;

    // Lock the network layer so we can modify the data.
    net_->lock();
    bool updated = false;

    auto mes = store_->getAllContents("");
    for (MonitorElement *me : mes) {
      auto fullpath = me->getFullname();
      seen.insert(fullpath);
      if (!me->wasUpdated())
        continue;

      o.lastreq = 0;
      o.hash = DQMNet::dqmhash(fullpath.c_str(), fullpath.size());
      o.flags = me->data_.flags;
      o.version = version;
      o.dirname = me->data_.dirname.substr(0, me->data_.dirname.size() - 1);
      o.objname = me->data_.objname;
      assert(o.rawdata.empty());
      assert(o.scalar.empty());
      assert(o.qdata.empty());

      // Pack object and reference, scalar and quality data.

      switch (me->kind()) {
        case MonitorElement::Kind::INT:
        case MonitorElement::Kind::REAL:
        case MonitorElement::Kind::STRING:
          me->packScalarData(o.scalar, "");
          break;
        default: {
          TBufferFile buffer(TBufferFile::kWrite);
          buffer.WriteObject(me->getTH1());
          // placeholder for (no longer supported) reference
          buffer.WriteObjectAny(nullptr, nullptr);
          o.rawdata.resize(buffer.Length());
          memcpy(&o.rawdata[0], buffer.Buffer(), buffer.Length());
          DQMNet::packQualityData(o.qdata, me->data_.qreports);
          break;
        }
      }

      net_->updateLocalObject(o);
      DQMNet::DataBlob().swap(o.rawdata);
      std::string().swap(o.scalar);
      std::string().swap(o.qdata);
      updated = true;
    }

    // Find removed contents and clear the network cache.
    if (net_->removeLocalExcept(seen))
      updated = true;

    // Unlock the network layer.
    net_->unlock();

    // Tell network to flush if we updated something.
    if (updated)
      net_->sendLocalChanges();
  }

  lastFlush_ = lat::Time::current().ns() * 1e-9;
}

void DQMService::shutdown ( )

private

Definition at line 129 of file DQMService.cc.

References net_, and DQMNet::shutdown().

Referenced by ~DQMService().

                          {
  // If we have a network, let it go.
  if (net_)
    net_->shutdown();
}

Member Data Documentation

double DQMService::lastFlush_

private

Definition at line 28 of file DQMService.h.

Referenced by flushStandalone().

DQMBasicNet* DQMService::net_

private

Definition at line 27 of file DQMService.h.

Referenced by DQMService(), flushStandalone(), and shutdown().

double DQMService::publishFrequency_

private

Definition at line 29 of file DQMService.h.

Referenced by DQMService(), and flushStandalone().

DQMStore* DQMService::store_

private

Definition at line 26 of file DQMService.h.

Referenced by flushStandalone().