Inheritance diagram for rawdatautils.unpack.utils.DAPHNEStreamUnpacker:

Collaboration diagram for rawdatautils.unpack.utils.DAPHNEStreamUnpacker:

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.DAPHNEStreamFrame

int	SAMPLING_PERIOD = 1

int	N_CHANNELS_PER_FRAME = 4

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 723 of file utils.py.

Member Function Documentation

◆ get_daq_header_version()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Reimplemented in rawdatautils.unpack.utils.DAPHNEEthStreamUnpacker.

Definition at line 743 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.DAPHNEStreamUnpacker.get_det_data_all	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 760 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)
 
        if not (get_ana_data or get_wvfm_data):
            return None,None
 
        ana_data = None
        wvfm_data = None
 
        adcs = self.unpacker.np_array_adc_stream(frag)
        dh = self.frame_obj(frag.get_data()).get_header()
        det, crate, slot, stream = self.get_det_crate_slot_stream(frag)
        daphne_chans = [ dh.channel_0, dh.channel_1, dh.channel_2, dh.channel_3 ]
        channels = [ self.channel_map.get_offline_channel_from_det_crate_slot_stream_chan(det, crate, slot, stream, c) for c in daphne_chans ]
 
        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 = [ DAPHNEStreamAnalysisData(run=frh.run_number,
                                                  trigger=frh.trigger_number,
                                                  sequence=frh.sequence_number,
                                                  src_id=frh.element_id.id,
                                                  channel=channels[i_ch],
                                                  daphne_chan=daphne_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_stream(frag)
            ffts = np.abs(np.fft.rfft(adcs,axis=0))
            wvfm_data = [ DAPHNEStreamWaveformData(run=frh.run_number,
                                                   trigger=frh.trigger_number,
                                                   sequence=frh.sequence_number,
                                                   src_id=frh.element_id.id,
                                                   channel=channels[i_ch],
                                                   daphne_chan=channels[i_ch],
                                                   adcs=adcs[:,i_ch],
                                                   timestamps=timestamps,
                                                   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.DAPHNEStreamUnpacker.get_det_data_version	(		self,
			frag )

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 740 of file utils.py.

    def get_det_data_version(self,frag):
        return 0
 

◆ get_det_header_data()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 747 of file utils.py.

    def get_det_header_data(self,frag):
        frh = frag.get_header()
        #dh = self.frame_obj(frag.get_data()).get_header()
        ts_diffs_vals, ts_diffs_counts = np.unique(np.diff( np.array(self.unpacker.np_array_timestamp_stream(frag), dtype=np.int64)), return_counts=True)
        return [ DAPHNEStreamHeaderData(run=frh.run_number,
                                        trigger=frh.trigger_number,
                                        sequence=frh.sequence_number,
                                        src_id=frh.element_id.id,
                                        n_channels=self.N_CHANNELS_PER_FRAME,
                                        sampling_period=self.SAMPLING_PERIOD,
                                        ts_diffs_vals=ts_diffs_vals,
                                        ts_diffs_counts=ts_diffs_counts) ]
 

◆ get_n_obj()

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

Reimplemented from rawdatautils.unpack.utils.FragmentUnpacker.

Definition at line 731 of file utils.py.

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

◆ get_timestamp_first()

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

Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.

Definition at line 737 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.DAPHNEStreamUnpacker.frame_obj = fddetdataformats.DAPHNEStreamFrame

static

Definition at line 726 of file utils.py.

◆ N_CHANNELS_PER_FRAME

int rawdatautils.unpack.utils.DAPHNEStreamUnpacker.N_CHANNELS_PER_FRAME = 4

static

Definition at line 729 of file utils.py.

◆ SAMPLING_PERIOD

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

static

Definition at line 728 of file utils.py.

◆ unpacker

rawdatautils.unpack.utils.DAPHNEStreamUnpacker.unpacker = rawdatautils.unpack.daphne

static

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