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

Definition at line 206 of file utils.py.

Constructor & Destructor Documentation

__init__()

rawdatautils.unpack.utils.TriggerActivityUnpacker.__init__	(		self,
			channel_map = None )

Reimplemented from rawdatautils.unpack.utils.Unpacker.

Definition at line 210 of file utils.py.

    def __init__(self,channel_map=None):
        super().__init__()
        if 'TPC' in channel_map:
            self.channel_map = detchannelmaps.make_tpc_map(channel_map)
        elif 'PDS' in channel_map:
            self.channel_map = detchannelmaps.make_pds_map(channel_map)
        else:
            self.channel_map = NullChannelMap
 

Member Function Documentation

get_n_obj()

rawdatautils.unpack.utils.TriggerActivityUnpacker.get_n_obj	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.FragmentUnpacker.

Definition at line 219 of file utils.py.

    def get_n_obj(self,frag):
        frag_data_size = frag.get_data_size()
        size_so_far = 0
        n_tobjs = 0
        while size_so_far < frag_data_size:
            tobj = self.trg_obj(frag.get_data(size_so_far))
            n_tobjs = n_tobjs + 1
            size_so_far = size_so_far + tobj.sizeof()
        return n_tobjs
 

get_trg_data_version()

rawdatautils.unpack.utils.TriggerActivityUnpacker.get_trg_data_version	(		self,
			frag )

Definition at line 229 of file utils.py.

    def get_trg_data_version(self,frag):
        if self.get_n_obj(frag)==0:
            return None
        trig_obj = self.trg_obj(frag.get_data())
        return trig_obj.data.version
 

get_trg_obj_data()

rawdatautils.unpack.utils.TriggerActivityUnpacker.get_trg_obj_data	(		self,
			frag )

Definition at line 235 of file utils.py.

    def get_trg_obj_data(self,frag):
        frh = frag.get_header()
        ta_list = []
        tpd_list = []
        size_so_far = 0
        for i_ta in range(self.get_n_obj(frag)):
            ta= self.trg_obj(frag.get_data(size_so_far))
            size_so_far = size_so_far + ta.sizeof()
            ch_info_ta = self.channel_map.get_channel_info_from_offline_channel(ta.data.channel_peak)
            ta_list.append( TriggerActivityData(run=frh.run_number,
                                                trigger=frh.trigger_number,
                                                sequence=frh.sequence_number,
                                                src_id=frh.element_id.id,
                                                id=i_ta,
                                                time_start=ta.data.time_start,
                                                time_end=ta.data.time_end,
                                                time_peak=ta.data.time_peak,
                                                time_activity=ta.data.time_activity,
                                                channel_start=ta.data.channel_start,
                                                channel_end=ta.data.channel_end,
                                                channel_peak=ta.data.channel_peak,
                                                plane=self.channel_map.get_plane_from_offline_channel(ta.data.channel_peak),
                                                element=ch_info_ta.element,
                                                adc_integral=ta.data.adc_integral,
                                                adc_peak=ta.data.adc_peak,
                                                detid=ta.data.detid,
                                                ta_type=ta.data.type,
                                                algorithm=ta.data.algorithm,
                                                n_tps=len(ta),
                                                id_tc=-1) )
            for i_tp in range(len(ta)):
                tp = ta[i_tp]
                ch_info_tp = self.channel_map.get_channel_info_from_offline_channel(tp.channel)
                tpd_list.append( TriggerPrimitiveData(run=frh.run_number,
                                                      trigger=frh.trigger_number,
                                                      sequence=frh.sequence_number,
                                                      src_id=frh.element_id.id,
                                                      time_start=tp.time_start,
                                                      samples_to_peak=tp.samples_to_peak,
                                                      samples_over_threshold=tp.samples_over_threshold,
                                                      channel=tp.channel,
                                                      plane=self.channel_map.get_plane_from_offline_channel(tp.channel),
                                                      element=ch_info_tp.element,
                                                      adc_integral=tp.adc_integral,
                                                      adc_peak=tp.adc_peak,
                                                      detid=tp.detid,
                                                      flag=tp.flag,
                                                      id_ta=i_ta) )
        
        if len(tpd_list)==0:
            tpd_list=None
        return ta_list, tpd_list
 

Member Data Documentation

channel_map

rawdatautils.unpack.utils.TriggerActivityUnpacker.channel_map = detchannelmaps.make_tpc_map(channel_map)

Definition at line 213 of file utils.py.

trg_obj

rawdatautils.unpack.utils.TriggerActivityUnpacker.trg_obj = trgdataformats.TriggerActivity

static

Definition at line 208 of file utils.py.

---

The documentation for this class was generated from the following file:

• /github/workspace/dunedaq/sourcecode/rawdatautils/python/rawdatautils/unpack/utils.py