Mirrors_Framework/rt-thread
1
0
Fork 0
mirror of https://github.com/RT-Thread/rt-thread.git synced 2026-02-07 18:02:15 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

[utest]: Modify the utest logic for thread allocation of idle harts

Browse Source 
Currently, this utest cannot determine whether threads are evenly distributed
across idle harts by observing the result of list_thread(). This is because
the presence of rt_thread_delay(5); causes all other threads to be in the
suspended state when thread information is printed. For example, if RT_CPUS_NR=4,
T0 executes list_thread() to print information, while T1~T3 are in hibernation
and thus it is impossible to observe which hart they are running on.

Solution:Here, the completion judgment condition has been modified. For example,
when RT_CPUS_NR=4, only RT_CPUS_NR-1 threads will be created (i.e., T0 to T2),
because running the utest occupies one hart. The execution is judged as completed
when finish_flag=0x0007, and the thread running the utest will call list_thread()
to print the information. Observe whether T0 to T2 are running on different
harts simultaneously.

Signed-off-by: Mengchen Teng <teng_mengchen@163.com>
This commit is contained in:
Tm-C-mT
2025-11-17 10:00:30 +08:00
committed by R b b666
parent 45f2246f73
commit 9308564a92
1 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/utest/smp/smp_assigned_idle_cores_tc.c
View File

@@ -21,24 +21,21 @@
#define THREAD_STACK_SIZE UTEST_THR_STACK_SIZE
#define THREAD_PRIORITY 20
static rt_thread_t threads[RT_CPUS_NR];
static int tick = 0, finsh_flag = 0;
static rt_thread_t threads[RT_CPUS_NR - 1];
static int tick = 0, finish_flag = 0;
static int num = 0;
/* thread entry function */
static void thread_entry(void *parameter)
{
int value = *(int *)parameter;
while (1)
{
tick++;
if (tick == 100)
if (tick >= 100 && (finish_flag & (1 << value)) == 0)
{
/* Output the current core running threads */
extern long list_thread(void);
list_thread();
finsh_flag = 0xA55A;
rt_atomic_or((volatile rt_atomic_t *)&finish_flag, (1 << value));
uassert_true(1);
}
rt_thread_delay(5);
}
}
@@ -54,8 +51,8 @@ static void thread_on_idle_core_tc(void)
params[i] = i;
}
/* Create RT_CPUS_NR threads and pass the entry parameters for each thread */
for (i = 0; i < RT_CPUS_NR; i++)
/* Create RT_CPUS_NR-1 threads and pass the entry parameters for each thread */
for (i = 0; i < RT_CPUS_NR - 1; i++)
{
rt_snprintf(thread_name, sizeof(thread_name), "T%d", i);
threads[i] = rt_thread_create(thread_name, thread_entry, &params[i], THREAD_STACK_SIZE, THREAD_PRIORITY, 20);
@@ -66,18 +63,23 @@ static void thread_on_idle_core_tc(void)
}
}
/* Waiting for test cases to finish */
while (finsh_flag != 0xA55A);
while (finish_flag != (1<<(RT_CPUS_NR-1))-1);
/* Output the current core running threads */
extern long list_thread(void);
list_thread();
}
static rt_err_t utest_tc_init(void)
{
finish_flag = 0;
tick = 0;
rt_kprintf("[Test case]: created threads are automatically assigned to run on idle cores\r\n");
return RT_EOK;
}
static rt_err_t utest_tc_cleanup(void)
{
for (num = 0; num < RT_CPUS_NR; num++)
for (num = 0; num < RT_CPUS_NR - 1; num++)
{
rt_thread_delete(threads[num]);
}
@@ -89,3 +91,4 @@ static void testcase(void)
UTEST_UNIT_RUN(thread_on_idle_core_tc);
}
UTEST_TC_EXPORT(testcase, "core.smp_assigned_idle_cores", utest_tc_init, utest_tc_cleanup, 10);