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 | /* * Copyright (c) 2016 Intel Corporation * * SPDX-License-Identifier: Apache-2.0 */ /** * @addtogroup t_kernel_msgq * @{ * @defgroup t_msgq_context test_msgq_context * @brief TestPurpose: verify zephyr msgq apis across contexts * @} */ #include "test_msgq.h" /**TESTPOINT: init via K_MSGQ_DEFINE*/ K_MSGQ_DEFINE(kmsgq, MSG_SIZE, MSGQ_LEN, 4); static char __noinit __stack tstack[STACK_SIZE]; static char __aligned(4) tbuffer[MSG_SIZE * MSGQ_LEN]; static uint32_t data[MSGQ_LEN] = { MSG0, MSG1 }; static struct k_sem end_sema; static void put_msgq(struct k_msgq *pmsgq) { int ret; for (int i = 0; i < MSGQ_LEN; i++) { ret = k_msgq_put(pmsgq, (void *)&data[i], K_NO_WAIT); assert_false(ret, NULL); /**TESTPOINT: msgq free get*/ assert_equal(k_msgq_num_free_get(pmsgq), MSGQ_LEN - 1 - i, NULL); /**TESTPOINT: msgq used get*/ assert_equal(k_msgq_num_used_get(pmsgq), i + 1, NULL); } } static void get_msgq(struct k_msgq *pmsgq) { uint32_t rx_data; int ret; for (int i = 0; i < MSGQ_LEN; i++) { ret = k_msgq_get(pmsgq, &rx_data, K_FOREVER); assert_false(ret, NULL); assert_equal(rx_data, data[i], NULL); /**TESTPOINT: msgq free get*/ assert_equal(k_msgq_num_free_get(pmsgq), i + 1, NULL); /**TESTPOINT: msgq used get*/ assert_equal(k_msgq_num_used_get(pmsgq), MSGQ_LEN - 1 - i, NULL); } } static void purge_msgq(struct k_msgq *pmsgq) { k_msgq_purge(pmsgq); assert_equal(k_msgq_num_free_get(pmsgq), MSGQ_LEN, NULL); assert_equal(k_msgq_num_used_get(pmsgq), 0, NULL); } static void tIsr_entry(void *p) { put_msgq((struct k_msgq *)p); } static void tThread_entry(void *p1, void *p2, void *p3) { get_msgq((struct k_msgq *)p1); k_sem_give(&end_sema); } static void msgq_thread(struct k_msgq *pmsgq) { k_sem_init(&end_sema, 0, 1); /**TESTPOINT: thread-thread data passing via message queue*/ k_tid_t tid = k_thread_spawn(tstack, STACK_SIZE, tThread_entry, pmsgq, NULL, NULL, K_PRIO_PREEMPT(0), 0, 0); put_msgq(pmsgq); k_sem_take(&end_sema, K_FOREVER); k_thread_abort(tid); /**TESTPOINT: msgq purge*/ purge_msgq(pmsgq); } static void msgq_isr(struct k_msgq *pmsgq) { /**TESTPOINT: thread-isr data passing via message queue*/ irq_offload(tIsr_entry, pmsgq); get_msgq(pmsgq); /**TESTPOINT: msgq purge*/ purge_msgq(pmsgq); } /*test cases*/ void test_msgq_thread(void) { struct k_msgq msgq; /**TESTPOINT: init via k_msgq_init*/ k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); msgq_thread(&msgq); msgq_thread(&kmsgq); } void test_msgq_isr(void) { struct k_msgq msgq; /**TESTPOINT: init via k_msgq_init*/ k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); msgq_isr(&msgq); msgq_isr(&kmsgq); } |