Inheritance diagram for rawdatautils.unpack.utils.TDEEthUnpacker:

Collaboration diagram for rawdatautils.unpack.utils.TDEEthUnpacker:

Public Member Functions
	__init__ (self, channel_map=None, ana_data_prescale=1, wvfm_data_prescale=None)

	get_n_obj (self, frag)

	get_daq_header_version (self, frag)

	get_timestamp_first (self, frag)

	get_det_data_version (self, frag)

	get_det_crate_slot_stream (self, frag)

	get_det_header_data (self, frag)

	get_det_data_all (self, frag)

Public Member Functions inherited from rawdatautils.unpack.utils.DetectorFragmentUnpacker
	get_daq_header_data (self, frag)

	get_det_data (self, frag)

Public Member Functions inherited from rawdatautils.unpack.utils.FragmentUnpacker
	get_trg_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.DetectorFragmentUnpacker
	ana_data_prescale = None if not ana_data_prescale else int(ana_data_prescale)

	wvfm_data_prescale = None if not wvfm_data_prescale else int(wvfm_data_prescale)

Public Attributes inherited from rawdatautils.unpack.utils.Unpacker
	index = index

Static Public Attributes
	unpacker = rawdatautils.unpack.tde

	frame_obj = fddetdataformats.TDEEthFrame

float	SAMPLING_PERIOD = 31.25

int	N_CHANNELS_PER_FRAME = 64

Static Public Attributes inherited from rawdatautils.unpack.utils.DetectorFragmentUnpacker
bool	is_detector_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 592 of file utils.py.

Constructor & Destructor Documentation

◆ init()

rawdatautils.unpack.utils.TDEEthUnpacker.__init__	(	self,
		channel_map = None,
		ana_data_prescale = 1,
		wvfm_data_prescale = None )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 600 of file utils.py.

    def __init__(self,channel_map=None,ana_data_prescale=1,wvfm_data_prescale=None):
        super().__init__(ana_data_prescale=ana_data_prescale, wvfm_data_prescale=wvfm_data_prescale)
        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_daq_header_version()

rawdatautils.unpack.utils.TDEEthUnpacker.get_daq_header_version	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 612 of file utils.py.

    def get_daq_header_version(self,frag):
        return self.frame_obj(frag.get_data()).get_daqheader().version
 

◆ get_det_crate_slot_stream()

rawdatautils.unpack.utils.TDEEthUnpacker.get_det_crate_slot_stream	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 621 of file utils.py.

    def get_det_crate_slot_stream(self,frag):
        dh = self.frame_obj(frag.get_data()).get_daqheader()
        return dh.det_id, dh.crate_id, dh.slot_id, dh.stream_id
 

◆ get_det_data_all()

rawdatautils.unpack.utils.TDEEthUnpacker.get_det_data_all	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 667 of file utils.py.

    def get_det_data_all(self,frag):
        frh = frag.get_header()
        trigger_number = frh.trigger_number
 
        get_ana_data = (self.ana_data_prescale is not None and (trigger_number % self.ana_data_prescale)==0)
        get_wvfm_data = (self.wvfm_data_prescale is not None and (trigger_number % self.wvfm_data_prescale)==0)
 
        #print(f'\t\tTrigger number {trigger_number}: get_ana_data? {get_ana_data} get_wvfm_data? {get_wvfm_data}')
 
        if not (get_ana_data or get_wvfm_data):
            return None,None
 
        ana_data = None
        wvfm_data = None
 
        adcs = self.unpacker.np_array_adc(frag)
        det, crate, slot, stream = self.get_det_crate_slot_stream(frag)
        channels = [ self.channel_map.get_offline_channel_from_det_crate_slot_stream_chan(det, crate, slot, stream, c) for c in range(self.N_CHANNELS_PER_FRAME) ]
        planes = [ self.channel_map.get_plane_from_offline_channel(uc) for uc in channels ]
        elements = [ self.channel_map.get_element_id_from_offline_channel(uc) for uc in channels ]
        tde_chans = range(self.N_CHANNELS_PER_FRAME)
 
        if get_ana_data:
            adc_mean = np.mean(adcs,axis=0)
            adc_rms = np.std(adcs,axis=0)
            adc_max = np.max(adcs,axis=0)
            adc_min = np.min(adcs,axis=0)
            adc_median = np.median(adcs,axis=0)
            ana_data = [ TDEEthAnalysisData(run=frh.run_number,
                                            trigger=frh.trigger_number,
                                            sequence=frh.sequence_number,
                                            src_id=frh.element_id.id,
                                            channel=channels[i_ch],
                                            plane=planes[i_ch],
                                            element=elements[i_ch],
                                            tde_chan=tde_chans[i_ch],
                                            adc_mean=adc_mean[i_ch],
                                            adc_rms=adc_rms[i_ch],
                                            adc_max=adc_max[i_ch],
                                            adc_min=adc_min[i_ch],
                                            adc_median=adc_median[i_ch]) for i_ch in range(self.N_CHANNELS_PER_FRAME) ]
        if get_wvfm_data:
            timestamps = self.unpacker.np_array_timestamp(frag)
            ffts = np.abs(np.fft.rfft(adcs,axis=0))
            wvfm_data = [ TDEEthWaveformData(run=frh.run_number,
                                             trigger=frh.trigger_number,
                                             sequence=frh.sequence_number,
                                             src_id=frh.element_id.id,
                                             channel=channels[i_ch],
                                             plane=planes[i_ch],
                                             element=elements[i_ch],
                                             tde_chan=tde_chans[i_ch],
                                             timestamps=timestamps,
                                             adcs=adcs[:,i_ch],
                                             fft_mag=ffts[:,i_ch]) for i_ch in range(self.N_CHANNELS_PER_FRAME) ]
 
        return ana_data, wvfm_data
 

