19 set_log_level(LogLevel.ERROR)
22 geom = register_module(
"Geometry")
34 raw2ds = register_module(
"Raw2Ds")
35 raw2ds.param(
"RingBufferName", argvs[1])
36 main.add_module(raw2ds)
41 histo = register_module(
'DqmHistoManager')
42 histo.param(
"Port", 9991)
43 histo.param(
"DumpInterval", 10000)
44 main.add_module(histo)
47 monitor = register_module(
'MonitorData')
48 main.add_module(monitor)
51 ds2rbuf = register_module(
"Ds2Rbuf")
52 ds2rbuf.param(
"RingBufferName", argvs[2])
53 main.add_module(ds2rbuf)
56 progress = register_module(
'Progress')
57 main.add_module(progress)
60 elapsed = register_module(
'ElapsedTime')
61 elapsed.param(
'EventInterval', 10000)
62 main.add_module(elapsed)
65 set_nprocesses(multiprocessing.cpu_count())