34 """Runs the dumping routines"""
37 if (args.verbosity > 0):
39 print(
"Opening", bsfile)
41 input = eformat.istream(bsfile)
45 code.interact(local=locals())
49 offset = args.skip
if args.skip
else 0
56 if args.events
is not None and event_count>args.events:
62 for stag
in event.stream_tag():
63 if (stag.type ==
'calibration')
and ((stag.name).startswith(
'DataScouting_')):
64 ds_module_ids[
int((stag.name).
split(
'_')[1])] = (
False, stag.name)
65 if stag.name
not in ds_ROB_counts:
66 ds_ROB_counts[stag.name] = {
'ROBfound':0,
'ROBnotFound':0,
'noContainers':0,
'emptyContainers':0}
69 for f
in event.children():
70 if (f.source_id().subdetector_id() == eformat.helper.SubDetector.TDAQ_HLT)
and (f.source_id().module_id()
in ds_module_ids):
71 if (args.verbosity >= 1):
72 print(
"======================= RunNumber : %d , Event: %d, LB: %d, LVL1_ID: %d, Global_ID: %d bunch-x: %d TT: x%x =========================="
73 % ( event.run_no(), event_count, event.lumi_block(), event.lvl1_id(), event.global_id(), event.bc_id(), event.lvl1_trigger_type()))
75 if (args.verbosity >= 1):
76 print(
".. Stream Tags:", [(s.name, s.type)
for s
in event.stream_tag()])
79 if (args.verbosity >= 1):
80 print(
'.. %s %s %s bytes' % (f.__class__.__name__, f.source_id(), f.fragment_size_word()*4))
83 ds_module_ids[f.source_id().module_id()] = (
True, ds_module_ids[f.source_id().module_id()][1])
84 if (args.verbosity >= 2):
86 for feature
in res.nav_payload:
87 key = feature[0]+
'#'+feature[1]
88 if key
not in featureSizes:
90 featureSizes[key] += feature[2]
91 except Exception
as ex:
92 print(
'... **** problems in analyzing payload', ex)
93 print(
'... **** raw data[:10]',
list(f.rod_data())[:10])
95 if (featureSizes == {}):
96 if (args.verbosity >= 1):
97 print(
" FATAL : No containers are available for Data Scouting HLTResult with module ID = ",f.source_id().module_id(),
", Stream name = ",ds_module_ids[f.source_id().module_id()][1])
98 ds_ROB_counts[ ds_module_ids[f.source_id().module_id()][1] ][
'noContainers'] += 1
99 for item
in featureSizes.items():
101 if (args.verbosity >= 1):
102 print(
" ERROR : Empty container for feature = ",item[0])
103 ds_ROB_counts[ ds_module_ids[f.source_id().module_id()][1] ][
'emptyContainers'] += 1
105 if (args.verbosity >= 2):
106 print(
".. EOF DS HLTResult with module ID = ", f.source_id().module_id())
109 for item
in ds_module_ids.items():
110 if (item[1][0]
is False):
111 if (args.verbosity >= 1):
112 print(
" FATAL : No Data Scouting HLTResult found for expected module ID = ",item[0],
", Stream name = ",item[1][1])
113 ds_ROB_counts[ item[1][1] ][
'ROBnotFound'] += 1
115 ds_ROB_counts[ item[1][1] ][
'ROBfound'] += 1
117 if (args.verbosity >= 0):
118 print(
"\n Events read: ", event_count)
119 print(
"\n Summary of Data Scouting information:\n",
" -------------------------------------\n", ds_ROB_counts)