◆ get_det_data_version()

rawdatautils.unpack.utils.TDEEthUnpacker.get_det_data_version	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 618 of file utils.py.

    def get_det_data_version(self,frag):
        return self.frame_obj(frag.get_data()).get_tdeheader().version
 

◆ get_det_header_data()

rawdatautils.unpack.utils.TDEEthUnpacker.get_det_header_data	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 625 of file utils.py.

    def get_det_header_data(self,frag):
        frh = frag.get_header()
 
        n_frames = self.get_n_obj(frag)
 
        errors_arr = np.empty(n_frames)
        tai_time_arr = np.empty(n_frames)
 
        for i in range(n_frames):
            tdeh = self.frame_obj(frag.get_data(i*self.frame_obj.sizeof())).get_tdeheader()
 
            errors_arr[i] = tdeh.tde_errors
            tai_time_arr[i] = tdeh.TAItime
 
        errors_change_idx, errors_change_val, _ = sparsify_array_diff_locs_and_vals(errors_arr)
 
        tai_time_diff = np.diff(tai_time_arr)
        tai_time_diff_change_idx, tai_time_diff_change_val, _ = sparsify_array_diff_locs_and_vals(tai_time_diff)
 
        ts_arr = self.unpacker.np_array_timestamp(frag)
        ts_diff_change_idx, ts_diff_change_val, _ = sparsify_array_diff_locs_and_vals(np.diff(ts_arr))
 
        tdeh = self.frame_obj(frag.get_data()).get_tdeheader()
        ts_diff_vals, ts_diff_counts = np.unique(np.diff(self.unpacker.np_array_timestamp(frag)),return_counts=True)
        return [ TDEEthHeaderData(run=frh.run_number,
                                  trigger=frh.trigger_number,
                                  sequence=frh.sequence_number,
                                  src_id=frh.element_id.id,
                                  channel_id=tdeh.channel,
                                  tde_header=tdeh.tde_header,
                                  version=tdeh.version,
                                  errors_vals=errors_change_val, errors_idx=errors_change_idx,
                                  tai_time_diff_vals=tai_time_diff_change_val,
                                  tai_time_diff_idx=tai_time_diff_change_idx,
                                  tai_time_first=tai_time_arr[0],
                                  timestamp_dts_diff_vals=ts_diff_change_val,
                                  timestamp_dts_diff_idx=ts_diff_change_idx,
                                  timestamp_dts_first=ts_arr[0],
                                  n_frames=n_frames,
                                  n_channels=self.N_CHANNELS_PER_FRAME,
                                  sampling_period=self.SAMPLING_PERIOD) ]
 

◆ get_n_obj()

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

Reimplemented from rawdatautils.unpack.utils.FragmentUnpacker.

Definition at line 609 of file utils.py.

    def get_n_obj(self,frag):
        return self.unpacker.get_n_frames(frag)
 

◆ get_timestamp_first()

rawdatautils.unpack.utils.TDEEthUnpacker.get_timestamp_first	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 615 of file utils.py.

    def get_timestamp_first(self,frag):
        return self.frame_obj(frag.get_data()).get_timestamp()
 

Member Data Documentation

◆ channel_map

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

Definition at line 603 of file utils.py.

◆ frame_obj

rawdatautils.unpack.utils.TDEEthUnpacker.frame_obj = fddetdataformats.TDEEthFrame

static

Definition at line 595 of file utils.py.

◆ N_CHANNELS_PER_FRAME

int rawdatautils.unpack.utils.TDEEthUnpacker.N_CHANNELS_PER_FRAME = 64

static

Definition at line 598 of file utils.py.

◆ SAMPLING_PERIOD

float rawdatautils.unpack.utils.TDEEthUnpacker.SAMPLING_PERIOD = 31.25

static

Definition at line 597 of file utils.py.

◆ unpacker

rawdatautils.unpack.utils.TDEEthUnpacker.unpacker = rawdatautils.unpack.tde

static

Definition at line 594 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

Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __init__()

Member Function Documentation

◆ get_daq_header_version()

◆ get_det_crate_slot_stream()

◆ get_det_data_all()

◆ get_det_data_version()

◆ get_det_header_data()

◆ get_n_obj()

◆ get_timestamp_first()

Member Data Documentation

◆ channel_map

◆ frame_obj

◆ N_CHANNELS_PER_FRAME

◆ SAMPLING_PERIOD

◆ unpacker

◆ init()