task.c

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

ソースコードを見る。

マクロ定義
#define	LOG_TEX_ENTER(texptn)
#define	LOG_TEX_LEAVE(texptn)
#define	PRIMAP_BIT(pri)   (1U << (pri))
関数
void	initialize_task (void)
Inline uint_t	bitmap_search (uint16_t bitmap)
Inline bool_t	primap_empty (void)
Inline uint_t	primap_search (void)
Inline void	primap_set (uint_t pri)
Inline void	primap_clear (uint_t pri)
TCB *	search_schedtsk (void)
bool_t	make_runnable (TCB *p_tcb)
bool_t	make_non_runnable (TCB *p_tcb)
void	make_dormant (TCB *p_tcb)
bool_t	make_active (TCB *p_tcb)
bool_t	change_priority (TCB *p_tcb, uint_t newpri)
bool_t	rotate_ready_queue (uint_t pri)
void	call_texrtn (void)
void	calltex (void)
変数
TCB *	p_runtsk
TCB *	p_schedtsk
bool_t	reqflg
bool_t	disdsp
bool_t	dspflg
QUEUE	ready_queue [TNUM_TPRI]
uint16_t	ready_primap
static const unsigned char	bitmap_search_table []

---

マクロ定義

#define LOG_TEX_ENTER

(

texptn

)

task.c の 55 行で定義されています。

参照元 call_texrtn().

#define LOG_TEX_LEAVE

(

texptn

)

task.c の 59 行で定義されています。

参照元 call_texrtn().

#define PRIMAP_BIT

(

pri

)

(1U << (pri))

task.c の 155 行で定義されています。

---

関数

Inline uint_t bitmap_search

(

uint16_t

bitmap

)

task.c の 164 行で定義されています。

参照先 assert, と bitmap_search_table.

{
    uint_t  n = 0U;

    assert(bitmap != 0U);
    if ((bitmap & 0x00ffU) == 0U) {
        bitmap >>= 8;
        n += 8;
    }
    if ((bitmap & 0x0fU) == 0U) {
        bitmap >>= 4;
        n += 4;
    }
    return(n + bitmap_search_table[(bitmap & 0x0fU) - 1]);
}

void call_texrtn

(

void

)

task.c の 427 行で定義されています。

参照先 disdsp, dispatch, dspflg, task_control_block::enatex, task_initialization_block::exinf, LOG_TEX_ENTER, LOG_TEX_LEAVE, task_control_block::p_tinib, t_get_ipm, t_lock_cpu, t_sense_lock, t_set_ipm, t_unlock_cpu, task_control_block::texptn, と task_initialization_block::texrtn.

{
    TEXPTN  texptn;
    PRI     saved_ipm;
    bool_t  saved_disdsp, saved_dspflg;

    saved_ipm = t_get_ipm();
    saved_disdsp = disdsp;
    saved_dspflg = dspflg;
    do {
        texptn = p_runtsk->texptn;
        p_runtsk->enatex = false;
        p_runtsk->texptn = 0U;

        t_unlock_cpu();
        LOG_TEX_ENTER(texptn);
        (*((TEXRTN)(p_runtsk->p_tinib->texrtn)))(texptn,
                                                p_runtsk->p_tinib->exinf);
        LOG_TEX_LEAVE(texptn);
        if (!t_sense_lock()) {
            t_lock_cpu();
        }
        t_set_ipm(saved_ipm);
        disdsp = saved_disdsp;
        dspflg = saved_dspflg;
        if (p_runtsk != p_schedtsk && dspflg) {
            dispatch();
        }
    } while (p_runtsk->texptn != 0U);
    p_runtsk->enatex = true;
}

void calltex

(

void

)

task.c の 467 行で定義されています。

参照先 call_texrtn, task_control_block::enatex, と task_control_block::texptn.

{
    if (p_runtsk->enatex && p_runtsk->texptn != 0U) {
        call_texrtn();
    }
}

bool_t change_priority	(	TCB *	p_tcb,
		uint_t	newpri
	)

