source: asp3_wo_tecs/trunk/test/test_mutex6.c@ 302

/*
 *  TOPPERS Software
 *      Toyohashi Open Platform for Embedded Real-Time Systems
 * 
 *  Copyright (C) 2007-2015 by Embedded and Real-Time Systems Laboratory
 *              Graduate School of Information Science, Nagoya Univ., JAPAN
 * 
 *  上記著作権者
は，以下の(1)〜(4)ã®æ¡ä»¶ã‚’æº€ãŸã™å ´åˆã«é™ã‚Šï¼Œæœ¬ã‚½ãƒ•ãƒˆã‚¦ã‚§
 *  ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
 *  変・再é…
å¸ƒï¼ˆä»¥ä¸‹ï¼Œåˆ©ç”¨ã¨å‘¼ã¶ï¼‰ã™ã‚‹ã“とを無償で許諾する．
 *  (1) æœ¬ã‚½ãƒ•ãƒˆã‚¦ã‚§ã‚¢ã‚’ã‚½ãƒ¼ã‚¹ã‚³ãƒ¼ãƒ‰ã®å½¢ã§åˆ©ç”¨ã™ã‚‹å ´åˆã«ã¯ï¼Œä¸Šè¨˜ã®è‘—ä½œ
 *      権表示，この利用条件および下記の無保証規定が，そのままの形でソー
 *      スコード中に含まれていること．
 *  (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
 *      用できる形で再é…
å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œå†é…
å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨
 *      者
マニュアルなど）に，上記の著作権表示，この利用条件および下記
 *      の無保証規定を掲載すること．
 *  (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
 *      用できない形で再é…
å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œæ¬¡ã®ã„ずれかの条件を満たすこ
 *      と．
 *    (a) 再é…
å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨è€…
マニュアルなど）に，上記の著
 *        作権表示，この利用条件および下記の無保証規定を掲載すること．
 *    (b) 再é…
å¸ƒã®å½¢æ…
‹ã‚’，別に定める方法によって，TOPPERSプロジェクトに
 *        å ±å‘Šã™ã‚‹ã“ã¨ï¼Ž
 *  (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
 *      害からも，上記著作権者
およびTOPPERSプロジェクトをå…
è²¬ã™ã‚‹ã“と．
 *      また，本ソフトウェアのユーザまたはエンドユーザからのいかなる理
 *      由に基づく請求からも，上記著作権者
およびTOPPERSプロジェクトを
 *      å…
è²¬ã™ã‚‹ã“と．
 * 
 *  本ソフトウェアは，無保証で提供されているものである．上記著作権者
お
 *  よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
 *  に対する適合性も含めて，いかなる保証も行わない．また，本ソフトウェ
 *  アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
 *  ã®è²¬ä»»ã‚’è² ã‚ãªã„ï¼Ž
 * 
 *  $Id: test_mutex6.c 310 2015-02-08 13:46:46Z ertl-hiro $
 */

