tests: Add queue tests
Change-Id: If4ffa10c8c63788e1c9f074b8761902b4bdf6f66 Signed-off-by: Luiz Augusto von Dentz <luiz.von.dentz@intel.com>
This commit is contained in:
parent
a7ddb87501
commit
d07a328a95
9 changed files with 372 additions and 0 deletions
4
tests/kernel/queue/Makefile
Normal file
4
tests/kernel/queue/Makefile
Normal file
|
@ -0,0 +1,4 @@
|
|||
BOARD ?= qemu_x86
|
||||
CONF_FILE = prj.conf
|
||||
|
||||
include ${ZEPHYR_BASE}/Makefile.inc
|
2
tests/kernel/queue/prj.conf
Normal file
2
tests/kernel/queue/prj.conf
Normal file
|
@ -0,0 +1,2 @@
|
|||
CONFIG_ZTEST=y
|
||||
CONFIG_IRQ_OFFLOAD=y
|
3
tests/kernel/queue/src/Makefile
Normal file
3
tests/kernel/queue/src/Makefile
Normal file
|
@ -0,0 +1,3 @@
|
|||
include $(ZEPHYR_BASE)/tests/Makefile.test
|
||||
|
||||
obj-y = main.o test_queue_contexts.o test_queue_fail.o test_queue_loop.o
|
31
tests/kernel/queue/src/main.c
Normal file
31
tests/kernel/queue/src/main.c
Normal file
|
@ -0,0 +1,31 @@
|
|||
/*
|
||||
* Copyright (c) 2017 Intel Corporation
|
||||
*
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
*/
|
||||
|
||||
/**
|
||||
* @addtogroup t_queue
|
||||
* @{
|
||||
* @defgroup t_queue_api test_queue_api
|
||||
* @}
|
||||
*/
|
||||
|
||||
#include <ztest.h>
|
||||
extern void test_queue_thread2thread(void);
|
||||
extern void test_queue_thread2isr(void);
|
||||
extern void test_queue_isr2thread(void);
|
||||
extern void test_queue_get_fail(void);
|
||||
extern void test_queue_loop(void);
|
||||
|
||||
/*test case main entry*/
|
||||
void test_main(void *p1, void *p2, void *p3)
|
||||
{
|
||||
ztest_test_suite(test_queue_api,
|
||||
ztest_unit_test(test_queue_thread2thread),
|
||||
ztest_unit_test(test_queue_thread2isr),
|
||||
ztest_unit_test(test_queue_isr2thread),
|
||||
ztest_unit_test(test_queue_get_fail),
|
||||
ztest_unit_test(test_queue_loop));
|
||||
ztest_run_test_suite(test_queue_api);
|
||||
}
|
11
tests/kernel/queue/src/test_queue.h
Normal file
11
tests/kernel/queue/src/test_queue.h
Normal file
|
@ -0,0 +1,11 @@
|
|||
#ifndef __TEST_FIFO_H__
|
||||
#define __TEST_FIFO_H__
|
||||
|
||||
#include <ztest.h>
|
||||
#include <irq_offload.h>
|
||||
|
||||
typedef struct qdata {
|
||||
sys_snode_t snode;
|
||||
uint32_t data;
|
||||
} qdata_t;
|
||||
#endif
|
165
tests/kernel/queue/src/test_queue_contexts.c
Normal file
165
tests/kernel/queue/src/test_queue_contexts.c
Normal file
|
@ -0,0 +1,165 @@
|
|||
/*
|
||||
* Copyright (c) 2017 Intel Corporation
|
||||
*
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
*/
|
||||
|
||||
/**
|
||||
* @addtogroup t_queue_api
|
||||
* @{
|
||||
* @defgroup t_queue_api_basic test_queue_api_basic
|
||||
* @brief TestPurpose: verify zephyr queue apis under different context
|
||||
* - API coverage
|
||||
* -# k_queue_init K_QUEUE_DEFINE
|
||||
* -# k_queue_append k_queue_prepend k_queue_append_list k_queue_merge_slist
|
||||
* -# k_queue_get
|
||||
* @}
|
||||
*/
|
||||
|
||||
#include "test_queue.h"
|
||||
|
||||
#define STACK_SIZE (512 + CONFIG_TEST_EXTRA_STACKSIZE)
|
||||
#define LIST_LEN 2
|
||||
/**TESTPOINT: init via K_QUEUE_DEFINE*/
|
||||
K_QUEUE_DEFINE(kqueue);
|
||||
|
||||
struct k_queue queue;
|
||||
static qdata_t data[LIST_LEN];
|
||||
static qdata_t data_p[LIST_LEN];
|
||||
static qdata_t data_l[LIST_LEN];
|
||||
static qdata_t data_sl[LIST_LEN];
|
||||
|
||||
static char __noinit __stack tstack[STACK_SIZE];
|
||||
static struct k_sem end_sema;
|
||||
|
||||
static void tqueue_append(struct k_queue *pqueue)
|
||||
{
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
/**TESTPOINT: queue append */
|
||||
k_queue_append(pqueue, (void *)&data[i]);
|
||||
}
|
||||
|
||||
for (int i = LIST_LEN - 1; i >= 0; i--) {
|
||||
/**TESTPOINT: queue prepend */
|
||||
k_queue_prepend(pqueue, (void *)&data_p[i]);
|
||||
}
|
||||
|
||||
/**TESTPOINT: queue append list*/
|
||||
static qdata_t *head = &data_l[0], *tail = &data_l[LIST_LEN-1];
|
||||
|
||||
head->snode.next = (sys_snode_t *)tail;
|
||||
tail->snode.next = NULL;
|
||||
k_queue_append_list(pqueue, (uint32_t *)head, (uint32_t *)tail);
|
||||
|
||||
/**TESTPOINT: queue merge slist*/
|
||||
sys_slist_t slist;
|
||||
|
||||
sys_slist_init(&slist);
|
||||
sys_slist_append(&slist, (sys_snode_t *)&(data_sl[0].snode));
|
||||
sys_slist_append(&slist, (sys_snode_t *)&(data_sl[1].snode));
|
||||
k_queue_merge_slist(pqueue, &slist);
|
||||
}
|
||||
|
||||
static void tqueue_get(struct k_queue *pqueue)
|
||||
{
|
||||
void *rx_data;
|
||||
|
||||
/*get queue data from "queue_prepend"*/
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
/**TESTPOINT: queue get*/
|
||||
rx_data = k_queue_get(pqueue, K_NO_WAIT);
|
||||
assert_equal(rx_data, (void *)&data_p[i], NULL);
|
||||
}
|
||||
/*get queue data from "queue_append"*/
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
/**TESTPOINT: queue get*/
|
||||
rx_data = k_queue_get(pqueue, K_NO_WAIT);
|
||||
assert_equal(rx_data, (void *)&data[i], NULL);
|
||||
}
|
||||
/*get queue data from "queue_append_list"*/
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
rx_data = k_queue_get(pqueue, K_NO_WAIT);
|
||||
assert_equal(rx_data, (void *)&data_l[i], NULL);
|
||||
}
|
||||
/*get queue data from "queue_merge_slist"*/
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
rx_data = k_queue_get(pqueue, K_NO_WAIT);
|
||||
assert_equal(rx_data, (void *)&data_sl[i], NULL);
|
||||
}
|
||||
}
|
||||
|
||||
/*entry of contexts*/
|
||||
static void tIsr_entry_append(void *p)
|
||||
{
|
||||
tqueue_append((struct k_queue *)p);
|
||||
}
|
||||
|
||||
static void tIsr_entry_get(void *p)
|
||||
{
|
||||
tqueue_get((struct k_queue *)p);
|
||||
}
|
||||
|
||||
static void tThread_entry(void *p1, void *p2, void *p3)
|
||||
{
|
||||
tqueue_get((struct k_queue *)p1);
|
||||
k_sem_give(&end_sema);
|
||||
}
|
||||
|
||||
static void tqueue_thread_thread(struct k_queue *pqueue)
|
||||
{
|
||||
k_sem_init(&end_sema, 0, 1);
|
||||
/**TESTPOINT: thread-thread data passing via queue*/
|
||||
k_tid_t tid = k_thread_spawn(tstack, STACK_SIZE,
|
||||
tThread_entry, pqueue, NULL, NULL,
|
||||
K_PRIO_PREEMPT(0), 0, 0);
|
||||
tqueue_append(pqueue);
|
||||
k_sem_take(&end_sema, K_FOREVER);
|
||||
k_thread_abort(tid);
|
||||
}
|
||||
|
||||
static void tqueue_thread_isr(struct k_queue *pqueue)
|
||||
{
|
||||
k_sem_init(&end_sema, 0, 1);
|
||||
/**TESTPOINT: thread-isr data passing via queue*/
|
||||
irq_offload(tIsr_entry_append, pqueue);
|
||||
tqueue_get(pqueue);
|
||||
}
|
||||
|
||||
static void tqueue_isr_thread(struct k_queue *pqueue)
|
||||
{
|
||||
k_sem_init(&end_sema, 0, 1);
|
||||
/**TESTPOINT: isr-thread data passing via queue*/
|
||||
tqueue_append(pqueue);
|
||||
irq_offload(tIsr_entry_get, pqueue);
|
||||
}
|
||||
|
||||
/*test cases*/
|
||||
void test_queue_thread2thread(void)
|
||||
{
|
||||
/**TESTPOINT: init via k_queue_init*/
|
||||
k_queue_init(&queue);
|
||||
tqueue_thread_thread(&queue);
|
||||
|
||||
/**TESTPOINT: test K_QUEUE_DEFINEed queue*/
|
||||
tqueue_thread_thread(&kqueue);
|
||||
}
|
||||
|
||||
void test_queue_thread2isr(void)
|
||||
{
|
||||
/**TESTPOINT: init via k_queue_init*/
|
||||
k_queue_init(&queue);
|
||||
tqueue_thread_isr(&queue);
|
||||
|
||||
/**TESTPOINT: test K_QUEUE_DEFINEed queue*/
|
||||
tqueue_thread_isr(&kqueue);
|
||||
}
|
||||
|
||||
void test_queue_isr2thread(void)
|
||||
{
|
||||
/**TESTPOINT: test k_queue_init queue*/
|
||||
k_queue_init(&queue);
|
||||
tqueue_isr_thread(&queue);
|
||||
|
||||
/**TESTPOINT: test K_QUEUE_DEFINE queue*/
|
||||
tqueue_isr_thread(&kqueue);
|
||||
}
|
32
tests/kernel/queue/src/test_queue_fail.c
Normal file
32
tests/kernel/queue/src/test_queue_fail.c
Normal file
|
@ -0,0 +1,32 @@
|
|||
/*
|
||||
* Copyright (c) 2017 Intel Corporation
|
||||
*
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
*/
|
||||
|
||||
/**
|
||||
* @addtogroup t_queue_api
|
||||
* @{
|
||||
* @defgroup t_queue_get_fail test_queue_get_fail
|
||||
* @brief TestPurpose: verify zephyr queue_get when no data
|
||||
* - API coverage
|
||||
* -# k_queue_init
|
||||
* -# k_queue_get
|
||||
* @}
|
||||
*/
|
||||
|
||||
#include "test_queue.h"
|
||||
|
||||
#define TIMEOUT 100
|
||||
|
||||
/*test cases*/
|
||||
void test_queue_get_fail(void *p1, void *p2, void *p3)
|
||||
{
|
||||
struct k_queue queue;
|
||||
|
||||
k_queue_init(&queue);
|
||||
/**TESTPOINT: queue get returns NULL*/
|
||||
assert_is_null(k_queue_get(&queue, K_NO_WAIT), NULL);
|
||||
assert_is_null(k_queue_get(&queue, TIMEOUT), NULL);
|
||||
}
|
||||
|
122
tests/kernel/queue/src/test_queue_loop.c
Normal file
122
tests/kernel/queue/src/test_queue_loop.c
Normal file
|
@ -0,0 +1,122 @@
|
|||
/*
|
||||
* Copyright (c) 2017 Intel Corporation
|
||||
*
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
*/
|
||||
|
||||
/**
|
||||
* @addtogroup t_queue_api
|
||||
* @{
|
||||
* @defgroup t_queue_loop test_queue_loop
|
||||
* @brief TestPurpose: verify zephyr queue continuous read write
|
||||
* in loop
|
||||
* @details
|
||||
* - Test Steps
|
||||
* -# queue append/prepend from main thread
|
||||
* -# queue read from isr
|
||||
* -# queue append/prepend from isr
|
||||
* -# queue get from spawn thread
|
||||
* -# loop above steps for LOOPs times
|
||||
* - Expected Results
|
||||
* -# queue data pass correctly and stably across contexts
|
||||
* - API coverage
|
||||
* -# k_queue_init
|
||||
* -# k_queue_append
|
||||
* -# k_queue_prepend
|
||||
* -# k_queue_get
|
||||
* @}
|
||||
*/
|
||||
|
||||
#include "test_queue.h"
|
||||
|
||||
#define STACK_SIZE (512 + CONFIG_TEST_EXTRA_STACKSIZE)
|
||||
#define LIST_LEN 4
|
||||
#define LOOPS 32
|
||||
|
||||
static qdata_t data[LIST_LEN];
|
||||
static qdata_t data_p[LIST_LEN];
|
||||
static struct k_queue queue;
|
||||
static char __noinit __stack tstack[STACK_SIZE];
|
||||
static struct k_sem end_sema;
|
||||
|
||||
static void tqueue_append(struct k_queue *pqueue)
|
||||
{
|
||||
/**TESTPOINT: queue append*/
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
k_queue_append(pqueue, (void *)&data[i]);
|
||||
}
|
||||
|
||||
/**TESTPOINT: queue prepend*/
|
||||
for (int i = LIST_LEN - 1; i >= 0; i--) {
|
||||
k_queue_prepend(pqueue, (void *)&data_p[i]);
|
||||
}
|
||||
}
|
||||
|
||||
static void tqueue_get(struct k_queue *pqueue)
|
||||
{
|
||||
void *rx_data;
|
||||
|
||||
/*get queue data from "queue_prepend"*/
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
/**TESTPOINT: queue get*/
|
||||
rx_data = k_queue_get(pqueue, K_NO_WAIT);
|
||||
assert_equal(rx_data, (void *)&data_p[i], NULL);
|
||||
}
|
||||
|
||||
/*get queue data from "queue_append"*/
|
||||
for (int i = 0; i < LIST_LEN; i++) {
|
||||
/**TESTPOINT: queue get*/
|
||||
rx_data = k_queue_get(pqueue, K_NO_WAIT);
|
||||
assert_equal(rx_data, (void *)&data[i], NULL);
|
||||
}
|
||||
}
|
||||
|
||||
/*entry of contexts*/
|
||||
static void tIsr_entry(void *p)
|
||||
{
|
||||
TC_PRINT("isr queue get\n");
|
||||
tqueue_get((struct k_queue *)p);
|
||||
TC_PRINT("isr queue append ---> ");
|
||||
tqueue_append((struct k_queue *)p);
|
||||
}
|
||||
|
||||
static void tThread_entry(void *p1, void *p2, void *p3)
|
||||
{
|
||||
TC_PRINT("thread queue get\n");
|
||||
tqueue_get((struct k_queue *)p1);
|
||||
k_sem_give(&end_sema);
|
||||
TC_PRINT("thread queue append ---> ");
|
||||
tqueue_append((struct k_queue *)p1);
|
||||
k_sem_give(&end_sema);
|
||||
}
|
||||
|
||||
/* queue read write job */
|
||||
static void tqueue_read_write(struct k_queue *pqueue)
|
||||
{
|
||||
k_sem_init(&end_sema, 0, 1);
|
||||
/**TESTPOINT: thread-isr-thread data passing via queue*/
|
||||
k_tid_t tid = k_thread_spawn(tstack, STACK_SIZE,
|
||||
tThread_entry, pqueue, NULL, NULL,
|
||||
K_PRIO_PREEMPT(0), 0, 0);
|
||||
|
||||
TC_PRINT("main queue append ---> ");
|
||||
tqueue_append(pqueue);
|
||||
irq_offload(tIsr_entry, pqueue);
|
||||
k_sem_take(&end_sema, K_FOREVER);
|
||||
k_sem_take(&end_sema, K_FOREVER);
|
||||
|
||||
TC_PRINT("main queue get\n");
|
||||
tqueue_get(pqueue);
|
||||
k_thread_abort(tid);
|
||||
TC_PRINT("\n");
|
||||
}
|
||||
|
||||
/*test cases*/
|
||||
void test_queue_loop(void)
|
||||
{
|
||||
k_queue_init(&queue);
|
||||
for (int i = 0; i < LOOPS; i++) {
|
||||
TC_PRINT("* Pass data by queue in loop %d\n", i);
|
||||
tqueue_read_write(&queue);
|
||||
}
|
||||
}
|
2
tests/kernel/queue/testcase.ini
Normal file
2
tests/kernel/queue/testcase.ini
Normal file
|
@ -0,0 +1,2 @@
|
|||
[test]
|
||||
tags = kernel
|
Loading…
Add table
Add a link
Reference in a new issue