task.c の 344 行で定義されています。

参照先 dspflg, task_control_block::p_winfo, primap_clear(), primap_set(), task_control_block::priority, queue_delete(), queue_empty(), queue_insert_prev(), search_schedtsk, task_control_block::task_queue, task_control_block::tstat, TSTAT_RUNNABLE, TSTAT_WAIT_WOBJCB, と wobj_change_priority().

{
    uint_t  oldpri;

    oldpri = p_tcb->priority;
    p_tcb->priority = newpri;

    if (TSTAT_RUNNABLE(p_tcb->tstat)) {
        /*
         *  タスクが実行できる状態の場合
         */
        queue_delete(&(p_tcb->task_queue));
        if (queue_empty(&(ready_queue[oldpri]))) {
            primap_clear(oldpri);
        }
        queue_insert_prev(&(ready_queue[newpri]), &(p_tcb->task_queue));
        primap_set(newpri);

        if (p_schedtsk == p_tcb) {
            if (newpri >= oldpri) {
                p_schedtsk = search_schedtsk();
                return(p_schedtsk != p_tcb && dspflg);
            }
        }
        else {
            if (newpri < p_schedtsk->priority) {
                p_schedtsk = p_tcb;
                return(dspflg);
            }
        }
    }
    else {
        if (TSTAT_WAIT_WOBJCB(p_tcb->tstat)) {
            /*
             *  タスクが，同期・通信オブジェクトの管理ブロックの共通部
             *  分（WOBJCB）の待ちキューにつながれている場合
             */
            wobj_change_priority(((WINFO_WOBJ *)(p_tcb->p_winfo))->p_wobjcb,
                                                                    p_tcb);
        }
    }
    return(false);
}

void initialize_task

(

void

)

task.c の 106 行で定義されています。

参照先 task_control_block::actque, disdsp, dspflg, INDEX_TSK, make_active, make_dormant, NULL, task_control_block::p_tinib, queue_initialize(), ready_primap, reqflg, TA_ACT, tcb_table, tinib_table, TNUM_TPRI, tnum_tsk, torder_table, と task_initialization_block::tskatr.

{
    uint_t  i, j;
    TCB     *p_tcb;

    p_runtsk = p_schedtsk = NULL;
    reqflg = false;
    disdsp = false;
    dspflg = true;

    for (i = 0; i < TNUM_TPRI; i++) {
        queue_initialize(&(ready_queue[i]));
    }
    ready_primap = 0U;

    for (i = 0; i < tnum_tsk; i++) {
        j = INDEX_TSK(torder_table[i]);
        p_tcb = &(tcb_table[j]);
        p_tcb->p_tinib = &(tinib_table[j]);
        p_tcb->actque = false;
        make_dormant(p_tcb);
        if ((p_tcb->p_tinib->tskatr & TA_ACT) != 0U) {
            make_active(p_tcb);
        }
    }
}

bool_t make_active

(

TCB *

p_tcb

)

task.c の 321 行で定義されています。

参照先 activate_context, と make_runnable.

{
    activate_context(p_tcb);
    return(make_runnable(p_tcb));
}

void make_dormant

(

TCB *

p_tcb

)

task.c の 303 行で定義されています。

参照先 task_control_block::enatex, task_initialization_block::ipriority, LOG_TSKSTAT, task_control_block::p_tinib, task_control_block::priority, task_control_block::texptn, TS_DORMANT, task_control_block::tstat, と task_control_block::wupque.

{
    p_tcb->tstat = TS_DORMANT;
    p_tcb->priority = p_tcb->p_tinib->ipriority;
    p_tcb->wupque = false;
    p_tcb->enatex = false;
    p_tcb->texptn = 0U;
    LOG_TSKSTAT(p_tcb);
}

bool_t make_non_runnable

(

TCB *

p_tcb

)

task.c の 273 行で定義されています。

