eventflag.c

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

ソースコードを見る。

マクロ定義
#define	LOG_SET_FLG_ENTER(flgid, setptn)
#define	LOG_SET_FLG_LEAVE(ercd)
#define	LOG_ISET_FLG_ENTER(flgid, setptn)
#define	LOG_ISET_FLG_LEAVE(ercd)
#define	LOG_CLR_FLG_ENTER(flgid, clrptn)
#define	LOG_CLR_FLG_LEAVE(ercd)
#define	LOG_WAI_FLG_ENTER(flgid, waiptn, wfmode, p_flgptn)
#define	LOG_WAI_FLG_LEAVE(ercd, flgptn)
#define	LOG_POL_FLG_ENTER(flgid, waiptn, wfmode, p_flgptn)
#define	LOG_POL_FLG_LEAVE(ercd, flgptn)
#define	LOG_TWAI_FLG_ENTER(flgid, waiptn, wfmode, p_flgptn, tmout)
#define	LOG_TWAI_FLG_LEAVE(ercd, flgptn)
#define	LOG_INI_FLG_ENTER(flgid)
#define	LOG_INI_FLG_LEAVE(ercd)
#define	LOG_REF_FLG_ENTER(flgid, pk_rflg)
#define	LOG_REF_FLG_LEAVE(ercd, pk_rflg)
#define	tnum_flg   ((uint_t)(tmax_flgid - TMIN_FLGID + 1))
#define	INDEX_FLG(flgid)   ((uint_t)((flgid) - TMIN_FLGID))
#define	get_flgcb(flgid)   (&(flgcb_table[INDEX_FLG(flgid)]))
関数
void	initialize_eventflag (void)
bool_t	check_flg_cond (FLGCB *p_flgcb, FLGPTN waiptn, MODE wfmode, FLGPTN *p_flgptn)
ER	set_flg (ID flgid, FLGPTN setptn)
ER	iset_flg (ID flgid, FLGPTN setptn)
ER	clr_flg (ID flgid, FLGPTN clrptn)
ER	wai_flg (ID flgid, FLGPTN waiptn, MODE wfmode, FLGPTN *p_flgptn)
ER	pol_flg (ID flgid, FLGPTN waiptn, MODE wfmode, FLGPTN *p_flgptn)
ER	twai_flg (ID flgid, FLGPTN waiptn, MODE wfmode, FLGPTN *p_flgptn, TMO tmout)
ER	ini_flg (ID flgid)
ER	ref_flg (ID flgid, T_RFLG *pk_rflg)

---

マクロ定義

#define get_flgcb

(

flgid

)

(&(flgcb_table[INDEX_FLG(flgid)]))

eventflag.c の 129 行で定義されています。

参照元 clr_flg(), ini_flg(), iset_flg(), pol_flg(), ref_flg(), set_flg(), twai_flg(), と wai_flg().

#define INDEX_FLG

(

flgid

)

((uint_t)((flgid) - TMIN_FLGID))

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

#define LOG_CLR_FLG_ENTER	(	flgid,
		clrptn		)

eventflag.c の 73 行で定義されています。

参照元 clr_flg().

#define LOG_CLR_FLG_LEAVE

(

ercd

)

eventflag.c の 77 行で定義されています。

参照元 clr_flg().

#define LOG_INI_FLG_ENTER

(

flgid

)

eventflag.c の 105 行で定義されています。

参照元 ini_flg().

#define LOG_INI_FLG_LEAVE

(

ercd

)

eventflag.c の 109 行で定義されています。

参照元 ini_flg().

#define LOG_ISET_FLG_ENTER	(	flgid,
		setptn		)

eventflag.c の 65 行で定義されています。

参照元 iset_flg().

#define LOG_ISET_FLG_LEAVE

(

ercd

)

eventflag.c の 69 行で定義されています。

参照元 iset_flg().

#define LOG_POL_FLG_ENTER	(	flgid,
		waiptn,
		wfmode,
		p_flgptn		)

eventflag.c の 89 行で定義されています。

参照元 pol_flg().

#define LOG_POL_FLG_LEAVE	(	ercd,
		flgptn		)

eventflag.c の 93 行で定義されています。

参照元 pol_flg().

#define LOG_REF_FLG_ENTER	(	flgid,
		pk_rflg		)

eventflag.c の 113 行で定義されています。

