RecvStream0.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
 
 
 
 
 
import basf2 as b2
import sys
argvs = sys.argv
if len(argvs) != 5:
    print('Usage : RecvStream0.py <COPPER hostname> <Use NSM(Network Shared Memory)? yes=1/no=0> <port # of eb0> <NSM nodename>')
    sys.exit()
 
# Set the log level to show only error and fatal messages
b2.set_log_level(b2.LogLevel.INFO)
 
# Modules
receiver = b2.register_module('DeSerializerPrePC')
dump = b2.register_module('RootOutput')
output = b2.register_module('PrintData')
 
# Receiver
receiver.param('NodeID', 3)  # ROPC node ID (only used for Run control)
receiver.param('NumConn', 1)
receiver.param('HostNameFrom', [argvs[1], 'aiueohost'])
receiver.param('PortFrom', [30000, 30000])
receiver.param('EventDataBufferWords', 4801)
receiver.param('MaxTime', -1.)
receiver.param('MaxEventNum', -1)
receiver.param('NodeName', argvs[4])  # node name for Run control
use_shm_flag = int(argvs[2])
receiver.param('UseShmFlag', use_shm_flag)
 
# Dump
dump.param('outputFileName', 'root_output.root')
 
# Sender
sender = b2.register_module('Serializer')
sender.param('DestPort', int(argvs[3]))
sender.param('LocalHostName', 'localhost')
 
# Create main path
main = b2.create_path()
 
# Add modules to main path
main.add_module(receiver)
# main.add_module(dump)
main.add_module(sender)
 
# Process all events
b2.process(main)