msgqtest00.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_MSGQTESTSET == 1)
 
#include <stdio.h>
#include <stdlib.h>
 
#define TASKWORKINGTIMEMS   500
#define TASKLOOPCOUNT       10
#define MSGSIZE             2
#define MSGCOUNT            10
 
static msgq_pt  _g_msgq     = NULL;
 
static void msgqtest00_task1func(void * arg) {
    unsigned int i;
    unsigned char buf[MSGSIZE];
 
    for (i=0; i<MSGSIZE; i++) {
        buf[i] = i;
    }
 
    for (i=0; i<TASKLOOPCOUNT; i++) {
        bsp_busywait((unsigned int) rand() % TASKWORKINGTIMEMS * bsp_getbusywaitcountperms());
        printf("task 1 produces one message\n");
 
        msgq_send(_g_msgq, buf);
    }
}
 
static void msgqtest00_task2func(void * arg) {
    unsigned int i;
    unsigned char buf[MSGSIZE];
 
    for (i=0; i<TASKLOOPCOUNT/2; i++) {
        printf("task 2 waits message\n");
        msgq_receive(_g_msgq, buf);
 
        printf("task 2 consumes one message\n");
        bsp_busywait((unsigned int) rand() % TASKWORKINGTIMEMS * bsp_getbusywaitcountperms());
    }
}
 
static void msgqtest00_task3func(void * arg) {
    unsigned int i;
    unsigned char buf[MSGSIZE];
 
    for (i=0; i<TASKLOOPCOUNT/2; i++) {
        printf("task 3 waits message\n");
        msgq_receive(_g_msgq, buf);
 
        printf("task 3 consumes one message\n");
        bsp_busywait((unsigned int) rand() % TASKWORKINGTIMEMS * bsp_getbusywaitcountperms());
    }
}
 
int ubik_test_msgqtest00(void) {
    int r;
    int r2;
    task_pt task_a[3];
 
    r = msgq_create(&_g_msgq, MSGSIZE, MSGCOUNT);
    if (0 != r) {
        printf("fail at msgq_create(), err=%d\n", r);
        r = -1;
        goto end0;
    }
 
    r = task_create_noautodel(&task_a[0], msgqtest00_task1func, NULL, task_getpriority(NULL)-1, 0, "task 1");
    if (0 != r) {
        printf("fail at task_create_noautodel(), err=%d\n", r);
        r = -1;
        goto end1;
    }
 
    r = task_create_noautodel(&task_a[1], msgqtest00_task2func, NULL, task_getpriority(NULL)-1, 0, "task 2");
    if (0 != r) {
        printf("fail at task_create_noautodel(), err=%d\n", r);
        r = -1;
        goto end2;
    }
 
    task_sleep(10);
 
    r = task_create_noautodel(&task_a[2], msgqtest00_task3func, NULL, task_getpriority(NULL)-1, 0, "task 3");
    if (0 != r) {
        printf("fail at task_create_noautodel(), err=%d\n", r);
        r = -1;
        goto end2;
    }
 
    r = 0;
 
end2:
    r2 = task_join_and_delete(task_a, NULL, 3);
    if (0 != r2) {
        printf("fail at task_join_and_delete(), err=%d\n", r2);
        r = -1;
    }
 
end1:
    r2 = msgq_delete(&_g_msgq);
    if (0 != r2) {
        printf("fail at msgq_delete(), err=%d\n", r2);
        r = -1;
    }
 
end0:
    return r;
}
 
#endif /* !(UBINOS__UBIK_TEST__EXCLUDE_MSGQTESTSET == 1) */
#endif /* (INCLUDE__UBINOS__UBIK_TEST == 1) */