参照先 dspflg, NULL, queue::p_next, primap_clear(), primap_empty(), task_control_block::priority, queue_delete(), queue_empty(), search_schedtsk, と task_control_block::task_queue.

{
    uint_t  pri = p_tcb->priority;
    QUEUE   *p_queue = &(ready_queue[pri]);

    queue_delete(&(p_tcb->task_queue));
    if (queue_empty(p_queue)) {
        primap_clear(pri);
        if (p_schedtsk == p_tcb) {
            p_schedtsk = primap_empty() ? (TCB *) NULL : search_schedtsk();
            return(dspflg);
        }
    }
    else {
        if (p_schedtsk == p_tcb) {
            p_schedtsk = (TCB *)(p_queue->p_next);
            return(dspflg);
        }
    }
    return(false);
}

bool_t make_runnable

(

TCB *

p_tcb

)

task.c の 244 行で定義されています。

参照先 dspflg, LOG_TSKSTAT, NULL, primap_set(), task_control_block::priority, queue_insert_prev(), task_control_block::task_queue, TS_RUNNABLE, と task_control_block::tstat.

{
    uint_t  pri = p_tcb->priority;

    p_tcb->tstat = TS_RUNNABLE;
    LOG_TSKSTAT(p_tcb);
    queue_insert_prev(&(ready_queue[pri]), &(p_tcb->task_queue));
    primap_set(pri);

    if (p_schedtsk == (TCB *) NULL || pri < p_schedtsk->priority) {
        p_schedtsk = p_tcb;
        return(dspflg);
    }
    return(false);
}

Inline void primap_clear

(

uint_t

pri

)

task.c の 213 行で定義されています。

参照先 PRIMAP_BIT, と ready_primap.

参照元 change_priority(), と make_non_runnable().

{
    ready_primap &= ~PRIMAP_BIT(pri);
}

Inline bool_t primap_empty

(

void

)

task.c の 186 行で定義されています。

参照先 ready_primap.

参照元 make_non_runnable().

{
    return(ready_primap == 0U);
}

Inline uint_t primap_search

(

void

)

task.c の 195 行で定義されています。

参照先 bitmap_search(), と ready_primap.

参照元 search_schedtsk().

{
    return(bitmap_search(ready_primap));
}

Inline void primap_set

(

uint_t

pri

)

task.c の 204 行で定義されています。

参照先 PRIMAP_BIT, と ready_primap.

参照元 change_priority(), と make_runnable().

{
    ready_primap |= PRIMAP_BIT(pri);
}

bool_t rotate_ready_queue

(

uint_t

pri

)

task.c の 399 行で定義されています。

参照先 dspflg, queue::p_next, queue_delete_next(), queue_empty(), と queue_insert_prev().

{
    QUEUE   *p_queue = &(ready_queue[pri]);
    QUEUE   *p_entry;

    if (!queue_empty(p_queue) && p_queue->p_next->p_next != p_queue) {
        p_entry = queue_delete_next(p_queue);
        queue_insert_prev(p_queue, p_entry);
        if (p_schedtsk == (TCB *) p_entry) {
            p_schedtsk = (TCB *)(p_queue->p_next);
            return(dspflg);
        }
    }
    return(false);
}

TCB* search_schedtsk

(

void

)

task.c の 224 行で定義されています。

参照先 primap_search().

{
    uint_t  schedpri;

    schedpri = primap_search();
    return((TCB *)(ready_queue[schedpri].p_next));
}

---

変数

const unsigned char bitmap_search_table[] [static]

初期値:

 { 0, 1, 0, 2, 0, 1, 0,
                                                3, 0, 1, 0, 2, 0, 1, 0 }

task.c の 160 行で定義されています。

参照元 bitmap_search().

bool_t disdsp

task.c の 82 行で定義されています。

bool_t dspflg

task.c の 87 行で定義されています。

TCB* p_runtsk

task.c の 67 行で定義されています。

TCB* p_schedtsk

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

uint16_t ready_primap

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

QUEUE ready_queue[TNUM_TPRI]

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

bool_t reqflg

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