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