ubinos
condvtest01.c
/*
* Copyright (c) 2009 Sung Ho Park
*
* SPDX-License-Identifier: Apache-2.0
*/
#include <ubinos/ubik_test.h>
#if (INCLUDE__UBINOS__UBIK_TEST == 1)
#if !(UBINOS__UBIK_TEST__EXCLUDE_CONDVTESTSET == 1)
#include <stdio.h>
#include <stdlib.h>
static void condvtest01_task1func(void * arg) {
int r;
int i;
unsigned int waitvalue = UBINOS__UBIK_TEST__TASKWAITTIMEMS * bsp_getbusywaitcountperms();
unsigned int waittick = ubik_timemstotick(UBINOS__UBIK_TEST__TASKWAITTIMEMS * UBINOS__UBIK_TEST__TASKLOOPCOUNT);
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count1++;
printf("1");
bsp_busywait(waitvalue);
}
printf("\n");
printf("Task 1 waits signal\n");
mutex_lock(_g_ubik_test_mutex);
r = condv_wait(_g_ubik_test_condv, _g_ubik_test_mutex);
mutex_unlock(_g_ubik_test_mutex);
if (0 != r) {
printf("Task 1: fail at condv_wait(), err=%d\n", r);
_g_ubik_test_result = -1;
goto end0;
}
printf("Task 1 receives signal\n");
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count1++;
printf("1");
bsp_busywait(waitvalue);
}
printf("\n");
printf("Task 1 waits signal\n");
mutex_lock(_g_ubik_test_mutex);
r = condv_wait(_g_ubik_test_condv, _g_ubik_test_mutex);
mutex_unlock(_g_ubik_test_mutex);
if (0 != r) {
printf("Task 1: fail at condv_wait(), err=%d\n", r);
_g_ubik_test_result = -1;
goto end0;
}
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count1++;
printf("1");
bsp_busywait(waitvalue);
}
printf("\n");
printf("Task 1 waits signal with timeout\n");
mutex_lock(_g_ubik_test_mutex);
r = condv_wait_timed(_g_ubik_test_condv, _g_ubik_test_mutex, waittick * 2);
mutex_unlock(_g_ubik_test_mutex);
if (UBIK_ERR__TIMEOUT != r) {
printf("Task 1: fail at condv_wait_timed(), err=%d\n", r);
_g_ubik_test_result = -1;
goto end0;
}
printf("\n");
printf("Task 1's timeout period expires\n");
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count1++;
printf("1");
bsp_busywait(waitvalue);
}
printf("\n");
end0:
printf("Task 1 ends\n");
}
static void condvtest01_task2func(void * arg) {
int r;
int i;
unsigned int waitvalue = UBINOS__UBIK_TEST__TASKWAITTIMEMS * bsp_getbusywaitcountperms();
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count2++;
printf("2");
bsp_busywait(waitvalue);
}
printf("\n");
printf("Task 2 waits signal\n");
mutex_lock(_g_ubik_test_mutex);
r = condv_wait(_g_ubik_test_condv, _g_ubik_test_mutex);
mutex_unlock(_g_ubik_test_mutex);
if (0 != r) {
printf("Task 2: fail at condv_wait(), err=%d\n", r);
_g_ubik_test_result = -1;
goto end0;
}
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count2++;
printf("2");
bsp_busywait(waitvalue);
}
printf("\n");
end0:
printf("Task 2 ends\n");
}
static void condvtest01_task3func(void * arg) {
int r;
int i;
unsigned int waitvalue = UBINOS__UBIK_TEST__TASKWAITTIMEMS * bsp_getbusywaitcountperms();
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count3++;
printf("3");
bsp_busywait(waitvalue);
}
printf("\n");
printf("Task 3 sends signal with no waiters\n");
mutex_lock(_g_ubik_test_mutex);
r = condv_signal(_g_ubik_test_condv);
mutex_unlock(_g_ubik_test_mutex);
if (0 != r) {
printf("Task 3: fail at condv_signal(), err=%d\n", r);
_g_ubik_test_result = -1;
goto end0;
}
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 2); i++) {
_g_ubik_test_count3++;
printf("3");
bsp_busywait(waitvalue);
}
printf("\n");
printf("Task 3 sends signal\n");
mutex_lock(_g_ubik_test_mutex);
r = condv_signal(_g_ubik_test_condv);
mutex_unlock(_g_ubik_test_mutex);
if (0 != r) {
printf("Task 3: fail at condv_signal(), err=%d\n", r);
_g_ubik_test_result = -1;
goto end0;
}
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 1); i++) {
_g_ubik_test_count3++;
printf("3");
bsp_busywait(waitvalue);
}
printf("\n");
printf("Task 3 broadcasts signal\n");
mutex_lock(_g_ubik_test_mutex);
r = condv_broadcast(_g_ubik_test_condv);
mutex_unlock(_g_ubik_test_mutex);
if (0 != r) {
printf("Task 3: fail at condv_broadcast(), err=%d\n", r);
_g_ubik_test_result = -1;
goto end0;
}
for (i=0; i<(UBINOS__UBIK_TEST__TASKLOOPCOUNT * 2); i++) {
_g_ubik_test_count3++;
printf("3");
bsp_busywait(waitvalue);
}
printf("\n");
end0:
printf("Task 3 ends\n");
}
int ubik_test_condvtest01(void) {
int r;
int r2;
unsigned int count1;
unsigned int count2;
unsigned int count3;
unsigned int sleepvalue = ubik_timemstotick(UBINOS__UBIK_TEST__TASKWAITTIMEMS) * UBINOS__UBIK_TEST__TASKLOOPCOUNT / 3;
printf("\n");
printf("<test>\n");
printf("<name>ubik_test_condvtest01</name>\n");
printf("<description>Basic functional test of condition variable</description>\n");
printf("<message>\n");
_g_ubik_test_result = 0;
_g_ubik_test_count1 = 0;
_g_ubik_test_count2 = 0;
_g_ubik_test_count3 = 0;
_g_ubik_test_task_a[0] = NULL;
_g_ubik_test_task_a[1] = NULL;
_g_ubik_test_task_a[2] = NULL;
r = condv_create(&_g_ubik_test_condv);
if (0 != r) {
printf("fail at condv_create(), err=%d\n", r);
r = -1;
goto end0;
}
r = mutex_create(&_g_ubik_test_mutex);
if (0 != r) {
printf("fail at mutex_create(), err=%d\n", r);
r = -1;
goto end1;
}
printf("Task 3 begins\n");
r = task_create_noautodel(&_g_ubik_test_task_a[3-1], condvtest01_task3func, NULL, task_getpriority(NULL)-3, 0, "condvtest01 task 3");
if (0 != r) {
printf("fail at task_create_noautodel(), err=%d\n", r);
r = -1;
goto end2;
}
task_sleep(sleepvalue);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 01: ");
if (count1 != _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 == _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 02: ");
if (count1 != _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 == _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue);
printf("\n");
printf("Task 1 begins\n");
r = task_create_noautodel(&_g_ubik_test_task_a[1-1], condvtest01_task1func, NULL, task_getpriority(NULL)-1, 0, "condvtest01 task 1");
if (0 != r) {
printf("fail at task_create_noautodel(), err=%d\n", r);
r = -1;
goto end3;
}
printf("Task 2 begins\n");
r = task_create_noautodel(&_g_ubik_test_task_a[2-1], condvtest01_task2func, NULL, task_getpriority(NULL)-2, 0, "condvtest01 task 2");
if (0 != r) {
printf("fail at task_create_noautodel(), err=%d\n", r);
r = -1;
goto end3;
}
task_sleep(sleepvalue);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 03: ");
if (count1 == _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 != _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 04: ");
if (count1 != _g_ubik_test_count1 || count2 == _g_ubik_test_count2 || count3 != _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 05: ");
if (count1 != _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 == _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 06: ");
if (count1 == _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 != _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 07: ");
if (count1 != _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 == _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 08: ");
if (count1 == _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 != _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 09: ");
if (count1 != _g_ubik_test_count1 || count2 == _g_ubik_test_count2 || count3 != _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 10: ");
if (count1 != _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 == _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 11: ");
if (count1 == _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 != _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
task_sleep(sleepvalue * 2);
count1 = _g_ubik_test_count1;
count2 = _g_ubik_test_count2;
count3 = _g_ubik_test_count3;
printf("\n");
printf("Checking\n");
task_sleep(sleepvalue);
printf("\n");
printf("Check point 12: ");
if (count1 != _g_ubik_test_count1 || count2 != _g_ubik_test_count2 || count3 == _g_ubik_test_count3) {
printf("fail\n");
r = -1;
goto end3;
}
printf("pass\n");
r = 0;
end3:
r2 = task_join_and_delete(_g_ubik_test_task_a, NULL, 3);
if (0 != r2) {
printf("fail at task_join_and_delete(), err=%d\n", r2);
r = -1;
}
end2:
r2 = mutex_delete(&_g_ubik_test_mutex);
if (0 != r2) {
printf("fail at mutex_delete(), err=%d\n", r2);
r = -1;
}
end1:
r2 = condv_delete(&_g_ubik_test_condv);
if (0 != r2) {
printf("fail at condv_delete(), err=%d\n", r2);
r = -1;
}
end0:
if (0 != r || 0 > _g_ubik_test_result) {
r = -1;
}
else {
r = 0;
}
printf("</message>\n");
printf("<result>");
if (0 == r) {
printf("pass");
}
else {
printf("fail");
}
printf("</result>\n");
printf("</test>\n");
printf("\n");
return r;
}
#endif /* !(UBINOS__UBIK_TEST__EXCLUDE_CONDVTESTSET == 1) */
#endif /* (INCLUDE__UBINOS__UBIK_TEST == 1) */
bsp_busywait
void bsp_busywait(unsigned int count)
bsp_getbusywaitcountperms
unsigned int bsp_getbusywaitcountperms(void)
condv_delete
int condv_delete(condv_pt *condv_p)
condv_signal
int condv_signal(condv_pt condv)
condv_create
int condv_create(condv_pt *condv_p)
condv_broadcast
int condv_broadcast(condv_pt condv)
condv_wait_timed
int condv_wait_timed(condv_pt condv, mutex_pt mutex, unsigned int tick)
condv_wait
int condv_wait(condv_pt condv, mutex_pt mutex)
mutex_unlock
int mutex_unlock(mutex_pt mutex)
mutex_create
int mutex_create(mutex_pt *mutex_p)
mutex_delete
int mutex_delete(mutex_pt *mutex_p)
mutex_lock
int mutex_lock(mutex_pt mutex)
stdlib.h
stdlib (Standard Library) API
task_create_noautodel
int task_create_noautodel(task_pt *task_p, taskfunc_ft func, void *arg, int priority, unsigned int stackdepth, const char *name)
task_join_and_delete
int task_join_and_delete(task_pt *task_p, int *result_p, int count)
task_sleep
int task_sleep(unsigned int tick)
task_getpriority
int task_getpriority(task_pt task)
NULL
#define NULL
Definition: type.h:42
UBIK_ERR__TIMEOUT
#define UBIK_ERR__TIMEOUT
Definition: ubik.h:32
ubik_timemstotick
unsigned int ubik_timemstotick(unsigned int timems)
ubik_test.h
ubik test API
_g_ubik_test_count1
volatile unsigned int _g_ubik_test_count1
태스크 별 시험 진행 상황을 저장하는 전역 변수 1
_g_ubik_test_task_a
task_pt _g_ubik_test_task_a[4]
시험 용 태스크 배열
_g_ubik_test_count2
volatile unsigned int _g_ubik_test_count2
태스크 별 시험 진행 상황을 저장하는 전역 변수 2
_g_ubik_test_condv
condv_pt _g_ubik_test_condv
시험 용 상태변수
ubik_test_condvtest01
int ubik_test_condvtest01(void)
Test on basic functions of condition variable.
_g_ubik_test_count3
volatile unsigned int _g_ubik_test_count3
태스크 별 시험 진행 상황을 저장하는 전역 변수 3
_g_ubik_test_result
volatile unsigned int _g_ubik_test_result
시험 결과를 저장하는 전역 변수
_g_ubik_test_mutex
mutex_pt _g_ubik_test_mutex
시험 용 뮤택스
Generated by doxygen 1.9.1