task_sync.c

#include "kernel_impl.h"
#include "check.h"
#include "task.h"
#include "wait.h"

ソースコードを見る。

マクロ定義
#define	LOG_SLP_TSK_ENTER()
#define	LOG_SLP_TSK_LEAVE(ercd)
#define	LOG_TSLP_TSK_ENTER(tmout)
#define	LOG_TSLP_TSK_LEAVE(ercd)
#define	LOG_WUP_TSK_ENTER(tskid)
#define	LOG_WUP_TSK_LEAVE(ercd)
#define	LOG_IWUP_TSK_ENTER(tskid)
#define	LOG_IWUP_TSK_LEAVE(ercd)
#define	LOG_CAN_WUP_ENTER(tskid)
#define	LOG_CAN_WUP_LEAVE(ercd)
#define	LOG_REL_WAI_ENTER(tskid)
#define	LOG_REL_WAI_LEAVE(ercd)
#define	LOG_IREL_WAI_ENTER(tskid)
#define	LOG_IREL_WAI_LEAVE(ercd)
#define	LOG_SUS_TSK_ENTER(tskid)
#define	LOG_SUS_TSK_LEAVE(ercd)
#define	LOG_RSM_TSK_ENTER(tskid)
#define	LOG_RSM_TSK_LEAVE(ercd)
#define	LOG_DLY_TSK_ENTER(dlytim)
#define	LOG_DLY_TSK_LEAVE(ercd)
関数
ER	slp_tsk (void)
ER	tslp_tsk (TMO tmout)
ER	wup_tsk (ID tskid)
ER	iwup_tsk (ID tskid)
ER_UINT	can_wup (ID tskid)
ER	rel_wai (ID tskid)
ER	irel_wai (ID tskid)
ER	sus_tsk (ID tskid)
ER	rsm_tsk (ID tskid)
ER	dly_tsk (RELTIM dlytim)

---

マクロ定義

#define LOG_CAN_WUP_ENTER

(

tskid

)

task_sync.c の 88 行で定義されています。

参照元 can_wup().

#define LOG_CAN_WUP_LEAVE

(

ercd

)

task_sync.c の 92 行で定義されています。

参照元 can_wup().

#define LOG_DLY_TSK_ENTER

(

dlytim

)

task_sync.c の 128 行で定義されています。

参照元 dly_tsk().

#define LOG_DLY_TSK_LEAVE

(

ercd

)

task_sync.c の 132 行で定義されています。

参照元 dly_tsk().

#define LOG_IREL_WAI_ENTER

(

tskid

)

task_sync.c の 104 行で定義されています。

参照元 irel_wai().

#define LOG_IREL_WAI_LEAVE

(

ercd

)

task_sync.c の 108 行で定義されています。

参照元 irel_wai().

#define LOG_IWUP_TSK_ENTER

(

tskid

)

task_sync.c の 80 行で定義されています。

参照元 iwup_tsk().

#define LOG_IWUP_TSK_LEAVE

(

ercd

)

task_sync.c の 84 行で定義されています。

参照元 iwup_tsk().

#define LOG_REL_WAI_ENTER

(

tskid

)

task_sync.c の 96 行で定義されています。

参照元 rel_wai().

#define LOG_REL_WAI_LEAVE

(

ercd

)

task_sync.c の 100 行で定義されています。

参照元 rel_wai().

#define LOG_RSM_TSK_ENTER

(

tskid

)

task_sync.c の 120 行で定義されています。

参照元 rsm_tsk().

#define LOG_RSM_TSK_LEAVE

(

ercd

)

task_sync.c の 124 行で定義されています。

参照元 rsm_tsk().

 

#define LOG_SLP_TSK_ENTER

(

)

task_sync.c の 56 行で定義されています。

参照元 slp_tsk().

#define LOG_SLP_TSK_LEAVE

(

ercd

)

task_sync.c の 60 行で定義されています。

参照元 slp_tsk().

#define LOG_SUS_TSK_ENTER

(

tskid

)

task_sync.c の 112 行で定義されています。

参照元 sus_tsk().

#define LOG_SUS_TSK_LEAVE

(

ercd

)

task_sync.c の 116 行で定義されています。

参照元 sus_tsk().

#define LOG_TSLP_TSK_ENTER

(

tmout

)

task_sync.c の 64 行で定義されています。

参照元 tslp_tsk().

#define LOG_TSLP_TSK_LEAVE

(

ercd

)

task_sync.c の 68 行で定義されています。

参照元 tslp_tsk().

#define LOG_WUP_TSK_ENTER

(

tskid

)

task_sync.c の 72 行で定義されています。

参照元 wup_tsk().

