Belle II Software  release-05-01-25
processor.py
1 #!/usr/bin/env python3
2 # -*- coding: utf-8 -*-
3 
4 import os
5 import sys
6 
7 from basf2 import *
8 
9 # command arguments
10 # argvs[1] = input ring buffer name
11 # argvs[2] = output ring buffer name
12 # argvs[3] = port number of hserver
13 # argvs[4] = number of cores for parallel processing
14 argvs = sys.argv
15 argc = len(argvs)
16 
17 # set_log_level(LogLevel.INFO)
18 set_log_level(LogLevel.ERROR)
19 
20 # to avoid undefined symbol
21 geom = register_module("Geometry")
22 
23 # path create
24 main = create_path()
25 
26 
27 # Rbuf2Ds as input module
28 # rbuf2ds = register_module("Rbuf2Ds")
29 # rbuf2ds.param("RingBufferName", argvs[1])
30 # main.add_module(rbuf2ds)
31 
32 # Raw2Ds as input module
33 raw2ds = register_module("Raw2Ds")
34 raw2ds.param("RingBufferName", argvs[1])
35 main.add_module(raw2ds)
36 
37 # Histo Module
38 # histo = register_module('HistoManager')
39 # main.add_module (histo)
40 histo = register_module('DqmHistoManager')
41 histo.param("Port", 9991)
42 histo.param("DumpInterval", 10000)
43 main.add_module(histo)
44 
45 # Monitor module
46 monitor = register_module('MonitorData')
47 main.add_module(monitor)
48 
49 # Ds2Rbuf as output module
50 ds2rbuf = register_module("Ds2Rbuf")
51 ds2rbuf.param("RingBufferName", argvs[2])
52 main.add_module(ds2rbuf)
53 
54 # Progress
55 progress = register_module('Progress')
56 main.add_module(progress)
57 
58 # Debug modules
59 elapsed = register_module('ElapsedTime')
60 elapsed.param('EventInterval', 10000)
61 main.add_module(elapsed)
62 
63 # Process events
64 set_nprocesses(int(argvs[4]))
65 process(main)