CSCMonitorModule/test/dqm_repacker_test.py

0001 from __future__ import print_function
0002 import FWCore.ParameterSet.Config as cms
0003
0004 process = cms.Process("CSCDQMLIVE")
0005
0006 #-------------------------------------------------
0007 # DQM Module Configuration
0008 #-------------------------------------------------
0009
0010
0011 process.load("DQM.CSCMonitorModule.test.csc_dqm_sourceclient_dev_cfi")
0012 process.load("DQM.CSCMonitorModule.csc_hlt_dqm_sourceclient_cfi")
0013 #process.load("DQM.CSCMonitorModule.csc_dqm_sourceclient_cfi")
0014 process.dqmCSCClient.EventProcessor.BINCHECKER_MODE_DDU = cms.untracked.bool(False)
0015 process.dqmCSCClient.EventProcessor.EFF_COLD_SIGFAIL = cms.untracked.double(2.0)
0016 process.dqmCSCClient.EventProcessor.EFF_HOT_THRESHOLD = cms.untracked.double(2.0)
0017 process.dqmCSCClient.EventProcessor.EFF_HOT_SIGFAIL = cms.untracked.double(10.0)
0018 process.dqmCSCClient.EventProcessor.EFF_NODATA_THRESHOLD = cms.untracked.double(0.95)
0019 process.dqmCSCClient.EventProcessor.EFF_HOT_SIGFAIL = cms.untracked.double(5.0)
0020
0021 #process.dqmCSCClient.FractUpdateEventFreq = cms.untracked.uint32(100)
0022 #process.dqmCSCClient.effParameters.threshold_hot = cms.untracked.double(10.0)
0023 #process.dqmCSCClient.effParameters.sigfail_cold = cms.untracked.double(3.0)
0024
0025 #-------------------------------------------------
0026 # Offline DQM Module Configuration
0027 #-------------------------------------------------
0028
0029 process.load("DQMOffline.Muon.CSCMonitor_cfi")
0030 process.load("Configuration/StandardSequences/MagneticField_cff")
0031 process.load("Configuration/StandardSequences/RawToDigi_Data_cff")
0032 process.load("Configuration.StandardSequences.Reconstruction_cff")
0033 process.csc2DRecHits.readBadChambers = cms.bool(False)
0034
0035 #----------------------------
0036 # DQM Environment
0037 #-----------------------------
0038
0039 process.load("DQMServices.Core.DQM_cfg")
0040 process.load("DQMServices.Components.DQMEnvironment_cfi")
0041
0042
0043 #----------------------------
0044 # DQM Playback Environment
0045 #-----------------------------
0046
0047 #process.load("DQM.Integration.test.environment_cfi")
0048 process.dqmEnv.subSystemFolder    = "CSC"
0049
0050 #process.DQM.collectorHost = 'pccmsdqm02.cern.ch'
0051 #process.DQM.collectorHost = 'localhost'
0052 #process.DQM.collectorPort = 8061
0053 #process.DQM.collectorHost = 'lxplus436.cern.ch'
0054 #process.DQM.collectorPort = 9190
0055 process.dqmSaver.convention = 'Online'
0056 process.dqmSaver.producer = 'DQM'
0057 #process.dqmSaver.workflow = '/Test/CSC/DQM'
0058 process.dqmSaver.dirName = '/tmp/barvic/dqmdata'
0059 process.DQMStore.verbose =  cms.untracked.int32(1)
0060 process.dqmSaver.saveByRun = 1
0061 process.dqmSaver.saveAtJobEnd = True
0062
0063 #-----------------------------
0064 # Magnetic Field
0065 #-----------------------------
0066
0067 #process.load("Configuration.GlobalRuns.ForceZeroTeslaField_cff")
0068
0069 #-------------------------------------------------
0070 # GEOMETRY
0071 #-------------------------------------------------
0072
0073 process.load("Configuration.StandardSequences.GeometryRecoDB_cff")
0074
0075 #-------------------------------------------------
0076 # Global Tag
0077 #-------------------------------------------------
0078
0079 #process.load("DQM.Integration.test.FrontierCondition_GT_cfi")
0080 process.load("Configuration.StandardSequences.FrontierConditions_GlobalTag_cff")
0081 #process.GlobalTag.globaltag = 'GR_R_52_V7::All'
0082 process.GlobalTag.globaltag = 'GR_E_V37::All'
0083
0084
0085
0086 """Customise digi/reco geometry to use unganged ME1/a channels"""
0087 process.CSCGeometryESModule.useGangedStripsInME1a = False
0088 process.idealForDigiCSCGeometry.useGangedStripsInME1a = False
0089
0090 """Settings for the upgrade raw vs offline condition channel translation"""
0091 process.CSCIndexerESProducer.AlgoName=cms.string("CSCIndexerPostls1")
0092 process.CSCChannelMapperESProducer.AlgoName=cms.string("CSCChannelMapperPostls1")
0093
0094 process.csc2DRecHits.readBadChannels = cms.bool(False)
0095 process.csc2DRecHits.CSCUseGasGainCorrection = cms.bool(False)
0096
0097
0098 """ Pick up upgrade condions data directly from DB tags using ESPrefer's.
0099 Might be useful when dealing with a global tag that doesn't include
0100 'unganged' CSC conditions.
0101 """
0102 myconds = [
0103         ('CSCDBGainsRcd', 'CSCDBGains_ungangedME11A_mc'),
0104         ('CSCDBNoiseMatrixRcd', 'CSCDBNoiseMatrix_ungangedME11A_mc'),
0105         ('CSCDBCrosstalkRcd', 'CSCDBCrosstalk_ungangedME11A_mc'),
0106         ('CSCDBPedestalsRcd', 'CSCDBPedestals_ungangedME11A_mc'),
0107         ('CSCDBGasGainCorrectionRcd', 'CSCDBGasGainCorrection_ungangedME11A_mc'),
0108         ('CSCDBChipSpeedCorrectionRcd', 'CSCDBChipSpeedCorrection_ungangedME11A_mc')
0109 ]
0110
0111 from CalibMuon.Configuration.getCSCConditions_frontier_cff import cscConditions
0112 for (classname, tag) in myconds:
0113       print(classname, tag)
0114       sourcename = 'unganged_' + classname
0115       process.__setattr__(sourcename, cscConditions.clone())
0116       process.__getattribute__(sourcename).toGet = cms.VPSet( cms.PSet( record = cms.string(classname), tag = cms.string(tag)) )
0117       process.__getattribute__(sourcename).connect = cms.string('frontier://FrontierProd/CMS_COND_CSC_000')
0118       process.__setattr__('esp_' + classname, cms.ESPrefer("PoolDBESSource", sourcename) )
0119
0120 del cscConditions
0121
0122 #--------------------------
0123 # Web Service
0124 #--------------------------
0125
0126 #process.ModuleWebRegistry = cms.Service("ModuleWebRegistry")
0127 #process.AdaptorConfig = cms.Service("AdaptorConfig")
0128
0129 #--------------------------
0130 # Message Logger
0131 #--------------------------
0132
0133 MessageLogger = cms.Service("MessageLogger",
0134
0135 # suppressInfo = cms.untracked.vstring('source'),
0136   suppressInfo = cms.untracked.vstring('*'),
0137   cout = cms.untracked.PSet(
0138     threshold = cms.untracked.string('INFO'),
0139     WARNING = cms.untracked.PSet(
0140       limit = cms.untracked.int32(0)
0141     ),
0142     noLineBreaks = cms.untracked.bool(False)
0143   ),
0144   detailedInfo = cms.untracked.PSet(
0145     threshold = cms.untracked.string('INFO')
0146   ),
0147   critical = cms.untracked.PSet(
0148     threshold = cms.untracked.string('ERROR')
0149   ),
0150   debugModules = cms.untracked.vstring('CSCMonitormodule'),
0151 #  destinations = cms.untracked.vstring('detailedInfo',
0152 #    'critical',
0153 #    'cout')
0154
0155 )
0156
0157 #--------------------------------------------------
0158 # Heavy Ion Specific Fed Raw Data Collection Label
0159 #--------------------------------------------------
0160
0161 #print "Running with run type = ", process.runType.getRunType()
0162
0163 #if (process.runType.getRunType() == process.runType.hi_run):
0164 #    process.castorDigis.InputLabel = cms.InputTag("rawDataRepacker")
0165 #    process.csctfDigis.producer = cms.InputTag("rawDataRepacker")
0166 #    process.dttfDigis.DTTF_FED_Source = cms.InputTag("rawDataRepacker")
0167 #    process.ecalDigis.InputLabel = cms.InputTag("rawDataRepacker")
0168 #    process.ecalPreshowerDigis.sourceTag = cms.InputTag("rawDataRepacker")
0169 #    process.gctDigis.inputLabel = cms.InputTag("rawDataRepacker")
0170 #    process.gtDigis.DaqGtInputTag = cms.InputTag("rawDataRepacker")
0171 #    process.gtEvmDigis.EvmGtInputTag = cms.InputTag("rawDataRepacker")
0172 #    process.hcalDigis.InputLabel = cms.InputTag("rawDataRepacker")
0173 #    process.muonCSCDigis.InputObjects = cms.InputTag("rawDataRepacker")
0174 #    process.muonDTDigis.inputLabel = cms.InputTag("rawDataRepacker")
0175 #    process.muonRPCDigis.InputLabel = cms.InputTag("rawDataRepacker")
0176 #    process.scalersRawToDigi.scalersInputTag = cms.InputTag("rawDataRepacker")
0177 #    process.siPixelDigis.InputLabel = cms.InputTag("rawDataRepacker")
0178 #    process.siStripDigis.ProductLabel = cms.InputTag("rawDataRepacker")
0179 #    process.cscMonitor.FEDRawDataCollectionTag = cms.InputTag("rawDataRepacker")
0180 #    process.dqmCSCClient.InputObjects = cms.untracked.InputTag("rawDataRepacker")
0181
0182
0183 process.cscpacker = cms.EDProducer("CSCDigiToRawModule",
0184     wireDigiTag = cms.InputTag("muonCSCDigis","MuonCSCWireDigi"),
0185     stripDigiTag = cms.InputTag("muonCSCDigis","MuonCSCStripDigi"),
0186     comparatorDigiTag = cms.InputTag("muonCSCDigis","MuonCSCComparatorDigi"),
0187     alctDigiTag = cms.InputTag("muonCSCDigis","MuonCSCALCTDigi"),
0188     clctDigiTag = cms.InputTag("muonCSCDigis","MuonCSCCLCTDigi"),
0189     preTriggerTag = cms.InputTag("simCscTriggerPrimitiveDigis"),
0190     correlatedLCTDigiTag = cms.InputTag("muonCSCDigis","MuonCSCCorrelatedLCTDigi"),
0191     alctWindowMin = cms.int32(-3),
0192     alctWindowMax = cms.int32(3),
0193     clctWindowMin = cms.int32(-3),
0194     clctWindowMax = cms.int32(3),
0195     preTriggerWindowMin = cms.int32(-3),
0196     preTriggerWindowMax = cms.int32(1)
0197 )
0198
0199 process.cscpacker.usePreTriggers = cms.untracked.bool(False)
0200 process.cscpacker.formatVersion = cms.untracked.uint32(2013)
0201
0202 #----------------------------
0203 # Event Source
0204 #-----------------------------
0205
0206 process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(-1) )
0207
0208 process.source = cms.Source("PoolSource",
0209     #debugFlag = cms.untracked.bool(True),
0210     #debugVebosity = cms.untracked.uint32(10),
0211     duplicateCheckMode = cms.untracked.string('noDuplicateCheck'),
0212     fileNames = cms.untracked.vstring(
0213 #   'file:/tmp/barvic/csc_00221766_Cosmic.root'
0214         'file:/tmp/barvic/digi_test.root'
0215 #   'file:/tmp/barvic/digi_packer_test.root'
0216 #   'rfio:/castor/cern.ch/cms/store/data/Commissioning2014/Cosmics/RAW/v1/000/220/744/00000/0C7ECA47-C4BE-E311-BDAB-02163E00E734.root'
0217 #           'rfio:/castor/cern.ch/cms/store/data/Run2012A/SingleMu/RAW/v1/000/193/621/00FED4BE-8D98-E111-B366-001D09F2924F.root',
0218 #   'rfio:/castor/cern.ch/cms/store/data/Run2012A/SingleMu/RAW/v1/000/193/621/042AC95C-8F98-E111-B665-0025901D631E.root'
0219 # ==
0220     )
0221 )
0222
0223 # Switch to packer FED RAW data collection tag "cscpacker", "CSCRawData"
0224 process.muonCSCDigis.InputObjects = cms.InputTag("cscpacker", "CSCRawData")
0225 process.dqmCSCClient.InputObjects = cms.untracked.InputTag("cscpacker", "CSCRawData")
0226 process.cscMonitor.FEDRawDataCollectionTag = cms.InputTag("cscpacker", "CSCRawData")
0227
0228
0229 #--------------------------
0230 # Sequences
0231 #--------------------------
0232
0233 process.p = cms.Path( process.cscpacker * process.dqmCSCClient * process.muonCSCDigis * process.csc2DRecHits * process.cscSegments * process.cscMonitor + process.dqmEnv + process.dqmSaver)
0234 #process.p = cms.Path( process.cscpacker * process.dqmCSCClient + process.dqmEnv + process.dqmSaver)
0235
0236 #process.dqmsave_step = cms.Path(process.dqmSaver)
0237
0238 # Schedule definition
0239 #process.schedule = cms.Schedule(
0240 #                                process.dqmCSCClient,
0241 #                                process.muonCSCDigis,
0242 #                                process.dqmEnv,
0243 #                                process.dqmsave_step
0244 #    )