#define LOG_WUP_TSK_LEAVE

(

ercd

)

task_sync.c の 76 行で定義されています。

参照元 wup_tsk().

---

関数

ER_UINT can_wup

(

ID

tskid

)

task_sync.c の 300 行で定義されています。

参照先 CHECK_TSKCTX_UNL, CHECK_TSKID_SELF, E_OBJ, get_tcb_self, LOG_CAN_WUP_ENTER, LOG_CAN_WUP_LEAVE, t_lock_cpu, t_unlock_cpu, task_control_block::tstat, TSTAT_DORMANT, と task_control_block::wupque.

参照元 main_task().

{
    TCB     *p_tcb;
    ER_UINT ercd;

    LOG_CAN_WUP_ENTER(tskid);
    CHECK_TSKCTX_UNL();
    CHECK_TSKID_SELF(tskid);
    p_tcb = get_tcb_self(tskid);

    t_lock_cpu();
    if (TSTAT_DORMANT(p_tcb->tstat)) {
        ercd = E_OBJ;
    }
    else {
        ercd = p_tcb->wupque ? 1 : 0;
        p_tcb->wupque = false;
    }
    t_unlock_cpu();

  error_exit:
    LOG_CAN_WUP_LEAVE(ercd);
    return(ercd);
}

ER dly_tsk

(

RELTIM

dlytim

)

task_sync.c の 503 行で定義されています。

参照先 CHECK_DISPATCH, CHECK_PAR, dispatch, LOG_DLY_TSK_ENTER, LOG_DLY_TSK_LEAVE, LOG_TSKSTAT, make_non_runnable, p_runtsk, waiting_information::p_tmevtb, t_lock_cpu, t_unlock_cpu, TMAX_RELTIM, tmevtb_enqueue(), TS_WAIT_DLY, TS_WAITING, wait_tmout_ok, と waiting_information::wercd.

参照元 logtask_flush(), logtask_main(), と task().

{
    WINFO   winfo;
    TMEVTB  tmevtb;
    ER      ercd;

    LOG_DLY_TSK_ENTER(dlytim);
    CHECK_DISPATCH();
    CHECK_PAR(dlytim <= TMAX_RELTIM);

    t_lock_cpu();
    p_runtsk->tstat = (TS_WAITING | TS_WAIT_DLY);
    (void) make_non_runnable(p_runtsk);
    p_runtsk->p_winfo = &winfo;
    winfo.p_tmevtb = &tmevtb;
    tmevtb_enqueue(&tmevtb, dlytim, (CBACK) wait_tmout_ok, (void *) p_runtsk);
    LOG_TSKSTAT(p_runtsk);
    dispatch();
    ercd = winfo.wercd;
    t_unlock_cpu();

  error_exit:
    LOG_DLY_TSK_LEAVE(ercd);
    return(ercd);
}

ER irel_wai

(

ID

tskid

)

task_sync.c の 368 行で定義されています。

参照先 CHECK_INTCTX_UNL, CHECK_TSKID, E_OBJ, E_OK, get_tcb, i_lock_cpu, i_unlock_cpu, LOG_IREL_WAI_ENTER, LOG_IREL_WAI_LEAVE, reqflg, task_control_block::tstat, TSTAT_WAITING, と wait_release.

{
    TCB     *p_tcb;
    ER      ercd;

    LOG_IREL_WAI_ENTER(tskid);
    CHECK_INTCTX_UNL();
    CHECK_TSKID(tskid);
    p_tcb = get_tcb(tskid);

    i_lock_cpu();
    if (!TSTAT_WAITING(p_tcb->tstat)) {
        ercd = E_OBJ;
    }
    else {
        if (wait_release(p_tcb)) {
            reqflg = true;
        }
        ercd = E_OK;
    }
    i_unlock_cpu();

  error_exit:
    LOG_IREL_WAI_LEAVE(ercd);
    return(ercd);
}

ER iwup_tsk

(

ID

tskid

)

task_sync.c の 258 行で定義されています。

参照先 CHECK_INTCTX_UNL, CHECK_TSKID, E_OBJ, E_OK, E_QOVR, get_tcb, i_lock_cpu, i_unlock_cpu, LOG_IWUP_TSK_ENTER, LOG_IWUP_TSK_LEAVE, reqflg, task_control_block::tstat, TSTAT_DORMANT, TSTAT_WAIT_SLP, wait_complete, と task_control_block::wupque.

