DQWorkerTask.h

Go to the documentation of this file.

#ifndef DQWorkerTask_H
#define DQWorkerTask_H
 
#include "DQM/EcalCommon/interface/DQWorker.h"
 
#include "DataFormats/EcalRawData/interface/EcalDCCHeaderBlock.h"
 
#include "Collections.h"
 
#include <bitset>
 
namespace edm {
  class TriggerResultsByName;
  class ConsumesCollector;
}  // namespace edm
 
namespace ecaldqm {
 
  struct Dependency {
    Collections dependant;
    std::set<Collections> requisite;
 
    Dependency() : dependant(Collections(-1)), requisite() {}
    Dependency(Collections _d, int _r1 = -1, int _r2 = -1, int _r3 = -1, int _r4 = -1) : dependant(_d), requisite() {
      if (_r1 >= 0)
        append(Collections(_r1));
      if (_r2 >= 0)
        append(Collections(_r2));
      if (_r3 >= 0)
        append(Collections(_r3));
      if (_r4 >= 0)
        append(Collections(_r4));
    }
    void append(Collections _r) {
      if (_r != int(dependant))
        requisite.insert(_r);
    }
    void append(std::set<Collections> const& _s) {
      for (std::set<Collections>::const_iterator sItr(_s.begin()); sItr != _s.end(); ++sItr)
        append(*sItr);
    }
  };
 
  struct DependencySet {
    DependencySet() : set_() {}
    void push_back(Dependency const& _d) {
      std::vector<Dependency>::iterator dItr(set_.begin());
      std::vector<Dependency>::iterator dEnd(set_.end());
      for (; dItr != dEnd; ++dItr)
        if (dItr->dependant == _d.dependant)
          dItr->append(_d.requisite);
      if (dItr == dEnd)
        set_.push_back(_d);
    }
    std::vector<Collections> formSequence() const {
      std::vector<Collections> sequence;
      for (unsigned iD(0); iD < set_.size(); iD++) {
        if (std::find(sequence.begin(), sequence.end(), set_[iD].dependant) != sequence.end())
          continue;
        formSequenceFragment_(set_[iD], sequence, sequence.end());
      }
      return sequence;
    }
 
  private:
    std::vector<Dependency> set_;
 
    void formSequenceFragment_(Dependency const&, std::vector<Collections>&, std::vector<Collections>::iterator) const;
  };
 
  class DQWorkerTask : public DQWorker {
  public:
    typedef EcalDCCHeaderBlock::EcalDCCEventSettings EventSettings;
 
    DQWorkerTask();
    ~DQWorkerTask() override {}
 
    static void fillDescriptions(edm::ParameterSetDescription&);
 
    virtual void beginEvent(edm::Event const&, edm::EventSetup const&) {}
    virtual void endEvent(edm::Event const&, edm::EventSetup const&) {}
 
    virtual bool filterRunType(short const*) { return true; };
    virtual bool filterTrigger(edm::TriggerResultsByName const&) { return true; };
    virtual void addDependencies(DependencySet&) {}
 
    // mechanisms to register EDGetTokens for any additional objects used internally
    virtual void setTokens(edm::ConsumesCollector&) {}
 
    // "Dry-run" mode when passed a null pointer
    // Returns true if the module runs on the collection
    virtual bool analyze(void const*, Collections) { return false; }
 
  protected:
    void setME(edm::ParameterSet const&) final;
  };
}  // namespace ecaldqm
#endif