Belle II Software  release-05-01-25
DataStorager.py
1 #!/usr/bin/env python3
2 # -*- coding: utf-8 -*-
3 
4 
19 
20 from basf2 import *
21 import sys
22 argv = sys.argv
23 
24 # Set the log level to show only error and fatal messages
25 # set_log_level(LogLevel.ERROR)
26 # set_log_level(LogLevel.INFO)
27 
28 # gearbox = register_module('Gearbox')
29 # SVDUnpack = register_module('SVDUnpacker')
30 # SVDClust = register_module('SVDClusterizer')
31 # vxdtf = register_module('VXDTF')
32 # SVD_DQM = register_module('SVDDQM')
33 # vxdtf_dqm = register_module('VXDTFDQM')
34 # trackfitter = register_module('GenFitter')
35 # roiprod = register_module('PXDDataReduction')
36 # roipayload = register_module('ROIPayloadAssembler')
37 
38 # Modules
39 deserializer = register_module('StorageDeserializer')
40 deserializer.param('InputBufferName', argv[1])
41 deserializer.param('InputBufferSize', int(argv[2]))
42 if len(argv) >= 6:
43  deserializer.param('NodeName', argv[5])
44  deserializer.param('NodeID', int(argv[6]))
45  deserializer.param('UseShmFlag', int(argv[7]))
46  deserializer.param('EB2', int(argv[8]))
47 output = register_module('StorageSerializer')
48 output.param('OutputBufferName', argv[3])
49 output.param('OutputBufferSize', int(argv[4]))
50 output.param('NodeID', int(argv[6]))
51 output.param('compressionLevel', 0)
52 
53 # Create main path
54 main = create_path()
55 
56 # Add modules to main path
57 main.add_module(deserializer)
58 main.add_module(output)
59 
60 # Process all events
61 process(main)