/* 
 *              ミューテックスのテスト(6)
 *
 * 【テストの目的】
 *
 *  優å…
ˆåº¦ä¸Šé™ãƒŸãƒ¥ãƒ¼ãƒ†ãƒƒã‚¯ã‚¹ã«å¯¾ã—て，タスクの終了時，タスクの優å…
ˆé †ä½
 *  の回転時のミューテックス関連の処理を網羅
的にテストする．
 *
 * ã€ãƒ†ã‚¹ãƒˆé …
目】
 *
 *      (A) タスクの終了時（ext_tsk）
 *              (A-1) ロックしていたミューテックス（1つ）がロック解除されること．
 *              (A-2) ロックしていたミューテックス（1つ）がロック解除され，ロッ
 *                        クを待
っていたタスクがそれをロックし，優å…
ˆåº¦ãŒå¤‰åŒ–し，待

 *                        ち解除されること．
 *              (A-3) ロックしていたミューテックス（複数）がすべてロック解除さ
 *                        れること．
 *              (A-4) ロックしていたミューテックス（複数）がロック解除され，ロッ
 *                        クを待
っていたタスク（複数）がそれをロックし，優å…
ˆåº¦ãŒå¤‰
 *                        化し，待
ち解除されること．その時に，後でミューテックスを
 *                        ロックしたタスク（å…
ˆã«ãƒ­ãƒƒã‚¯ã—ていたミューテックスを待
っ
 *                        ていたタスク）の方が，優å…
ˆé †ä½ãŒé«˜ããªã‚‹ã“と．
 *      (B) タスクの優å…
ˆé †ä½ã®å›žè»¢ï¼ˆrot_rdq）
 *              (B-1) TPRI_SELFを指定した時に，タスクのベース優å…
ˆåº¦ã®å„ªå…
ˆé †ä½ãŒ
 *              　　　回転すること．
 *              (B-2) TPRI_SELFを指定した時に，タスクの現在優å…
ˆåº¦ã®å„ªå…
ˆé †ä½ãŒå›ž
 *              　　　転しないこと．
 *
 * ã€ãƒ†ã‚¹ãƒˆé …
目の実現方法】
 *
 *      (A-1)
 *              低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ï¼ˆTASK2）にミューテックス（MTX1）をロックさせ，
 *              ext_tskすると，ロックが解除されることを確認する．
 *      (A-2)
 *              低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ï¼ˆTASK2）に高優å…
ˆåº¦ä¸Šé™ãƒŸãƒ¥ãƒ¼ãƒ†ãƒƒã‚¯ã‚¹ï¼ˆMTX1）をロッ
 *              クさせ，別の低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ï¼ˆTASK3）にMTX1を待
たせた状æ…
‹ã§ï¼Œ
 *              TASK2 がext_tskすると，TASK3が高優å…
ˆåº¦ã«ãªã£ã¦å¾…
ち解除されるこ
 *              とを確認する．
 *      (A-3)
 *              低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ï¼ˆTASK2）にミューテックスを2つ（MTX1，MTX2）ロッ
 *              クさせ，ext_tskすると，両方のロックが解除されることを確認する．
 *      (A-4)
 *              低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ï¼ˆTASK2）に高優å…
ˆåº¦ä¸Šé™ãƒŸãƒ¥ãƒ¼ãƒ†ãƒƒã‚¯ã‚¹2つ（MTX1，
 *              MTX2ï¼‰ã‚’ã“ã®é †ã§ãƒ­ãƒƒã‚¯ã•ã›ï¼Œåˆ¥ã®ä½Žå„ªå…
ˆåº¦ã‚¿ã‚¹ã‚¯2つ（TASK3，
 *              TASK4）にそれぞれのロックを待
たせた状æ…
‹ã§ï¼ŒTASK2をext_tskすると，
 *              TASK3とTASK4が高優å…
ˆåº¦ã«ãªã£ã¦å¾…
ち解除されることを確認する．ま
 *              た，å…
ˆã«ãƒ­ãƒƒã‚¯ã—ていたミューテックス（MTX1）を待
っていたタスク
 *              （TASK3）が，TASK4よりも優å…
ˆé †ä½ãŒé«˜ããªã‚‹ã“とを確認する．
 *      (B-1)
 *              低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ãŒ3つ（TASK2，TASK3，TASK4）が実行できる状æ…
‹ã®æ™‚
 *              に，1つの低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ï¼ˆTASK2）に高優å…
ˆåº¦ä¸Šé™ãƒŸãƒ¥ãƒ¼ãƒ†ãƒƒã‚¯ã‚¹ã‚’
 *              ロックさせ，rot_rdq(TPRI_SELF)すると，残りの2つの低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯
 *              の優å…
ˆé †ä½ãŒå›žè»¢ã™ã‚‹ã“とを確認する．
 *      (B-2)
 *              上と同じ状況で，高優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ã®å„ªå…
ˆé †ä½ãŒå›žè»¢ã—ないことを確認
 *              する．
 *
 * 【使用リソース】
 *
 *      TASK1: 低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯ï¼Œãƒ¡ã‚¤ãƒ³ã‚¿ã‚¹ã‚¯ï¼Œæœ€åˆã‹ã‚‰èµ·å‹•
 *      TASK2: 低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯
 *      TASK3: 低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯
 *      TASK4: 低優å…
ˆåº¦ã‚¿ã‚¹ã‚¯
 *      MTX1: ミューテックス（TA_CEILING属性，上限は高優å…
ˆåº¦ï¼‰
 *      MTX2: ミューテックス（TA_CEILING属性，上限は高優å…
ˆåº¦ï¼‰
 *
 * 【テストシーケンス】
 *
 *      == TASK1（優å…
ˆåº¦ï¼šä½Žï¼‰==
 *              call(set_bit_func(bit_mutex))
 *      1:      act_tsk(TASK2)
 *      2:      rot_rdq(TPRI_SELF)
 *      //              低：TASK2→TASK1
 *      == TASK2-1（優å…
ˆåº¦ï¼šä½Žï¼‰1回め ==
 *      3:      loc_mtx(MTX1)
 *      //              高：TASK2，低：TASK1，MTX1：TASK2
 *      4:      ext_tsk() -> noreturn                   ... (A-1)
 *      //              低：TASK1
 *      == TASK1（続き）==
 *      5:      ref_mtx(MTX1, &rmtx)
 *              assert(rmtx.htskid == TSK_NONE)
 *              assert(rmtx.wtskid == TSK_NONE)
 *
 *      6:      act_tsk(TASK2)
 *              act_tsk(TASK3)
 *      7:      rot_rdq(TPRI_SELF)
 *      //              低：TASK2→TASK3→TASK1
 *      == TASK2-2（優å…
ˆåº¦ï¼šä½Žï¼‰2回め ==
 *      8:      loc_mtx(MTX1)
 *      //              高：TASK2，低：TASK3→TASK1，MTX1：TASK2
 *      9:      slp_tsk()
 *      //              低：TASK3→TASK1，MTX1：TASK2
 *      == TASK3（優å…
ˆåº¦ï¼šä½Žï¼‰==
 *      10:     loc_mtx(MTX1)
 *      //              低：TASK1，MTX1：TASK2→TASK3
 *      == TASK1（続き）==
 *      11:     wup_tsk(TASK2)
 *      //              高：TASK2，低：TASK1，MTX1：TASK2→TASK3
 *      == TASK2-2（続き）==
 *      12:     ext_tsk() -> noreturn                   ... (A-2)
 *      //              高：TASK3，低：TASK1，MTX1：TASK3
 *      == TASK3（続き）==
 *      13:     ref_mtx(MTX1, &rmtx)
 *              assert(rmtx.htskid == TASK3)
 *              assert(rmtx.wtskid == TSK_NONE)
 *              get_pri(TPRI_SELF, &tskpri)
 *              assert(tskpri == HIGH_PRIORITY)
 *              unl_mtx(MTX1)
 *              slp_tsk()
 *      //              低：TASK1
 *
 *      == TASK1（続き）==
 *      14:     act_tsk(TASK2)
 *      15:     rot_rdq(TPRI_SELF)
 *      //              低：TASK2→TASK1
 *      == TASK2-3（優å…
ˆåº¦ï¼šä½Žï¼‰3回め ==
 *      16:     loc_mtx(MTX1)
 *              loc_mtx(MTX2)
 *      //              高：TASK2，低：TASK1，MTX1：TASK2，MTX2：TASK2
 *      17:     ext_tsk() -> noreturn                   ... (A-3)
 *      //              低：TASK1
 *      == TASK1（続き）==
 *      18:     ref_mtx(MTX1, &rmtx)
 *              assert(rmtx.htskid == TSK_NONE)
 *              assert(rmtx.wtskid == TSK_NONE)
 *              ref_mtx(MTX2, &rmtx)
 *              assert(rmtx.htskid == TSK_NONE)
 *              assert(rmtx.wtskid == TSK_NONE)
 *
 *      19:     act_tsk(TASK2)
 *              wup_tsk(TASK3)
 *              act_tsk(TASK4)
 *      20:     rot_rdq(TPRI_SELF)
 *      //              低：TASK2→TASK3→TASK4→TASK1
 *      == TASK2-4（優å…
ˆåº¦ï¼šä½Žï¼‰4回め ==
 *      21:     loc_mtx(MTX1)
 *              loc_mtx(MTX2)
 *      //              高：TASK2，低：TASK3→TASK4→TASK1，MTX1：TASK2，MTX2：TASK2
 *      22:     chg_pri(TASK1, HIGH_PRIORITY)
 *      //              高：TASK2→TASK1，低：TASK3→TASK4，MTX1：TASK2，MTX2：TASK2
 *      23:     rot_rdq(TPRI_SELF)                              ... (B-1)(B-2)
 *      //              高：TASK2→TASK1，低：TASK4→TASK3，MTX1：TASK2，MTX2：TASK2
 *      24:     slp_tsk()
 *      //              高：TASK1，低：TASK4→TASK3，MTX1：TASK2，MTX2：TASK2
 *      == TASK1（続き）==
 *      25:     chg_pri(TSK_SELF, TPRI_INI)
 *      //              低：TASK4→TASK3→TASK1，MTX1：TASK2，MTX2：TASK2
 *      == TASK4（優å…
ˆåº¦ï¼šä½Žï¼‰==
 *      26:     loc_mtx(MTX2)
 *      //              低：TASK3→TASK1，MTX1：TASK2，MTX2：TASK2→TASK4
 *      == TASK3（続き）==
 *      27:     loc_mtx(MTX1)
 *      //              低：TASK1，MTX1：TASK2→TASK3，MTX2：TASK2→TASK4
 *      == TASK1（続き）==
 *      28:     wup_tsk(TASK2)
 *      //              高：TASK2，低：TASK1，MTX1：TASK2→TASK3，MTX2：TASK2→TASK4
 *      == TASK2-4（続き）==
 *      29:     ext_tsk() -> noreturn                   ... (A-4)
 *      //              高：TASK4→TASK3，低：TASK1，MTX1：TASK3，MTX2：TASK4
 *      == TASK4（続き）==
 *      30:     ref_mtx(MTX1, &rmtx)
 *              assert(rmtx.htskid == TASK3)
 *              assert(rmtx.wtskid == TSK_NONE)
 *              ref_mtx(MTX2, &rmtx)
 *              assert(rmtx.htskid == TASK4)
 *              assert(rmtx.wtskid == TSK_NONE)
 *              get_pri(TPRI_SELF, &tskpri)
 *              assert(tskpri == HIGH_PRIORITY)
 *              ext_tsk() -> noreturn
 *      //              高：TASK3，低：TASK1，MTX2：TASK4
 *      == TASK3（続き）==
 *      31:     get_pri(TPRI_SELF, &tskpri)
 *              assert(tskpri == HIGH_PRIORITY)
 *              ext_tsk() -> noreturn
 *      //              低：TASK1
 *      == TASK1（続き）==
 *      32:     END
 */

