| /* |
| * Copyright (c) 2016 Intel Corporation |
| * |
| * SPDX-License-Identifier: Apache-2.0 |
| */ |
| |
| #include "test_msgq.h" |
| |
| /**TESTPOINT: init via K_MSGQ_DEFINE*/ |
| K_MSGQ_DEFINE(kmsgq, MSG_SIZE, MSGQ_LEN, 4); |
| __kernel struct k_msgq msgq; |
| K_THREAD_STACK_DEFINE(tstack, STACK_SIZE); |
| __kernel struct k_thread tdata; |
| static char __aligned(4) tbuffer[MSG_SIZE * MSGQ_LEN]; |
| static u32_t data[MSGQ_LEN] = { MSG0, MSG1 }; |
| __kernel 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); |
| zassert_equal(ret, 0, NULL); |
| /**TESTPOINT: msgq free get*/ |
| zassert_equal(k_msgq_num_free_get(pmsgq), |
| MSGQ_LEN - 1 - i, NULL); |
| /**TESTPOINT: msgq used get*/ |
| zassert_equal(k_msgq_num_used_get(pmsgq), i + 1, NULL); |
| } |
| } |
| |
| static void get_msgq(struct k_msgq *pmsgq) |
| { |
| u32_t rx_data; |
| int ret; |
| |
| for (int i = 0; i < MSGQ_LEN; i++) { |
| ret = k_msgq_get(pmsgq, &rx_data, K_FOREVER); |
| zassert_equal(ret, 0, NULL); |
| zassert_equal(rx_data, data[i], NULL); |
| /**TESTPOINT: msgq free get*/ |
| zassert_equal(k_msgq_num_free_get(pmsgq), i + 1, NULL); |
| /**TESTPOINT: msgq used get*/ |
| zassert_equal(k_msgq_num_used_get(pmsgq), |
| MSGQ_LEN - 1 - i, NULL); |
| } |
| } |
| |
| static void purge_msgq(struct k_msgq *pmsgq) |
| { |
| k_msgq_purge(pmsgq); |
| zassert_equal(k_msgq_num_free_get(pmsgq), MSGQ_LEN, NULL); |
| zassert_equal(k_msgq_num_used_get(pmsgq), 0, NULL); |
| } |
| |
| static void tisr_entry(void *p) |
| { |
| put_msgq((struct k_msgq *)p); |
| } |
| |
| static void thread_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) |
| { |
| /**TESTPOINT: thread-thread data passing via message queue*/ |
| k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, |
| thread_entry, pmsgq, NULL, NULL, |
| K_PRIO_PREEMPT(0), |
| K_USER | K_INHERIT_PERMS, 0); |
| put_msgq(pmsgq); |
| k_sem_take(&end_sema, K_FOREVER); |
| k_thread_abort(tid); |
| |
| /**TESTPOINT: msgq purge*/ |
| purge_msgq(pmsgq); |
| } |
| |
| static void thread_entry_overflow(void *p1, void *p2, void *p3) |
| { |
| int ret; |
| |
| u32_t rx_buf[MSGQ_LEN]; |
| |
| ret = k_msgq_get(p1, &rx_buf[0], K_FOREVER); |
| |
| zassert_equal(ret, 0, NULL); |
| |
| ret = k_msgq_get(p1, &rx_buf[1], K_FOREVER); |
| |
| zassert_equal(ret, 0, NULL); |
| |
| k_sem_give(&end_sema); |
| } |
| |
| static void msgq_thread_overflow(struct k_msgq *pmsgq) |
| { |
| int ret; |
| |
| ret = k_msgq_put(pmsgq, (void *)&data[0], K_FOREVER); |
| |
| zassert_equal(ret, 0, NULL); |
| |
| /**TESTPOINT: thread-thread data passing via message queue*/ |
| k_tid_t tid = k_thread_create(&tdata, tstack, STACK_SIZE, |
| thread_entry_overflow, pmsgq, NULL, NULL, |
| K_PRIO_PREEMPT(0), |
| K_USER | K_INHERIT_PERMS, 0); |
| |
| ret = k_msgq_put(pmsgq, (void *)&data[1], K_FOREVER); |
| |
| zassert_equal(ret, 0, NULL); |
| |
| k_sem_take(&end_sema, K_FOREVER); |
| k_thread_abort(tid); |
| |
| /**TESTPOINT: msgq purge*/ |
| k_msgq_purge(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); |
| } |
| /** |
| * @brief Verify zephyr msgq apis across contexts |
| * @addtogroup kernel_message_queue |
| * @{ |
| */ |
| void test_msgq_thread(void) |
| { |
| /**TESTPOINT: init via k_msgq_init*/ |
| k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); |
| k_sem_init(&end_sema, 0, 1); |
| |
| msgq_thread(&msgq); |
| msgq_thread(&kmsgq); |
| } |
| |
| void test_msgq_thread_overflow(void) |
| { |
| /**TESTPOINT: init via k_msgq_init*/ |
| k_msgq_init(&msgq, tbuffer, MSG_SIZE, 1); |
| k_sem_init(&end_sema, 0, 1); |
| |
| msgq_thread_overflow(&msgq); |
| msgq_thread_overflow(&kmsgq); |
| } |
| |
| #ifdef CONFIG_USERSPACE |
| void test_msgq_user_thread(void) |
| { |
| struct k_msgq *q; |
| |
| q = k_object_alloc(K_OBJ_MSGQ); |
| zassert_not_null(q, "couldn't alloc message queue"); |
| zassert_false(k_msgq_alloc_init(q, MSG_SIZE, MSGQ_LEN), NULL); |
| k_sem_init(&end_sema, 0, 1); |
| |
| msgq_thread(q); |
| } |
| |
| void test_msgq_user_thread_overflow(void) |
| { |
| struct k_msgq *q; |
| |
| q = k_object_alloc(K_OBJ_MSGQ); |
| zassert_not_null(q, "couldn't alloc message queue"); |
| zassert_false(k_msgq_alloc_init(q, MSG_SIZE, 1), NULL); |
| k_sem_init(&end_sema, 0, 1); |
| |
| msgq_thread_overflow(q); |
| } |
| #endif /* CONFIG_USERSPACE */ |
| |
| void test_msgq_isr(void) |
| { |
| struct k_msgq stack_msgq; |
| |
| /**TESTPOINT: init via k_msgq_init*/ |
| k_msgq_init(&stack_msgq, tbuffer, MSG_SIZE, MSGQ_LEN); |
| |
| msgq_isr(&stack_msgq); |
| msgq_isr(&kmsgq); |
| } |
| |
| /** |
| * @} |
| */ |