Modules/test/sleepingModules_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("Test")
0004
0005 process.source =cms.Source("EmptySource")
0006
0007 process.maxEvents = cms.untracked.PSet(input = cms.untracked.int32(10))
0008
0009 process.options = cms.untracked.PSet(numberOfThreads = cms.untracked.uint32(4),
0010                                      numberOfStreams = cms.untracked.uint32(0))
0011
0012 #allows something like simulation of source
0013 process.s1 = cms.EDProducer("timestudy::OneSleepingProducer",
0014     resource = cms.string("source"),
0015     ivalue = cms.int32(1),
0016     consumes = cms.VInputTag(),
0017     eventTimes = cms.vdouble(0.01,0.005))
0018
0019 process.s2 = cms.EDProducer("timestudy::OneSleepingProducer",
0020     resource = cms.string("source"),
0021     ivalue = cms.int32(2),
0022     consumes = cms.VInputTag(),
0023     eventTimes = cms.vdouble(0.02,0.03))
0024
0025 process.p1 = cms.EDProducer("timestudy::SleepingProducer",
0026     ivalue = cms.int32(3),
0027     consumes = cms.VInputTag("s1","s2"),
0028     eventTimes = cms.vdouble(0.05))
0029
0030
0031 process.p2 = cms.EDProducer("timestudy::SleepingProducer",
0032     ivalue = cms.int32(3),
0033     consumes = cms.VInputTag("s2"),
0034     eventTimes = cms.vdouble(0.03))
0035
0036 process.p3 = cms.EDProducer("timestudy::SleepingProducer",
0037     ivalue = cms.int32(3),
0038     consumes = cms.VInputTag("p1","p2"),
0039     eventTimes = cms.vdouble(0.03))
0040
0041 #external work
0042 process.add_(cms.Service("timestudy::SleepingServer",
0043                          nWaitingEvents = cms.untracked.uint32(4)))
0044
0045 process.e = cms.EDProducer("timestudy::ExternalWorkSleepingProducer",
0046                         consumes = cms.VInputTag("p2","p3"),
0047                         ivalue = cms.int32(10),
0048                         eventTimes = cms.vdouble(0.01),
0049                         serviceInitTimes = cms.vdouble(0.,0.),
0050                         serviceWorkTimes = cms.vdouble(0.1,0.15),
0051                         serviceFinishTimes = cms.vdouble(0.,0.)
0052 )
0053
0054 #approximates an OutputModule
0055 process.out = cms.EDAnalyzer("timestudy::OneSleepingAnalyzer",
0056     consumes = cms.VInputTag("s1","s2", "p1", "p2", "p3","e"),
0057     eventTimes = cms.vdouble(0.02,0.03)
0058 )
0059
0060
0061 process.o = cms.EndPath(process.out, cms.Task(process.s1,process.s2,process.p1,process.p2,process.p3,process.e))
0062
0063 #process.add_(cms.Service("Tracer"))
0064
0065 #process.add_(cms.Service("StallMonitor", fileName = cms.untracked.string("stall_sleep.log")))
0066
0067 process.add_(cms.Service("ZombieKillerService", secondsBetweenChecks = cms.untracked.uint32(10)))