---

DQMService Class Reference

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

#include <DQMServices/Core/src/DQMService.h>

List of all members.

Public Member Functions
	DQMService (const edm::ParameterSet &pset, edm::ActivityRegistry &ar)
	~DQMService (void)
Private Member Functions
void	flush (const edm::Event &, const edm::EventSetup &)
void	shutdown (void)
Private Attributes
lat::Regexp *	filter_
double	lastFlush_
DQMNet *	net_
double	publishFrequency_
DQMStore *	store_

---

Detailed Description

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

Definition at line 13 of file DQMService.h.

---

Constructor & Destructor Documentation

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

Definition at line 46 of file DQMService.cc.

References DQMNet::debug(), e, lat::Regexp::errorMessage(), lat::Regexp::errorOffset(), Exception, lat::Error::explain(), filter, filter_, flush(), edm::ParameterSet::getUntrackedParameter(), cmsBenchmark::host, net_, python_dbs::port, publishFrequency_, releaseDQMAccess(), releaseDQMAccessM(), restrictDQMAccess(), restrictDQMAccessM(), shutdown(), DQMNet::start(), lat::Regexp::study(), DQMNet::updateToCollector(), lat::Regexp::valid(), edm::ActivityRegistry::watchPostEndJob(), edm::ActivityRegistry::watchPostModule(), edm::ActivityRegistry::watchPostProcessEvent(), edm::ActivityRegistry::watchPostSource(), edm::ActivityRegistry::watchPostSourceConstruction(), edm::ActivityRegistry::watchPreModule(), edm::ActivityRegistry::watchPreSource(), and edm::ActivityRegistry::watchPreSourceConstruction().

  : store_(&*edm::Service<DQMStore>()),
    net_(0),
    filter_(0),
    lastFlush_(0),
    publishFrequency_(5.0)
{
  ar.watchPreSourceConstruction(&restrictDQMAccessM);
  ar.watchPostSourceConstruction(&releaseDQMAccessM);
  ar.watchPreSource(&restrictDQMAccess);
  ar.watchPostSource(&releaseDQMAccess);
  ar.watchPreModule(&restrictDQMAccessM);
  ar.watchPostModule(&releaseDQMAccessM);
  ar.watchPostProcessEvent(this, &DQMService::flush);
  ar.watchPostEndJob(this, &DQMService::shutdown);

  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_);
  std::string filter = pset.getUntrackedParameter<std::string>("filter", "");

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

  if (! filter.empty())
  {
    try
    {
      filter_ = new lat::Regexp(filter);
      if (! filter_->valid())
        throw cms::Exception("DQMService")
          << "Invalid 'filter' parameter value '" << filter << "':"
          << " bad regular expression syntax at character "
          << filter_->errorOffset() << ": " << filter_->errorMessage();
      filter_->study();
    }
    catch (lat::Error &e)
    {
      throw cms::Exception("DQMService")
        << "Invalid regular expression 'filter' parameter value '"
        << filter << "': " << e.explain();
    }
  }
}

DQMService::~DQMService

(

void

)

Definition at line 97 of file DQMService.cc.

References shutdown().

{
  shutdown();
}

---

Member Function Documentation

void DQMService::flush	(	const edm::Event &	,
		const edm::EventSetup &
	)			[private]

Definition at line 106 of file DQMService.cc.

References lat::Time::current(), DQMStore::data_, MonitorElement::data_, e, filter_, DQMNet::CoreObject::flags, i, lastFlush_, DQMNet::Object::lastreq, DQMNet::lock(), me, DQMNet::CoreObject::name, net_, DQMNet::CoreObject::object, publishFrequency_, DQMNet::CoreObject::qreports, MonitorElement::qualityTagString(), DQMNet::Object::rawdata, DQMNet::CoreObject::reference, DQMStore::removed_, DQMNet::removeLocalObject(), DQMStore::reset(), s, lat::Regexp::search(), DQMNet::sendLocalChanges(), store_, DQMNet::CoreObject::tags, DQMNet::unlock(), DQMNet::updateLocalObject(), version(), DQMNet::CoreObject::version, and MonitorElement::wasUpdated().

Referenced by DQMService().

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

  // OK, send an update.
  if (net_)
  {
    // Lock the network layer so we can modify the data.
    net_->lock();
    bool updated = false;

    // Find updated contents and update the network cache.
    DQMStore::MEMap::iterator i, e;
    for (i = store_->data_.begin(), e = store_->data_.end(); i != e; ++i)
    {
      MonitorElement &me = i->second;
      if (! me.wasUpdated())
        continue;

      if (filter_ && filter_->search(me.data_.name) < 0)
        continue;

      assert(me.data_.object);

      DQMNet::Object o;
      o.version = version;
      o.name = me.data_.name;
      o.tags = me.data_.tags;
      o.object = 0;
      o.reference = 0;
      o.flags = me.data_.flags;
      o.lastreq = 0;

      DQMRootBuffer buffer (DQMRootBuffer::kWrite);
      buffer.WriteObject(me.data_.object);
      if (me.data_.reference)
        buffer.WriteObject(me.data_.reference);
      else
        buffer.WriteObjectAny(0, 0);

      // Save the quality test results.
      DQMNet::QReports::iterator qi, qe;
      for (qi = me.data_.qreports.begin(), qe = me.data_.qreports.end(); qi != qe; ++qi)
      {
        TObjString s (me.qualityTagString(*qi).c_str());
        buffer.WriteObject(&s);
      }

      // Save this ensemble to the buffer.
      o.rawdata.resize(buffer.Length());
      memcpy(&o.rawdata[0], buffer.Buffer(), buffer.Length());
      net_->updateLocalObject(o);
      updated = true;
    }

    // Find removed contents and clear the network cache.
    std::vector<std::string>::iterator ri, re;
    for (ri = store_->removed_.begin(), re = store_->removed_.end(); ri != re; ++ri, updated = true)
      net_->removeLocalObject(*ri);

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

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

  store_->reset();
}

void DQMService::shutdown

(

void

)

[private]

Definition at line 184 of file DQMService.cc.

References net_, and DQMNet::shutdown().

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

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

---

Member Data Documentation

lat::Regexp* DQMService::filter_ [private]

Definition at line 25 of file DQMService.h.

Referenced by DQMService(), and flush().

double DQMService::lastFlush_ [private]

Definition at line 26 of file DQMService.h.

Referenced by flush().

DQMNet* DQMService::net_ [private]

Definition at line 24 of file DQMService.h.

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

double DQMService::publishFrequency_ [private]

Definition at line 27 of file DQMService.h.

Referenced by DQMService(), and flush().

DQMStore* DQMService::store_ [private]

Definition at line 23 of file DQMService.h.

Referenced by flush().

---

The documentation for this class was generated from the following files:

• DQMServices/Core/src/DQMService.h
• DQMServices/Core/src/DQMService.cc

---