#include <kernel.h>
#include <t_syslog.h>
#include "syssvc/test_svc.h"
#include "kernel_cfg.h"
#include "test_mutex6.h"

extern ER       bit_mutex(void);

/* DO NOT DELETE THIS LINE -- gentest depends on it. */

void
task1(intptr_t exinf)
{
        ER_UINT ercd;
        T_RMTX  rmtx;

        test_start(__FILE__);

        set_bit_func(bit_mutex);

        check_point(1);
        ercd = act_tsk(TASK2);
        check_ercd(ercd, E_OK);

        check_point(2);
        ercd = rot_rdq(TPRI_SELF);
        check_ercd(ercd, E_OK);

        check_point(5);
        ercd = ref_mtx(MTX1, &rmtx);
        check_ercd(ercd, E_OK);

        check_assert(rmtx.htskid == TSK_NONE);

        check_assert(rmtx.wtskid == TSK_NONE);

        check_point(6);
        ercd = act_tsk(TASK2);
        check_ercd(ercd, E_OK);

        ercd = act_tsk(TASK3);
        check_ercd(ercd, E_OK);

        check_point(7);
        ercd = rot_rdq(TPRI_SELF);
        check_ercd(ercd, E_OK);

        check_point(11);
        ercd = wup_tsk(TASK2);
        check_ercd(ercd, E_OK);

        check_point(14);
        ercd = act_tsk(TASK2);
        check_ercd(ercd, E_OK);

        check_point(15);
        ercd = rot_rdq(TPRI_SELF);
        check_ercd(ercd, E_OK);

        check_point(18);
        ercd = ref_mtx(MTX1, &rmtx);
        check_ercd(ercd, E_OK);

        check_assert(rmtx.htskid == TSK_NONE);

        check_assert(rmtx.wtskid == TSK_NONE);

        ercd = ref_mtx(MTX2, &rmtx);
        check_ercd(ercd, E_OK);

        check_assert(rmtx.htskid == TSK_NONE);

        check_assert(rmtx.wtskid == TSK_NONE);

        check_point(19);
        ercd = act_tsk(TASK2);
        check_ercd(ercd, E_OK);

        ercd = wup_tsk(TASK3);
        check_ercd(ercd, E_OK);

        ercd = act_tsk(TASK4);
        check_ercd(ercd, E_OK);

        check_point(20);
        ercd = rot_rdq(TPRI_SELF);
        check_ercd(ercd, E_OK);

        check_point(25);
        ercd = chg_pri(TSK_SELF, TPRI_INI);
        check_ercd(ercd, E_OK);

        check_point(28);
        ercd = wup_tsk(TASK2);
        check_ercd(ercd, E_OK);

        check_finish(32);
        check_point(0);
}

