rawdatautils.unpack.utils.TriggerCandidateUnpacker Class Reference
Inheritance diagram for rawdatautils.unpack.utils.TriggerCandidateUnpacker:
Collaboration diagram for rawdatautils.unpack.utils.TriggerCandidateUnpacker:
Public Member Functions | |
| __init__ (self, channel_map=None) | |
| get_n_obj (self, frag) | |
| get_trg_data_version (self, frag) | |
| get_trg_obj_data (self, frag) | |
 Public Member Functions inherited from rawdatautils.unpack.utils.TriggerDataUnpacker | |
| get_trg_data (self, frag) | |
| get_trg_header_data (self, frag) | |
| Public Member Functions inherited from rawdatautils.unpack.utils.FragmentUnpacker | |
| get_det_data (self, in_data) | |
| get_frh_data (self, frag) | |
| get_all_data (self, in_data) | |
| Public Member Functions inherited from rawdatautils.unpack.utils.Unpacker | |
Public Attributes | |
| channel_map = detchannelmaps.make_tpc_map(channel_map) | |
| Public Attributes inherited from rawdatautils.unpack.utils.Unpacker | |
| index = index | |
Static Public Attributes | |
| trg_obj = trgdataformats.TriggerCandidate | |
| Static Public Attributes inherited from rawdatautils.unpack.utils.TriggerDataUnpacker | |
| bool | is_trigger_unpacker = True |
| Static Public Attributes inherited from rawdatautils.unpack.utils.FragmentUnpacker | |
| bool | is_fragment_unpacker = True |
| bool | is_detector_unpacker = False |
| bool | is_trigger_unpacker = False |
| Static Public Attributes inherited from rawdatautils.unpack.utils.Unpacker | |
| bool | is_fragment_unpacker = False |
| bool | is_detector_unpacker = False |
| bool | is_trigger_unpacker = False |
Detailed Description
Constructor & Destructor Documentation
◆ __init__()
| rawdatautils.unpack.utils.TriggerCandidateUnpacker.__init__ | ( | self, | |
| channel_map = None ) |
Reimplemented from rawdatautils.unpack.utils.Unpacker.
Definition at line 291 of file utils.py.
291 def __init__(self,channel_map=None):
292 super().__init__()
293 if 'TPC' in channel_map:
294 self.channel_map = detchannelmaps.make_tpc_map(channel_map)
295 elif 'PDS' in channel_map:
296 self.channel_map = detchannelmaps.make_pds_map(channel_map)
297 else:
298 self.channel_map = NullChannelMap
299
Member Function Documentation
◆ get_n_obj()
| rawdatautils.unpack.utils.TriggerCandidateUnpacker.get_n_obj | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.FragmentUnpacker.
Definition at line 300 of file utils.py.
300 def get_n_obj(self,frag):
301 frag_data_size = frag.get_data_size()
302 size_so_far = 0
303 n_tobjs = 0
304 while size_so_far < frag_data_size:
305 tobj = self.trg_obj(frag.get_data(size_so_far))
306 n_tobjs = n_tobjs + 1
307 size_so_far = size_so_far + tobj.sizeof()
308 return n_tobjs
309
◆ get_trg_data_version()
| rawdatautils.unpack.utils.TriggerCandidateUnpacker.get_trg_data_version | ( | self, | |
| frag ) |
◆ get_trg_obj_data()
| rawdatautils.unpack.utils.TriggerCandidateUnpacker.get_trg_obj_data | ( | self, | |
| frag ) |
Definition at line 316 of file utils.py.
316 def get_trg_obj_data(self,frag):
317 frh = frag.get_header()
318 tc_list = []
319 ta_list = []
320 size_so_far = 0
321 for i_tc in range(self.get_n_obj(frag)):
322 tc = self.trg_obj(frag.get_data(size_so_far))
323 size_so_far = size_so_far + tc.sizeof()
324 tc_list.append( TriggerCandidateData(run=frh.run_number,
325 trigger=frh.trigger_number,
326 sequence=frh.sequence_number,
327 src_id=frh.element_id.id,
328 id=i_tc,
329 time_start=tc.data.time_start,
330 time_end=tc.data.time_end,
331 time_candidate=tc.data.time_candidate,
332 detid=tc.data.detid,
333 tc_type=tc.data.type,
334 algorithm=tc.data.algorithm,
335 n_tas=len(tc) ) )
336 for i_ta in range(len(tc)):
337 ta = tc[i_ta]
338 ch_info_ta = self.channel_map.get_channel_info_from_offline_channel(ta.data.channel_peak)
339 ta_list.append( TriggerActivityData(run=frh.run_number,
340 trigger=frh.trigger_number,
341 sequence=frh.sequence_number,
342 src_id=frh.element_id.id,
343 id=i_ta,
344 time_start=ta.time_start,
345 time_end=ta.time_end,
346 time_peak=ta.time_peak,
347 time_activity=ta.time_activity,
348 channel_start=ta.channel_start,
349 channel_end=ta.channel_end,
350 channel_peak=ta.channel_peak,
351 plane=self.channel_map.get_plane_from_offline_channel(ta.channel_peak),
352 element=ch_info_ta.element,
353 adc_integral=ta.adc_integral,
354 adc_peak=ta.adc_peak,
355 detid=ta.detid,
356 ta_type=ta.type,
357 algorithm=ta.algorithm,
358 n_tps=-1,
359 id_tc=i_tc) )
360 if len(ta_list)==0:
361 ta_list=None
362 return tc_list, ta_list
363
364
Member Data Documentation
◆ channel_map
| rawdatautils.unpack.utils.TriggerCandidateUnpacker.channel_map = detchannelmaps.make_tpc_map(channel_map) |
◆ trg_obj
|
static |
The documentation for this class was generated from the following file:
- /github/workspace/dunedaq/sourcecode/rawdatautils/python/rawdatautils/unpack/utils.py
Generated on Sat Jun 28 2025 for DUNE-DAQ by
1.12.0