116 lines
2.8 KiB
C
116 lines
2.8 KiB
C
|
/*
|
||
|
|
* Copyright (c) 2019 - 2020 Nordic Semiconductor ASA
|
||
|
|
*
|
||
|
|
* SPDX-License-Identifier: Apache-2.0
|
||
|
|
*/
|
||
|
|
|
||
|
|
/** @file
|
||
|
|
* @brief Thread analyzer implementation
|
||
|
|
*/
|
||
|
|
|
||
|
|
#include <kernel.h>
|
||
|
|
#include <debug/thread_analyzer.h>
|
||
|
|
#include <debug/stack.h>
|
||
|
|
#include <kernel.h>
|
||
|
|
#include <logging/log.h>
|
||
|
|
#include <stdio.h>
|
||
|
|
|
||
|
|
LOG_MODULE_REGISTER(thread_analyzer, CONFIG_THREAD_ANALYZER_LOG_LEVEL);
|
||
|
|
|
||
|
|
#if IS_ENABLED(CONFIG_THREAD_ANALYZER_USE_PRINTK)
|
||
|
|
#define THREAD_ANALYZER_PRINT(...) printk(__VA_ARGS__)
|
||
|
|
#define THREAD_ANALYZER_FMT(str) str "\n"
|
||
|
|
#define THREAD_ANALYZER_VSTR(str) (str)
|
||
|
|
#else
|
||
|
|
#define THREAD_ANALYZER_PRINT(...) LOG_INF(__VA_ARGS__)
|
||
|
|
#define THREAD_ANALYZER_FMT(str) str
|
||
|
|
#define THREAD_ANALYZER_VSTR(str) log_strdup(str)
|
||
|
|
#endif
|
||
|
|
|
||
|
|
/* @brief Maximum length of the pointer when converted to string
|
||
|
|
*
|
||
|
|
* Pointer is converted to string in hexadecimal form.
|
||
|
|
* It would use 2 hex digits for every single byte of the pointer
|
||
|
|
* but some implementations adds 0x prefix when used with %p format option.
|
||
|
|
*/
|
||
|
|
#define PTR_STR_MAXLEN (sizeof(void *) * 2 + 2)
|
||
|
|
|
||
|
|
static void thread_print_cb(struct thread_analyzer_info *info)
|
||
|
|
{
|
||
|
|
unsigned int pcnt = (info->stack_used * 100U) / info->stack_size;
|
||
|
|
|
||
|
|
THREAD_ANALYZER_PRINT(
|
||
|
|
THREAD_ANALYZER_FMT(
|
||
|
|
" %-20s: unused %zu usage %zu / %zu (%zu %%)"),
|
||
|
|
THREAD_ANALYZER_VSTR(info->name),
|
||
|
|
info->stack_size - info->stack_used, info->stack_used,
|
||
|
|
info->stack_size, pcnt);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void thread_analyze_cb(const struct k_thread *cthread, void *user_data)
|
||
|
|
{
|
||
|
|
struct k_thread *thread = (struct k_thread *)cthread;
|
||
|
|
size_t size = thread->stack_info.size;
|
||
|
|
thread_analyzer_cb cb = user_data;
|
||
|
|
struct thread_analyzer_info info;
|
||
|
|
char hexname[PTR_STR_MAXLEN + 1];
|
||
|
|
const char *name;
|
||
|
|
size_t unused;
|
||
|
|
int err;
|
||
|
|
|
||
|
|
name = k_thread_name_get((k_tid_t)thread);
|
||
|
|
if (!name || name[0] == '\0') {
|
||
|
|
name = hexname;
|
||
|
|
sprintf(hexname, "%p", (void *)thread);
|
||
|
|
}
|
||
|
|
|
||
|
|
err = k_thread_stack_space_get(thread, &unused);
|
||
|
|
if (err) {
|
||
|
|
THREAD_ANALYZER_PRINT(
|
||
|
|
THREAD_ANALYZER_FMT(
|
||
|
|
" %-20s: unable to get stack space (%d)"),
|
||
|
|
name, err);
|
||
|
|
|
||
|
|
unused = 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
info.name = name;
|
||
|
|
info.stack_size = size;
|
||
|
|
info.stack_used = size - unused;
|
||
|
|
cb(&info);
|
||
|
|
}
|
||
|
|
|
||
|
|
void thread_analyzer_run(thread_analyzer_cb cb)
|
||
|
|
{
|
||
|
|
if (IS_ENABLED(CONFIG_THREAD_ANALYZER_RUN_UNLOCKED)) {
|
||
|
|
k_thread_foreach_unlocked(thread_analyze_cb, cb);
|
||
|
|
} else {
|
||
|
|
k_thread_foreach(thread_analyze_cb, cb);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
void thread_analyzer_print(void)
|
||
|
|
{
|
||
|
|
THREAD_ANALYZER_PRINT(THREAD_ANALYZER_FMT("Thread analyze:"));
|
||
|
|
thread_analyzer_run(thread_print_cb);
|
||
|
|
}
|
||
|
|
|
||
|
|
#if IS_ENABLED(CONFIG_THREAD_ANALYZER_AUTO)
|
||
|
|
|
||
|
|
void thread_analyzer_auto(void)
|
||
|
|
{
|
||
|
|
for (;;) {
|
||
|
|
thread_analyzer_print();
|
||
|
|
k_sleep(K_SECONDS(CONFIG_THREAD_ANALYZER_AUTO_INTERVAL));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
K_THREAD_DEFINE(thread_analyzer,
|
||
|
|
CONFIG_THREAD_ANALYZER_AUTO_STACK_SIZE,
|
||
|
|
thread_analyzer_auto,
|
||
|
|
NULL, NULL, NULL,
|
||
|
|
K_LOWEST_APPLICATION_THREAD_PRIO,
|
||
|
|
0, 0);
|
||
|
|
|
||
|
|
#endif
|