Revert "tests: logging: Add stress test"
This reverts commit 12f9b4b31c.
Signed-off-by: Anas Nashif <anas.nashif@intel.com>
This commit is contained in:
Anas Nashif
parent
85c4f5dd55
commit
b4d28a8186
4 changed files with 0 additions and 332 deletions
|
|
@ -1,7 +0,0 @@
|
||||||
# SPDX-License-Identifier: Apache-2.0
|
|
||||||
|
|
||||||
cmake_minimum_required(VERSION 3.20.0)
|
|
||||||
find_package(Zephyr REQUIRED HINTS $ENV{ZEPHYR_BASE})
|
|
||||||
project(log_core)
|
|
||||||
|
|
||||||
target_sources(app PRIVATE src/main.c)
|
|
||||||
|
|
@ -1,22 +0,0 @@
|
||||||
CONFIG_ZTEST=y
|
|
||||||
CONFIG_ZTRESS=y
|
|
||||||
|
|
||||||
CONFIG_TEST_LOGGING_DEFAULTS=n
|
|
||||||
CONFIG_LOG=y
|
|
||||||
CONFIG_LOG_PRINTK=n
|
|
||||||
CONFIG_LOG_BUFFER_SIZE=512
|
|
||||||
CONFIG_ASSERT=y
|
|
||||||
CONFIG_MAIN_STACK_SIZE=2048
|
|
||||||
|
|
||||||
# Disable any logs that could interfere.
|
|
||||||
CONFIG_KERNEL_LOG_LEVEL_OFF=y
|
|
||||||
CONFIG_SOC_LOG_LEVEL_OFF=y
|
|
||||||
CONFIG_ARCH_LOG_LEVEL_OFF=y
|
|
||||||
CONFIG_LOG_FUNC_NAME_PREFIX_DBG=n
|
|
||||||
CONFIG_LOG_PROCESS_THREAD=y
|
|
||||||
|
|
||||||
# Disable all potential default backends
|
|
||||||
CONFIG_LOG_BACKEND_UART=n
|
|
||||||
CONFIG_LOG_BACKEND_NATIVE_POSIX=n
|
|
||||||
CONFIG_LOG_BACKEND_RTT=n
|
|
||||||
CONFIG_LOG_BACKEND_XTENSA_SIM=n
|
|
||||||
|
|
@ -1,241 +0,0 @@
|
||||||
/*
|
|
||||||
* Copyright (c) 2022 Nordic Semiconductor ASA
|
|
||||||
*
|
|
||||||
* SPDX-License-Identifier: Apache-2.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
#include <ztest.h>
|
|
||||||
#include <sys/util.h>
|
|
||||||
#include <string.h>
|
|
||||||
#include <ztress.h>
|
|
||||||
#include <random/rand32.h>
|
|
||||||
#include <logging/log.h>
|
|
||||||
#include <logging/log_ctrl.h>
|
|
||||||
#include <logging/log_backend.h>
|
|
||||||
|
|
||||||
#define MODULE_NAME test
|
|
||||||
|
|
||||||
LOG_MODULE_REGISTER(MODULE_NAME);
|
|
||||||
|
|
||||||
static uint32_t test_source_id;
|
|
||||||
|
|
||||||
#define CNT_BITS 28
|
|
||||||
|
|
||||||
struct mock_log_backend {
|
|
||||||
uint32_t last_id[16];
|
|
||||||
uint32_t cnt[16];
|
|
||||||
uint32_t dropped;
|
|
||||||
uint32_t missing;
|
|
||||||
};
|
|
||||||
|
|
||||||
static struct mock_log_backend mock_backend;
|
|
||||||
static uint32_t log_process_delay = 10;
|
|
||||||
|
|
||||||
static int16_t log_source_id_get(const char *name)
|
|
||||||
{
|
|
||||||
|
|
||||||
for (int16_t i = 0; i < log_src_cnt_get(CONFIG_LOG_DOMAIN_ID); i++) {
|
|
||||||
if (strcmp(log_source_name_get(CONFIG_LOG_DOMAIN_ID, i), name)
|
|
||||||
== 0) {
|
|
||||||
return i;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void handle_msg(uint32_t arg0)
|
|
||||||
{
|
|
||||||
uint32_t ctx_id = arg0 >> CNT_BITS;
|
|
||||||
uint32_t id = arg0 & BIT_MASK(CNT_BITS);
|
|
||||||
int off = id - mock_backend.last_id[ctx_id] - 1;
|
|
||||||
|
|
||||||
mock_backend.cnt[ctx_id]++;
|
|
||||||
|
|
||||||
k_busy_wait(log_process_delay);
|
|
||||||
|
|
||||||
if (off > 0) {
|
|
||||||
mock_backend.missing += off;
|
|
||||||
}
|
|
||||||
|
|
||||||
mock_backend.last_id[ctx_id] = id;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void put(const struct log_backend *const backend,
|
|
||||||
struct log_msg *msg)
|
|
||||||
{
|
|
||||||
/* Test expects that no other module will log at the time of the test. */
|
|
||||||
zassert_equal(log_msg_source_id_get(msg), test_source_id, NULL);
|
|
||||||
|
|
||||||
log_msg_get(msg);
|
|
||||||
|
|
||||||
handle_msg((uint32_t)log_msg_arg_get(msg, 0));
|
|
||||||
|
|
||||||
log_msg_put(msg);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void process(const struct log_backend *const backend,
|
|
||||||
union log_msg2_generic *msg)
|
|
||||||
{
|
|
||||||
size_t len;
|
|
||||||
uint8_t *package = log_msg2_get_package(&msg->log, &len);
|
|
||||||
|
|
||||||
package += 2 * sizeof(void *);
|
|
||||||
|
|
||||||
handle_msg(*(uint32_t *)package);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void mock_init(struct log_backend const *const backend)
|
|
||||||
{
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
static void panic(struct log_backend const *const backend)
|
|
||||||
{
|
|
||||||
zassert_true(false, NULL);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void dropped(const struct log_backend *const backend, uint32_t cnt)
|
|
||||||
{
|
|
||||||
mock_backend.dropped += cnt;
|
|
||||||
}
|
|
||||||
|
|
||||||
static const struct log_backend_api log_backend_api = {
|
|
||||||
.process = IS_ENABLED(CONFIG_LOG2) ? process : NULL,
|
|
||||||
.put = IS_ENABLED(CONFIG_LOG1_DEFERRED) ? put : NULL,
|
|
||||||
.panic = panic,
|
|
||||||
.init = mock_init,
|
|
||||||
.dropped = IS_ENABLED(CONFIG_LOG_MODE_DEFERRED) ? dropped : NULL,
|
|
||||||
};
|
|
||||||
|
|
||||||
LOG_BACKEND_DEFINE(test, log_backend_api, true, NULL);
|
|
||||||
|
|
||||||
static void validate(int ctx_cnt)
|
|
||||||
{
|
|
||||||
uint64_t in_cnt = 0;
|
|
||||||
uint64_t out_cnt = 0;
|
|
||||||
|
|
||||||
for (int i = 0; i < ctx_cnt; i++) {
|
|
||||||
/* First exectution skips (-1) but there is one final round of logging
|
|
||||||
* when ztress execution is completed (+1).
|
|
||||||
*/
|
|
||||||
in_cnt += ztress_exec_count(i) - 1 + 1;
|
|
||||||
out_cnt += mock_backend.cnt[i];
|
|
||||||
}
|
|
||||||
|
|
||||||
out_cnt += mock_backend.dropped;
|
|
||||||
|
|
||||||
zassert_equal(mock_backend.dropped, mock_backend.missing,
|
|
||||||
"dropped:%u missing:%u",
|
|
||||||
mock_backend.dropped, mock_backend.missing);
|
|
||||||
zassert_equal(in_cnt, out_cnt, NULL);
|
|
||||||
}
|
|
||||||
|
|
||||||
static bool context_handler(void *user_data, uint32_t cnt, bool last, int prio)
|
|
||||||
{
|
|
||||||
/* Skip first execution to start from id = 1. That simplifies handling in
|
|
||||||
* the backend and validation of message.
|
|
||||||
*/
|
|
||||||
if (cnt == 0) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
uint32_t i = cnt | (prio << CNT_BITS);
|
|
||||||
|
|
||||||
switch (sys_rand32_get() % 4) {
|
|
||||||
case 0:
|
|
||||||
LOG_INF("%u", i);
|
|
||||||
break;
|
|
||||||
case 1:
|
|
||||||
LOG_INF("%u %u %u %u", i, 1, 2, 3);
|
|
||||||
break;
|
|
||||||
case 2:
|
|
||||||
{
|
|
||||||
char test_str[] = "test string";
|
|
||||||
#ifdef CONFIG_BOARD_NATIVE_POSIX
|
|
||||||
/* native posix has no detection for rodata */
|
|
||||||
LOG_INF("%u %s %s", i, log_strdup("test"), log_strdup(test_str));
|
|
||||||
#else
|
|
||||||
LOG_INF("%u %s %s", i, "test", log_strdup(test_str));
|
|
||||||
#endif
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
default:
|
|
||||||
LOG_INF("%u %d", i, 100);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
static int get_test_timeout(void)
|
|
||||||
{
|
|
||||||
if (IS_ENABLED(CONFIG_BOARD_QEMU_CORTEX_A9)) {
|
|
||||||
/* Emulation for that target is extremely slow. */
|
|
||||||
return 500;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (IS_ENABLED(CONFIG_BOARD_QEMU_X86)) {
|
|
||||||
/* Emulation for that target is very fast. */
|
|
||||||
return 10000;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (IS_ENABLED(CONFIG_BOARD_QEMU_X86_64)) {
|
|
||||||
/* Emulation for that target is very fast. */
|
|
||||||
return 10000;
|
|
||||||
}
|
|
||||||
|
|
||||||
return 5000;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void test_stress(uint32_t delay)
|
|
||||||
{
|
|
||||||
uint32_t preempt = 2000;
|
|
||||||
uint32_t ctx_cnt = 3;
|
|
||||||
|
|
||||||
memset(&mock_backend, 0, sizeof(mock_backend));
|
|
||||||
log_process_delay = delay;
|
|
||||||
ztress_set_timeout(K_MSEC(get_test_timeout()));
|
|
||||||
ZTRESS_EXECUTE(
|
|
||||||
ZTRESS_TIMER(context_handler, NULL, 0, Z_TIMEOUT_TICKS(30)),
|
|
||||||
ZTRESS_THREAD(context_handler, NULL, 0, preempt, Z_TIMEOUT_TICKS(30)),
|
|
||||||
ZTRESS_THREAD(context_handler, NULL, 0, preempt, Z_TIMEOUT_TICKS(30)));
|
|
||||||
|
|
||||||
while (log_data_pending()) {
|
|
||||||
k_msleep(200);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Log last messages, they should not be dropped as all messages are processed earlier. */
|
|
||||||
for (int i = 0; i < ctx_cnt; i++) {
|
|
||||||
uint32_t data = (i << CNT_BITS) | ztress_exec_count(i);
|
|
||||||
|
|
||||||
LOG_INF("%u", data);
|
|
||||||
}
|
|
||||||
|
|
||||||
while (log_data_pending()) {
|
|
||||||
k_msleep(100);
|
|
||||||
}
|
|
||||||
|
|
||||||
validate(ctx_cnt);
|
|
||||||
}
|
|
||||||
|
|
||||||
void test_stress_fast_processing(void)
|
|
||||||
{
|
|
||||||
test_stress(10);
|
|
||||||
}
|
|
||||||
|
|
||||||
void test_stress_slow_processing(void)
|
|
||||||
{
|
|
||||||
test_stress(100);
|
|
||||||
}
|
|
||||||
|
|
||||||
void test_main(void)
|
|
||||||
{
|
|
||||||
test_source_id = log_source_id_get(STRINGIFY(MODULE_NAME));
|
|
||||||
|
|
||||||
ztest_test_suite(test_log_stress,
|
|
||||||
ztest_unit_test(test_stress_fast_processing),
|
|
||||||
ztest_unit_test(test_stress_slow_processing)
|
|
||||||
);
|
|
||||||
ztest_run_test_suite(test_log_stress);
|
|
||||||
}
|
|
||||||
|
|
@ -1,62 +0,0 @@
|
||||||
common:
|
|
||||||
filter: CONFIG_QEMU_TARGET and not CONFIG_SMP
|
|
||||||
tags: log_api logging
|
|
||||||
integration_platforms:
|
|
||||||
- qemu_x86
|
|
||||||
tests:
|
|
||||||
logging.log_stress_light_v1:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG1=y
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=y
|
|
||||||
- CONFIG_LOG_STRDUP_BUF_COUNT=1
|
|
||||||
- CONFIG_LOG_STRDUP_MAX_STRING=8
|
|
||||||
logging.log_stress_light_v1_no_overflow:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG1=y
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=n
|
|
||||||
- CONFIG_LOG_STRDUP_BUF_COUNT=1
|
|
||||||
- CONFIG_LOG_STRDUP_MAX_STRING=8
|
|
||||||
logging.log_stress_light_v2:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=y
|
|
||||||
logging.log_stress_light_v2_no_overflow:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=n
|
|
||||||
logging.log_stress_v1:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG1=y
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_STRDUP_BUF_COUNT=1
|
|
||||||
- CONFIG_LOG_STRDUP_MAX_STRING=8
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=y
|
|
||||||
- CONFIG_SYS_CLOCK_TICKS_PER_SEC=100000
|
|
||||||
platform_allow: qemu_x86 qemu_riscv32 qemu_cortex_m3 qemu_cortex_a9
|
|
||||||
qemu_x86_64
|
|
||||||
logging.log_stress_v1_no_overflow:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG1=y
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_STRDUP_BUF_COUNT=1
|
|
||||||
- CONFIG_LOG_STRDUP_MAX_STRING=8
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=n
|
|
||||||
- CONFIG_SYS_CLOCK_TICKS_PER_SEC=100000
|
|
||||||
platform_allow: qemu_x86 qemu_riscv32 qemu_cortex_m3 qemu_cortex_a9
|
|
||||||
qemu_x86_64
|
|
||||||
logging.log_stress_v2:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=y
|
|
||||||
- CONFIG_SYS_CLOCK_TICKS_PER_SEC=100000
|
|
||||||
platform_allow: qemu_x86 qemu_riscv32 qemu_cortex_m3 qemu_cortex_a9
|
|
||||||
qemu_x86_64
|
|
||||||
logging.log_stress_v2_no_overflow:
|
|
||||||
extra_configs:
|
|
||||||
- CONFIG_LOG_MODE_DEFERRED=y
|
|
||||||
- CONFIG_LOG_MODE_OVERFLOW=n
|
|
||||||
- CONFIG_SYS_CLOCK_TICKS_PER_SEC=100000
|
|
||||||
platform_allow: qemu_x86 qemu_riscv32 qemu_cortex_m3 qemu_cortex_a9
|
|
||||||
qemu_x86_64
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue