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 | /* * Copyright (c) 2016 Intel Corporation * * SPDX-License-Identifier: Apache-2.0 */ #include <ztest.h> #define TIMEOUT 500 #define STACK_SIZE (512 + CONFIG_TEST_EXTRA_STACKSIZE) /**TESTPOINT: init via K_MUTEX_DEFINE*/ K_MUTEX_DEFINE(kmutex); static struct k_mutex mutex; static K_THREAD_STACK_DEFINE(tstack, STACK_SIZE); static struct k_thread tdata; static void tThread_entry_lock_forever(void *p1, void *p2, void *p3) { zassert_false(k_mutex_lock((struct k_mutex *)p1, K_FOREVER) == 0, "access locked resource from spawn thread"); /* should not hit here */ } static void tThread_entry_lock_no_wait(void *p1, void *p2, void *p3) { zassert_true(k_mutex_lock((struct k_mutex *)p1, K_NO_WAIT) != 0, NULL); TC_PRINT("bypass locked resource from spawn thread\n"); } static void tThread_entry_lock_timeout_fail(void *p1, void *p2, void *p3) { zassert_true(k_mutex_lock((struct k_mutex *)p1, TIMEOUT - 100) != 0, NULL); TC_PRINT("bypass locked resource from spawn thread\n"); } static void tThread_entry_lock_timeout_pass(void *p1, void *p2, void *p3) { zassert_true(k_mutex_lock((struct k_mutex *)p1, TIMEOUT + 100) == 0, NULL); TC_PRINT("access resource from spawn thread\n"); k_mutex_unlock((struct k_mutex *)p1); } static void tmutex_test_lock(struct k_mutex *pmutex, void (*entry_fn)(void *, void *, void *)) { k_mutex_init(pmutex); k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, entry_fn, pmutex, NULL, NULL, K_PRIO_PREEMPT(0), 0, 0); k_mutex_lock(pmutex, K_FOREVER); TC_PRINT("access resource from main thread\n"); /* wait for spawn thread to take action */ k_sleep(TIMEOUT); /* teardown */ k_thread_abort(tid); } static void tmutex_test_lock_timeout(struct k_mutex *pmutex, void (*entry_fn)(void *, void *, void *)) { /**TESTPOINT: test k_mutex_init mutex*/ k_mutex_init(pmutex); k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, entry_fn, pmutex, NULL, NULL, K_PRIO_PREEMPT(0), 0, 0); k_mutex_lock(pmutex, K_FOREVER); TC_PRINT("access resource from main thread\n"); /* wait for spawn thread to take action */ k_sleep(TIMEOUT); k_mutex_unlock(pmutex); k_sleep(TIMEOUT); /* teardown */ k_thread_abort(tid); } static void tmutex_test_lock_unlock(struct k_mutex *pmutex) { k_mutex_init(pmutex); zassert_true(k_mutex_lock(pmutex, K_FOREVER) == 0, "fail to lock K_FOREVER"); k_mutex_unlock(pmutex); zassert_true(k_mutex_lock(pmutex, K_NO_WAIT) == 0, "fail to lock K_NO_WAIT"); k_mutex_unlock(pmutex); zassert_true(k_mutex_lock(pmutex, TIMEOUT) == 0, "fail to lock TIMEOUT"); k_mutex_unlock(pmutex); } /*test cases*/ void test_mutex_reent_lock_forever(void) { /**TESTPOINT: test k_mutex_init mutex*/ k_mutex_init(&mutex); tmutex_test_lock(&mutex, tThread_entry_lock_forever); /**TESTPOINT: test K_MUTEX_DEFINE mutex*/ tmutex_test_lock(&kmutex, tThread_entry_lock_forever); } void test_mutex_reent_lock_no_wait(void) { /**TESTPOINT: test k_mutex_init mutex*/ tmutex_test_lock(&mutex, tThread_entry_lock_no_wait); /**TESTPOINT: test K_MUTEX_DEFINE mutex*/ tmutex_test_lock(&kmutex, tThread_entry_lock_no_wait); } void test_mutex_reent_lock_timeout_fail(void) { /**TESTPOINT: test k_mutex_init mutex*/ tmutex_test_lock_timeout(&mutex, tThread_entry_lock_timeout_fail); /**TESTPOINT: test K_MUTEX_DEFINE mutex*/ tmutex_test_lock_timeout(&kmutex, tThread_entry_lock_no_wait); } void test_mutex_reent_lock_timeout_pass(void) { /**TESTPOINT: test k_mutex_init mutex*/ tmutex_test_lock_timeout(&mutex, tThread_entry_lock_timeout_pass); /**TESTPOINT: test K_MUTEX_DEFINE mutex*/ tmutex_test_lock_timeout(&kmutex, tThread_entry_lock_no_wait); } void test_mutex_lock_unlock(void) { /**TESTPOINT: test k_mutex_init mutex*/ tmutex_test_lock_unlock(&mutex); /**TESTPOINT: test K_MUTEX_DEFINE mutex*/ tmutex_test_lock_unlock(&kmutex); } |