RecvOnlyCOPPER.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
 
 
 
 
 
import basf2 as b2
import sys
argvs = sys.argv
 
if len(argvs) < 6:
    print('Usage : RecvSendCOPPER.py <COPPER hostname> <COPPER nodeID> <bit flag of FINNESEs> '
          '<Use shared memory? yes=1/no=0> <nodename>')
    sys.exit()
 
# Set the log level to show only error and fatal messages
b2.set_log_level(b2.LogLevel.ERROR)
b2.set_log_level(b2.LogLevel.INFO)
 
# Reader
# reader = register_module('HSLBReaderArray')
reader = b2.register_module('DeSerializerCOPPER')
reader.param('NodeID', int(argvs[2]))
reader.param('FinesseBitFlag', int(argvs[3]))
use_shm_flag = int(argvs[4])
reader.param('UseShmFlag', use_shm_flag)
reader.param('NodeName', argvs[5])
# reader.param('DumpFileName', 'COPPERdump.dat' )
 
# Histo Module
# histo = register_module('HistoManager')
# main.add_module (histo)
histo = b2.register_module('DqmHistoManager')
histo.param('HostName', 'ropc04')
histo.param('Port', 9991)
histo.param('DumpInterval', 10)
 
histo.param('HistoFileName', 'histo_file_'.join([argvs[1], '.root']))
 
# Monitor module
monitor = b2.register_module('MonitorDataCOPPER')
 
# Sender
sender = b2.register_module('Serializer')
sender.param('DestPort', 30000)
# sender.param('LocalHostName', 'cpr006')
sender.param('LocalHostName', argvs[1])
 
# Create main path
main = b2.create_path()
 
# Add modules to main path
main.add_module(reader)
# if use_shm_flag != 0:
#    main.add_module(histo)
#    main.add_module(monitor)
# main.add_module(sender)
 
# Process all events
b2.process(main)