Back to home page

Project CMSSW displayed by LXR

 
 

    


File indexing completed on 2022-04-01 23:54:12

0001 import FWCore.ParameterSet.Config as cms
0002 import FWCore.Utilities.FileUtils as FileUtils
0003 import FWCore.ParameterSet.VarParsing as VarParsing
0004 import pkgutil
0005 import sys
0006 
0007 
0008 # PART 1 : PARSE ARGUMENTS
0009 
0010 options = VarParsing.VarParsing ('analysis')
0011 options.register('redir', 'root://cms-xrd-global.cern.ch/', VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.string, "The XRootD redirector to use")
0012 options.register('nstart', 0,VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.int, "File index to start on")
0013 options.register('nfiles', -1,VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.int, "Number of files to process per job")
0014 options.register('storeTracks', False, VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.bool, "Store tracks in NTuple")
0015 options.register('l1Tracks','TTTracksFromTrackletEmulation:Level1TTTracks', VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.string, 'L1 track collection to use')
0016 options.register('runVariations', False, VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.bool, "Run some pre-defined algorithmic variations")
0017 options.register('threads', 1,VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.int, "Number of threads to run")
0018 options.register('streams', 0,VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.int, "Number of streams to run")
0019 options.register('memoryProfiler', False, VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.bool, "Run the memory profile")
0020 options.register('tmi', False, VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.bool, "Run a simple profiler")
0021 options.register('trace', False, VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.bool, "Dump the paths and consumes")
0022 options.register('dump', False, VarParsing.VarParsing.multiplicity.singleton, VarParsing.VarParsing.varType.bool, "Dump the configuration and exit")
0023 options.parseArguments()
0024 
0025 # handle site name usage
0026 if options.redir[0]=="T":
0027     options.redir = "root://cms-xrd-global.cern.ch//store/test/xrootd/"+options.redir
0028 
0029 # Load input files
0030 inputFiles = cms.untracked.vstring()
0031 
0032 for filePath in options.inputFiles:
0033     if filePath.endswith(".root") :    
0034         inputFiles.append( filePath )
0035     elif filePath.endswith(".txt"):
0036         inputFiles += FileUtils.loadListFromFile( filePath )
0037     elif filePath.endswith("_cff.py"):
0038         inputFilesImport = getattr(__import__(filePath.strip(".py").strip("python/").replace('/','.'),fromlist=["readFiles"]),"readFiles")
0039         if options.nfiles==-1:
0040             inputFiles.extend( inputFilesImport )
0041         else:
0042             inputFiles.extend( inputFilesImport[options.nstart:(options.nstart+options.nfiles)] )
0043     elif pkgutil.find_loader("L1Trigger.VertexFinder."+filePath+"_cff") is not None:
0044         inputFilesImport = getattr(__import__("L1Trigger.VertexFinder."+filePath+"_cff",fromlist=["readFiles"]),"readFiles")
0045         if options.nfiles==-1:
0046             inputFiles.extend( inputFilesImport )
0047         else:
0048             inputFiles.extend( inputFilesImport[options.nstart:(options.nstart+options.nfiles)] )
0049     else:
0050         raise RuntimeError("Must specify a list of ROOT files, a list of txt files containing a list of ROOT files, or a list of python input files.")
0051 
0052 if options.redir != "":
0053     inputFiles = [(options.redir if val.startswith("/") else "")+val for val in inputFiles]
0054 
0055 if options.l1Tracks.count(':') != 1:
0056     raise RuntimeError("Value for 'l1Tracks' command-line argument (= '{}') should contain one colon".format(options.l1Tracks))
0057 
0058 l1TracksTag = cms.InputTag(options.l1Tracks.split(':')[0], options.l1Tracks.split(':')[1])
0059 print "Input Track Collection = {0}  {1}".format(*options.l1Tracks.split(':')) 
0060 
0061 
0062 # PART 2: SETUP MAIN CMSSW PROCESS 
0063 
0064 process = cms.Process("L1TVertexFinder")
0065 
0066 process.load('Configuration.Geometry.GeometryExtended2026D49Reco_cff')
0067 process.load('Configuration.Geometry.GeometryExtended2026D49_cff')
0068 process.load('Configuration.StandardSequences.MagneticField_cff')
0069 process.load('Configuration.StandardSequences.FrontierConditions_GlobalTag_cff')
0070 from Configuration.AlCa.GlobalTag import GlobalTag
0071 process.GlobalTag = GlobalTag(process.GlobalTag, 'auto:upgradePLS3', '')
0072 process.load("FWCore.MessageService.MessageLogger_cfi")
0073 
0074 process.source = cms.Source("PoolSource", fileNames = cms.untracked.vstring(inputFiles) )
0075 process.TFileService = cms.Service("TFileService", fileName = cms.string(options.outputFile))
0076 process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(options.maxEvents) )
0077 process.options = cms.untracked.PSet(
0078     numberOfThreads = cms.untracked.uint32(options.threads),
0079     numberOfStreams = cms.untracked.uint32(options.streams if options.streams>0 else 0)
0080 )
0081 
0082 process.load('L1Trigger.VertexFinder.VertexProducer_cff')
0083 process.VertexProducer.l1TracksInputTag = l1TracksTag
0084 
0085 process.load('L1Trigger.VertexFinder.TPStubValueMapProducer_cff')
0086 process.load('L1Trigger.VertexFinder.InputDataProducer_cff')
0087 
0088 process.load('L1Trigger.VertexFinder.VertexNTupler_cff')
0089 process.L1TVertexNTupler.l1TracksInputTag = l1TracksTag
0090 
0091 if process.L1TVertexNTupler.debug == 0:
0092     process.MessageLogger.cerr.FwkReport.reportEvery = 50
0093 process.Timing = cms.Service("Timing", summaryOnly = cms.untracked.bool(True))
0094 
0095 producerSum = process.VertexProducer
0096 additionalProducerAlgorithms = ["fastHistoEmulation", "fastHistoLooseAssociation", "DBSCAN"]
0097 for algo in additionalProducerAlgorithms:
0098     producerName = 'VertexProducer{0}'.format(algo)
0099     producerName = producerName.replace(".","p") # legalize the name
0100 
0101     producer = process.VertexProducer.clone()
0102     producer.VertexReconstruction.Algorithm = cms.string(algo)
0103 
0104     if "Emulation" in algo:
0105         if "L1GTTInputProducer" not in process.producerNames():
0106             process.load('L1Trigger.L1TTrackMatch.L1GTTInputProducer_cfi')
0107             producer.l1TracksInputTag = cms.InputTag("L1GTTInputProducer","Level1TTTracksConverted")
0108             producerSum = process.L1GTTInputProducer + producerSum
0109 
0110         process.L1TVertexNTupler.emulationVertexInputTags.append( cms.InputTag(producerName, 'l1verticesEmulation') )
0111         process.L1TVertexNTupler.emulationVertexBranchNames.append(algo)
0112     else:
0113         process.L1TVertexNTupler.l1VertexInputTags.append( cms.InputTag(producerName, 'l1vertices') )
0114         process.L1TVertexNTupler.l1VertexBranchNames.append(algo)
0115         process.L1TVertexNTupler.l1VertexTrackInputs.append('hybrid')
0116 
0117     setattr(process, producerName, producer)
0118     producerSum += producer
0119 
0120 # PART 3: PERFORM SCAN OVER ALGO PARAMETER SPACE
0121 if options.runVariations:
0122     for i in range(1, 9):
0123         dist = float(i) * 0.05
0124         for j in range(6):
0125             minPt = 2.0 + float(j) * 0.2
0126             for k in range(1, 6):
0127                 minDensity = k
0128                 for l in range(7):
0129                     seedTrackPt = 2.0 + float(l) * 0.5
0130 
0131                     print
0132                     print "dist       =", dist
0133                     print "minPt      =", minPt
0134                     print "minDensity =", minDensity
0135                     print "seedTrkPt  =", seedTrackPt
0136 
0137                     producer = process.VertexProducer.clone()
0138                     producer.VertexReconstruction.VertexDistance = cms.double(dist)
0139                     producer.VertexReconstruction.VxMinTrackPt = cms.double(minPt)
0140                     producer.VertexReconstruction.DBSCANMinDensityTracks = cms.uint32(minDensity)
0141                     producer.VertexReconstruction.DBSCANPtThreshold = cms.double(seedTrackPt)
0142 
0143                     producerName = 'VertexProducerDBSCANDist{0}minPt{1}minDensity{2}seedTrackPt{3}'.format(dist, minPt, minDensity, seedTrackPt)
0144                     producerName = producerName.replace(".","p")
0145                     print "producer name =", producerName
0146                     setattr(process, producerName, producer)
0147                     producerNames += [producerName]
0148                     process.L1TVertexNTupler.extraVertexDescriptions += ['DBSCAN(dist={0},minPt={1},minDensity={2},seedTrackPt{3})'.format(dist, minPt, minDensity, seedTrackPt)]
0149                     process.L1TVertexNTupler.extraVertexInputTags.append( cms.InputTag(producerName, 'l1vertices'))
0150                     producerSum += producer
0151 
0152 print "Total number of producers =", len(additionalProducerAlgorithms)+1
0153 print "  Producers = [{0}]".format(producerSum.dumpSequenceConfig().replace('&',', '))
0154 print "  Algorithms = [fastHisto, {0}]".format(', '.join(additionalProducerAlgorithms))
0155 
0156 # PART 4: UTILITIES
0157 
0158 # MEMORY PROFILING
0159 if options.memoryProfiler:
0160     process.IgProfService = cms.Service("IgProfService",
0161         reportEventInterval = cms.untracked.int32(1),
0162         reportFirstEvent = cms.untracked.int32(1),
0163         reportToFileAtPostEndJob = cms.untracked.string('| gzip -c > '+options.outputFile+'___memory___%I_EndOfJob.gz'),
0164         reportToFileAtPostEvent = cms.untracked.string('| gzip -c > '+options.outputFile+'___memory___%I.gz')
0165     )
0166 
0167 # SIMPLER PROFILING
0168 if options.tmi:
0169     from Validation.Performance.TimeMemoryInfo import customise
0170     process = customise(process)
0171 
0172 if options.trace:
0173     process.add_(cms.Service("Tracer", dumpPathsAndConsumes = cms.untracked.bool(True)))
0174 
0175 # SETUP THE PATH
0176 process.p = cms.Path(producerSum + process.TPStubValueMapProducer + process.InputDataProducer + process.L1TVertexNTupler)
0177 
0178 # DUMP AND EXIT
0179 if options.dump:
0180     print process.dumpPython()
0181     sys.exit(0)