|
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
|
import FWCore.ParameterSet.Config as cms
process = cms.Process("TEST")
process.DQMStore = cms.Service("DQMStore")
process.MessageLogger = cms.Service("MessageLogger")
process.load("DQMServices.Demo.test_cfi")
process.load("DQMServices.Demo.testone_cfi")
process.load("DQMServices.Demo.testonefillrun_cfi")
process.load("DQMServices.Demo.testonelumi_cfi")
process.load("DQMServices.Demo.testonelumifilllumi_cfi")
process.load("DQMServices.Demo.testglobal_cfi")
process.load("DQMServices.Demo.testglobalrunsummary_cfi")
process.load("DQMServices.Demo.testlegacy_cfi")
process.load("DQMServices.Demo.testlegacyfillrun_cfi")
process.load("DQMServices.Demo.testlegacyfilllumi_cfi")
process.test_general = cms.Sequence(process.test
+ process.testglobal
+ process.testglobalrunsummary)
process.test_one = cms.Sequence(process.testone
+ process.testonefillrun)
process.test_legacy = cms.Sequence(process.testonelumi + process.testonelumifilllumi
+ process.testlegacy + process.testlegacyfillrun + process.testlegacyfilllumi)
import FWCore.ParameterSet.VarParsing as VarParsing
parser = VarParsing.VarParsing('python')
one = VarParsing.VarParsing.multiplicity.singleton
int = VarParsing.VarParsing.varType.int
bool = VarParsing.VarParsing.varType.bool
string = VarParsing.VarParsing.varType.string
parser.register('nolegacy', False, one, bool, "Don't run modules which block concurrent lumis.")
parser.register('noone', False, one, bool, "Don't run any one modules.")
parser.register('legacyoutput', False, one, bool, "Use DQMFileSaver for output instead of DQMIO.")
parser.register('protobufoutput', False, one, bool, "Use DQMFileSaverPB for output instead of DQMIO.")
parser.register('onlineoutput', False, one, bool, "Use DQMFileSaverOnline for output instead of DQMIO. This *does not* cover live mode.")
parser.register('metoedmoutput', False, one, bool, "Use MEtoEDMConverter and PoolOutputModule for output.")
parser.register('firstLuminosityBlock', 1, one, int, "See EmptySource.")
parser.register('firstEvent', 1, one, int, "See EmptySource.")
parser.register('firstRun', 1, one, int, "See EmptySource.")
parser.register('numberEventsInRun', 100, one, int, "See EmptySource.")
parser.register('numberEventsInLuminosityBlock', 20, one, int, "See EmptySource.")
parser.register('processingMode', 'RunsLumisAndEvents', one, string, "See EmptySource.")
parser.register('nEvents', 100, one, int, "Total number of events.")
parser.register('nLumisections', -1, one, int, "Total number of lumisections.")
parser.register('nThreads', 1, one, int, "Number of threads and streams.")
parser.register('nConcurrent', 1, one, int, "Number of concurrent runs/lumis.")
parser.register('howmany', 1, one, int, "Number of MEs to book of each type.")
parser.register('outfile', "dqm.root", one, string, "Output file name.")
parser.parseArguments()
args = parser
process.source = cms.Source("EmptySource", numberEventsInRun = cms.untracked.uint32(args.numberEventsInRun),
numberEventsInLuminosityBlock = cms.untracked.uint32(args.numberEventsInLuminosityBlock),
firstLuminosityBlock = cms.untracked.uint32(args.firstLuminosityBlock),
firstEvent = cms.untracked.uint32(args.firstEvent),
firstRun = cms.untracked.uint32(args.firstRun),
processingMode = cms.untracked.string(args.processingMode))
process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(args.nEvents) )
if args.nLumisections > 0:
process.maxLuminosityBlocks = cms.untracked.PSet( input = cms.untracked.int32(args.nLumisections) )
process.options = cms.untracked.PSet(
numberOfThreads = cms.untracked.uint32(args.nThreads),
numberOfStreams = cms.untracked.uint32(args.nThreads),
numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(args.nConcurrent),
# Must be one for now.
numberOfConcurrentRuns = cms.untracked.uint32(1)
)
if args.nConcurrent > 1:
process.DQMStore.assertLegacySafe = cms.untracked.bool(False)
for mod in [process.test, process.testglobal, process.testglobalrunsummary, process.testone, process.testonefillrun, process.testonelumi, process.testonelumifilllumi, process.testlegacy, process.testlegacyfillrun, process.testlegacyfilllumi]:
mod.howmany = args.howmany
if args.noone:
process.p = cms.Path(process.test_general)
elif args.nolegacy:
process.p = cms.Path(process.test_general + process.test_one)
else:
process.p = cms.Path(process.test_general + process.test_one + process.test_legacy)
# DQMIO output
process.out = cms.OutputModule(
"DQMRootOutputModule",
fileName = cms.untracked.string(args.outfile),
outputCommands = cms.untracked.vstring(
'keep *'
)
)
# legacy output
process.dqmSaver = cms.EDAnalyzer("DQMFileSaver",
convention = cms.untracked.string('Offline'),
fileFormat = cms.untracked.string('ROOT'),
producer = cms.untracked.string('DQM'),
workflow = cms.untracked.string('/EmptySource/DQMTests/DQMIO'),
dirName = cms.untracked.string('.'),
saveByRun = cms.untracked.int32(-1),
saveAtJobEnd = cms.untracked.bool(True),
)
# protobuf output
process.pbSaver = cms.EDAnalyzer("DQMFileSaverPB",
producer = cms.untracked.string('DQM'),
path = cms.untracked.string('./'),
tag = cms.untracked.string('UNKNOWN'),
fakeFilterUnitMode = cms.untracked.bool(True),
streamLabel = cms.untracked.string("streamDQMHistograms"),
)
# online output
process.onlineSaver = cms.EDAnalyzer("DQMFileSaverOnline",
producer = cms.untracked.string('DQM'),
path = cms.untracked.string('./'),
tag = cms.untracked.string('UNKNOWN'),
backupLumiCount = cms.untracked.int32(2),
keepBackupLumi = cms.untracked.bool(False)
)
# MEtoEDM
process.MEtoEDMConverter = cms.EDProducer("MEtoEDMConverter",
Name = cms.untracked.string('MEtoEDMConverter'),
Verbosity = cms.untracked.int32(0),
Frequency = cms.untracked.int32(50),
MEPathToSave = cms.untracked.string('')
)
process.metoedmoutput = cms.OutputModule("PoolOutputModule",
dataset = cms.untracked.PSet(
dataTier = cms.untracked.string('ALCARECO'),
),
fileName = cms.untracked.string(args.outfile),
outputCommands = cms.untracked.vstring(
'keep *'
)
)
if args.legacyoutput:
process.o = cms.EndPath(process.dqmSaver)
elif args.protobufoutput:
process.o = cms.EndPath(process.pbSaver)
elif args.onlineoutput:
process.o = cms.EndPath(process.onlineSaver)
elif args.metoedmoutput:
process.o = cms.EndPath(process.MEtoEDMConverter + process.metoedmoutput)
else:
process.o = cms.EndPath(process.out)
#process.Tracer = cms.Service("Tracer")
#process.DQMStore.trackME = cms.untracked.string("testlegacyfillrun")
|