static uint_t   task2_count = 0;

void
task2(intptr_t exinf)
{
        ER_UINT ercd;

        switch (++task2_count) {
        case 1:
                check_point(3);
                ercd = loc_mtx(MTX1);
                check_ercd(ercd, E_OK);

                check_point(4);
                ercd = ext_tsk();

                check_point(0);

        case 2:
                check_point(8);
                ercd = loc_mtx(MTX1);
                check_ercd(ercd, E_OK);

                check_point(9);
                ercd = slp_tsk();
                check_ercd(ercd, E_OK);

                check_point(12);
                ercd = ext_tsk();

                check_point(0);

        case 3:
                check_point(16);
                ercd = loc_mtx(MTX1);
                check_ercd(ercd, E_OK);

                ercd = loc_mtx(MTX2);
                check_ercd(ercd, E_OK);

                check_point(17);
                ercd = ext_tsk();

                check_point(0);

        case 4:
                check_point(21);
                ercd = loc_mtx(MTX1);
                check_ercd(ercd, E_OK);

                ercd = loc_mtx(MTX2);
                check_ercd(ercd, E_OK);

                check_point(22);
                ercd = chg_pri(TASK1, HIGH_PRIORITY);
                check_ercd(ercd, E_OK);

                check_point(23);
                ercd = rot_rdq(TPRI_SELF);
                check_ercd(ercd, E_OK);

                check_point(24);
                ercd = slp_tsk();
                check_ercd(ercd, E_OK);

                check_point(29);
                ercd = ext_tsk();

                check_point(0);

        default:
                check_point(0);
        }
        check_point(0);
}

