wait.h

#include "task.h"
#include "time_event.h"

ソースコードを見る。

データ構造
struct	wait_object_initialization_block
struct	wait_object_control_block
struct	wait_object_waiting_information
型定義
typedef struct wait_object_initialization_block	WOBJINIB
typedef struct wait_object_control_block	WOBJCB
typedef struct wait_object_waiting_information	WINFO_WOBJ
関数
Inline void	queue_insert_tpri (QUEUE *p_queue, TCB *p_tcb)
Inline void	make_wait (WINFO *p_winfo)
void	make_wait_tmout (WINFO *p_winfo, TMEVTB *p_tmevtb, TMO tmout)
Inline void	wait_dequeue_wobj (TCB *p_tcb)
Inline void	wait_dequeue_tmevtb (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 ID	wait_tskid (QUEUE *p_wait_queue)
void	wobj_make_wait (WOBJCB *p_wobjcb, WINFO_WOBJ *p_winfo)
void	wobj_make_wait_tmout (WOBJCB *p_wobjcb, WINFO_WOBJ *p_winfo, TMEVTB *p_tmevtb, TMO tmout)
Inline void	wobj_change_priority (WOBJCB *p_wobjcb, TCB *p_tcb)
bool_t	init_wait_queue (QUEUE *p_wait_queue)

---

型定義

typedef struct wait_object_waiting_information WINFO_WOBJ

typedef struct wait_object_control_block WOBJCB

typedef struct wait_object_initialization_block WOBJINIB

---

関数

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 void make_wait

(

WINFO *

p_winfo

)

wait.h の 82 行で定義されています。

参照先 make_non_runnable, NULL, p_runtsk, と waiting_information::p_tmevtb.

参照元 rcv_dtq(), rcv_pdq(), slp_tsk(), と wobj_make_wait().

{
    (void) make_non_runnable(p_runtsk);
    p_runtsk->p_winfo = p_winfo;
    p_winfo->p_tmevtb = NULL;
}

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;
    }
}

Inline void queue_insert_tpri	(	QUEUE *	p_queue,
		TCB *	p_tcb
	)

wait.h の 60 行で定義されています。

参照先 queue::p_next, task_control_block::priority, queue_insert_prev(), と task_control_block::task_queue.

参照元 wobj_change_priority(), と wobj_queue_insert().

{
    QUEUE   *p_entry;
    uint_t  priority = p_tcb->priority;

    for (p_entry = p_queue->p_next; p_entry != p_queue;
                                        p_entry = p_entry->p_next) {
        if (priority < ((TCB *) p_entry)->priority) {
            break;
        }
    }
    queue_insert_prev(p_entry, &(p_tcb->task_queue));
}

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));
}

Inline void wait_dequeue_tmevtb

(

TCB *

p_tcb

)

wait.h の 120 行で定義されています。

参照先 NULL, waiting_information::p_tmevtb, task_control_block::p_winfo, と tmevtb_dequeue().

参照元 init_wait_queue(), ter_tsk(), wait_complete(), と wait_release().

{
    if (p_tcb->p_winfo->p_tmevtb != NULL) {
        tmevtb_dequeue(p_tcb->p_winfo->p_tmevtb);
    }
}

Inline void wait_dequeue_wobj

(

TCB *

p_tcb

)

wait.h の 106 行で定義されています。

参照先 queue_delete(), task_control_block::task_queue, task_control_block::tstat, と TSTAT_WAIT_WOBJ.

参照元 ter_tsk(), wait_release(), と wait_tmout().

{
    if (TSTAT_WAIT_WOBJ(p_tcb->tstat)) {
        queue_delete(&(p_tcb->task_queue));
    }
}

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();
}

Inline ID wait_tskid

(

QUEUE *

p_wait_queue

)

wait.h の 173 行で定義されています。

参照先 queue::p_next, queue_empty(), TSK_NONE, と TSKID.

参照元 ref_dtq(), ref_flg(), ref_mbx(), ref_mpf(), ref_pdq(), と ref_sem().

{
    if (!queue_empty(p_wait_queue)) {
        return(TSKID((TCB *) p_wait_queue->p_next));
    }
    else {
        return(TSK_NONE);
    }
}

Inline void wobj_change_priority	(	WOBJCB *	p_wobjcb,
		TCB *	p_tcb
	)

wait.h の 241 行で定義されています。

参照先 wait_object_control_block::p_wobjinib, queue_delete(), queue_insert_tpri(), TA_TPRI, task_control_block::task_queue, wait_object_control_block::wait_queue, と wait_object_initialization_block::wobjatr.

参照元 change_priority().

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

void wobj_make_wait	(	WOBJCB *	p_wobjcb,
		WINFO_WOBJ *	p_winfo
	)

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,
		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);
}