@@ -68,12 +68,12 @@ TEST_F(MessageDiagnosticsTest, FrameRateMsgTest)
6868 message_diagnostics::MessageDiagnostics message_diagnostics (
6969 *node_, " test_topic" , message_diagnostics::MessageDiagnosticsConfig ());
7070
71- uint64_t timestamp = test_constants::kStartTimestampNs ; // in nanoseconds
71+ uint64_t timestamp = test_constants::kStartTimestampNs ; // in nanoseconds
7272 for (int i = 0 ; i < 1000 ; i++) {
7373 message_diagnostics.updateDiagnostics (timestamp);
74- timestamp += 10000000 ; // 10 ms in nanoseconds
74+ timestamp += 10000000 ; // 10 ms in nanoseconds
7575 }
76- EXPECT_EQ (message_diagnostics.getFrameRateMsg (), 100 ); // 100 Hz
76+ EXPECT_EQ (message_diagnostics.getFrameRateMsg (), 100 ); // 100 Hz
7777}
7878
7979TEST_F (MessageDiagnosticsTest, FrameRateNodeTest)
@@ -82,11 +82,12 @@ TEST_F(MessageDiagnosticsTest, FrameRateNodeTest)
8282 message_diagnostics::MessageDiagnostics message_diagnostics (
8383 *node_, " test_topic" , message_diagnostics::MessageDiagnosticsConfig ());
8484
85- constexpr auto timestamp = test_constants::kStartTimestampNs ; // dummy timestamp, not used for node time calculation
85+ // dummy timestamp, not used for node time calculation
86+ constexpr auto timestamp = test_constants::kStartTimestampNs ;
8687 const auto start_time = std::chrono::high_resolution_clock::now ();
8788
8889 constexpr int num_messages = 1000 ;
89- constexpr int interarrival_time_ms = 10 ; // 100 hz
90+ constexpr int interarrival_time_ms = 10 ; // 100 hz
9091
9192 for (int i = 0 ; i < num_messages; i++) {
9293 message_diagnostics.updateDiagnostics (timestamp);
@@ -98,7 +99,7 @@ TEST_F(MessageDiagnosticsTest, FrameRateNodeTest)
9899
99100 const double expected_frame_rate = static_cast <double >(num_messages) / total_duration.count ();
100101
101- EXPECT_NEAR (message_diagnostics.getFrameRateNode (), expected_frame_rate, 2.0 ); // allow 2.0 Hz error
102+ EXPECT_NEAR (message_diagnostics.getFrameRateNode (), expected_frame_rate, 2.0 ); // allow 2.0 Hz error
102103}
103104
104105TEST_F (MessageDiagnosticsTest, MessageLatencyTest)
@@ -116,22 +117,24 @@ TEST_F(MessageDiagnosticsTest, MessageLatencyTest)
116117
117118 message_diagnostics.updateDiagnostics (msg_timestamp.nanoseconds ());
118119
119- EXPECT_NEAR (message_diagnostics.getLatency (), expected_latency_ms, 1.0 ); // allow 1 ms tolerance
120+ EXPECT_NEAR (message_diagnostics.getLatency (), expected_latency_ms, 1.0 ); // allow 1 ms tolerance
120121}
121122
122123TEST_F (MessageDiagnosticsTest, DiagnosticPublishSubscribeTest)
123124{
124- constexpr int input_frequency = 50 ; // 50 Hz
125+ constexpr int input_frequency = 50 ; // 50 Hz
126+ // 20 ms in nanoseconds
125127 const int64_t interarrival_time_ns = static_cast <int64_t >(
126- ::message_diagnostics::constants::kSecondsToNanoseconds / input_frequency); // 20 ms in nanoseconds
128+ ::message_diagnostics::constants::kSecondsToNanoseconds / input_frequency);
127129
128130 // Initialize MessageDiagnostics with diagnostics enabled
129131 message_diagnostics::MessageDiagnosticsConfig config;
130132 config.enable_msg_time_diagnostics = true ;
131133 config.enable_node_time_diagnostics = true ;
132134 config.enable_increasing_msg_time_diagnostics = true ;
135+ // in us
133136 config.expected_dt_us = interarrival_time_ns /
134- ::message_diagnostics::constants::kMicrosecondsToNanoseconds ; // in us
137+ ::message_diagnostics::constants::kMicrosecondsToNanoseconds ;
135138
136139 message_diagnostics::MessageDiagnostics message_diagnostics (*node_, " test_topic" , config);
137140
@@ -144,10 +147,12 @@ TEST_F(MessageDiagnosticsTest, DiagnosticPublishSubscribeTest)
144147 received_diagnostics.push_back (msg);
145148 });
146149
150+ // 50 ms delay
147151 constexpr int64_t delay_time_ns = 50 *
148152 static_cast <int64_t >(::message_diagnostics::constants::kMillisecondsToMicroseconds ) *
149- static_cast <int64_t >(::message_diagnostics::constants::kMicrosecondsToNanoseconds ); // 50 ms delay
150- auto msg_timestamp = test_constants::kStartTimestampNs ; // Starting message timestamp in nanoseconds
153+ static_cast <int64_t >(::message_diagnostics::constants::kMicrosecondsToNanoseconds );
154+ // Starting message timestamp in nanoseconds
155+ auto msg_timestamp = test_constants::kStartTimestampNs ;
151156
152157 int sent_count = 0 ;
153158 const auto start_time = std::chrono::high_resolution_clock::now ();
@@ -170,7 +175,7 @@ TEST_F(MessageDiagnosticsTest, DiagnosticPublishSubscribeTest)
170175 }
171176 // Add a jitter by delaying at count 10
172177 if (sent_count == 10 ) {
173- std::this_thread::sleep_for (std::chrono::nanoseconds (delay_time_ns)); // 50 ms delay
178+ std::this_thread::sleep_for (std::chrono::nanoseconds (delay_time_ns)); // 50 ms delay
174179 msg_timestamp += delay_time_ns;
175180 }
176181
0 commit comments