参照元 ref_flg().

#define LOG_REF_FLG_LEAVE	(	ercd,
		pk_rflg		)

eventflag.c の 117 行で定義されています。

参照元 ref_flg().

#define LOG_SET_FLG_ENTER	(	flgid,
		setptn		)

eventflag.c の 57 行で定義されています。

参照元 set_flg().

#define LOG_SET_FLG_LEAVE

(

ercd

)

eventflag.c の 61 行で定義されています。

参照元 set_flg().

#define LOG_TWAI_FLG_ENTER	(	flgid,
		waiptn,
		wfmode,
		p_flgptn,
		tmout		)

eventflag.c の 97 行で定義されています。

参照元 twai_flg().

#define LOG_TWAI_FLG_LEAVE	(	ercd,
		flgptn		)

eventflag.c の 101 行で定義されています。

参照元 twai_flg().

#define LOG_WAI_FLG_ENTER	(	flgid,
		waiptn,
		wfmode,
		p_flgptn		)

eventflag.c の 81 行で定義されています。

参照元 wai_flg().

#define LOG_WAI_FLG_LEAVE	(	ercd,
		flgptn		)

eventflag.c の 85 行で定義されています。

参照元 wai_flg().

#define tnum_flg   ((uint_t)(tmax_flgid - TMIN_FLGID + 1))

eventflag.c の 123 行で定義されています。

参照元 initialize_eventflag().

---

関数

bool_t check_flg_cond	(	FLGCB *	p_flgcb,
		FLGPTN	waiptn,
		MODE	wfmode,
		FLGPTN *	p_flgptn
	)

eventflag.c の 157 行で定義されています。

参照先 eventflag_initialization_block::flgatr, eventflag_control_block::flgptn, eventflag_control_block::p_flginib, TA_CLR, と TWF_ORW.

参照元 iset_flg(), pol_flg(), set_flg(), twai_flg(), と wai_flg().

{
    if ((wfmode & TWF_ORW) != 0U ? (p_flgcb->flgptn & waiptn) != 0U
                                    : (p_flgcb->flgptn & waiptn) == waiptn) {
        *p_flgptn = p_flgcb->flgptn;
        if ((p_flgcb->p_flginib->flgatr & TA_CLR) != 0U) {
            p_flgcb->flgptn = 0U;
        }
        return(true);
    }
    return(false);
}

ER clr_flg	(	ID	flgid,
		FLGPTN	clrptn
	)

eventflag.c の 276 行で定義されています。

参照先 CHECK_FLGID, CHECK_TSKCTX_UNL, E_OK, eventflag_control_block::flgptn, get_flgcb, LOG_CLR_FLG_ENTER, LOG_CLR_FLG_LEAVE, t_lock_cpu, と t_unlock_cpu.

{
    FLGCB   *p_flgcb;
    ER      ercd;

    LOG_CLR_FLG_ENTER(flgid, clrptn);
    CHECK_TSKCTX_UNL();
    CHECK_FLGID(flgid);
    p_flgcb = get_flgcb(flgid);

    t_lock_cpu();
    p_flgcb->flgptn &= clrptn; 
    ercd = E_OK;
    t_unlock_cpu();

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

ER ini_flg

(

ID

flgid

)

eventflag.c の 442 行で定義されています。

参照先 CHECK_FLGID, CHECK_TSKCTX_UNL, dispatch, E_OK, eventflag_control_block::flgptn, get_flgcb, eventflag_initialization_block::iflgptn, init_wait_queue, LOG_INI_FLG_ENTER, LOG_INI_FLG_LEAVE, eventflag_control_block::p_flginib, t_lock_cpu, t_unlock_cpu, と eventflag_control_block::wait_queue.

{
    FLGCB   *p_flgcb;
    bool_t  dspreq;
    ER      ercd;
    
    LOG_INI_FLG_ENTER(flgid);
    CHECK_TSKCTX_UNL();
    CHECK_FLGID(flgid);
    p_flgcb = get_flgcb(flgid);

    t_lock_cpu();
    dspreq = init_wait_queue(&(p_flgcb->wait_queue));
    p_flgcb->flgptn = p_flgcb->p_flginib->iflgptn;
    if (dspreq) {
        dispatch();
    }
    ercd = E_OK;
    t_unlock_cpu();

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

void initialize_eventflag

(

void

)

eventflag.c の 137 行で定義されています。

参照先 flgcb_table, flginib_table, eventflag_control_block::flgptn, eventflag_initialization_block::iflgptn, eventflag_control_block::p_flginib, queue_initialize(), tnum_flg, と eventflag_control_block::wait_queue.

{
    uint_t  i;
    FLGCB   *p_flgcb;

    for (p_flgcb = flgcb_table, i = 0; i < tnum_flg; p_flgcb++, i++) {
        queue_initialize(&(p_flgcb->wait_queue));
        p_flgcb->p_flginib = &(flginib_table[i]);
        p_flgcb->flgptn = p_flgcb->p_flginib->iflgptn;
    }
}

ER iset_flg	(	ID	flgid,
		FLGPTN	setptn
	)

eventflag.c の 229 行で定義されています。

参照先 check_flg_cond(), CHECK_FLGID, CHECK_INTCTX_UNL, E_OK, eventflag_initialization_block::flgatr, eventflag_waiting_information::flgptn, eventflag_control_block::flgptn, get_flgcb, i_lock_cpu, i_unlock_cpu, LOG_ISET_FLG_ENTER, LOG_ISET_FLG_LEAVE, eventflag_control_block::p_flginib, queue::p_next, task_control_block::p_winfo, queue_delete(), reqflg, TA_CLR, task_control_block::task_queue, eventflag_waiting_information::waiptn, wait_complete, eventflag_control_block::wait_queue, と eventflag_waiting_information::wfmode.

{
    FLGCB   *p_flgcb;
    QUEUE   *p_queue;
    TCB     *p_tcb;
    WINFO_FLG *p_winfo_flg;
    ER      ercd;

    LOG_ISET_FLG_ENTER(flgid, setptn);
    CHECK_INTCTX_UNL();
    CHECK_FLGID(flgid);
    p_flgcb = get_flgcb(flgid);

    i_lock_cpu();
    p_flgcb->flgptn |= setptn;
    p_queue = p_flgcb->wait_queue.p_next;
    while (p_queue != &(p_flgcb->wait_queue)) {
        p_tcb = (TCB *) p_queue;
        p_queue = p_queue->p_next;
        p_winfo_flg = (WINFO_FLG *)(p_tcb->p_winfo);
        if (check_flg_cond(p_flgcb, p_winfo_flg->waiptn,
                            p_winfo_flg->wfmode, &(p_winfo_flg->flgptn))) {
            queue_delete(&(p_tcb->task_queue));
            if (wait_complete(p_tcb)) {
                reqflg = true;
            }
            if ((p_flgcb->p_flginib->flgatr & TA_CLR) != 0U) {
                break;
            }
        }
    }
    ercd = E_OK;
    i_unlock_cpu();

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

ER pol_flg	(	ID	flgid,
		FLGPTN	waiptn,
		MODE	wfmode,
		FLGPTN *	p_flgptn
	)

eventflag.c の 351 行で定義されています。

参照先 check_flg_cond(), CHECK_FLGID, CHECK_PAR, CHECK_TSKCTX_UNL, E_ILUSE, E_OK, E_TMOUT, eventflag_initialization_block::flgatr, get_flgcb, LOG_POL_FLG_ENTER, LOG_POL_FLG_LEAVE, eventflag_control_block::p_flginib, queue_empty(), t_lock_cpu, t_unlock_cpu, TA_WMUL, TWF_ANDW, TWF_ORW, と eventflag_control_block::wait_queue.

{
    FLGCB   *p_flgcb;
    ER      ercd;

    LOG_POL_FLG_ENTER(flgid, waiptn, wfmode, p_flgptn);
    CHECK_TSKCTX_UNL();
    CHECK_FLGID(flgid);
    CHECK_PAR(waiptn != 0U);
    CHECK_PAR(wfmode == TWF_ORW || wfmode == TWF_ANDW);
    p_flgcb = get_flgcb(flgid);

    t_lock_cpu();
    if ((p_flgcb->p_flginib->flgatr & TA_WMUL) == 0U
                    && !queue_empty(&(p_flgcb->wait_queue))) {
        ercd = E_ILUSE;
    }
    else if (check_flg_cond(p_flgcb, waiptn, wfmode, p_flgptn)) {
        ercd = E_OK;
    }
    else {
        ercd = E_TMOUT;
    }
    t_unlock_cpu();

  error_exit:
    LOG_POL_FLG_LEAVE(ercd, *p_flgptn);
    return(ercd);
}

ER ref_flg	(	ID	flgid,
		T_RFLG *	pk_rflg
	)

eventflag.c の 475 行で定義されています。

参照先 CHECK_FLGID, CHECK_TSKCTX_UNL, E_OK, eventflag_control_block::flgptn, t_rflg::flgptn, get_flgcb, LOG_REF_FLG_ENTER, LOG_REF_FLG_LEAVE, t_lock_cpu, t_unlock_cpu, eventflag_control_block::wait_queue, wait_tskid(), と t_rflg::wtskid.

{
    FLGCB   *p_flgcb;
    ER      ercd;
    
    LOG_REF_FLG_ENTER(flgid, pk_rflg);
    CHECK_TSKCTX_UNL();
    CHECK_FLGID(flgid);
    p_flgcb = get_flgcb(flgid);

    t_lock_cpu();
    pk_rflg->wtskid = wait_tskid(&(p_flgcb->wait_queue));
    pk_rflg->flgptn = p_flgcb->flgptn;
    ercd = E_OK;
    t_unlock_cpu();

  error_exit:
    LOG_REF_FLG_LEAVE(ercd, pk_rflg);
    return(ercd);
}

ER set_flg	(	ID	flgid,
		FLGPTN	setptn
	)

eventflag.c の 178 行で定義されています。

参照先 check_flg_cond(), CHECK_FLGID, CHECK_TSKCTX_UNL, dispatch, E_OK, eventflag_initialization_block::flgatr, eventflag_waiting_information::flgptn, eventflag_control_block::flgptn, get_flgcb, LOG_SET_FLG_ENTER, LOG_SET_FLG_LEAVE, eventflag_control_block::p_flginib, queue::p_next, task_control_block::p_winfo, queue_delete(), t_lock_cpu, t_unlock_cpu, TA_CLR, task_control_block::task_queue, eventflag_waiting_information::waiptn, wait_complete, eventflag_control_block::wait_queue, と eventflag_waiting_information::wfmode.

{
    FLGCB   *p_flgcb;
    QUEUE   *p_queue;
    TCB     *p_tcb;
    WINFO_FLG *p_winfo_flg;
    bool_t  dspreq = false;
    ER      ercd;

    LOG_SET_FLG_ENTER(flgid, setptn);
    CHECK_TSKCTX_UNL();
    CHECK_FLGID(flgid);
    p_flgcb = get_flgcb(flgid);

    t_lock_cpu();
    p_flgcb->flgptn |= setptn;
    p_queue = p_flgcb->wait_queue.p_next;
    while (p_queue != &(p_flgcb->wait_queue)) {
        p_tcb = (TCB *) p_queue;
        p_queue = p_queue->p_next;
        p_winfo_flg = (WINFO_FLG *)(p_tcb->p_winfo);
        if (check_flg_cond(p_flgcb, p_winfo_flg->waiptn,
                            p_winfo_flg->wfmode, &(p_winfo_flg->flgptn))) {
            queue_delete(&(p_tcb->task_queue));
            if (wait_complete(p_tcb)) {
                dspreq = true;
            }
            if ((p_flgcb->p_flginib->flgatr & TA_CLR) != 0U) {
                break;
            }
        }
    }
    if (dspreq) {
        dispatch();
    }
    ercd = E_OK;
    t_unlock_cpu();

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

ER twai_flg	(	ID	flgid,
		FLGPTN	waiptn,
		MODE	wfmode,
		FLGPTN *	p_flgptn,
		TMO	tmout
	)

eventflag.c の 389 行で定義されています。

参照先 CHECK_DISPATCH, check_flg_cond(), CHECK_FLGID, CHECK_PAR, CHECK_TMOUT, dispatch, E_ILUSE, E_OK, E_TMOUT, eventflag_initialization_block::flgatr, get_flgcb, LOG_TWAI_FLG_ENTER, LOG_TWAI_FLG_LEAVE, eventflag_control_block::p_flginib, p_runtsk, queue_empty(), t_lock_cpu, t_unlock_cpu, TA_WMUL, TMO_POL, TS_WAIT_FLG, TS_WAITING, TWF_ANDW, TWF_ORW, eventflag_waiting_information::waiptn, eventflag_control_block::wait_queue, waiting_information::wercd, eventflag_waiting_information::wfmode, wait_object_waiting_information::winfo, と wobj_make_wait_tmout.

{
    FLGCB   *p_flgcb;
    WINFO_FLG winfo_flg;
    TMEVTB  tmevtb;
    ER      ercd;

    LOG_TWAI_FLG_ENTER(flgid, waiptn, wfmode, p_flgptn, tmout);
    CHECK_DISPATCH();
    CHECK_FLGID(flgid);
    CHECK_PAR(waiptn != 0U);
    CHECK_PAR(wfmode == TWF_ORW || wfmode == TWF_ANDW);
    CHECK_TMOUT(tmout);
    p_flgcb = get_flgcb(flgid);

    t_lock_cpu();
    if ((p_flgcb->p_flginib->flgatr & TA_WMUL) == 0U
                    && !queue_empty(&(p_flgcb->wait_queue))) {
        ercd = E_ILUSE;
    }
    else if (check_flg_cond(p_flgcb, waiptn, wfmode, p_flgptn)) {
        ercd = E_OK;
    }
    else if (tmout == TMO_POL) {
        ercd = E_TMOUT;
    }
    else {
        winfo_flg.waiptn = waiptn;
        winfo_flg.wfmode = wfmode;
        p_runtsk->tstat = (TS_WAITING | TS_WAIT_FLG);
        wobj_make_wait_tmout((WOBJCB *) p_flgcb, (WINFO_WOBJ *) &winfo_flg,
                                                        &tmevtb, tmout);
        dispatch();
        ercd = winfo_flg.winfo.wercd;
        if (ercd == E_OK) {
            *p_flgptn = winfo_flg.flgptn;
        }
    }
    t_unlock_cpu();

  error_exit:
    LOG_TWAI_FLG_LEAVE(ercd, *p_flgptn);
    return(ercd);
}

ER wai_flg	(	ID	flgid,
		FLGPTN	waiptn,
		MODE	wfmode,
		FLGPTN *	p_flgptn
	)

eventflag.c の 304 行で定義されています。

参照先 CHECK_DISPATCH, check_flg_cond(), CHECK_FLGID, CHECK_PAR, dispatch, E_ILUSE, E_OK, eventflag_initialization_block::flgatr, get_flgcb, LOG_WAI_FLG_ENTER, LOG_WAI_FLG_LEAVE, eventflag_control_block::p_flginib, p_runtsk, queue_empty(), t_lock_cpu, t_unlock_cpu, TA_WMUL, TS_WAIT_FLG, TS_WAITING, TWF_ANDW, TWF_ORW, eventflag_waiting_information::waiptn, eventflag_control_block::wait_queue, waiting_information::wercd, eventflag_waiting_information::wfmode, wait_object_waiting_information::winfo, と wobj_make_wait.

{
    FLGCB   *p_flgcb;
    WINFO_FLG winfo_flg;
    ER      ercd;

    LOG_WAI_FLG_ENTER(flgid, waiptn, wfmode, p_flgptn);
    CHECK_DISPATCH();
    CHECK_FLGID(flgid);
    CHECK_PAR(waiptn != 0U);
    CHECK_PAR(wfmode == TWF_ORW || wfmode == TWF_ANDW);
    p_flgcb = get_flgcb(flgid);

    t_lock_cpu();
    if ((p_flgcb->p_flginib->flgatr & TA_WMUL) == 0U
                    && !queue_empty(&(p_flgcb->wait_queue))) {
        ercd = E_ILUSE;
    }
    else if (check_flg_cond(p_flgcb, waiptn, wfmode, p_flgptn)) {
        ercd = E_OK;
    }
    else {
        winfo_flg.waiptn = waiptn;
        winfo_flg.wfmode = wfmode;
        p_runtsk->tstat = (TS_WAITING | TS_WAIT_FLG);
        wobj_make_wait((WOBJCB *) p_flgcb, (WINFO_WOBJ *) &winfo_flg);
        dispatch();
        ercd = winfo_flg.winfo.wercd;
        if (ercd == E_OK) {
            *p_flgptn = winfo_flg.flgptn;
        }
    }
    t_unlock_cpu();

  error_exit:
    LOG_WAI_FLG_LEAVE(ercd, *p_flgptn);
    return(ercd);
}