processor.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
 
 
 
import sys
 
import basf2 as b2
 
# command arguments
#   argvs[1] = input ring buffer name
#   argvs[2] = output ring buffer name
#   argvs[3] = port number of hserver
#   argvs[4] = number of cores for parallel processing
argvs = sys.argv
argc = len(argvs)
 
# set_log_level(LogLevel.INFO)
b2.set_log_level(b2.LogLevel.ERROR)
 
# to avoid undefined symbol
geom = b2.register_module("Geometry")
 
# path create
main = b2.create_path()
 
 
# Rbuf2Ds as input module
rbuf2ds = b2.register_module("Rbuf2Ds")
rbuf2ds.param("RingBufferName", argvs[1])
main.add_module(rbuf2ds)
 
# Raw2Ds as input module
# raw2ds = register_module("Raw2Ds")
# raw2ds.param("RingBufferName", argvs[1])
# main.add_module(raw2ds)
 
# Histo Module
# histo = register_module('HistoManager')
# main.add_module (histo)
 
histo = b2.register_module('DqmHistoManager')
# histo.param("Port", 9991)
histo.param("Port", 10391)
histo.param("DumpInterval", 10000)
main.add_module(histo)
 
# Sampler module
sample = b2.register_module('Ds2Sample')
sample.param('RingBufferName', argvs[2])
main.add_module(sample)
 
# Monitor module
# monitor = register_module('MonitorData')
# main.add_module(monitor)
 
# PXD monitor
unpacker = b2.register_module('PXDUnpacker')
unpacker.param("IgnoreDATCON", True)
main.add_module(unpacker)
 
PXDRawDQM = b2.register_module('PXDRawDQM')
main.add_module(PXDRawDQM)
 
# Progress
progress = b2.register_module('Progress')
main.add_module(progress)
 
# Debug modules
elapsed = b2.register_module('ElapsedTime')
elapsed.param('EventInterval', 10000)
main.add_module(elapsed)
 
 
# Process events
b2.set_nprocesses(int(argvs[4]))
b2.process(main)