|
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
118
119
|
// -*- C++ -*-
//
// Package: test
// Class : DeleteEarlyModules
//
// Implementation:
// [Notes on implementation]
//
// Original Author: Chris Jones
// Created: Tue Feb 7 15:36:37 CST 2012
//
// system include files
#include <vector>
#include <memory>
// user include files
#include "DataFormats/TestObjects/interface/DeleteEarly.h"
#include "DataFormats/Common/interface/RefProd.h"
#include "FWCore/Framework/interface/global/EDProducer.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/Framework/interface/global/EDAnalyzer.h"
#include "FWCore/Utilities/interface/InputTag.h"
#include "FWCore/Utilities/interface/Exception.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Framework/interface/Event.h"
namespace edmtest {
class DeleteEarlyProducer : public edm::global::EDProducer<> {
public:
explicit DeleteEarlyProducer(edm::ParameterSet const& pset) { produces<DeleteEarly>(); }
void beginJob() override {
// Needed because DeleteEarly objects may be allocated and deleted in initialization
edmtest::DeleteEarly::resetDeleteCount();
}
void produce(edm::StreamID, edm::Event& e, edm::EventSetup const&) const override {
e.put(std::make_unique<DeleteEarly>());
}
};
class DeleteEarlyRefProdProducer : public edm::global::EDProducer<> {
public:
explicit DeleteEarlyRefProdProducer(edm::ParameterSet const& pset)
: m_token{consumes(pset.getParameter<edm::InputTag>("get"))} {
m_put = produces<edm::RefProd<DeleteEarly>>();
}
void produce(edm::StreamID, edm::Event& e, edm::EventSetup const&) const override {
auto h = e.getHandle(m_token);
e.emplace(m_put, h);
}
private:
const edm::EDGetTokenT<DeleteEarly> m_token;
edm::EDPutTokenT<edm::RefProd<DeleteEarly>> m_put;
};
class DeleteEarlyReader : public edm::global::EDAnalyzer<> {
public:
DeleteEarlyReader(edm::ParameterSet const& pset)
: getToken_(consumes(pset.getUntrackedParameter<edm::InputTag>("tag"))) {}
void analyze(edm::StreamID, edm::Event const& e, edm::EventSetup const&) const override { e.get(getToken_); }
private:
edm::EDGetTokenT<DeleteEarly> getToken_;
};
class DeleteEarlyConsumer : public edm::global::EDAnalyzer<> {
public:
DeleteEarlyConsumer(edm::ParameterSet const& pset) {
consumes<DeleteEarly>(pset.getUntrackedParameter<edm::InputTag>("tag"));
}
void analyze(edm::StreamID, edm::Event const&, edm::EventSetup const&) const override {}
private:
};
class DeleteEarlyRefProdReader : public edm::global::EDAnalyzer<> {
public:
DeleteEarlyRefProdReader(edm::ParameterSet const& pset)
: getToken_(consumes(pset.getUntrackedParameter<edm::InputTag>("tag"))) {}
void analyze(edm::StreamID, edm::Event const& e, edm::EventSetup const&) const override { e.get(getToken_).get(); }
private:
edm::EDGetTokenT<edm::RefProd<DeleteEarly>> getToken_;
};
class DeleteEarlyCheckDeleteAnalyzer : public edm::one::EDAnalyzer<> {
public:
DeleteEarlyCheckDeleteAnalyzer(edm::ParameterSet const& pset)
: m_expectedValues(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedValues")), m_index(0) {}
void analyze(edm::Event const&, edm::EventSetup const&) override {
if (DeleteEarly::nDeletes() != m_expectedValues.at(m_index)) {
throw cms::Exception("DeleteEarlyError")
<< "On index " << m_index << " we expected " << m_expectedValues[m_index] << " deletes but we see "
<< DeleteEarly::nDeletes();
}
++m_index;
}
private:
std::vector<unsigned int> m_expectedValues;
unsigned int m_index;
};
} // namespace edmtest
using namespace edmtest;
DEFINE_FWK_MODULE(DeleteEarlyProducer);
DEFINE_FWK_MODULE(DeleteEarlyRefProdProducer);
DEFINE_FWK_MODULE(DeleteEarlyReader);
DEFINE_FWK_MODULE(DeleteEarlyRefProdReader);
DEFINE_FWK_MODULE(DeleteEarlyConsumer);
DEFINE_FWK_MODULE(DeleteEarlyCheckDeleteAnalyzer);
|