tests: zbus: publish_stats: test zbus_chan_pub_stats_data_age

Test the behaviour of `zbus_chan_pub_stats_data_age`.

Signed-off-by: Jordan Yates <jordan@embeint.com>

Author: JordanYates

tests/subsys/zbus/publish_stats/src/main.c

@@ -23,18 +23,21 @@ ZTEST(publish_stats, test_channel_metadata)
 	zassert_equal(0, zbus_chan_pub_stats_count(&chan));
 	zassert_equal(0, zbus_chan_pub_stats_last_time(&chan));
 	zassert_equal(0, zbus_chan_pub_stats_avg_period(&chan));
+	zassert_equal(UINT64_MAX, zbus_chan_pub_stats_msg_age(&chan));
 
 	/* Should be no different after a second of runtime */
 	k_sleep(K_TIMEOUT_ABS_MS(1000));
 	zassert_equal(0, zbus_chan_pub_stats_count(&chan));
 	zassert_equal(0, zbus_chan_pub_stats_last_time(&chan));
 	zassert_equal(0, zbus_chan_pub_stats_avg_period(&chan));
+	zassert_equal(UINT64_MAX, zbus_chan_pub_stats_msg_age(&chan));
 
 	/* Normal publish */
 	zassert_equal(0, zbus_chan_pub(&chan, &val, K_NO_WAIT));
 	zassert_equal(1, zbus_chan_pub_stats_count(&chan));
 	zassert_within(k_uptime_ticks(), zbus_chan_pub_stats_last_time(&chan), clock_window);
 	zassert_within(1000, zbus_chan_pub_stats_avg_period(&chan), 50);
+	zassert_equal(0, zbus_chan_pub_stats_msg_age(&chan));
 
 	/* Push 4 times in quick succession, wait for 2 second boundary */
 	for (int i = 0; i < 4; i++) {
@@ -45,24 +48,28 @@ ZTEST(publish_stats, test_channel_metadata)
 	zassert_equal(5, zbus_chan_pub_stats_count(&chan));
 	zassert_within(pub_time, zbus_chan_pub_stats_last_time(&chan), clock_window);
 	zassert_within(400, zbus_chan_pub_stats_avg_period(&chan), 50);
+	zassert_within(1000, zbus_chan_pub_stats_msg_age(&chan), clock_window);
 
 	/* Channel claim and finish does not update metadata by default */
 	zassert_equal(0, zbus_chan_claim(&chan, K_NO_WAIT));
 	zassert_equal(0, zbus_chan_finish(&chan));
+	zassert_within(1000, zbus_chan_pub_stats_msg_age(&chan), clock_window);
 
 	zassert_equal(0, zbus_chan_claim(&chan, K_NO_WAIT));
 	cval = zbus_chan_msg(&chan);
 	cval->x = 1000;
 	zassert_equal(0, zbus_chan_finish(&chan));
 	zassert_equal(5, zbus_chan_pub_stats_count(&chan));
 	zassert_within(pub_time, zbus_chan_pub_stats_last_time(&chan), clock_window);
+	zassert_within(1000, zbus_chan_pub_stats_msg_age(&chan), clock_window);
 
 	/* Channel notify does not update metadata */
 	for (int i = 0; i < 10; i++) {
 		zassert_equal(0, zbus_chan_notify(&chan, K_NO_WAIT));
 	}
 	zassert_equal(5, zbus_chan_pub_stats_count(&chan));
 	zassert_within(pub_time, zbus_chan_pub_stats_last_time(&chan), clock_window);
+	zassert_within(1000, zbus_chan_pub_stats_msg_age(&chan), clock_window);
 
 	/* Manually update publish statistics with claim */
 	zassert_equal(0, zbus_chan_claim(&chan, K_NO_WAIT));
@@ -74,6 +81,10 @@ ZTEST(publish_stats, test_channel_metadata)
 	zassert_equal(6, zbus_chan_pub_stats_count(&chan));
 	zassert_within(pub_time, zbus_chan_pub_stats_last_time(&chan), clock_window);
 	zassert_within(500, zbus_chan_pub_stats_avg_period(&chan), 50);
+	zassert_within(1000, zbus_chan_pub_stats_msg_age(&chan), clock_window);
+
+	k_sleep(K_TIMEOUT_ABS_MS(5000));
+	zassert_within(3000, zbus_chan_pub_stats_msg_age(&chan), clock_window);
 }
 
 ZTEST_SUITE(publish_stats, NULL, NULL, NULL, NULL, NULL);