File indexing completed on 2024-12-01 23:40:27
0001
0002
0003
0004
0005
0006
0007
0008 import os,sys
0009 from FWCore.ParameterSet.VarParsing import VarParsing
0010 options = VarParsing ('analysis')
0011 options.parseArguments()
0012
0013 if True:
0014 print('-> You are using a 2 process file to unzip/untar events on the fly')
0015
0016
0017 from subprocess import call, check_output
0018 import threading
0019 import time
0020 def call_exe(cmd):
0021 print("-> Executing cmd: '"+cmd+"'")
0022 st=call(cmd,shell=True)
0023 print("-> End cmd: status=",st)
0024 return
0025 cmd="rm /tmp/"+os.environ['USER']+"/hepmc10K.dat"
0026 call(cmd,shell=True)
0027 cmd="mkfifo /tmp/"+os.environ['USER']+"/hepmc10K.dat"
0028 call(cmd,shell=True)
0029 exe="cat /tmp/"+os.environ['USER']+"/hepmc.dat.tgz | gunzip -c > /tmp/"+os.environ['USER']+"/hepmc10K.dat &"
0030 t = threading.Thread(target=call_exe, args= ( [exe] ) )
0031 t.start()
0032 print("(sleep 1s to allow start of pipes)")
0033 time.sleep(1)
0034
0035
0036 import FWCore.ParameterSet.Config as cms
0037
0038 process = cms.Process("GEN")
0039
0040
0041 process.source = cms.Source("MCFileSource",
0042
0043 fileNames = cms.untracked.vstring('file:/tmp/'+os.environ['USER']+'/hepmc10K.dat'),
0044 )
0045
0046 maxEvents=options.maxEvents
0047 process.maxEvents = cms.untracked.PSet(input = cms.untracked.int32(maxEvents))
0048
0049
0050 process.load("FWCore.MessageService.MessageLogger_cfi")
0051 process.MessageLogger.cerr.threshold = 'INFO'
0052
0053 process.GEN = cms.OutputModule("PoolOutputModule",
0054 fileName = cms.untracked.string('HepMC_GEN.root')
0055 )
0056
0057
0058 process.load('Configuration.StandardSequences.Services_cff')
0059 process.load('SimGeneral.HepPDTESSource.pythiapdt_cfi')
0060 process.load('GeneratorInterface.Core.genFilterSummary_cff')
0061 process.load('Configuration.StandardSequences.Generator_cff')
0062 process.genParticles.src= cms.InputTag("source","generator")
0063
0064
0065
0066
0067 from IOMC.EventVertexGenerators.VtxSmearedParameters_cfi import GaussVtxSmearingParameters,VtxSmearedCommon
0068 VtxSmearedCommon.src=cms.InputTag("source","generator")
0069 process.generatorSmeared = cms.EDProducer("GaussEvtVtxGenerator",
0070 GaussVtxSmearingParameters,
0071 VtxSmearedCommon
0072 )
0073 process.load('Configuration.StandardSequences.Services_cff')
0074 process.RandomNumberGeneratorService = cms.Service("RandomNumberGeneratorService",
0075 generatorSmeared = cms.PSet( initialSeed = cms.untracked.uint32(1243987),
0076 engineName = cms.untracked.string('TRandom3'),
0077 ),
0078 )
0079
0080
0081
0082 process.p = cms.Path(process.genParticles * process.generatorSmeared)
0083 process.outpath = cms.EndPath(process.GEN)
0084
0085
0086
0087
0088
0089
0090
0091
0092
0093
0094
0095
0096
0097
0098
0099
0100
0101
0102
0103
0104
0105
0106
0107
0108
0109
0110
0111
0112
0113
0114
0115