michaelh/zephyr
1
0
Fork 0
Code Releases Activity

samples: subsys: zbus: benchmark: use native posix host rtc for ARCH_POSIX

Browse source 
Because posix emulated execution is significantly faster than posix
emulated timer and benchmark finishes before even the first tick occurs.

Signed-off-by: Alp Sayin <alp.sayin@amd.com>
This commit is contained in:
Alp Sayin 2023-01-09 08:20:24 +00:00 • committed by Carles Cufí
commit f5c39f998c
1 changed files with 12 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

15
samples/subsys/zbus/benchmark/src/benchmark.c
View file

@ -11,6 +11,14 @@
#include <zephyr/logging/log.h> #include <zephyr/logging/log.h>
#include <zephyr/sys/util_macro.h> #include <zephyr/sys/util_macro.h>
#include <zephyr/zbus/zbus.h> #include <zephyr/zbus/zbus.h>
#if defined(CONFIG_ARCH_POSIX)
#include "native_rtc.h"
#define GET_ARCH_TIME_NS() (native_rtc_gettime_us(RTC_CLOCK_PSEUDOHOSTREALTIME) * NSEC_PER_USEC)
#else
#define GET_ARCH_TIME_NS() (k_cyc_to_ns_near32(sys_clock_cycle_get_32()))
#endif
LOG_MODULE_DECLARE(zbus, CONFIG_ZBUS_LOG_LEVEL); LOG_MODULE_DECLARE(zbus, CONFIG_ZBUS_LOG_LEVEL);
#define CONSUMER_STACK_SIZE (CONFIG_IDLE_STACK_SIZE + CONFIG_BM_MESSAGE_SIZE) #define CONSUMER_STACK_SIZE (CONFIG_IDLE_STACK_SIZE + CONFIG_BM_MESSAGE_SIZE)
@ -185,7 +193,7 @@ static void producer_thread(void)
zbus_chan_finish(&bm_channel); zbus_chan_finish(&bm_channel);
uint32_t start_ns = k_cyc_to_ns_near32(sys_clock_cycle_get_32()); uint32_t start_ns = GET_ARCH_TIME_NS();
for (uint64_t internal_count = BYTES_TO_BE_SENT / CONFIG_BM_ONE_TO; internal_count > 0; for (uint64_t internal_count = BYTES_TO_BE_SENT / CONFIG_BM_ONE_TO; internal_count > 0;
internal_count -= CONFIG_BM_MESSAGE_SIZE) { internal_count -= CONFIG_BM_MESSAGE_SIZE) {
@ -200,7 +208,7 @@ static void producer_thread(void)
zbus_chan_notify(&bm_channel, K_MSEC(200)); zbus_chan_notify(&bm_channel, K_MSEC(200));
} }
uint32_t end_ns = k_cyc_to_ns_near32(sys_clock_cycle_get_32()); uint32_t end_ns = GET_ARCH_TIME_NS();
uint32_t duration = end_ns - start_ns; uint32_t duration = end_ns - start_ns;
@ -218,4 +226,5 @@ static void producer_thread(void)
printk("\n@%u\n", duration); printk("\n@%u\n", duration);
} }
K_THREAD_DEFINE(producer_thread_id, PRODUCER_STACK_SIZE, producer_thread, NULL, NULL, NULL, 5, 0, 0); K_THREAD_DEFINE(producer_thread_id, PRODUCER_STACK_SIZE, producer_thread,
NULL, NULL, NULL, 5, 0, 0);