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 | /* * Copyright (c) 2016 Intel Corporation * * SPDX-License-Identifier: Apache-2.0 */ /** * @addtogroup t_sema_api * @{ * @defgroup t_sema_api_basic test_sema_api_basic * @brief TestPurpose: verify zephyr sema apis across different context * - API coverage * -# k_sem_init K_SEMA_DEFINE * -# k_sem_take k_sema_give k_sema_reset * -# k_sem_count_get * @} */ #include <ztest.h> #include <irq_offload.h> #define TIMEOUT 100 #define STACK_SIZE 512 #define SEM_INITIAL 0 #define SEM_LIMIT 2 /**TESTPOINT: init via K_SEM_DEFINE*/ K_SEM_DEFINE(ksema, SEM_INITIAL, SEM_LIMIT); static struct k_sem sema; static K_THREAD_STACK_DEFINE(tstack, STACK_SIZE); static struct k_thread tdata; /*entry of contexts*/ static void tisr_entry(void *p) { k_sem_give((struct k_sem *)p); } static void thread_entry(void *p1, void *p2, void *p3) { k_sem_give((struct k_sem *)p1); } static void tsema_thread_thread(struct k_sem *psem) { /**TESTPOINT: thread-thread sync via sema*/ k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, thread_entry, psem, NULL, NULL, K_PRIO_PREEMPT(0), 0, 0); zassert_false(k_sem_take(psem, K_FOREVER), NULL); /*clean the spawn thread avoid side effect in next TC*/ k_thread_abort(tid); } static void tsema_thread_isr(struct k_sem *psem) { /**TESTPOINT: thread-isr sync via sema*/ irq_offload(tisr_entry, psem); zassert_false(k_sem_take(psem, K_FOREVER), NULL); } /*test cases*/ void test_sema_thread2thread(void) { struct k_sem sema; /**TESTPOINT: test k_sem_init sema*/ k_sem_init(&sema, SEM_INITIAL, SEM_LIMIT); tsema_thread_thread(&sema); /**TESTPOINT: test K_SEM_DEFINE sema*/ tsema_thread_thread(&ksema); } void test_sema_thread2isr(void) { /**TESTPOINT: test k_sem_init sema*/ k_sem_init(&sema, SEM_INITIAL, SEM_LIMIT); tsema_thread_isr(&sema); /**TESTPOINT: test K_SEM_DEFINE sema*/ tsema_thread_isr(&ksema); } void test_sema_reset(void) { k_sem_init(&sema, SEM_INITIAL, SEM_LIMIT); k_sem_give(&sema); k_sem_reset(&sema); zassert_false(k_sem_count_get(&sema), NULL); /**TESTPOINT: sem take return -EBUSY*/ zassert_equal(k_sem_take(&sema, K_NO_WAIT), -EBUSY, NULL); /**TESTPOINT: sem take return -EAGAIN*/ zassert_equal(k_sem_take(&sema, TIMEOUT), -EAGAIN, NULL); k_sem_give(&sema); zassert_false(k_sem_take(&sema, K_FOREVER), NULL); } void test_sema_count_get(void) { k_sem_init(&sema, SEM_INITIAL, SEM_LIMIT); /**TESTPOINT: sem count get upon init*/ zassert_equal(k_sem_count_get(&sema), SEM_INITIAL, NULL); k_sem_give(&sema); /**TESTPOINT: sem count get after give*/ zassert_equal(k_sem_count_get(&sema), SEM_INITIAL + 1, NULL); k_sem_take(&sema, K_FOREVER); /**TESTPOINT: sem count get after take*/ for (int i = 0; i < SEM_LIMIT; i++) { zassert_equal(k_sem_count_get(&sema), SEM_INITIAL + i, NULL); k_sem_give(&sema); } /**TESTPOINT: sem give above limit*/ k_sem_give(&sema); zassert_equal(k_sem_count_get(&sema), SEM_LIMIT, NULL); } |