Inheritance diagram for rawdatautils.unpack.utils.DAPHNEUnpacker:

Collaboration diagram for rawdatautils.unpack.utils.DAPHNEUnpacker:

Public Member Functions
	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
	__init__ (self, channel_map=None, ana_data_prescale=1, wvfm_data_prescale=None)

	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

Static Public Attributes
	unpacker = rawdatautils.unpack.daphne

	frame_obj = fddetdataformats.DAPHNEFrame

int	SAMPLING_PERIOD = 1

int	N_CHANNELS_PER_FRAME = 1

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

Additional Inherited Members
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)

	channel_map = NullChannelMap

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

Detailed Description

Definition at line 810 of file utils.py.

Member Function Documentation

◆ get_daq_header_version()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 821 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.DAPHNEUnpacker.get_det_crate_slot_stream	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 830 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.link_id
 

◆ get_det_data_all()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 837 of file utils.py.

    def get_det_data_all(self,frag):
        frh = frag.get_header()
        trigger_number = frh.trigger_number
        wvfm_data = None
        ana_data = None
 
        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)
 
        if not (get_ana_data or get_wvfm_data):
            return None,None
 
        n_frames = self.get_n_obj(frag)
        adcs = self.unpacker.np_array_adc(frag)
 
        daphne_headers = [ self.frame_obj(frag.get_data(iframe*self.frame_obj.sizeof())).get_header() for iframe in range(n_frames) ]
        timestamp = self.unpacker.np_array_timestamp(frag)
 
        if (len(adcs)) == 0:
            return None, None
 
        det, crate, slot, stream = self.get_det_crate_slot_stream(frag)
 
        if get_ana_data:
            ax = 1
            adc_mean = np.mean(adcs,axis=ax)
            adc_rms = np.std(adcs,axis=ax)
            adc_max = np.max(adcs,axis=ax)
            adc_min = np.min(adcs,axis=ax)
            adc_median = np.median(adcs,axis=ax)
            ts_max = np.argmax(adcs,axis=ax)*self.SAMPLING_PERIOD + timestamp
            ts_min = np.argmin(adcs,axis=ax)*self.SAMPLING_PERIOD + timestamp
 
            ana_data = [ DAPHNEAnalysisData(run=frh.run_number,
                                            trigger=frh.trigger_number,
                                            sequence=frh.sequence_number,
                                            src_id=frh.element_id.id,
                                            channel=self.channel_map.get_offline_channel_from_det_crate_slot_stream_chan(det, crate, slot, stream, daphne_headers[iframe].channel),
                                            daphne_chan=daphne_headers[iframe].channel,
                                            timestamp_dts=timestamp[iframe],
                                            trigger_sample_value=daphne_headers[iframe].trigger_sample_value,
                                            threshold=daphne_headers[iframe].threshold,
                                            baseline=daphne_headers[iframe].baseline,
                                            adc_mean=adc_mean[iframe],
                                            adc_rms=adc_rms[iframe],
                                            adc_max=adc_max[iframe],
                                            adc_min=adc_min[iframe],
                                            adc_median=adc_median[iframe],
                                            timestamp_max_dts=ts_max[iframe],
                                            timestamp_min_dts=ts_min[iframe]) for iframe in range(n_frames) ]
 
 
        if get_wvfm_data:
 
            wvfm_data = [ DAPHNEWaveformData(run=frh.run_number,
                                             trigger=frh.trigger_number,
                                             sequence=frh.sequence_number,
                                             src_id=frh.element_id.id,
                                             channel=self.channel_map.get_offline_channel_from_det_crate_slot_stream_chan(det, crate, slot, stream, daphne_headers[iframe].channel),
                                             daphne_chan=daphne_headers[iframe].channel,
                                             timestamp_dts=timestamp[iframe],
                                             timestamps=np.arange(np.size(adcs[iframe,:]))*self.SAMPLING_PERIOD+timestamp[iframe],
                                             adcs=adcs[iframe,:]) for iframe in range(n_frames) ]
 
        return ana_data, wvfm_data
 
 
 

◆ get_det_data_version()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 827 of file utils.py.

    def get_det_data_version(self,frag):
        return 0
 

◆ get_det_header_data()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 834 of file utils.py.

    def get_det_header_data(self,frag):
        return None
 

◆ get_n_obj()

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

Reimplemented from rawdatautils.unpack.utils.FragmentUnpacker.

Definition at line 818 of file utils.py.

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

◆ get_timestamp_first()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 824 of file utils.py.

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

Member Data Documentation

◆ frame_obj

rawdatautils.unpack.utils.DAPHNEUnpacker.frame_obj = fddetdataformats.DAPHNEFrame

static

Definition at line 813 of file utils.py.

◆ N_CHANNELS_PER_FRAME

int rawdatautils.unpack.utils.DAPHNEUnpacker.N_CHANNELS_PER_FRAME = 1

static

Definition at line 816 of file utils.py.

◆ SAMPLING_PERIOD

int rawdatautils.unpack.utils.DAPHNEUnpacker.SAMPLING_PERIOD = 1

static

Definition at line 815 of file utils.py.

◆ unpacker

rawdatautils.unpack.utils.DAPHNEUnpacker.unpacker = rawdatautils.unpack.daphne

static

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

Static Public Attributes

Additional Inherited Members

Detailed Description

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

◆ frame_obj

◆ N_CHANNELS_PER_FRAME

◆ SAMPLING_PERIOD

◆ unpacker