Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 | /* * Copyright (c) 2016 Intel Corporation * * SPDX-License-Identifier: Apache-2.0 */ #include <ztest.h> #include "tests_thread_apis.h" static ZTEST_BMEM int execute_flag; K_SEM_DEFINE(sync_sema, 0, 1); #define BLOCK_SIZE 64 static void thread_entry(void *p1, void *p2, void *p3) { execute_flag = 1; k_sleep(K_MSEC(100)); execute_flag = 2; } static void thread_entry_abort(void *p1, void *p2, void *p3) { /**TESTPOINT: abort current thread*/ execute_flag = 1; k_thread_abort(k_current_get()); /*unreachable*/ execute_flag = 2; zassert_true(1 == 0, NULL); } /** * @ingroup kernel_thread_tests * @brief Validate k_thread_abort() when called by current thread * * @details Create a user thread and let the thread execute. * Then call k_thread_abort() and check if the thread is terminated. * Here the main thread is also a user thread. * * @see k_thread_abort() */ void test_threads_abort_self(void) { execute_flag = 0; k_thread_create(&tdata, tstack, STACK_SIZE, thread_entry_abort, NULL, NULL, NULL, 0, K_USER, K_NO_WAIT); k_sleep(K_MSEC(100)); /**TESTPOINT: spawned thread executed but abort itself*/ zassert_true(execute_flag == 1, NULL); } /** * @ingroup kernel_thread_tests * @brief Validate k_thread_abort() when called by other thread * * @details Create a user thread and abort the thread before its * execution. Create a another user thread and abort the thread * after it has started. * * @see k_thread_abort() */ void test_threads_abort_others(void) { execute_flag = 0; k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, thread_entry, NULL, NULL, NULL, 0, K_USER, K_NO_WAIT); k_thread_abort(tid); k_sleep(K_MSEC(100)); /**TESTPOINT: check not-started thread is aborted*/ zassert_true(execute_flag == 0, NULL); tid = k_thread_create(&tdata, tstack, STACK_SIZE, thread_entry, NULL, NULL, NULL, 0, K_USER, K_NO_WAIT); k_sleep(K_MSEC(50)); k_thread_abort(tid); /**TESTPOINT: check running thread is aborted*/ zassert_true(execute_flag == 1, NULL); k_sleep(K_MSEC(1000)); zassert_true(execute_flag == 1, NULL); } /** * @ingroup kernel_thread_tests * @brief Test abort on a terminated thread * * @see k_thread_abort() */ void test_threads_abort_repeat(void) { execute_flag = 0; k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, thread_entry, NULL, NULL, NULL, 0, K_USER, K_NO_WAIT); k_thread_abort(tid); k_sleep(K_MSEC(100)); k_thread_abort(tid); k_sleep(K_MSEC(100)); k_thread_abort(tid); /* If no fault occurred till now. The test case passed. */ ztest_test_pass(); } bool abort_called; void *block; static void abort_function(void) { printk("Child thread's abort handler called\n"); abort_called = true; k_free(block); } static void uthread_entry(void) { block = k_malloc(BLOCK_SIZE); zassert_true(block != NULL, NULL); printk("Child thread is running\n"); k_sleep(K_MSEC(2)); } /** * @ingroup kernel_thread_tests * @brief Test to validate the call of abort handler * specified by thread when it is aborted * * @see k_thread_abort(), #k_thread.fn_abort */ void test_abort_handler(void) { k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, (k_thread_entry_t)uthread_entry, NULL, NULL, NULL, 0, 0, K_NO_WAIT); tdata.fn_abort = &abort_function; k_sleep(K_MSEC(1)); abort_called = false; printk("Calling abort of child from parent\n"); k_thread_abort(tid); zassert_true(abort_called == true, "Abort handler" " is not called"); } static void delayed_thread_entry(void *p1, void *p2, void *p3) { execute_flag = 1; zassert_unreachable("Delayed thread shouldn't be executed"); } /** * @ingroup kernel_thread_tests * @brief Test abort on delayed thread before it has started * execution * * @see k_thread_abort() */ void test_delayed_thread_abort(void) { int current_prio = k_thread_priority_get(k_current_get()); /* Make current thread preemptive */ k_thread_priority_set(k_current_get(), K_PRIO_PREEMPT(2)); /* Create a preemptive thread of higher priority than * current thread */ k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, (k_thread_entry_t)delayed_thread_entry, NULL, NULL, NULL, K_PRIO_PREEMPT(1), 0, K_MSEC(100)); /* Give up CPU */ k_sleep(K_MSEC(50)); /* Test point: check if thread delayed for 100ms has not started*/ zassert_true(execute_flag == 0, "Delayed thread created is not" " put to wait queue"); k_thread_abort(tid); /* Test point: Test abort of thread before its execution*/ zassert_false(execute_flag == 1, "Delayed thread is has executed" " before cancellation"); /* Restore the priority */ k_thread_priority_set(k_current_get(), current_prio); } |