15 print(
'Usage : RecvStream1.py <Use NSM(Network Shared Memory)? yes=1/no=0> <port # of eb0> <NSM nodename>')
19 set_log_level(LogLevel.INFO)
22 receiver = register_module(
'DeSerializerPC')
23 dump = register_module(
'SeqRootOutput')
24 converter = register_module(
'Convert2RawDet')
27 receiver.param(
'NodeID', 3)
28 receiver.param(
'NumConn', 2)
29 receiver.param(
'HostNameFrom', [
'localhost',
'localhost'])
30 receiver.param(
'PortFrom', [34008, 34009])
31 receiver.param(
'EventDataBufferWords', 4801)
32 receiver.param(
'MaxTime', -1.)
33 receiver.param(
'MaxEventNum', -1)
34 receiver.param(
'NodeName', argvs[3])
35 use_shm_flag = int(argvs[1])
36 receiver.param(
'UseShmFlag', use_shm_flag)
39 dump.param(
'outputFileName',
'root_output.sroot')
42 sender = register_module(
'Serializer')
43 sender.param(
'DestPort', 36000)
44 sender.param(
'LocalHostName',
'localhost')
50 main.add_module(receiver)
51 main.add_module(converter)