wait.c

#include "kernel_impl.h"
#include "wait.h"

ソースコードを見る。

関数
void	make_wait_tmout (WINFO *p_winfo, TMEVTB *p_tmevtb, TMO tmout)
Inline bool_t	make_non_wait (TCB *p_tcb)
bool_t	wait_complete (TCB *p_tcb)
void	wait_tmout (TCB *p_tcb)
void	wait_tmout_ok (TCB *p_tcb)
bool_t	wait_release (TCB *p_tcb)
Inline void	wobj_queue_insert (WOBJCB *p_wobjcb)
void	wobj_make_wait (WOBJCB *p_wobjcb, WINFO_WOBJ *p_winfo_wobj)
void	wobj_make_wait_tmout (WOBJCB *p_wobjcb, WINFO_WOBJ *p_winfo_wobj, TMEVTB *p_tmevtb, TMO tmout)
bool_t	init_wait_queue (QUEUE *p_wait_queue)

---

関数

bool_t init_wait_queue

(

QUEUE *

p_wait_queue

)

wait.c の 225 行で定義されています。

参照先 E_DLT, make_non_wait(), task_control_block::p_winfo, queue_delete_next(), queue_empty(), wait_dequeue_tmevtb(), と waiting_information::wercd.

{
    TCB     *p_tcb;
    bool_t  dspreq = false;

    while (!queue_empty(p_wait_queue)) {
        p_tcb = (TCB *) queue_delete_next(p_wait_queue);
        wait_dequeue_tmevtb(p_tcb);
        p_tcb->p_winfo->wercd = E_DLT;
        if (make_non_wait(p_tcb)) {
            dspreq = true;
        };
    }
    return(dspreq);
}

Inline bool_t make_non_wait

(

TCB *

p_tcb

)

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

参照先 assert, LOG_TSKSTAT, make_runnable, TS_SUSPENDED, task_control_block::tstat, TSTAT_SUSPENDED, と TSTAT_WAITING.

参照元 init_wait_queue(), wait_complete(), wait_release(), wait_tmout(), と wait_tmout_ok().

{
    assert(TSTAT_WAITING(p_tcb->tstat));

    if (!TSTAT_SUSPENDED(p_tcb->tstat)) {
        /*
         *  待ち状態から実行できる状態への遷移
         */
        return(make_runnable(p_tcb));
    }
    else {
        /*
         *  二重待ち状態から強制待ち状態への遷移
         */
        p_tcb->tstat = TS_SUSPENDED;
        LOG_TSKSTAT(p_tcb);
        return(false);
    }
}

void make_wait_tmout	(	WINFO *	p_winfo,
		TMEVTB *	p_tmevtb,
		TMO	tmout
	)

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

参照先 assert, make_non_runnable, NULL, p_runtsk, waiting_information::p_tmevtb, tmevtb_enqueue(), TMO_FEVR, と wait_tmout.

{
    (void) make_non_runnable(p_runtsk);
    p_runtsk->p_winfo = p_winfo;
    if (tmout > 0) {
        p_winfo->p_tmevtb = p_tmevtb;
        tmevtb_enqueue(p_tmevtb, (RELTIM) tmout,
                        (CBACK) wait_tmout, (void *) p_runtsk);
    }
    else {
        assert(tmout == TMO_FEVR);
        p_winfo->p_tmevtb = NULL;
    }
}

bool_t wait_complete

(

TCB *

p_tcb

)

wait.c の 107 行で定義されています。

参照先 E_OK, make_non_wait(), task_control_block::p_winfo, wait_dequeue_tmevtb(), と waiting_information::wercd.

{
    wait_dequeue_tmevtb(p_tcb);
    p_tcb->p_winfo->wercd = E_OK;
    return(make_non_wait(p_tcb));
}

bool_t wait_release

(

TCB *

p_tcb

)

wait.c の 163 行で定義されています。

参照先 E_RLWAI, make_non_wait(), task_control_block::p_winfo, wait_dequeue_tmevtb(), wait_dequeue_wobj(), と waiting_information::wercd.

{
    wait_dequeue_wobj(p_tcb);
    wait_dequeue_tmevtb(p_tcb);
    p_tcb->p_winfo->wercd = E_RLWAI;
    return(make_non_wait(p_tcb));
}

void wait_tmout

(

TCB *

p_tcb

)

wait.c の 122 行で定義されています。

参照先 E_TMOUT, i_lock_cpu, i_unlock_cpu, make_non_wait(), task_control_block::p_winfo, reqflg, wait_dequeue_wobj(), と waiting_information::wercd.

{
    wait_dequeue_wobj(p_tcb);
    p_tcb->p_winfo->wercd = E_TMOUT;
    if (make_non_wait(p_tcb)) {
        reqflg = true;
    }

    /*
     *  ここで優先度の高い割込みを受け付ける．
     */
    i_unlock_cpu();
    i_lock_cpu();
}

void wait_tmout_ok

(

TCB *

p_tcb

)

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

参照先 E_OK, i_lock_cpu, i_unlock_cpu, make_non_wait(), task_control_block::p_winfo, reqflg, と waiting_information::wercd.

{
    p_tcb->p_winfo->wercd = E_OK;
    if (make_non_wait(p_tcb)) {
        reqflg = true;
    }

    /*
     *  ここで優先度の高い割込みを受け付ける．
     */
    i_unlock_cpu();
    i_lock_cpu();
}

void wobj_make_wait	(	WOBJCB *	p_wobjcb,
		WINFO_WOBJ *	p_winfo_wobj
	)

wait.c の 196 行で定義されています。

参照先 LOG_TSKSTAT, make_wait(), p_runtsk, と wobj_queue_insert().

{
    make_wait((WINFO *) p_winfo_wobj);
    wobj_queue_insert(p_wobjcb);
    p_winfo_wobj->p_wobjcb = p_wobjcb;
    LOG_TSKSTAT(p_runtsk);
}

void wobj_make_wait_tmout	(	WOBJCB *	p_wobjcb,
		WINFO_WOBJ *	p_winfo_wobj,
		TMEVTB *	p_tmevtb,
		TMO	tmout
	)

wait.c の 208 行で定義されています。

参照先 LOG_TSKSTAT, make_wait_tmout, p_runtsk, と wobj_queue_insert().

{
    make_wait_tmout((WINFO *) p_winfo_wobj, p_tmevtb, tmout);
    wobj_queue_insert(p_wobjcb);
    p_winfo_wobj->p_wobjcb = p_wobjcb;
    LOG_TSKSTAT(p_runtsk);
}

Inline void wobj_queue_insert

(

WOBJCB *

p_wobjcb

)

wait.c の 180 行で定義されています。

参照先 p_runtsk, wait_object_control_block::p_wobjinib, queue_insert_prev(), queue_insert_tpri(), TA_TPRI, wait_object_control_block::wait_queue, と wait_object_initialization_block::wobjatr.

参照元 wobj_make_wait(), と wobj_make_wait_tmout().

{
    if ((p_wobjcb->p_wobjinib->wobjatr & TA_TPRI) != 0U) {
        queue_insert_tpri(&(p_wobjcb->wait_queue), p_runtsk);
    }
    else {
        queue_insert_prev(&(p_wobjcb->wait_queue), &(p_runtsk->task_queue));
    }
}