@@ -42,9 +42,9 @@ inline constexpr uint64_t kMicrosecondsToNanoseconds = 1000ULL;
4242inline constexpr uint64_t kMillisecondsToMicroseconds = 1000ULL ;
4343// Convenience constant for converting milliseconds to seconds in floating-point math
4444inline constexpr uint64_t kMillisecondsToSeconds = 1000ULL ;
45- inline constexpr int64_t kDropWarnTimeoutSeconds = 5 ;
45+ inline constexpr int64_t kDropWarnTimeoutSeconds = 5LL ;
4646// Cutoff where we consider latency to be nonsense
47- inline constexpr int64_t kNonsenseLatencyMs = 365 * 24 * 60 * 60 * 1000 ;
47+ inline constexpr int64_t kNonsenseLatencyMs = 365LL * 24LL * 60LL * 60LL * 1000LL ;
4848} // namespace constants
4949
5050// Configurations for a message diagnostics
@@ -66,10 +66,10 @@ struct MessageDiagnosticsConfig
6666 int filter_window_size{300 };
6767
6868 // Expected time difference between messages in microseconds for this topic
69- int64_t expected_dt_us{0 };
69+ int64_t expected_dt_us{0LL };
7070
7171 // Tolerance for jitter from expected frame rate in microseconds
72- int jitter_tolerance_us{0 };
72+ int64_t jitter_tolerance_us{0LL };
7373};
7474
7575class MessageDiagnostics
@@ -280,18 +280,18 @@ class MessageDiagnostics
280280 RCLCPP_ERROR (
281281 node_.get_logger (),
282282 " expected_hz is 0.0. It should be set to a value greater than 0."
283- " Keeping previous values: expected_dt_us = %" PRId64 " , jitter_tolerance_us = %d ." ,
283+ " Keeping previous values: expected_dt_us = %" PRId64 " , jitter_tolerance_us = %" PRId64 " ." ,
284284 static_cast <int64_t >(diagnostics_config_.expected_dt_us ),
285285 diagnostics_config_.jitter_tolerance_us );
286286 return ;
287287 }
288288
289- const int expected_dt_us =
290- static_cast <int >(message_diagnostics::constants::kSecondsToMicroseconds / expected_hz);
289+ const int64_t expected_dt_us =
290+ static_cast <int64_t >(message_diagnostics::constants::kSecondsToMicroseconds / expected_hz);
291291 diagnostics_config_.expected_dt_us = expected_dt_us;
292292
293- const int tolerance_us =
294- static_cast <int >((message_diagnostics::constants::kSecondsToMicroseconds / expected_hz) *
293+ const int64_t tolerance_us =
294+ static_cast <int64_t >((message_diagnostics::constants::kSecondsToMicroseconds / expected_hz) *
295295 (tolerance_percent / 100.0 ));
296296 diagnostics_config_.jitter_tolerance_us = tolerance_us;
297297 }
@@ -302,18 +302,18 @@ class MessageDiagnostics
302302 diagnostics_config_.enable_node_time_diagnostics = false ;
303303 diagnostics_config_.enable_msg_time_diagnostics = false ;
304304
305- diagnostics_config_.expected_dt_us = 0 ;
306- diagnostics_config_.jitter_tolerance_us = 0 ;
305+ diagnostics_config_.expected_dt_us = 0LL ;
306+ diagnostics_config_.jitter_tolerance_us = 0LL ;
307307 }
308308
309309private:
310310 struct RollingWindow
311311 {
312312 int window_size{0 };
313313 std::queue<int64_t > interarrival_us;
314- int64_t sum_interarrival_us{0 };
314+ int64_t sum_interarrival_us{0LL };
315315 std::queue<int64_t > jitter_abs_us;
316- int64_t sum_jitter_abs_us{0 };
316+ int64_t sum_jitter_abs_us{0LL };
317317 int64_t max_abs_jitter_us{0 };
318318 uint64_t outlier_count{0 };
319319
@@ -328,7 +328,7 @@ class MessageDiagnostics
328328 }
329329
330330 // Returns true if abs_jitter_us exceeded tolerance (i.e., counts as a missed deadline)
331- bool addJitter (int64_t abs_jitter_us, int jitter_tolerance_us)
331+ bool addJitter (int64_t abs_jitter_us, int64_t jitter_tolerance_us)
332332 {
333333 max_abs_jitter_us = std::max (max_abs_jitter_us, abs_jitter_us);
334334 jitter_abs_us.push (abs_jitter_us);
@@ -337,7 +337,7 @@ class MessageDiagnostics
337337 sum_jitter_abs_us -= jitter_abs_us.front ();
338338 jitter_abs_us.pop ();
339339 }
340- if (abs_jitter_us > static_cast < int64_t >( jitter_tolerance_us) ) {
340+ if (abs_jitter_us > jitter_tolerance_us) {
341341 ++outlier_count;
342342 return true ;
343343 }
@@ -357,7 +357,7 @@ class MessageDiagnostics
357357 int64_t meanAbsJitterUs () const
358358 {
359359 if (jitter_abs_us.empty ()) {
360- return 0 ;
360+ return 0LL ;
361361 }
362362 return sum_jitter_abs_us / static_cast <int64_t >(jitter_abs_us.size ());
363363 }
0 commit comments