1 /*
2 * Copyright (c) 2016 Intel Corporation
3 *
4 * SPDX-License-Identifier: Apache-2.0
5 */
6
7 #include "test_msgq.h"
8
9 K_THREAD_STACK_DECLARE(tstack, STACK_SIZE);
10 extern struct k_thread tdata;
11 extern k_tid_t tids[2];
12 extern struct k_msgq msgq;
13 static ZTEST_BMEM char __aligned(4) tbuffer[MSG_SIZE * MSGQ_LEN];
14 static ZTEST_DMEM uint32_t data[MSGQ_LEN] = { MSG0, MSG1 };
15
tThread_entry(void * p1,void * p2,void * p3)16 static void tThread_entry(void *p1, void *p2, void *p3)
17 {
18 int ret = k_msgq_put((struct k_msgq *)p1, (void *)&data[0], TIMEOUT);
19
20 zassert_equal(ret, -ENOMSG);
21 }
22
purge_when_put(struct k_msgq * q)23 static void purge_when_put(struct k_msgq *q)
24 {
25 int ret;
26
27 /*fill the queue to full*/
28 for (int i = 0; i < MSGQ_LEN; i++) {
29 ret = k_msgq_put(q, (void *)&data[i], K_NO_WAIT);
30 zassert_equal(ret, 0);
31 }
32 /*create another thread waiting to put msg*/
33 tids[0] = k_thread_create(&tdata, tstack, STACK_SIZE,
34 tThread_entry, q, NULL, NULL,
35 K_PRIO_PREEMPT(0), K_USER | K_INHERIT_PERMS,
36 K_NO_WAIT);
37 k_msleep(TIMEOUT_MS >> 1);
38 /**TESTPOINT: msgq purge while another thread waiting to put msg*/
39 k_msgq_purge(q);
40
41 /*verify msg put after purge*/
42 for (int i = 0; i < MSGQ_LEN; i++) {
43 ret = k_msgq_put(q, (void *)&data[i], K_NO_WAIT);
44 zassert_equal(ret, 0);
45 }
46
47 k_thread_abort(tids[0]);
48 }
49
50 /**
51 * @addtogroup kernel_message_queue_tests
52 * @{
53 */
54
55 /**
56 * @brief Test purge a message queue
57 * @see k_msgq_init(), k_msgq_purge(), k_msgq_put()
58 */
ZTEST(msgq_api_1cpu,test_msgq_purge_when_put)59 ZTEST(msgq_api_1cpu, test_msgq_purge_when_put)
60 {
61 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN);
62
63 purge_when_put(&msgq);
64 }
65
66 #ifdef CONFIG_USERSPACE
67 /**
68 * @brief Test purge a message queue
69 * @see k_msgq_init(), k_msgq_purge(), k_msgq_put()
70 */
ZTEST_USER(msgq_api,test_msgq_user_purge_when_put)71 ZTEST_USER(msgq_api, test_msgq_user_purge_when_put)
72 {
73 struct k_msgq *q;
74
75 q = k_object_alloc(K_OBJ_MSGQ);
76 zassert_not_null(q, "couldn't alloc message queue");
77 zassert_false(k_msgq_alloc_init(q, MSG_SIZE, MSGQ_LEN));
78
79 purge_when_put(q);
80 }
81 #endif
82
83 /**
84 * @}
85 */
86
