|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
// -*- C++ -*-
//
// Package: Modules
// Class: AbortOnEventIDAnalyzer
//
/**\class AbortOnEventIDAnalyzer AbortOnEventIDAnalyzer.cc FWCore/Modules/src/AbortOnEventIDAnalyzer.cc
Description: Does a system abort when it seens the specified EventID. Useful for testing error handling.
Implementation:
<Notes on implementation>
*/
//
// 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/global/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>
#include <cstdlib>
//
// class decleration
//
class AbortOnEventIDAnalyzer : public edm::global::EDAnalyzer<> {
public:
explicit AbortOnEventIDAnalyzer(edm::ParameterSet const&);
~AbortOnEventIDAnalyzer() override;
static void fillDescriptions(edm::ConfigurationDescriptions& descriptions);
private:
void beginJob() override;
void analyze(edm::StreamID, edm::Event const&, edm::EventSetup const&) const override;
void endJob() override;
// ----------member data ---------------------------
std::vector<edm::EventID> ids_;
bool throwException_;
};
//
// constants, enums and typedefs
//
//
// static data member definitions
//
//
// constructors and destructor
//
AbortOnEventIDAnalyzer::AbortOnEventIDAnalyzer(edm::ParameterSet const& iConfig)
: ids_(iConfig.getUntrackedParameter<std::vector<edm::EventID> >("eventsToAbort")),
throwException_(iConfig.getUntrackedParameter<bool>("throwExceptionInsteadOfAbort")) {
//now do what ever initialization is needed
}
AbortOnEventIDAnalyzer::~AbortOnEventIDAnalyzer() {
// 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;
};
} // namespace
// ------------ method called to for each event ------------
void AbortOnEventIDAnalyzer::analyze(edm::StreamID, edm::Event const& iEvent, edm::EventSetup const&) const {
auto itFind = std::find_if(ids_.begin(), ids_.end(), CompareWithoutLumi(iEvent.id()));
if (itFind != ids_.end()) {
if (throwException_) {
throw cms::Exception("AbortEvent") << "Found event " << iEvent.id() << "\n";
} else {
abort();
}
}
}
// ------------ method called once each job just before starting event loop ------------
void AbortOnEventIDAnalyzer::beginJob() {}
// ------------ method called once each job just after ending the event loop ------------
void AbortOnEventIDAnalyzer::endJob() {}
// ------------ method called once each job for validation
void AbortOnEventIDAnalyzer::fillDescriptions(edm::ConfigurationDescriptions& descriptions) {
edm::ParameterSetDescription desc;
desc.addUntracked<std::vector<edm::EventID> >("eventsToAbort");
desc.addUntracked<bool>("throwExceptionInsteadOfAbort", false);
descriptions.add("abortOnEventID", desc);
}
//define this as a plug-in
DEFINE_FWK_MODULE(AbortOnEventIDAnalyzer);
|