Line data Source code
1 : /**
2 : * @file DAPHNEEthStreamFrame_test.cxx DAPHNEEthStreamFrame class Unit Tests
3 : *
4 : * This is part of the DUNE DAQ Application Framework, copyright 2022.
5 : * Licensing/copyright details are in the COPYING file that you should have
6 : * received with this code.
7 : */
8 :
9 : #include "fddetdataformats/DAPHNEEthStreamFrame.hpp"
10 :
11 : #define BOOST_TEST_MODULE DAPHNEEthStreamFrame_test // NOLINT
12 :
13 : #include "boost/test/unit_test.hpp"
14 :
15 : #include <cstdint>
16 : #include <random>
17 : #include <vector>
18 :
19 : // NOLINTBEGIN(build/unsigned)
20 :
21 : BOOST_AUTO_TEST_SUITE(DAPHNEEthStreamFrame_test)
22 :
23 2 : BOOST_AUTO_TEST_CASE(DAPHNEEthStreamFrame_ADCDataMutators)
24 : {
25 1 : using dunedaq::fddetdataformats::DAPHNEEthStreamFrame;
26 :
27 1 : std::random_device dev;
28 1 : std::mt19937 rng(dev());
29 1 : std::uniform_int_distribution<uint16_t> dist(0, (1 << DAPHNEEthStreamFrame::s_bits_per_adc) - 1);
30 :
31 1 : std::vector<std::vector<uint16_t>> adcs(DAPHNEEthStreamFrame::s_adcs_per_channel,
32 1 : std::vector<uint16_t>(DAPHNEEthStreamFrame::s_num_channels));
33 :
34 5 : for (uint32_t channel = 0; channel < DAPHNEEthStreamFrame::s_num_channels; ++channel) {
35 1124 : for (uint32_t adc_index = 0; adc_index < DAPHNEEthStreamFrame::s_adcs_per_channel; ++adc_index) {
36 1120 : adcs[adc_index][channel] = dist(rng);
37 : }
38 : }
39 :
40 1 : DAPHNEEthStreamFrame frame{};
41 :
42 5 : for (uint32_t channel = 0; channel < DAPHNEEthStreamFrame::s_num_channels; ++channel) {
43 1124 : for (uint32_t adc_index = 0; adc_index < DAPHNEEthStreamFrame::s_adcs_per_channel; ++adc_index) {
44 1120 : frame.set_adc(channel, adc_index, adcs[adc_index][channel]);
45 : }
46 : }
47 :
48 5 : for (uint32_t channel = 0; channel < DAPHNEEthStreamFrame::s_num_channels; ++channel) {
49 1124 : for (uint32_t adc_index = 0; adc_index < DAPHNEEthStreamFrame::s_adcs_per_channel; ++adc_index) {
50 1120 : BOOST_REQUIRE_EQUAL(frame.get_adc(adc_index, channel), adcs[adc_index][channel]);
51 : }
52 : }
53 :
54 1 : frame.set_adc(0, 0, adcs[0][0]);
55 :
56 5 : for (uint32_t channel = 0; channel < DAPHNEEthStreamFrame::s_num_channels; ++channel) {
57 1124 : for (uint32_t adc_index = 0; adc_index < DAPHNEEthStreamFrame::s_adcs_per_channel; ++adc_index) {
58 1120 : BOOST_REQUIRE_EQUAL(frame.get_adc(adc_index, channel), adcs[adc_index][channel]);
59 : }
60 : }
61 1 : }
62 :
63 2 : BOOST_AUTO_TEST_CASE(DAPHNEEthStreamFrame_IndexAndValueBounds)
64 : {
65 1 : using dunedaq::fddetdataformats::DAPHNEEthStreamFrame;
66 :
67 1 : DAPHNEEthStreamFrame frame{};
68 :
69 1 : BOOST_CHECK_THROW(frame.get_adc(DAPHNEEthStreamFrame::s_adcs_per_channel, 0), std::out_of_range);
70 1 : BOOST_CHECK_THROW(frame.get_adc(0, DAPHNEEthStreamFrame::s_num_channels), std::out_of_range);
71 1 : BOOST_CHECK_THROW(frame.get_adc(static_cast<uint32_t>(-1), 0), std::out_of_range);
72 1 : BOOST_CHECK_THROW(frame.get_adc(0, static_cast<uint32_t>(-1)), std::out_of_range);
73 :
74 1 : BOOST_CHECK_THROW(frame.set_adc(DAPHNEEthStreamFrame::s_num_channels, 0, 123), std::out_of_range);
75 1 : BOOST_CHECK_THROW(frame.set_adc(0, DAPHNEEthStreamFrame::s_adcs_per_channel, 123), std::out_of_range);
76 1 : BOOST_CHECK_THROW(frame.set_adc(static_cast<uint32_t>(-1), 0, 123), std::out_of_range);
77 1 : BOOST_CHECK_THROW(frame.set_adc(0, static_cast<uint32_t>(-1), 123), std::out_of_range);
78 1 : BOOST_CHECK_THROW(frame.set_adc(0, 0, static_cast<uint16_t>(1 << DAPHNEEthStreamFrame::s_bits_per_adc)),
79 : std::out_of_range);
80 :
81 1 : BOOST_CHECK_NO_THROW(frame.set_adc(0, 0, static_cast<uint16_t>((1 << DAPHNEEthStreamFrame::s_bits_per_adc) - 1)));
82 1 : BOOST_CHECK_EQUAL(frame.get_adc(0, 0), static_cast<uint16_t>((1 << DAPHNEEthStreamFrame::s_bits_per_adc) - 1));
83 1 : }
84 :
85 2 : BOOST_AUTO_TEST_CASE(DAPHNEEthStreamFrame_BitPackingBoundaryIsolation)
86 : {
87 1 : using dunedaq::fddetdataformats::DAPHNEEthStreamFrame;
88 :
89 1 : DAPHNEEthStreamFrame frame{};
90 1 : constexpr auto max_adc = static_cast<uint16_t>((1u << DAPHNEEthStreamFrame::s_bits_per_adc) - 1u);
91 :
92 1 : constexpr uint32_t boundary_sample = 1;
93 1 : constexpr uint32_t boundary_channel = 0;
94 :
95 1 : frame.set_adc(3, 0, 0x0000u);
96 1 : frame.set_adc(boundary_channel, boundary_sample, 0x0000u);
97 1 : frame.set_adc(1, boundary_sample, 0x0000u);
98 :
99 1 : frame.set_adc(boundary_channel, boundary_sample, 0x2AAAu);
100 1 : BOOST_CHECK_EQUAL(frame.get_adc(0, 3), 0x0000u);
101 1 : BOOST_CHECK_EQUAL(frame.get_adc(boundary_sample, boundary_channel), 0x2AAAu);
102 1 : BOOST_CHECK_EQUAL(frame.get_adc(boundary_sample, 1), 0x0000u);
103 :
104 1 : frame.set_adc(3, 0, max_adc);
105 1 : BOOST_CHECK_EQUAL(frame.get_adc(0, 3), max_adc);
106 1 : BOOST_CHECK_EQUAL(frame.get_adc(boundary_sample, boundary_channel), 0x2AAAu);
107 1 : BOOST_CHECK_EQUAL(frame.get_adc(boundary_sample, 1), 0x0000u);
108 :
109 1 : frame.set_adc(1, boundary_sample, 0x1555u);
110 1 : BOOST_CHECK_EQUAL(frame.get_adc(0, 3), max_adc);
111 1 : BOOST_CHECK_EQUAL(frame.get_adc(boundary_sample, boundary_channel), 0x2AAAu);
112 1 : BOOST_CHECK_EQUAL(frame.get_adc(boundary_sample, 1), 0x1555u);
113 1 : }
114 :
115 2 : BOOST_AUTO_TEST_CASE(DAPHNEEthStreamFrame_MetadataMutators)
116 : {
117 1 : using dunedaq::fddetdataformats::DAPHNEEthStreamFrame;
118 :
119 1 : DAPHNEEthStreamFrame frame{};
120 :
121 1 : frame.set_timestamp(0x0123456789ABCDEFuLL);
122 1 : BOOST_CHECK_EQUAL(frame.get_timestamp(), 0x0123456789ABCDEFuLL);
123 :
124 1 : frame.set_channel(0, 10);
125 1 : frame.set_channel(1, 20);
126 1 : frame.set_channel(2, 30);
127 1 : frame.set_channel(3, 40);
128 :
129 1 : BOOST_CHECK_EQUAL(frame.get_channel(0), 10);
130 1 : BOOST_CHECK_EQUAL(frame.get_channel(1), 20);
131 1 : BOOST_CHECK_EQUAL(frame.get_channel(2), 30);
132 1 : BOOST_CHECK_EQUAL(frame.get_channel(3), 40);
133 :
134 1 : BOOST_CHECK_EQUAL(frame.get_channel0(), 10);
135 1 : BOOST_CHECK_EQUAL(frame.get_channel1(), 20);
136 1 : BOOST_CHECK_EQUAL(frame.get_channel2(), 30);
137 1 : BOOST_CHECK_EQUAL(frame.get_channel3(), 40);
138 :
139 1 : BOOST_CHECK_THROW(frame.get_channel(DAPHNEEthStreamFrame::s_num_channels), std::out_of_range);
140 1 : BOOST_CHECK_THROW(frame.set_channel(DAPHNEEthStreamFrame::s_num_channels, 50), std::out_of_range);
141 1 : }
142 :
143 : BOOST_AUTO_TEST_SUITE_END()
144 :
145 : // NOLINTEND(build/unsigned)
|