void
task3(intptr_t exinf)
{
        ER_UINT ercd;
        PRI             tskpri;
        T_RMTX  rmtx;

        check_point(10);
        ercd = loc_mtx(MTX1);
        check_ercd(ercd, E_OK);

        check_point(13);
        ercd = ref_mtx(MTX1, &rmtx);
        check_ercd(ercd, E_OK);

        check_assert(rmtx.htskid == TASK3);

        check_assert(rmtx.wtskid == TSK_NONE);

        ercd = get_pri(TPRI_SELF, &tskpri);
        check_ercd(ercd, E_OK);

        check_assert(tskpri == HIGH_PRIORITY);

        ercd = unl_mtx(MTX1);
        check_ercd(ercd, E_OK);

        ercd = slp_tsk();
        check_ercd(ercd, E_OK);

        check_point(27);
        ercd = loc_mtx(MTX1);
        check_ercd(ercd, E_OK);

        check_point(31);
        ercd = get_pri(TPRI_SELF, &tskpri);
        check_ercd(ercd, E_OK);

        check_assert(tskpri == HIGH_PRIORITY);

        ercd = ext_tsk();

        check_point(0);
}

void
task4(intptr_t exinf)
{
        ER_UINT ercd;
        PRI             tskpri;
        T_RMTX  rmtx;

        check_point(26);
        ercd = loc_mtx(MTX2);
        check_ercd(ercd, E_OK);

        check_point(30);
        ercd = ref_mtx(MTX1, &rmtx);
        check_ercd(ercd, E_OK);

        check_assert(rmtx.htskid == TASK3);

        check_assert(rmtx.wtskid == TSK_NONE);

        ercd = ref_mtx(MTX2, &rmtx);
        check_ercd(ercd, E_OK);

        check_assert(rmtx.htskid == TASK4);

        check_assert(rmtx.wtskid == TSK_NONE);

        ercd = get_pri(TPRI_SELF, &tskpri);
        check_ercd(ercd, E_OK);

        check_assert(tskpri == HIGH_PRIORITY);

        ercd = ext_tsk();

        check_point(0);
}