{
    TCB     *p_tcb;
    ER      ercd;

    LOG_IWUP_TSK_ENTER(tskid);
    CHECK_INTCTX_UNL();
    CHECK_TSKID(tskid);
    p_tcb = get_tcb(tskid);

    i_lock_cpu();
    if (TSTAT_DORMANT(p_tcb->tstat)) {
        ercd = E_OBJ;
    }
    else if (TSTAT_WAIT_SLP(p_tcb->tstat)) {
        if (wait_complete(p_tcb)) {
            reqflg = true;
        }
        ercd = E_OK;
    }
    else if (!(p_tcb->wupque)) {
        p_tcb->wupque = true;
        ercd = E_OK;
    }
    else {
        ercd = E_QOVR;
    }
    i_unlock_cpu();

  error_exit:
    LOG_IWUP_TSK_LEAVE(ercd);
    return(ercd);
}

ER rel_wai

(

ID

tskid

)

task_sync.c の 333 行で定義されています。

参照先 CHECK_TSKCTX_UNL, CHECK_TSKID, dispatch, E_OBJ, E_OK, get_tcb, LOG_REL_WAI_ENTER, LOG_REL_WAI_LEAVE, t_lock_cpu, t_unlock_cpu, task_control_block::tstat, TSTAT_WAITING, と wait_release.

参照元 main_task().

{
    TCB     *p_tcb;
    ER      ercd;

    LOG_REL_WAI_ENTER(tskid);
    CHECK_TSKCTX_UNL();
    CHECK_TSKID(tskid);
    p_tcb = get_tcb(tskid);

    t_lock_cpu();
    if (!TSTAT_WAITING(p_tcb->tstat)) {
        ercd = E_OBJ;
    }
    else {
        if (wait_release(p_tcb)) {
            dispatch();
        }
        ercd = E_OK;
    }
    t_unlock_cpu();

  error_exit:
    LOG_REL_WAI_LEAVE(ercd);
    return(ercd);
}

ER rsm_tsk

(

ID

tskid

)

task_sync.c の 457 行で定義されています。

参照先 CHECK_TSKCTX_UNL, CHECK_TSKID, dispatch, E_OBJ, E_OK, get_tcb, LOG_RSM_TSK_ENTER, LOG_RSM_TSK_LEAVE, LOG_TSKSTAT, make_runnable, t_lock_cpu, t_unlock_cpu, TS_SUSPENDED, task_control_block::tstat, TSTAT_SUSPENDED, と TSTAT_WAITING.

参照元 main_task().

{
    TCB     *p_tcb;
    ER      ercd;

    LOG_RSM_TSK_ENTER(tskid);
    CHECK_TSKCTX_UNL();
    CHECK_TSKID(tskid);
    p_tcb = get_tcb(tskid);

    t_lock_cpu();
    if (!TSTAT_SUSPENDED(p_tcb->tstat)) {
        ercd = E_OBJ;
    }
    else if (!TSTAT_WAITING(p_tcb->tstat)) {
        /*
         *  強制待ち状態から実行できる状態への遷移
         */
        if (make_runnable(p_tcb)) {
            dispatch();
        }
        ercd = E_OK;
    }
    else {
        /*
         *  二重待ち状態から待ち状態への遷移
         */
        p_tcb->tstat &= ~TS_SUSPENDED;
        LOG_TSKSTAT(p_tcb);
        ercd = E_OK;
    }
    t_unlock_cpu();

  error_exit:
    LOG_RSM_TSK_LEAVE(ercd);
    return(ercd);
}

ER slp_tsk

(

void

)

task_sync.c の 141 行で定義されています。

参照先 CHECK_DISPATCH, dispatch, E_OK, LOG_SLP_TSK_ENTER, LOG_SLP_TSK_LEAVE, LOG_TSKSTAT, make_wait(), p_runtsk, t_lock_cpu, t_unlock_cpu, TS_WAIT_SLP, TS_WAITING, と waiting_information::wercd.

参照元 task().

{
    WINFO   winfo;
    ER      ercd;

    LOG_SLP_TSK_ENTER();
    CHECK_DISPATCH();

    t_lock_cpu();
    if (p_runtsk->wupque) {
        p_runtsk->wupque = false;
        ercd = E_OK;
    }
    else {
        p_runtsk->tstat = (TS_WAITING | TS_WAIT_SLP);
        make_wait(&winfo);
        LOG_TSKSTAT(p_runtsk);
        dispatch();
        ercd = winfo.wercd;
    }
    t_unlock_cpu();

  error_exit:
    LOG_SLP_TSK_LEAVE(ercd);
    return(ercd);
}

ER sus_tsk

(

ID

tskid

)

task_sync.c の 403 行で定義されています。

