|
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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
|
import FWCore.ParameterSet.Config as cms
process = cms.Process("READ")
process.options = cms.untracked.PSet(
numberOfStreams = cms.untracked.uint32(1),
numberOfThreads = cms.untracked.uint32(1),
numberOfConcurrentRuns = cms.untracked.uint32(1),
numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
)
process.source = cms.Source("PoolSource",
fileNames = cms.untracked.vstring(
'file:testProcessBlockTest.root'
)
)
process.out = cms.OutputModule("PoolOutputModule",
fileName = cms.untracked.string('testProcessBlockRead.root')
)
process.testGlobalOutput = cms.OutputModule("TestGlobalOutput",
verbose = cms.untracked.bool(False),
expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'READ'),
expectedWriteProcessBlockTransitions = cms.untracked.int32(4)
)
process.testLimitedOutput = cms.OutputModule("TestLimitedOutput",
verbose = cms.untracked.bool(False),
expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'READ'),
expectedWriteProcessBlockTransitions = cms.untracked.int32(4)
)
process.testOneOutput = cms.OutputModule("TestOneOutput",
verbose = cms.untracked.bool(False),
expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'READ'),
expectedWriteProcessBlockTransitions = cms.untracked.int32(4)
)
process.intProducerBeginProcessBlockR = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(100))
process.intProducerEndProcessBlockR = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(1000))
process.readProcessBlocks = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzer",
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
expectedByRun = cms.vint32(11, 22),
sleepTime = cms.uint32(10000)
)
process.readProcessBlocksG = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzerG",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77),
sleepTime = cms.uint32(10000)
)
process.readProcessBlocksNS = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzerNS")
process.readProcessBlocksGNS = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzerGNS")
process.readProcessBlocksStreamFilter = cms.EDFilter("edmtest::stream::InputProcessBlockIntFilter",
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
expectedByRun = cms.vint32(11, 22),
sleepTime = cms.uint32(10000)
)
process.readProcessBlocksGStreamFilter = cms.EDFilter("edmtest::stream::InputProcessBlockIntFilterG",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77),
sleepTime = cms.uint32(10000)
)
process.readProcessBlocksStreamProducer = cms.EDProducer("edmtest::stream::InputProcessBlockIntProducer",
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
expectedByRun = cms.vint32(11, 22),
sleepTime = cms.uint32(10000)
)
process.readProcessBlocksGStreamProducer = cms.EDProducer("edmtest::stream::InputProcessBlockIntProducerG",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77),
sleepTime = cms.uint32(10000)
)
process.readProcessBlocksOneAnalyzer = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77),
consumesBeginProcessBlockNotFound = cms.InputTag("intProducerBeginProcessBlock"),
consumesEndProcessBlockNotFound = cms.InputTag("intProducerEndProcessBlock")
)
process.readProcessBlocksOneFilter = cms.EDFilter("edmtest::one::InputProcessBlockIntFilter",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77)
)
process.readProcessBlocksOneProducer = cms.EDProducer("edmtest::one::InputProcessBlockIntProducer",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77)
)
process.readProcessBlocksGlobalAnalyzer = cms.EDAnalyzer("edmtest::global::InputProcessBlockIntAnalyzer",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77)
)
process.readProcessBlocksGlobalFilter = cms.EDFilter("edmtest::global::InputProcessBlockIntFilter",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77)
)
process.readProcessBlocksGlobalProducer = cms.EDProducer("edmtest::global::InputProcessBlockIntProducer",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77)
)
process.readProcessBlocksLimitedAnalyzer = cms.EDAnalyzer("edmtest::limited::InputProcessBlockIntAnalyzer",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77),
concurrencyLimit = cms.untracked.uint32(4)
)
process.readProcessBlocksLimitedFilter = cms.EDFilter("edmtest::limited::InputProcessBlockIntFilter",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77),
concurrencyLimit = cms.untracked.uint32(4)
)
process.readProcessBlocksLimitedProducer = cms.EDProducer("edmtest::limited::InputProcessBlockIntProducer",
transitions = cms.int32(15),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun = cms.vint32(11, 22),
expectedSum = cms.int32(77),
concurrencyLimit = cms.untracked.uint32(4)
)
process.readProcessBlocksGlobalAnalyzerNoRegistration = cms.EDAnalyzer("edmtest::global::InputProcessBlockIntAnalyzerNoRegistration",
transitions = cms.int32(6),
)
process.readProcessBlocksDoesNotExist = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerThreeTags",
transitions = cms.int32(9),
consumesBeginProcessBlock0 = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock0 = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlock1 = cms.InputTag("doesNotExist", ""),
consumesEndProcessBlock1 = cms.InputTag("doesNotExist", ""),
consumesBeginProcessBlock2 = cms.InputTag("intProducerBeginProcessBlockM", ""),
consumesEndProcessBlock2 = cms.InputTag("intProducerEndProcessBlockM", ""),
expectedByRun0 = cms.vint32(11, 22),
expectedByRun1 = cms.vint32(),
expectedByRun2 = cms.vint32(44, 44)
)
process.readProcessBlocksExplicitProcess = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerThreeTags",
transitions = cms.int32(10),
consumesBeginProcessBlock0 = cms.InputTag("intProducerBeginProcessBlockB", ""),
consumesEndProcessBlock0 = cms.InputTag("intProducerEndProcessBlockB", ""),
consumesBeginProcessBlock1 = cms.InputTag("intProducerBeginProcessBlockB", "", "PROD1"),
consumesEndProcessBlock1 = cms.InputTag("intProducerEndProcessBlockB", "", "PROD1"),
consumesBeginProcessBlock2 = cms.InputTag("intProducerBeginProcessBlockB", "", "MERGE"),
consumesEndProcessBlock2 = cms.InputTag("intProducerEndProcessBlockB", "", "MERGE"),
expectedByRun0 = cms.vint32(88, 88),
expectedByRun1 = cms.vint32(55, 77),
expectedByRun2 = cms.vint32(88, 88)
)
process.readProcessBlocksExplicitProcess2 = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerThreeTags",
transitions = cms.int32(11),
consumesBeginProcessBlock0 = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock0 = cms.InputTag("intProducerEndProcessBlock", ""),
consumesBeginProcessBlock1 = cms.InputTag("intProducerBeginProcessBlock", "", "PROD1"),
consumesEndProcessBlock1 = cms.InputTag("intProducerEndProcessBlock", "", "PROD1"),
consumesBeginProcessBlock2 = cms.InputTag("intProducerBeginProcessBlockM", "", "MERGE"),
consumesEndProcessBlock2 = cms.InputTag("intProducerEndProcessBlockM", "", "MERGE"),
expectedByRun0 = cms.vint32(11, 22),
expectedByRun1 = cms.vint32(11, 22),
expectedByRun2 = cms.vint32(44, 44)
)
process.readProcessBlocksReuseCache = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerReuseCache",
transitions = cms.int32(8),
consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
expectedByRun = cms.vint32(11, 11)
)
process.p = cms.Path(process.intProducerBeginProcessBlockR *
process.intProducerEndProcessBlockR *
process.readProcessBlocks *
process.readProcessBlocksG *
process.readProcessBlocksNS *
process.readProcessBlocksGNS *
process.readProcessBlocksStreamFilter *
process.readProcessBlocksGStreamFilter *
process.readProcessBlocksStreamProducer *
process.readProcessBlocksGStreamProducer *
process.readProcessBlocksOneAnalyzer *
process.readProcessBlocksOneFilter *
process.readProcessBlocksOneProducer *
process.readProcessBlocksGlobalAnalyzer *
process.readProcessBlocksGlobalFilter *
process.readProcessBlocksGlobalProducer *
process.readProcessBlocksLimitedAnalyzer *
process.readProcessBlocksLimitedFilter *
process.readProcessBlocksLimitedProducer *
process.readProcessBlocksDoesNotExist *
process.readProcessBlocksGlobalAnalyzerNoRegistration *
process.readProcessBlocksExplicitProcess *
process.readProcessBlocksExplicitProcess2 *
process.readProcessBlocksReuseCache
)
process.e = cms.EndPath(
process.out *
process.testGlobalOutput *
process.testLimitedOutput *
process.testOneOutput
)
|