rawdatautils.unpack.utils.WIBEthUnpacker Class Reference
Inheritance diagram for rawdatautils.unpack.utils.WIBEthUnpacker:
Collaboration diagram for rawdatautils.unpack.utils.WIBEthUnpacker:
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.wibeth | |
| frame_obj = fddetdataformats.WIBEthFrame | |
| int | SAMPLING_PERIOD = 32 |
| 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 |
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
Member Function Documentation
◆ get_daq_header_version()
| rawdatautils.unpack.utils.WIBEthUnpacker.get_daq_header_version | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.
Definition at line 435 of file utils.py.
435 def get_daq_header_version(self,frag):
436 return self.frame_obj(frag.get_data()).get_daqheader().version
437
◆ get_det_crate_slot_stream()
| rawdatautils.unpack.utils.WIBEthUnpacker.get_det_crate_slot_stream | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.
Definition at line 444 of file utils.py.
444 def get_det_crate_slot_stream(self,frag):
445 dh = self.frame_obj(frag.get_data()).get_daqheader()
446 return dh.det_id, dh.crate_id, dh.slot_id, dh.stream_id
447
◆ get_det_data_all()
| rawdatautils.unpack.utils.WIBEthUnpacker.get_det_data_all | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.
Definition at line 540 of file utils.py.
540 def get_det_data_all(self,frag):
541 frh = frag.get_header()
542 trigger_number = frh.trigger_number
543
544 get_ana_data = (self.ana_data_prescale is not None and (trigger_number % self.ana_data_prescale)==0)
545 get_wvfm_data = (self.wvfm_data_prescale is not None and (trigger_number % self.wvfm_data_prescale)==0)
546
547 #print(f'\t\tTrigger number {trigger_number}: get_ana_data? {get_ana_data} get_wvfm_data? {get_wvfm_data}')
548
549 if not (get_ana_data or get_wvfm_data):
550 return None,None
551
552 ana_data = None
553 wvfm_data = None
554
555 adcs = self.unpacker.np_array_adc(frag)
556 det, crate, slot, stream = self.get_det_crate_slot_stream(frag)
557 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) ]
558 planes = [ self.channel_map.get_plane_from_offline_channel(uc) for uc in channels ]
559 elements = [ self.channel_map.get_element_id_from_offline_channel(uc) for uc in channels ]
560 wib_chans = range(self.N_CHANNELS_PER_FRAME)
561
562 if get_ana_data:
563 adc_mean = np.mean(adcs,axis=0)
564 adc_rms = np.std(adcs,axis=0)
565 adc_max = np.max(adcs,axis=0)
566 adc_min = np.min(adcs,axis=0)
567 adc_median = np.median(adcs,axis=0)
568 ana_data = [ WIBEthAnalysisData(run=frh.run_number,
569 trigger=frh.trigger_number,
570 sequence=frh.sequence_number,
571 src_id=frh.element_id.id,
572 channel=channels[i_ch],
573 plane=planes[i_ch],
574 element=elements[i_ch],
575 wib_chan=wib_chans[i_ch],
576 adc_mean=adc_mean[i_ch],
577 adc_rms=adc_rms[i_ch],
578 adc_max=adc_max[i_ch],
579 adc_min=adc_min[i_ch],
580 adc_median=adc_median[i_ch]) for i_ch in range(self.N_CHANNELS_PER_FRAME) ]
581 if get_wvfm_data:
582 timestamps = self.unpacker.np_array_timestamp(frag)
583 ffts = np.abs(np.fft.rfft(adcs,axis=0))
584 wvfm_data = [ WIBEthWaveformData(run=frh.run_number,
585 trigger=frh.trigger_number,
586 sequence=frh.sequence_number,
587 src_id=frh.element_id.id,
588 channel=channels[i_ch],
589 plane=planes[i_ch],
590 element=elements[i_ch],
591 wib_chan=wib_chans[i_ch],
592 timestamps=timestamps,
593 adcs=adcs[:,i_ch],
594 fft_mag=ffts[:,i_ch]) for i_ch in range(self.N_CHANNELS_PER_FRAME) ]
595
596 return ana_data, wvfm_data
597
598
◆ get_det_data_version()
| rawdatautils.unpack.utils.WIBEthUnpacker.get_det_data_version | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.
Definition at line 441 of file utils.py.
441 def get_det_data_version(self,frag):
442 return self.frame_obj(frag.get_data()).get_wibheader().version
443
◆ get_det_header_data()
| rawdatautils.unpack.utils.WIBEthUnpacker.get_det_header_data | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.
Definition at line 448 of file utils.py.
448 def get_det_header_data(self,frag):
449 frh = frag.get_header()
450
451 n_frames = self.get_n_obj(frag)
452
453 pulser_arr = np.empty(n_frames)
454 calibration_arr = np.empty(n_frames)
455 ready_arr = np.empty(n_frames)
456 context_arr = np.empty(n_frames)
457 wib_sync_arr = np.empty(n_frames)
458 femb_sync_arr = np.empty(n_frames)
459 cd_arr = np.empty(n_frames)
460 crc_err_arr = np.empty(n_frames)
461 link_valid_arr = np.empty(n_frames)
462 lol_arr = np.empty(n_frames)
463 colddata_ts0_arr = np.empty(n_frames)
464 colddata_ts1_arr = np.empty(n_frames)
465
466 for i in range(n_frames):
467 wh = self.frame_obj(frag.get_data(i*self.frame_obj.sizeof())).get_wibheader()
468
469 pulser_arr[i] = wh.pulser
470 calibration_arr[i] = wh.calibration
471 ready_arr[i] = wh.ready
472 context_arr[i] = wh.context
473
474 wib_sync_arr[i] = wh.wib_sync
475 femb_sync_arr[i] = wh.femb_sync
476
477 cd_arr[i] = wh.cd
478 crc_err_arr[i] = wh.crc_err
479 link_valid_arr[i] = wh.link_valid
480 lol_arr[i] = wh.lol
481
482 colddata_ts0_arr[i] = wh.colddata_timestamp_0
483 colddata_ts1_arr[i] = wh.colddata_timestamp_1
484
485 pulser_change_idx, pulser_change_val, _ = sparsify_array_diff_locs_and_vals(pulser_arr)
486 calibration_change_idx, calibration_change_val, _ = sparsify_array_diff_locs_and_vals(calibration_arr)
487 ready_change_idx, ready_change_val, _ = sparsify_array_diff_locs_and_vals(context_arr)
488 context_change_idx, context_change_val, _ = sparsify_array_diff_locs_and_vals(context_arr)
489
490 wib_sync_change_idx, wib_sync_change_val, _ = sparsify_array_diff_locs_and_vals(wib_sync_arr)
491 femb_sync_change_idx, femb_sync_change_val, _ = sparsify_array_diff_locs_and_vals(femb_sync_arr)
492
493 cd_change_idx, cd_change_val, _ = sparsify_array_diff_locs_and_vals(cd_arr)
494 crc_err_change_idx, crc_err_change_val, _ = sparsify_array_diff_locs_and_vals(crc_err_arr)
495 link_valid_change_idx, link_valid_change_val, _ = sparsify_array_diff_locs_and_vals(link_valid_arr)
496 lol_change_idx, lol_change_val, _ = sparsify_array_diff_locs_and_vals(context_arr)
497
498 colddata_ts0_diff = np.diff(colddata_ts0_arr)
499 colddata_ts0_diff[colddata_ts0_diff<0] = colddata_ts0_diff[colddata_ts0_diff<0]+0x8000
500 colddata_ts0_diff_change_idx, colddata_ts0_diff_change_val, _ = sparsify_array_diff_locs_and_vals(colddata_ts0_diff)
501
502 colddata_ts1_diff = np.diff(colddata_ts1_arr)
503 colddata_ts1_diff[colddata_ts1_diff<0] = colddata_ts1_diff[colddata_ts1_diff<0]+0x8000
504 colddata_ts1_diff_change_idx, colddata_ts1_diff_change_val, _ = sparsify_array_diff_locs_and_vals(colddata_ts1_diff)
505
506 ts_arr = self.unpacker.np_array_timestamp(frag)
507 ts_diff_change_idx, ts_diff_change_val, _ = sparsify_array_diff_locs_and_vals(np.diff(ts_arr))
508
509 wh = self.frame_obj(frag.get_data()).get_wibheader()
510 ts_diff_vals, ts_diff_counts = np.unique(np.diff(self.unpacker.np_array_timestamp(frag)),return_counts=True)
511 return [ WIBEthHeaderData(run=frh.run_number,
512 trigger=frh.trigger_number,
513 sequence=frh.sequence_number,
514 src_id=frh.element_id.id,
515 femb_id=(wh.channel>>1)&0x3,
516 colddata_id=wh.channel&0x1,
517 version=wh.version,
518 pulser_vals=pulser_change_val, pulser_idx=pulser_change_idx,
519 calibration_vals=calibration_change_val, calibration_idx=calibration_change_idx,
520 ready_vals=ready_change_val, ready_idx=ready_change_idx,
521 context_vals=context_change_val, context_idx=context_change_idx,
522 wib_sync_vals=wib_sync_change_val, wib_sync_idx=wib_sync_change_idx,
523 femb_sync_vals=femb_sync_change_val, femb_sync_idx=femb_sync_change_idx,
524 cd_vals=cd_change_val, cd_idx=cd_change_idx,
525 crc_err_vals=crc_err_change_val, crc_err_idx=crc_err_change_idx,
526 link_valid_vals=link_valid_change_val, link_valid_idx=link_valid_change_idx,
527 lol_vals=lol_change_val, lol_idx=lol_change_idx,
528 colddata_timestamp_0_diff_vals=colddata_ts0_diff_change_val,
529 colddata_timestamp_0_diff_idx=colddata_ts0_diff_change_idx,
530 colddata_timestamp_0_first=colddata_ts0_arr[0],
531 colddata_timestamp_1_diff_vals=colddata_ts1_diff_change_val,
532 colddata_timestamp_1_diff_idx=colddata_ts1_diff_change_idx,
533 colddata_timestamp_1_first=colddata_ts1_arr[0],
534 timestamp_dts_diff_vals=ts_diff_change_val, timestamp_dts_diff_idx=ts_diff_change_idx,
535 timestamp_dts_first=ts_arr[0],
536 n_frames=n_frames,
537 n_channels=self.N_CHANNELS_PER_FRAME,
538 sampling_period=self.SAMPLING_PERIOD) ]
539
◆ get_n_obj()
| rawdatautils.unpack.utils.WIBEthUnpacker.get_n_obj | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.FragmentUnpacker.
Definition at line 432 of file utils.py.
432 def get_n_obj(self,frag):
433 return self.unpacker.get_n_frames(frag)
434
◆ get_timestamp_first()
| rawdatautils.unpack.utils.WIBEthUnpacker.get_timestamp_first | ( | self, | |
| frag ) |
Reimplemented from rawdatautils.unpack.utils.DetectorFragmentUnpacker.
Definition at line 438 of file utils.py.
438 def get_timestamp_first(self,frag):
439 return self.frame_obj(frag.get_data()).get_timestamp()
440
Member Data Documentation
◆ frame_obj
|
static |
◆ N_CHANNELS_PER_FRAME
|
static |
◆ SAMPLING_PERIOD
|
static |
◆ unpacker
|
static |
The documentation for this class was generated from the following file:
- /github/workspace/dunedaq/sourcecode/rawdatautils/python/rawdatautils/unpack/utils.py
Generated on Thu Dec 25 2025 for DUNE-DAQ by
1.12.0