参照先 CHECK_TSKCTX_UNL, CHECK_TSKID_SELF, dispatch, dspflg, E_CTX, E_OBJ, E_OK, E_QOVR, get_tcb_self, LOG_SUS_TSK_ENTER, LOG_SUS_TSK_LEAVE, LOG_TSKSTAT, make_non_runnable, p_runtsk, t_lock_cpu, t_unlock_cpu, TS_SUSPENDED, task_control_block::tstat, TSTAT_DORMANT, TSTAT_RUNNABLE, と TSTAT_SUSPENDED.

参照元 main_task().

{
    TCB     *p_tcb;
    ER      ercd;

    LOG_SUS_TSK_ENTER(tskid);
    CHECK_TSKCTX_UNL();
    CHECK_TSKID_SELF(tskid);
    p_tcb = get_tcb_self(tskid);

    t_lock_cpu();
    if (p_tcb == p_runtsk && !dspflg) {
        ercd = E_CTX;
    }
    else if (TSTAT_DORMANT(p_tcb->tstat)) {
        ercd = E_OBJ;
    }
    else if (TSTAT_RUNNABLE(p_tcb->tstat)) {
        /*
         *  実行できる状態から強制待ち状態への遷移
         */
        p_tcb->tstat = TS_SUSPENDED;
        LOG_TSKSTAT(p_tcb);
        if (make_non_runnable(p_tcb)) {
            dispatch();
        }
        ercd = E_OK;
    }
    else if (TSTAT_SUSPENDED(p_tcb->tstat)) {
        ercd = E_QOVR;
    }
    else {
        /*
         *  待ち状態から二重待ち状態への遷移
         */
        p_tcb->tstat |= TS_SUSPENDED;
        LOG_TSKSTAT(p_tcb);
        ercd = E_OK;
    }
    t_unlock_cpu();

  error_exit:
    LOG_SUS_TSK_LEAVE(ercd);
    return(ercd);
}

ER tslp_tsk

(

TMO

tmout

)

task_sync.c の 176 行で定義されています。

参照先 CHECK_DISPATCH, CHECK_TMOUT, dispatch, E_OK, E_TMOUT, LOG_TSKSTAT, LOG_TSLP_TSK_ENTER, LOG_TSLP_TSK_LEAVE, make_wait_tmout, p_runtsk, t_lock_cpu, t_unlock_cpu, TMO_POL, TS_WAIT_SLP, TS_WAITING, と waiting_information::wercd.

参照元 task().

{
    WINFO   winfo;
    TMEVTB  tmevtb;
    ER      ercd;

    LOG_TSLP_TSK_ENTER(tmout);
    CHECK_DISPATCH();
    CHECK_TMOUT(tmout);

    t_lock_cpu();
    if (p_runtsk->wupque) {
        p_runtsk->wupque = false;
        ercd = E_OK;
    }
    else if (tmout == TMO_POL) {
        ercd = E_TMOUT;
    }
    else {
        p_runtsk->tstat = (TS_WAITING | TS_WAIT_SLP);
        make_wait_tmout(&winfo, &tmevtb, tmout);
        LOG_TSKSTAT(p_runtsk);
        dispatch();
        ercd = winfo.wercd;
    }
    t_unlock_cpu();

  error_exit:
    LOG_TSLP_TSK_LEAVE(ercd);
    return(ercd);
}

ER wup_tsk

(

ID

tskid

)

task_sync.c の 216 行で定義されています。

参照先 CHECK_TSKCTX_UNL, CHECK_TSKID_SELF, dispatch, E_OBJ, E_OK, E_QOVR, get_tcb_self, LOG_WUP_TSK_ENTER, LOG_WUP_TSK_LEAVE, t_lock_cpu, t_unlock_cpu, task_control_block::tstat, TSTAT_DORMANT, TSTAT_WAIT_SLP, wait_complete, と task_control_block::wupque.

参照元 main_task().

{
    TCB     *p_tcb;
    ER      ercd;

    LOG_WUP_TSK_ENTER(tskid);
    CHECK_TSKCTX_UNL();
    CHECK_TSKID_SELF(tskid);
    p_tcb = get_tcb_self(tskid);

    t_lock_cpu();
    if (TSTAT_DORMANT(p_tcb->tstat)) {
        ercd = E_OBJ;
    }
    else if (TSTAT_WAIT_SLP(p_tcb->tstat)) {
        if (wait_complete(p_tcb)) {
            dispatch();
        }
        ercd = E_OK;
    }
    else if (!(p_tcb->wupque)) {
        p_tcb->wupque = true;
        ercd = E_OK;
    }
    else {
        ercd = E_QOVR;
    }
    t_unlock_cpu();

  error_exit:
    LOG_WUP_TSK_LEAVE(ercd);
    return(ercd);
}