Line Code
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
import FWCore.ParameterSet.Config as cms

process = cms.Process("HLT-DTDQM")

#----------------------------
#### Event Source
#----------------------------
process.load("DQM.Integration.test.inputsource_cfi")
process.EventStreamHttpReader.consumerName = 'DT DQM Consumer'


#----------------------------
#### DQM Environment
#----------------------------
process.load("DQMServices.Core.DQM_cfg")

process.load("DQMServices.Components.DQMEnvironment_cfi")


#----------------------------
#### DQM Live Environment
#----------------------------
process.load("DQM.Integration.test.environment_cfi")
process.DQM.collectorHost = 'srv-c2d05-13.cms'
process.DQM.collectorPort = 9190
process.dqmEnv.subSystemFolder = 'DT'
process.dqmSaver.convention = 'Online'
process.dqmSaver.dirName = '/localdatadisk/DTDQM/dqmdata'
process.dqmSaver.producer = 'DQM'

process.dqmSaver.saveByTime = -1
process.dqmSaver.saveByLumiSection = -1
process.dqmSaver.saveByMinute = -1
process.dqmSaver.saveByRun = 1
process.dqmSaver.saveAtJobEnd = True
#-----------------------------


# DT reco and DQM sequences
process.load("Configuration.StandardSequences.GeometryRecoDB_cff")

# filter on trigger type
physicsEventsFilter = cms.EDFilter("HLTTriggerTypeFilter",
                                   # 1=Physics, 2=Calibration, 3=Random, 4=Technical
                                   SelectedTriggerType = cms.int32(1) 
                                   )


from Configuration.StandardSequences.FrontierConditions_GlobalTag_cff import *
#---- for P5 (online) DB access
process.GlobalTag.globaltag = "CRAFT_V17H::All"
#---- for offline DB
#process.GlobalTag.globaltag = "CRAFT_V2P::All"

# segment reco task
process.load("DQM.DTMonitorModule.dtSegmentTask_cfi")
process.dtSegmentAnalysisMonitor.recHits4DLabel = 'hltDt4DSegments'
process.dtSegmentAnalysisMonitor.topHistoFolder = "HLT/DTSegments"
process.dtSegmentAnalysisMonitor.hltDQMMode = True
process.load("DQM.DTMonitorClient.dtSegmentAnalysisTest_cfi")
process.segmentTest.topHistoFolder = "HLT/DTSegments"
process.segmentTest.hltDQMMode = True


# resolution task
process.load("DQM.DTMonitorModule.dtResolutionTask_cfi")
process.dtResolutionAnalysisMonitor.recHits4DLabel = 'hltDt4DSegments'
process.dtResolutionAnalysisMonitor.topHistoFolder = "HLT/DTSegments"
process.load("DQM.DTMonitorClient.dtResolutionAnalysisTest_cfi")
process.dtResolutionAnalysisTest.topHistoFolder = "HLT/DTSegments"


# message logger
process.MessageLogger = cms.Service("MessageLogger",
                                    destinations = cms.untracked.vstring('cout'),
                                    cout = cms.untracked.PSet(threshold = cms.untracked.string('WARNING'))
                                    )

process.dqmmodules = cms.Sequence(process.dqmEnv + process.dqmSaver)

process.dtDQMTask = cms.Sequence(dtSegmentAnalysisMonitor + dtResolutionAnalysisMonitor)

process.dtDQMTest = cms.Sequence(segmentTest + dtResolutionAnalysisTest)

process.dtDQMPathPhys = cms.Path(process.unpackers + process.dqmmodules + process.physicsEventsFilter * process.dtDQMTask + process.dtDQMTest)