rawdatautils.unpack.utils.TriggerActivityUnpacker Class Reference
Inheritance diagram for rawdatautils.unpack.utils.TriggerActivityUnpacker:
Collaboration diagram for rawdatautils.unpack.utils.TriggerActivityUnpacker:
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.TriggerActivity | |
| 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.TriggerActivityUnpacker.__init__ | ( | self, | |
| channel_map = None ) |
Reimplemented from rawdatautils.unpack.utils.Unpacker.
Definition at line 209 of file utils.py.
209 def __init__(self,channel_map=None):
210 super().__init__()
211 if 'TPC' in channel_map:
212 self.channel_map = detchannelmaps.make_tpc_map(channel_map)
213 elif 'PDS' in channel_map:
214 self.channel_map = detchannelmaps.make_pds_map(channel_map)
215 else:
216 self.channel_map = NullChannelMap
217
Member Function Documentation
◆ get_n_obj()
| rawdatautils.unpack.utils.TriggerActivityUnpacker.get_n_obj | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.FragmentUnpacker.
Definition at line 218 of file utils.py.
218 def get_n_obj(self,frag):
219 frag_data_size = frag.get_data_size()
220 size_so_far = 0
221 n_tobjs = 0
222 while size_so_far < frag_data_size:
223 tobj = self.trg_obj(frag.get_data(size_so_far))
224 n_tobjs = n_tobjs + 1
225 size_so_far = size_so_far + tobj.sizeof()
226 return n_tobjs
227
◆ get_trg_data_version()
| rawdatautils.unpack.utils.TriggerActivityUnpacker.get_trg_data_version | ( | self, | |
| frag ) |
◆ get_trg_obj_data()
| rawdatautils.unpack.utils.TriggerActivityUnpacker.get_trg_obj_data | ( | self, | |
| frag ) |
Definition at line 234 of file utils.py.
234 def get_trg_obj_data(self,frag):
235 frh = frag.get_header()
236 ta_list = []
237 tpd_list = []
238 size_so_far = 0
239 for i_ta in range(self.get_n_obj(frag)):
240 ta= self.trg_obj(frag.get_data(size_so_far))
241 size_so_far = size_so_far + ta.sizeof()
242 ch_info_ta = self.channel_map.get_channel_info_from_offline_channel(ta.data.channel_peak)
243 ta_list.append( TriggerActivityData(run=frh.run_number,
244 trigger=frh.trigger_number,
245 sequence=frh.sequence_number,
246 src_id=frh.element_id.id,
247 id=i_ta,
248 time_start=ta.data.time_start,
249 time_end=ta.data.time_end,
250 time_peak=ta.data.time_peak,
251 time_activity=ta.data.time_activity,
252 channel_start=ta.data.channel_start,
253 channel_end=ta.data.channel_end,
254 channel_peak=ta.data.channel_peak,
255 plane=self.channel_map.get_plane_from_offline_channel(ta.data.channel_peak),
256 element=ch_info_ta.element,
257 adc_integral=ta.data.adc_integral,
258 adc_peak=ta.data.adc_peak,
259 detid=ta.data.detid,
260 ta_type=ta.data.type,
261 algorithm=ta.data.algorithm,
262 n_tps=len(ta),
263 id_tc=-1) )
264 for i_tp in range(len(ta)):
265 tp = ta[i_tp]
266 ch_info_tp = self.channel_map.get_channel_info_from_offline_channel(tp.channel)
267 tpd_list.append( TriggerPrimitiveData(run=frh.run_number,
268 trigger=frh.trigger_number,
269 sequence=frh.sequence_number,
270 src_id=frh.element_id.id,
271 time_start=tp.time_start,
272 samples_to_peak=tp.samples_to_peak,
273 samples_over_threshold=tp.samples_over_threshold,
274 channel=tp.channel,
275 plane=self.channel_map.get_plane_from_offline_channel(tp.channel),
276 element=ch_info_tp.element,
277 adc_integral=tp.adc_integral,
278 adc_peak=tp.adc_peak,
279 detid=tp.detid,
280 flag=tp.flag,
281 id_ta=i_ta) )
282
283 if len(tpd_list)==0:
284 tpd_list=None
285 return ta_list, tpd_list
286
Member Data Documentation
◆ channel_map
| rawdatautils.unpack.utils.TriggerActivityUnpacker.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