EventIDChecker.cc

Go to the documentation of this file.

// -*- C++ -*-
//
// Package:    Modules
// Class:      EventIDChecker
//
//
// Original Author:  Chris Jones
//         Created:  Tue Jun 16 15:42:17 CDT 2009
//
//

// user include files
#include "DataFormats/Provenance/interface/EventID.h"
#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "FWCore/ParameterSet/interface/ConfigurationDescriptions.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/ParameterSet/interface/ParameterSetDescription.h"

// system include files
#include <algorithm>
#include <memory>
#include <vector>

//
// class decleration
//

class EventIDChecker : public edm::EDAnalyzer {
public:
   explicit EventIDChecker(edm::ParameterSet const&);
   ~EventIDChecker();
    static void fillDescriptions(edm::ConfigurationDescriptions& descriptions);


private:
   virtual void beginJob();
   virtual void analyze(edm::Event const&, edm::EventSetup const&);
   virtual void endJob();
   virtual void postForkReacquireResources(unsigned int iChildIndex, unsigned int iNumberOfChildren);

   // ----------member data ---------------------------
   std::vector<edm::EventID> ids_;
   unsigned int index_;

   unsigned int multiProcessSequentialEvents_;
   unsigned int numberOfEventsLeftBeforeSearch_;
   bool mustSearch_;
};

//
// constants, enums and typedefs
//

//
// static data member definitions
//

//
// constructors and destructor
//
EventIDChecker::EventIDChecker(edm::ParameterSet const& iConfig) :
  ids_(iConfig.getUntrackedParameter<std::vector<edm::EventID> >("eventSequence")),
  index_(0),
  multiProcessSequentialEvents_(iConfig.getUntrackedParameter<unsigned int>("multiProcessSequentialEvents")),
  numberOfEventsLeftBeforeSearch_(0),
  mustSearch_(false)
{
   //now do what ever initialization is needed

}


EventIDChecker::~EventIDChecker() {

   // do anything here that needs to be done at desctruction time
   // (e.g. close files, deallocate resources etc.)

}


//
// member functions
//

namespace {
   struct CompareWithoutLumi {
      CompareWithoutLumi(edm::EventID const& iThis) : m_this(iThis) {
      }
      bool operator()(edm::EventID const& iOther) {
         return m_this.run() == iOther.run() && m_this.event() == iOther.event();
      }
      edm::EventID m_this;
   };
}

// ------------ method called to for each event  ------------
void
EventIDChecker::analyze(edm::Event const& iEvent, edm::EventSetup const&) {
   if(mustSearch_) {
      if(0 == numberOfEventsLeftBeforeSearch_) {
         numberOfEventsLeftBeforeSearch_ = multiProcessSequentialEvents_;
         //the event must be after the last event in our list since multicore doesn't go backwards
         std::vector<edm::EventID>::iterator itFind= std::find_if(ids_.begin()+index_, ids_.end(), CompareWithoutLumi(iEvent.id()));
         if(itFind == ids_.end()) {
            throw cms::Exception("MissedEvent") << "The event " << iEvent.id() << "is not in the list.\n";
         }
         index_ = itFind-ids_.begin();
      }
      --numberOfEventsLeftBeforeSearch_;
   }

   if(index_ >= ids_.size()) {
      throw cms::Exception("TooManyEvents") << "Was passes " << ids_.size() << " EventIDs but have processed more events than that\n";
   }
   if(iEvent.id().run() != ids_[index_].run() || iEvent.id().event() != ids_[index_].event()) {
      throw cms::Exception("WrongEvent") << "Was expecting event " << ids_[index_] << " but was given " << iEvent.id() << "\n";
   }
   ++index_;
}

// ------------ method called once each job just before starting event loop  ------------
void
EventIDChecker::beginJob() {
}

// ------------ method called once each job just after ending the event loop  ------------
void
EventIDChecker::endJob() {
}

// ------------ method called once each job for validation
void
EventIDChecker::fillDescriptions(edm::ConfigurationDescriptions& descriptions) {
  edm::ParameterSetDescription desc;
  desc.addUntracked<std::vector<edm::EventID> >("eventSequence");
  desc.addUntracked<unsigned int>("multiProcessSequentialEvents", 0U);
  descriptions.add("eventIDChecker", desc);
}

void
EventIDChecker::postForkReacquireResources(unsigned int /*iChildIndex*/, unsigned int /*iNumberOfChildren*/) {
   mustSearch_ = true;
}

//define this as a plug-in
DEFINE_FWK_MODULE(EventIDChecker);